/*

* 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:  SourceStream that reads InputStream

*

*/

package com.nokia.microedition.media;

import com.nokia.microedition.media.InputStreamSeekControl;

import java.io.IOException;

import java.io.InputStream;

import javax.microedition.media.protocol.ContentDescriptor;

import javax.microedition.media.protocol.SourceStream;

import javax.microedition.media.Control;

/**

 * This class implements SourceStream interface. From the interface

 * only read and getSeekType method will be used. This class is used

 * to read InputStream.

 */

public class InputStreamSourceStream implements SourceStream

{

    // Stream used to read the content.

    protected InputStream iInputStream = null;

    private static final String SEEK_CONTROL = "SeekControl";

    private InputStreamSeekControl iSeekControl;

    /**

     * Constructor.

     * @param aInputStream An InputStream

     */

    public InputStreamSourceStream(InputStream aInputStream)

    {

        setStream(aInputStream);

        iSeekControl = new InputStreamSeekControl(aInputStream);

    }

    /**

     * Constructor.

     */

    public InputStreamSourceStream()

    {

    }

    /**

     * Sets new InputStream.

     * @param aInputStream An InputStream

     */

    public final void setStream(InputStream aInputStream)

    {

        iInputStream = aInputStream;

    }

    /**

     * Closes the InputStream. This method can only be called if MMA

     * must close the stream.

     *

     * @throws NullPointerException if setStream is not called.

     * @throws IOException If an I/O error occurs

     */

    public void close() throws IOException

    {

        iInputStream.close();

    }

    /**

     * Read from Input Stream

     * @param aBuffer Input Stream

     * @param aOffset where reading starts

     * @param aLength length of read data

     * @return bytes read

     * @throws IOException

     */

    public int read(byte[] aBuffer, int aOffset, int aLength) throws IOException

    {

        return iInputStream.read(aBuffer, aOffset, aLength);

    }

    /**

     * Seek type of the stream

     * @return seek type based on the inputstream's capability

     */

    public int getSeekType()

    {

        if (iInputStream != null && iInputStream.markSupported() == true)

        {

            return SEEKABLE_TO_START;

        }

        else

        {

            return NOT_SEEKABLE;

        }

    }

    /**

     * From interface SourceStream. Method not implemented.

     * @see SourceStream

     * @return size of the stream available

     */

    public int getTransferSize()

    {

        return 0;

    }

    /**

     * From interface SourceStream. Method not implemented.

     * @see SourceStream

     * @param aWhere where to seek

     * @return seeked position, allways the current position

     * @throws IOException

     */

    public long seek(long aWhere) throws IOException

    {

        return 0;

    }

    /**

     * From interface SourceStream. Method not implemented.

     * @see SourceStream

     * @return current position

     */

    public long tell()

    {

        return 0;

    }

    /**

     * From interface SourceStream. Method not implemented.

     * @see SourceStream

     * @return The content type

     * @see ContentDescriptor

     */

    public ContentDescriptor getContentDescriptor()

    {

        // Return empty content descriptor.

        // This method is not used.

        return new ContentDescriptor("");

    }

    /**

     * From interface SourceStream. Method not implemented.

     * @see SourceStream

     * @return content length which is allways 0

     */

    public long getContentLength()

    {

        return 0;

    }

    /**

     * From interface Controllable. Method not implemented.

     * @see SourceStream

     * @see Controllable

     */

    public Control[] getControls()

    {

        Control [] aControls = new Control[1];

        aControls[0] = iSeekControl;

        return aControls;

    }

    /**

     * From interface Controllable. Method not implemented.

     * @param aControlType wanted control type

     * @return Control null

     * @See Controllable

     */

    public Control getControl(String aControlType)

    {

        if (aControlType == SEEK_CONTROL && getSeekType() == SEEKABLE_TO_START)

        {

            return iSeekControl;

        }

        else

        {

            return null;

        }

    }

    /**

     * @return

     */

    }

}

// End of File