Bind protocols

• About binding protocols
• Bind request
• Binding
• Unbind request
• Bind request example
• Bind example
• CloseListenSession example

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "tvsserver_base.h"
#include "tvs_redefine_api_names.h"

int main() {
	BindStruct bindToTCPIP={0};
	BindStruct bindToHTTP={0};

	//fill in the first bindToStruct with protocol "TCP/IP" 
	bindToTCPIP.protocolName = "TCPIP";
	bindToTCPIP.type = PT_RECEIVER;

	//link this structure to the next bindTo structure
	bindToTCPIP.next = &bindToHTTP;

	//Bind the TCP/IP to HTTP by filling in the linked structure
	bindToHTTP.protocolName = "HTTP";
	bindToHTTP.type = PT_LABORER;

	//Start the binding process
	if(!BindToProtocol(psess, &bindToTCPIP)) {
		//Some error came up, try to read the error code in the protocolsession and every error code in the BindStruct structures to find out what the problem is.
	} else {
		//Succesfully
	}
}

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <Winsock2.h>
#include "tvsserver_base.h"
#include "tvs_redefine_api_names.h"

typedef struct MyTCPIPstruct{
	SOCKET socket;
} MyTCPIPstruct;

typedef struct MyHTTPstruct{
	char* serverPath;
} MyHTTPstruct;

ProtocolSession *http_psess;
ProtocolSession *tcpip_psess;

#define OPT_TCP_PORT 1
#define OPT_TCP_VERSION6 2

int __stdcall BindToProtocolCallBack(ProtocolSession *psess, ListenSession *lsess, int flags) {
	ProtocolData* pdata = FindProtocolDataStruct(psess, lsess->data);
	MyTCPIPstruct* tcpData;
	MyHTTPstruct* httpData;
	struct sockaddr_in bindAddr={0};
	struct sockaddr_in6 bindAddr6={0};

	//The controlpanel always saves an byte/showt/integer as long long in 64-bit
	#ifdef _WIN64
		long long listenPort;
		long long useVersion6;
	#else
		int listenPort;
		int useVersion6;
	#endif

	
	int len;

	if(psess==tcpip_psess) {
		tcpData = (MyTCPIPstruct*) &pdata->data;

		//Get the port this listenSession should listen to
		len = sizeof(listenPort);
		if(!GetPluginData(psess, lsess, (ClientSession*) 0, (char*) OPT_TCP_PORT, (char*) &listenPort, &len, GDPD_NAME_IS_INTEGER))
			return 0; //GetPluginData failed, return an error

		if(!GetPluginData(psess, lsess, (ClientSession*) 0, (char*) OPT_TCP_VERSION6, (char*) &useVersion6, &len, GDPD_NAME_IS_INTEGER))
			return 0; //GetPluginData failed, return an error

		//Init a TCP/IP v4 of v6 socket
		if(useVersion6) {
			//return false if the socket failed to initialate
			tcpData->socket = socket(AF_INET6, SOCK_STREAM, IPPROTO_TCP);
			if(tcpData->socket==INVALID_SOCKET)
				return 0;

			//bind to the port to listen to
			bindAddr6.sin6_family = AF_INET6;
			bindAddr6.sin6_port = htons(listenPort);
			if(bind(tcpData->socket, (struct sockaddr*) &bindAddr6, sizeof(bindAddr6)))
				return 0;
		} else {
			//return false if the socket failed to initialate
			tcpData->socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
			if(tcpData->socket==INVALID_SOCKET)
				return 0;

			//bind to the port to listen to
			bindAddr.sin_family = AF_INET;
			bindAddr.sin_port = htons(listenPort);
			if(bind(tcpData->socket, (struct sockaddr*) &bindAddr, sizeof(bindAddr)))
				return 0;
		}

		//make the socket listen to the port
		if(listen(tcpData->socket, SOMAXCONN))
			return 0;

		//stop the socket if the other protocols in the lsess do not succees in initiating
		if(!RequestToBindToNextProtocol(psess, lsess)) {
			closesocket(tcpData->socket);
			return 0;
		}

		//return true, the function succeed
		return 1;
	//initiate the HTTP protocol in the listen session
	} else if(psess==http_psess) {
		httpData = (MyHTTPstruct*) &pdata->data;

		//get the length of the server path
		len = 0;
		GetPluginData(psess, lsess, (ClientSession*) 0, "opt1", (char*) 0, &len, 0);

		//allocate memory to receive the memory path
		httpData->serverPath = (char*) malloc(len);
		
		//reveice the server path
		if(!GetPluginData(psess, lsess, (ClientSession*) 0, "opt1", httpData->serverPath, &len, 0))
			return 0; //GetPluginData failed, return an error

		//free the memory if the other Bind functions fail.
		if(!RequestToBindToNextProtocol(psess, lsess)) {
			free(httpData->serverPath);
			return 0;
		}
		return 1;
	}
}

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <Winsock2.h>
#include "tvsserver_base.h"
#include "tvs_redefine_api_names.h"

//Close the socket
int __stdcall PrepareCloseListenSession(ProtocolSession *psess, ListenSession *lsess){
    ProtocolData* pdata = FindProtocolDataStruct(psess, lsess->data);
    MyTCPIPstruct* tcpData = (MyTCPIPstruct*) &pdata->data;
	SOCKET mySock;

	//Get socket
	mySock = tcpData->socket;
	//clear tcpData->socket
	tcpData->socket = 0;
	//Close the socket
	closesocket(mySock);

	return 1;
}

int __stdcall CloseListenSession(ProtocolSession *psess, ListenSession *lsess) {
    ProtocolData* pdata = FindProtocolDataStruct(psess, lsess->data);
    MyTCPIPstruct* tcpData = (MyTCPIPstruct*) &pdata->data;
    MyHTTPstruct* httpData = (MyHTTPstruct*) &pdata->data;
	
	//If protocol is TCP/IP: close the socket (if not already done)
	if(psess==tcpip_psess) {
		if(tcpData->socket!=0) {
			closesocket(tcpData->socket);
			tcpData->socket = 0;
		}
	//If protocol is Replay: free teh memory for the serverPath
	} else if(psess==http_psess) {
		if(httpData->serverPath){
			free(httpData->serverPath);
			httpData->serverPath=0;
		}
	}
	return 1;
}