/*

* Copyright (c) 2002 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:  This class is an imlementation of DataSource

*

*/

package com.nokia.microedition.media;

import javax.microedition.media.MediaException;

import java.io.IOException;

import javax.microedition.io.Connection;

import javax.microedition.io.HttpConnection;

import javax.microedition.media.Control;

/**

 * This class extends ConnectorDataSource and adds http connection

 * return value checking.

 */

public class HttpDataSource extends ConnectorDataSource implements SeekControl

{

    private static final String SEEK_CONTROL = "SeekControl";

    // true when closed

    boolean iClosed = false;

    /**

     * Default constructor

     */

    public HttpDataSource(Locator aLocator)

    throws IOException, MediaException

    {

        super(aLocator);

    }

    /**

     * From ConnectorDataSource

     * @see ConnectorDataSource

     */

    protected void checkConnection(Connection aConnection) throws IOException

    {

        // Must handle also HTTP response codes

        HttpConnection httpConnection = (HttpConnection)aConnection;

        if (httpConnection.getResponseCode() != HttpConnection.HTTP_OK)

        {

            throw new IOException(

                "Could not connect to source, " + httpConnection.getResponseMessage());

        }

    }

    /**

     * From SeekControl

     */

    public void seek(int aWhere) throws IOException

    {

        // Only seek to start is supported.

        if (aWhere == 0)

        {

            disconnect();

            // do not connect if stream is closed

            if (!iClosed)

            {

                connect();

            }

            if (iClosed)

            {

                // disconnect if stream was closed during connect operation

                disconnect();

            }

        }

        else

        {

            throw new IOException("Internal error, invalid position: " + aWhere);

        }

    }

    /**

     * From SeekControl

     */

    public void close()

    {

        iClosed = true;

    }

    /**

     * From Controllable

     */

    public Control getControl(String aControlType)

    {

        Control control = null;

        if (aControlType.equals(SEEK_CONTROL))

        {

            control = this;

        }

        // else return null

        return control;

    }

}

// End of File