vdr-plugin-streamdev/server/connectionHTTP.c

/*
 *  $Id: connectionHTTP.c,v 1.9 2005/05/09 20:22:29 lordjaxom Exp $
 */

#include <ctype.h>
 
#include "server/connectionHTTP.h"
#include "server/setup.h"

cConnectionHTTP::cConnectionHTTP(void): 
		cServerConnection("HTTP"),
		m_Status(hsRequest),
		m_LiveStreamer(NULL),
		m_Channel(NULL),
		m_Apid(0),
		m_StreamType((eStreamType)StreamdevServerSetup.HTTPStreamType),
		m_ListChannel(NULL)
{
	Dprintf("constructor hsRequest\n");
}

cConnectionHTTP::~cConnectionHTTP() 
{
	delete m_LiveStreamer;
}

bool cConnectionHTTP::Command(char *Cmd) 
{
	Dprintf("command %s\n", Cmd);
	switch (m_Status) {
	case hsRequest:
		Dprintf("Request\n");
		m_Request = Cmd;
		m_Status = hsHeaders;
		return true;

	case hsHeaders:
		if (*Cmd == '\0') {
			m_Status = hsBody;
			return ProcessRequest();
		}
		Dprintf("header\n");
		return true;
	}
	return false; // ??? shouldn't happen
}

bool cConnectionHTTP::ProcessRequest(void) 
{
	Dprintf("process\n");
	if (m_Request.substr(0, 4) == "GET " && CmdGET(m_Request.substr(4))) {
		switch (m_Job) {
		case hjListing:
			return Respond("HTTP/1.0 200 OK")
			    && Respond("Content-Type: text/html")
			    && Respond("")
			    && Respond("<html><head><title>VDR Channel Listing</title></head>")
			    && Respond("<body><ul>");

		case hjTransfer:
			if (m_Channel == NULL) {
				DeferClose();
				return Respond("HTTP/1.0 404 not found");
			}
			
			m_LiveStreamer = new cStreamdevLiveStreamer(0);
			cDevice *device = GetDevice(m_Channel, 0);
			if (device != NULL) {
				device->SwitchChannel(m_Channel, false);
				if (m_LiveStreamer->SetChannel(m_Channel, m_StreamType, m_Apid)) {
					m_LiveStreamer->SetDevice(device);
					if (m_StreamType == stES && (m_Apid != 0 || ISRADIO(m_Channel))) {
						return Respond("HTTP/1.0 200 OK")
						    && Respond("Content-Type: audio/mpeg")
						    && Respond("icy-name: %s", true, m_Channel->Name())
						    && Respond("");
					} else {
						return Respond("HTTP/1.0 200 OK")
						    && Respond("Content-Type: video/mpeg")
						    && Respond("");
					}
				}
			}
			DELETENULL(m_LiveStreamer);
			DeferClose();
			return Respond("HTTP/1.0 409 Channel not available");
		}
	}

	DeferClose();
	return Respond("HTTP/1.0 400 Bad Request");
}

