/*
 * Copyright 2016, Dario Casalinuovo. All rights reserved.
 * Distributed under the terms of the MIT License.
 */
#ifndef _RTSP_MEDIA_IO_H
#define _RTSP_MEDIA_IO_H


#include <AdapterIO.h>
#include <Url.h>

#include "rtsp.h"


class HaikuRTSPClient;


class RTSPMediaIO : public BAdapterIO
{
public:
										RTSPMediaIO(BUrl ourUrl);
	virtual								~RTSPMediaIO();

	virtual	ssize_t						WriteAt(off_t position,
											const void* buffer,
											size_t size);

	virtual	status_t					SetSize(off_t size);

	virtual status_t					Open();

			void						LoopThread();
			void						ShutdownLoop();
private:
			static int32				_LoopThread(void* data);

			BUrl						fUrl;

			HaikuRTSPClient*			fClient;
			UsageEnvironment*			fEnv;
			TaskScheduler*				fScheduler;

			char						fLoopWatchVariable;
			thread_id					fLoopThread;
};


class HaikuRTSPClient : public RTSPClient
{
public:
										HaikuRTSPClient(UsageEnvironment& env,
											char const* rtspURL,
											portNumBits tunnelOverHTTPPortNum,
											RTSPMediaIO* fInputAdapter);

			void						Close();

			BInputAdapter*				GetInputAdapter() const;

			status_t					WaitForInit(bigtime_t timeout);

			void						NotifyError();
			void						NotifySucces();

protected:

	virtual 							~HaikuRTSPClient();
public:
			MediaSubsessionIterator* 	iter;
			MediaSession*				session;
			MediaSubsession*			subsession;
			TaskToken					streamTimerTask;
			double						duration;

private:
			RTSPMediaIO*				fInterface;

			port_id						fInitPort;
};

#endif