Added: freeswitch/branches/seven/src/mod/endpoints/mod_skypiax/skypiax_proxy.c (0 => 14730)

--- freeswitch/branches/seven/src/mod/endpoints/mod_skypiax/skypiax_proxy.c	                        (rev 0)
+++ freeswitch/branches/seven/src/mod/endpoints/mod_skypiax/skypiax_proxy.c	2009-09-02 13:22:44 UTC (rev 14730)
@@ -0,0 +1,303 @@
+/* a mac proxy bridge FreeSWITCH to skype, must run before load mod_skypiax */
+
+#include <stdio.h>
+#include <stdlib.h>  
+#include <pthread.h>
+#include <sys/socket.h>
+#include <unistd.h>
+#include <sys/types.h>
+#include <netinet/in.h>
+#include <time.h>
+
+// You must have Skype.framework inplace like /Library/Frameworks/Skype.framework
+#import <Skype/Skype.h>
+
+// #import <CoreFoundation/CoreFoundation.h>
+// #import <Cocoa/Cocoa.h>  
+// #include <Foundation/NSAutoreleasePool.h>
+#include "AutoreleasePool.h"       
+#define INVALID_SOCKET -1
+#define MAX_MESSAGE_LEN 512
+
+
+
+typedef struct SkypeDelegate SkypeDelegate;
+
+int attached = 0;
+int client_socket = INVALID_SOCKET; 
+int server_socket = INVALID_SOCKET;
+
+char current_user_handle[MAX_MESSAGE_LEN];
+
+void close_socket(int *sock) {
+	if (*sock != INVALID_SOCKET) {
+		close(*sock);
+		*sock = INVALID_SOCKET;
+	}
+}                   
+
+void SkypeNotificationReceived(CFStringRef n_string){
+	char *c_string = NULL;
+
+	int length = CFStringGetMaximumSizeForEncoding(CFStringGetLength(n_string), kCFStringEncodingUTF8);
+
+	c_string = (char *)CFStringGetCStringPtr(n_string, kCFStringEncodingUTF8);
+	if (!c_string)
+	{
+		c_string = NewPtr(length + 1);
+		CFStringGetCString(n_string, c_string, length + 1, kCFStringEncodingUTF8);
+	}
+	printf("Message received  %s\n", c_string);
+
+	if (!strncmp(c_string, "CURRENTUSERHANDLE", 17)) {
+		strncpy(current_user_handle, c_string, strlen(c_string));
+	}                                 
+
+	if (client_socket != INVALID_SOCKET) {
+		int len = 0; 
+		int sent = 0;
+		while(*(c_string + len)) len++;
+
+		len = len > MAX_MESSAGE_LEN ? MAX_MESSAGE_LEN : len;
+
+		sent = send(client_socket, c_string, strlen(c_string), 0);     
+		printf("Sent %d bytes to FreeSWITCH\n", sent);
+	}
+
+}       
+
+void SkypeAttachResponse(unsigned int aAttachResponseCode){
+	attached = aAttachResponseCode;
+	printf("Got %d, Skype instance Attached\n", attached);
+}                                          
+
+void SkypeBecameAvailable(CFPropertyListRef aNotification){}
+void SkypeBecameUnavailable(CFPropertyListRef aNotification){}
+
+#define SERVER_PORT 23456 // Waiting for FreeSWITCH to connect
+#define LENGTH_OF_LISTEN_QUEUE 10 //length of listen queue in server
+#define BUFFER_SIZE 255
+#define WELCOME_MESSAGE "SKYPIAX PROXY 0.1 "
+
+int server_port = 0;                   
+
+
+void send_skype_command(char *command) {
+	CFStringRef cmd, resp;  
+
+	InitAutoreleasePool();
+
+	cmd = CFStringCreateWithCString(kCFAllocatorDefault, command, kCFStringEncodingASCII);
+	printf("Send to skype: %s\n", CFStringGetCStringPtr(cmd, 0));
+	resp = SendSkypeCommand(cmd);
+	CFRelease(cmd);
+	if (resp != NULL) {
+		printf("Respond: %s\n", CFStringGetCStringPtr(resp, 0));
+	}                     
+
+	ReleaseAutoreleasePool();
+
+}
+
+void socket_thread() {
+
+	struct sockaddr_in server_addr,client_addr;
+
+	if ((server_socket = socket(AF_INET,SOCK_STREAM,0)) < 0)
+	{
+		printf("SOCKET error!\n");
+		exit(1);
+	}
+
+	bzero(&server_addr,sizeof(server_addr));
+	server_addr.sin_family = AF_INET;
+
+	if (server_port > 0) {
+		server_addr.sin_port = htons(server_port);
+	} else {
+		server_addr.sin_port = htons(SERVER_PORT);
+	}                                   
+
+	server_addr.sin_addr.s_addr = htons(INADDR_ANY);
+
+	if (bind(server_socket, (struct sockaddr*)&server_addr,sizeof(server_addr))<0)
+	{
+		printf("Bind port %d failure!\n",SERVER_PORT);
+		exit(1);
+	}
+
+	if (listen(server_socket, LENGTH_OF_LISTEN_QUEUE) < 0)
+	{
+		printf("Listen failure!\n");
+		exit(1);
+	}
+
+	printf("Socket server started. Socket %d waiting for connect\n", server_socket) ;
+
+	while (1)
+	{
+
+		char buf[BUFFER_SIZE];
+		long timestamp;
+		socklen_t length = sizeof(client_addr);
+
+		client_socket = accept(server_socket, (struct sockaddr*)&client_addr, &length);
+
+		if (client_socket < 0)
+		{
+			printf("ACCEPT error!\n");
+			break;
+		}
+
+		strcpy(buf,WELCOME_MESSAGE);
+
+		//inet_ntop(INET_ADDRSTRLEN,cliaddr.sin_addr,buf,BUFFER_SIZE);
+
+		printf("New connection from %s:%d\n", 
+			(char *)inet_ntoa(client_addr.sin_addr), (int)ntohs(client_addr.sin_port) );
+
+		timestamp = time(NULL);
+		strcat(buf,ctime(&timestamp));
+		send(client_socket, buf, BUFFER_SIZE, 0);      
+
+		fd_set sockset;
+		FD_ZERO(&sockset);
+		FD_SET(client_socket, &sockset);           
+
+		while(1) {
+
+			if (select(client_socket + 1, &sockset, &sockset, NULL, NULL) > 0) {
+				length = recv(client_socket, buf, BUFFER_SIZE, 0);          
+				
+				if (length <= 0 ) {
+					break;
+				}         
+				
+				length = length >= BUFFER_SIZE ? BUFFER_SIZE - 1 : length;
+				buf[length] = '\0';       
+				printf("Sending to skype: %s\n", buf);
+				send_skype_command(buf);
+
+				if (!strncmp(buf, "NAME skypiax", 5)) { 
+					printf("current_user_handle: %s\n", current_user_handle);
+					send(client_socket, current_user_handle, strlen(current_user_handle), 0);
+				}                           
+
+				if (!strncmp(buf, "/close", 6)) { 
+
+					close_socket(&client_socket);
+					printf("client disconnected\n");
+					break;
+				}    
+			}
+
+		}
+
+		send(client_socket, "ERR", 3, 0);
+		close_socket(&client_socket);  
+
+	}//exit
+
+	close_socket(&server_socket);
+	attached = 0;
+
+}
+
+void console_thread() {
+	char c = 'A';
+	char buffer[1024];                                 
+	char *tmp = buffer;
+
+	bzero(tmp, 1024);
+
+	InitAutoreleasePool();
+	printf("Console started:\n");
+	while(c != EOF) {       
+		c = getchar();
+		switch(c) {
+			case '\n': /* parse and execute. */
+			if (tmp[0] != '\0') {
+				if (!strcmp("exit", tmp)) {
+					close_socket(&client_socket);
+					close_socket(&server_socket);
+					goto end;
+				}
+
+				if (*tmp == '/') {
+					tmp++;                
+					send(client_socket, tmp, strlen(tmp), 0);
+					bzero(tmp, strlen(tmp));
+					continue;
+				}
+
+				send_skype_command(tmp);
+				bzero(tmp, sizeof(tmp));
+			} 
+			printf(">>> \n");      
+			break;
+			default: strncat(tmp, &c, 1);
+			break;
+		}
+	}
+	end:	                                                       
+	DisconnectFromSkype();     
+	RemoveSkypeDelegate();
+	ReleaseAutoreleasePool();
+	attached = 0;
+
+}                          
+
+int main(int argc, char **argv)
+{
+
+	SkypeDelegate skype_delegate;
+	skype_delegate.clientApplicationName = CFSTR("skypiax");
+	skype_delegate.SkypeNotificationReceived = SkypeNotificationReceived;
+	skype_delegate.SkypeAttachResponse = SkypeAttachResponse;
+	skype_delegate.SkypeBecameAvailable = SkypeBecameAvailable;
+	skype_delegate.SkypeBecameUnavailable = SkypeBecameUnavailable; 
+
+	pthread_t console_tid, socket_tid;
+
+	if (argc > 1 && atoi(argv[1]) > 1024) {
+		server_port = atoi(argv[1]);
+	}               
+
+	// InitAutoreleasePool();
+
+	NSAutoreleasePool* pool	= [[NSAutoreleasePool alloc] init];
+
+	SetSkypeDelegate(&skype_delegate); 
+
+	if (! IsSkypeRunning()) {
+		printf("Please start skype first\n");
+		exit(1);
+	};
+
+	ConnectToSkype();
+
+	while(!attached) {
+		printf("Waiting for skype response...");
+		RunCurrentEventLoop(1);
+
+	}       	
+
+	pthread_create(&console_tid, NULL, (void *) console_thread, NULL);
+	pthread_create(&socket_tid, NULL, (void *) socket_thread, NULL);
+
+	printf("Run application event loop\n");
+	while (attached) {
+		RunCurrentEventLoop(0.5);
+		// printf("sleep 0.5\n");
+	}
+
+	// DisconnectFromSkype();     
+	// RemoveSkypeDelegate();
+	// ReleaseAutoreleasePool();
+	[pool release]; 
+
+	close_socket(&server_socket);
+	// pthread_join(console_tid, NULL);
+	// pthread_join(socket_tid, NULL);     
+	return 0;
+}
\ No newline at end of file