void cConnectionHTTP::Flushed(void) 
{
	std::string line;

	if (m_Status != hsBody)
		return;

	switch (m_Job) {
	case hjListing:
		if (m_ListChannel == NULL) {
			Respond("</ul></body></html>");
			DeferClose();
			m_Status = hsFinished;
			return;
		}

		if (m_ListChannel->GroupSep())
			line = (std::string)"<li>--- " + m_ListChannel->Name() + "---</li>";
		else {
			int index = 1;
			line = (std::string)"<li><a href=\"http://" + LocalIp() + ":" 
			     + (const char*)itoa(StreamdevServerSetup.HTTPServerPort) + "/"
			     + StreamTypes[m_StreamType] + "/"
			     + (const char*)m_ListChannel->GetChannelID().ToString() + "\">"
			     + m_ListChannel->Name() + "</a> ";
			for (int i = 0; m_ListChannel->Apid(i) != 0; ++i, ++index) {
				line += "<a href=\"http://" + LocalIp() + ":"
				     + (const char*)itoa(StreamdevServerSetup.HTTPServerPort) + "/"
				     + StreamTypes[m_StreamType] + "/"
				     + (const char*)m_ListChannel->GetChannelID().ToString() + "+"
				     + (const char*)itoa(index) + "\">("
				     + m_ListChannel->Alang(i) + ")</a> ";
			}
			for (int i = 0; m_ListChannel->Dpid(i) != 0; ++i, ++index) {
				line += "<a href=\"http://" + LocalIp() + ":"
				     + (const char*)itoa(StreamdevServerSetup.HTTPServerPort) + "/"
				     + StreamTypes[m_StreamType] + "/"
				     + (const char*)m_ListChannel->GetChannelID().ToString() + "+"
				     + (const char*)itoa(index) + "\">("
				     + m_ListChannel->Dlang(i) + ")</a> ";
			}
			line += "</li>";
		}
		if (!Respond(line.c_str()))
			DeferClose();
		m_ListChannel = Channels.Next(m_ListChannel);
		break;

	case hjTransfer:
		Dprintf("streamer start\n");
		m_LiveStreamer->Start(this);
		m_Status = hsFinished;
		break;
	}
}

bool cConnectionHTTP::CmdGET(const std::string &Opts) 
{
	const char *sp = Opts.c_str(), *ptr = sp, *ep;
	const cChannel *chan;
	int apid = 0, pos;

	ptr = skipspace(ptr);
	while (*ptr == '/')
		++ptr;

	if (strncasecmp(ptr, "PS/", 3) == 0) {
		m_StreamType = stPS;
		ptr += 3;
	} else if (strncasecmp(ptr, "PES/", 4) == 0) {
		m_StreamType = stPES;
		ptr += 4;
	} else if (strncasecmp(ptr, "TS/", 3) == 0) {
		m_StreamType = stTS;
		ptr += 3;
	} else if (strncasecmp(ptr, "ES/", 3) == 0) {
		m_StreamType = stES;
		ptr += 3;
	} else if (strncasecmp(ptr, "Extern/", 3) == 0) {
		m_StreamType = stExtern;
		ptr += 7;
	}

	while (*ptr == '/')
		++ptr;
	for (ep = ptr + strlen(ptr); ep >= ptr && !isspace(*ep); --ep) 
		;

	std::string filespec = Opts.substr(ptr - sp, ep - ptr);
	Dprintf("substr: %s\n", filespec.c_str());

	Dprintf("before channelfromstring\n");
	if (filespec == "" || filespec.substr(0, 12) == "channels.htm") {
		m_ListChannel = Channels.First();
		m_Job = hjListing;
	} else if ((chan = ChannelFromString(filespec.c_str(), &apid)) != NULL) {
		m_Channel = chan;
		m_Apid = apid;
		Dprintf("Apid is %d\n", apid);
		m_Job = hjTransfer;
	}
	Dprintf("after channelfromstring\n");
	return true;
}
Initial revision 2004-12-30 23:43:55 +01:00			`/*`
- added TS compatibility mode 2005-05-09 22:22:29 +02:00			`* $Id: connectionHTTP.c,v 1.9 2005/05/09 20:22:29 lordjaxom Exp $`
Initial revision 2004-12-30 23:43:55 +01:00			`*/`
- some compilers complained about missing declarations, added <ctype.h> 2005-04-24 18:26:14 +02:00
			`#include <ctype.h>`
Initial revision 2004-12-30 23:43:55 +01:00
			`#include "server/connectionHTTP.h"`
			`#include "server/setup.h"`

- transfer 2005-02-11 17:44:14 +01:00			`cConnectionHTTP::cConnectionHTTP(void):`
			`cServerConnection("HTTP"),`
			`m_Status(hsRequest),`
			`m_LiveStreamer(NULL),`
			`m_Channel(NULL),`
			`m_Apid(0),`
			`m_StreamType((eStreamType)StreamdevServerSetup.HTTPStreamType),`
			`m_ListChannel(NULL)`
			`{`
			`Dprintf("constructor hsRequest\n");`
Initial revision 2004-12-30 23:43:55 +01:00			`}`

- transfer 2005-02-11 17:44:14 +01:00			`cConnectionHTTP::~cConnectionHTTP()`
			`{`
			`delete m_LiveStreamer;`
Initial revision 2004-12-30 23:43:55 +01:00			`}`

- transfer 2005-02-11 17:44:14 +01:00			`bool cConnectionHTTP::Command(char *Cmd)`
			`{`
			`Dprintf("command %s\n", Cmd);`
Initial revision 2004-12-30 23:43:55 +01:00			`switch (m_Status) {`
			`case hsRequest:`
- transfer 2005-02-11 17:44:14 +01:00			`Dprintf("Request\n");`
			`m_Request = Cmd;`
			`m_Status = hsHeaders;`
			`return true;`
Initial revision 2004-12-30 23:43:55 +01:00
			`case hsHeaders:`
			`if (*Cmd == '\0') {`
- transfer 2005-02-11 17:44:14 +01:00			`m_Status = hsBody;`
			`return ProcessRequest();`
			`}`
			`Dprintf("header\n");`
			`return true;`
			`}`
			`return false; // ??? shouldn't happen`
			`}`

- added TS compatibility mode 2005-05-09 22:22:29 +02:00			`bool cConnectionHTTP::ProcessRequest(void)`
			`{`
- transfer 2005-02-11 17:44:14 +01:00			`Dprintf("process\n");`
			`if (m_Request.substr(0, 4) == "GET " && CmdGET(m_Request.substr(4))) {`
			`switch (m_Job) {`
			`case hjListing:`
			`return Respond("HTTP/1.0 200 OK")`
			`&& Respond("Content-Type: text/html")`
			`&& Respond("")`
			`&& Respond("<html><head><title>VDR Channel Listing</title></head>")`
			`&& Respond("<body><ul>");`

			`case hjTransfer:`
			`if (m_Channel == NULL) {`
Initial revision 2004-12-30 23:43:55 +01:00			`DeferClose();`
			`return Respond("HTTP/1.0 404 not found");`
			`}`
- transfer 2005-02-11 17:44:14 +01:00
Initial revision 2004-12-30 23:43:55 +01:00			`m_LiveStreamer = new cStreamdevLiveStreamer(0);`
			`cDevice *device = GetDevice(m_Channel, 0);`
			`if (device != NULL) {`
			`device->SwitchChannel(m_Channel, false);`
- implemented audio track selection for http 2005-02-10 23:24:26 +01:00			`if (m_LiveStreamer->SetChannel(m_Channel, m_StreamType, m_Apid)) {`
- transfer 2005-02-08 20:54:52 +01:00			`m_LiveStreamer->SetDevice(device);`
- transfer 2005-02-11 17:44:14 +01:00			`if (m_StreamType == stES && (m_Apid != 0 \|\| ISRADIO(m_Channel))) {`
Initial revision 2004-12-30 23:43:55 +01:00			`return Respond("HTTP/1.0 200 OK")`
- transfer 2005-02-11 17:44:14 +01:00			`&& Respond("Content-Type: audio/mpeg")`
- added TS compatibility mode 2005-05-09 22:22:29 +02:00			`&& Respond("icy-name: %s", true, m_Channel->Name())`
- transfer 2005-02-11 17:44:14 +01:00			`&& Respond("");`
Initial revision 2004-12-30 23:43:55 +01:00			`} else {`
			`return Respond("HTTP/1.0 200 OK")`
- transfer 2005-02-11 17:44:14 +01:00			`&& Respond("Content-Type: video/mpeg")`
			`&& Respond("");`
Initial revision 2004-12-30 23:43:55 +01:00			`}`
			`}`
			`}`
			`DELETENULL(m_LiveStreamer);`
			`DeferClose();`
			`return Respond("HTTP/1.0 409 Channel not available");`
			`}`
			`}`
- transfer 2005-02-11 17:44:14 +01:00
			`DeferClose();`
			`return Respond("HTTP/1.0 400 Bad Request");`
Initial revision 2004-12-30 23:43:55 +01:00			`}`

- added TS compatibility mode 2005-05-09 22:22:29 +02:00			`void cConnectionHTTP::Flushed(void)`
			`{`
- transfer 2005-02-11 17:44:14 +01:00			`std::string line;`

			`if (m_Status != hsBody)`
			`return;`

			`switch (m_Job) {`
			`case hjListing:`
Initial revision 2004-12-30 23:43:55 +01:00			`if (m_ListChannel == NULL) {`
			`Respond("</ul></body></html>");`
			`DeferClose();`
- transfer 2005-02-11 17:44:14 +01:00			`m_Status = hsFinished;`
Initial revision 2004-12-30 23:43:55 +01:00			`return;`
			`}`

			`if (m_ListChannel->GroupSep())`
- transfer 2005-02-08 18:22:35 +01:00			`line = (std::string)"<li>--- " + m_ListChannel->Name() + "---</li>";`
- transfer 2005-02-11 17:44:14 +01:00			`else {`
			`int index = 1;`
- transfer 2005-02-08 18:22:35 +01:00			`line = (std::string)"<li><a href=\"http://" + LocalIp() + ":"`
			`+ (const char*)itoa(StreamdevServerSetup.HTTPServerPort) + "/"`
- transfer 2005-02-11 17:44:14 +01:00			`+ StreamTypes[m_StreamType] + "/"`
- transfer 2005-02-08 18:22:35 +01:00			`+ (const char*)m_ListChannel->GetChannelID().ToString() + "\">"`
- transfer 2005-02-11 17:44:14 +01:00			`+ m_ListChannel->Name() + "</a> ";`
			`for (int i = 0; m_ListChannel->Apid(i) != 0; ++i, ++index) {`
			`line += "<a href=\"http://" + LocalIp() + ":"`
			`+ (const char*)itoa(StreamdevServerSetup.HTTPServerPort) + "/"`
			`+ StreamTypes[m_StreamType] + "/"`
			`+ (const char*)m_ListChannel->GetChannelID().ToString() + "+"`
			`+ (const char*)itoa(index) + "\">("`
			`+ m_ListChannel->Alang(i) + ")</a> ";`
			`}`
			`for (int i = 0; m_ListChannel->Dpid(i) != 0; ++i, ++index) {`
			`line += "<a href=\"http://" + LocalIp() + ":"`
			`+ (const char*)itoa(StreamdevServerSetup.HTTPServerPort) + "/"`
			`+ StreamTypes[m_StreamType] + "/"`
			`+ (const char*)m_ListChannel->GetChannelID().ToString() + "+"`
			`+ (const char*)itoa(index) + "\">("`
			`+ m_ListChannel->Dlang(i) + ")</a> ";`
			`}`
			`line += "</li>";`
			`}`
- added TS compatibility mode 2005-05-09 22:22:29 +02:00			`if (!Respond(line.c_str()))`
Initial revision 2004-12-30 23:43:55 +01:00			`DeferClose();`
			`m_ListChannel = Channels.Next(m_ListChannel);`
- transfer 2005-02-11 17:44:14 +01:00			`break;`

			`case hjTransfer:`
Initial revision 2004-12-30 23:43:55 +01:00			`Dprintf("streamer start\n");`
			`m_LiveStreamer->Start(this);`
- transfer 2005-02-11 17:44:14 +01:00			`m_Status = hsFinished;`
			`break;`
Initial revision 2004-12-30 23:43:55 +01:00			`}`
			`}`

- added TS compatibility mode 2005-05-09 22:22:29 +02:00			`bool cConnectionHTTP::CmdGET(const std::string &Opts)`
			`{`
- transfer 2005-02-11 17:44:14 +01:00			`const char sp = Opts.c_str(), ptr = sp, *ep;`
- implemented audio track selection for http 2005-02-10 23:24:26 +01:00			`const cChannel *chan;`
- transfer 2005-02-11 17:44:14 +01:00			`int apid = 0, pos;`
Initial revision 2004-12-30 23:43:55 +01:00
- transfer 2005-02-11 17:44:14 +01:00			`ptr = skipspace(ptr);`
			`while (*ptr == '/')`
			`++ptr;`
Initial revision 2004-12-30 23:43:55 +01:00
- transfer 2005-02-11 17:44:14 +01:00			`if (strncasecmp(ptr, "PS/", 3) == 0) {`
Initial revision 2004-12-30 23:43:55 +01:00			`m_StreamType = stPS;`
- transfer 2005-02-11 17:44:14 +01:00			`ptr += 3;`
			`} else if (strncasecmp(ptr, "PES/", 4) == 0) {`
Initial revision 2004-12-30 23:43:55 +01:00			`m_StreamType = stPES;`
- transfer 2005-02-11 17:44:14 +01:00			`ptr += 4;`
			`} else if (strncasecmp(ptr, "TS/", 3) == 0) {`
Initial revision 2004-12-30 23:43:55 +01:00			`m_StreamType = stTS;`
- transfer 2005-02-11 17:44:14 +01:00			`ptr += 3;`
			`} else if (strncasecmp(ptr, "ES/", 3) == 0) {`
Initial revision 2004-12-30 23:43:55 +01:00			`m_StreamType = stES;`
- transfer 2005-02-11 17:44:14 +01:00			`ptr += 3;`
			`} else if (strncasecmp(ptr, "Extern/", 3) == 0) {`
			`m_StreamType = stExtern;`
			`ptr += 7;`
Initial revision 2004-12-30 23:43:55 +01:00			`}`

- transfer 2005-02-11 17:44:14 +01:00			`while (*ptr == '/')`
			`++ptr;`
			`for (ep = ptr + strlen(ptr); ep >= ptr && !isspace(*ep); --ep)`
Initial revision 2004-12-30 23:43:55 +01:00			`;`
- transfer 2005-02-11 17:44:14 +01:00
			`std::string filespec = Opts.substr(ptr - sp, ep - ptr);`
			`Dprintf("substr: %s\n", filespec.c_str());`
Initial revision 2004-12-30 23:43:55 +01:00
- implemented audio track selection for http 2005-02-10 23:24:26 +01:00			`Dprintf("before channelfromstring\n");`
- transfer 2005-02-11 17:44:14 +01:00			`if (filespec == "" \|\| filespec.substr(0, 12) == "channels.htm") {`
Initial revision 2004-12-30 23:43:55 +01:00			`m_ListChannel = Channels.First();`
- transfer 2005-02-11 17:44:14 +01:00			`m_Job = hjListing;`
			`} else if ((chan = ChannelFromString(filespec.c_str(), &apid)) != NULL) {`
Initial revision 2004-12-30 23:43:55 +01:00			`m_Channel = chan;`
- implemented audio track selection for http 2005-02-10 23:24:26 +01:00			`m_Apid = apid;`
			`Dprintf("Apid is %d\n", apid);`
- transfer 2005-02-11 17:44:14 +01:00			`m_Job = hjTransfer;`
Initial revision 2004-12-30 23:43:55 +01:00			`}`
- implemented audio track selection for http 2005-02-10 23:24:26 +01:00			`Dprintf("after channelfromstring\n");`
Initial revision 2004-12-30 23:43:55 +01:00			`return true;`
			`}`