Author: gmaruzz Date: Sat Mar 28 13:03:33 2009 New Revision: 12825 Log: skypiax: added configs/client.c, will be the basis for farming out :-) Added: freeswitch/trunk/src/mod/endpoints/mod_skypiax/configs/client.c Added: freeswitch/trunk/src/mod/endpoints/mod_skypiax/configs/client.c ============================================================================== --- (empty file) +++ freeswitch/trunk/src/mod/endpoints/mod_skypiax/configs/client.c Sat Mar 28 13:03:33 2009 @@ -0,0 +1,282 @@ +//gcc -Wall -ggdb client.c -o client -lX11 -lpthread +#include <stdio.h> +#include <unistd.h> +#include <X11/Xlib.h> +#include <X11/Xlibint.h> +#include <X11/Xatom.h> +#include <pthread.h> + +Display *disp = NULL; + +struct SkypiaxHandles { + Window skype_win; + Display *disp; + Window win; + int api_connected; + int fdesc[2]; +}; + +XErrorHandler old_handler = 0; +int xerror = 0; +char *dispname; + +int X11_errors_handler(Display * dpy, XErrorEvent * err) +{ + (void) dpy; + + xerror = err->error_code; + printf("\n\nReceived error code %d from X Server on display '%s'\n\n", xerror, + dispname); + return 0; /* ignore the error */ +} + +static void X11_errors_trap(void) +{ + xerror = 0; + old_handler = XSetErrorHandler(X11_errors_handler); +} + +static int X11_errors_untrap(void) +{ + XSetErrorHandler(old_handler); + return (xerror != BadValue) && (xerror != BadWindow); +} + +int skypiax_send_message(struct SkypiaxHandles *SkypiaxHandles, const char *message_P) +{ + + Window w_P; + Display *disp; + Window handle_P; + int ok; + + w_P = SkypiaxHandles->skype_win; + disp = SkypiaxHandles->disp; + handle_P = SkypiaxHandles->win; + + Atom atom1 = XInternAtom(disp, "SKYPECONTROLAPI_MESSAGE_BEGIN", False); + Atom atom2 = XInternAtom(disp, "SKYPECONTROLAPI_MESSAGE", False); + unsigned int pos = 0; + unsigned int len = strlen(message_P); + XEvent e; + + memset(&e, 0, sizeof(e)); + e.xclient.type = ClientMessage; + e.xclient.message_type = atom1; /* leading message */ + e.xclient.display = disp; + e.xclient.window = handle_P; + e.xclient.format = 8; + + X11_errors_trap(); + do { + unsigned int i; + for (i = 0; i < 20 && i + pos <= len; ++i) + e.xclient.data.b[i] = message_P[i + pos]; + XSendEvent(disp, w_P, False, 0, &e); + + e.xclient.message_type = atom2; /* following messages */ + pos += i; + } while (pos <= len); + + XSync(disp, False); + ok = X11_errors_untrap(); + + if (!ok) + printf("Sending message failed with status %d\n", xerror); + + return 1; +} + +int skypiax_present(struct SkypiaxHandles *SkypiaxHandles) +{ + Atom skype_inst = XInternAtom(SkypiaxHandles->disp, "_SKYPE_INSTANCE", True); + + Atom type_ret; + int format_ret; + unsigned long nitems_ret; + unsigned long bytes_after_ret; + unsigned char *prop; + int status; + + X11_errors_trap(); + status = + XGetWindowProperty(SkypiaxHandles->disp, DefaultRootWindow(SkypiaxHandles->disp), + skype_inst, 0, 1, False, XA_WINDOW, &type_ret, &format_ret, + &nitems_ret, &bytes_after_ret, &prop); + + X11_errors_untrap(); + /* sanity check */ + if (status != Success || format_ret != 32 || nitems_ret != 1) { + SkypiaxHandles->skype_win = (Window) - 1; + printf("Skype instance not found on display '%s'\n", dispname); + return 0; + } + + SkypiaxHandles->skype_win = *(const unsigned long *) prop & 0xffffffff; + //printf("Skype instance found on display '%s', with id #%d\n", dispname, (unsigned int) SkypiaxHandles->skype_win); + return 1; +} + +void skypiax_clean_disp(void *data) +{ + + int *dispptr; + int disp; + + dispptr = data; + disp = *dispptr; + + if (disp) { + close(disp); + } else { + } + usleep(1000); +} + +typedef struct { + int value; + char string[128]; +} thread_parm_t; + +void *threadfunc(void *parm) +{ //child + thread_parm_t *p = (thread_parm_t *) parm; + //printf("%s, parm = %d\n", p->string, p->value); + free(p); + + /* perform an events loop */ + XEvent an_event; + char buf[21]; /* can't be longer */ + char buffer[17000]; + char *b; + int i; + + b = buffer; + + while (1) { + + XNextEvent(disp, &an_event); + switch (an_event.type) { + case ClientMessage: + + if (an_event.xclient.format != 8) + break; + + for (i = 0; i < 20 && an_event.xclient.data.b[i] != '\0'; ++i) + buf[i] = an_event.xclient.data.b[i]; + + buf[i] = '\0'; + + strcat(buffer, buf); + + if (i < 20) { /* last fragment */ + unsigned int howmany; + + howmany = strlen(b) + 1; + + //printf("\tRECEIVED\t==>\t%s\n", b); + printf("%s\n", b); + memset(buffer, '\0', 17000); + } + + break; + default: + break; + } + + } + return NULL; +} + +int main(int argc, char *argv[]) +{ + + struct SkypiaxHandles SkypiaxHandles; + char buf[512]; + //Display *disp = NULL; + Window root = -1; + Window win = -1; + + if (argc == 2) + dispname = argv[1]; + else + dispname = ":0.0"; + + disp = XOpenDisplay(dispname); + if (!disp) { + printf("Cannot open X Display '%s', exiting\n", dispname); + return -1; + } + + int xfd; + xfd = XConnectionNumber(disp); + + SkypiaxHandles.disp = disp; + + if (skypiax_present(&SkypiaxHandles)) { + root = DefaultRootWindow(disp); + win = + XCreateSimpleWindow(disp, root, 0, 0, 1, 1, 0, + BlackPixel(disp, DefaultScreen(disp)), BlackPixel(disp, + DefaultScreen + (disp))); + + SkypiaxHandles.win = win; + + snprintf(buf, 512, "NAME skypiax"); + + if (!skypiax_send_message(&SkypiaxHandles, buf)) { + printf + ("Sending message failed - probably Skype crashed. Please run/restart Skype manually and launch skypiax_auth again\n"); + return -1; + } + + snprintf(buf, 512, "PROTOCOL 6"); + if (!skypiax_send_message(&SkypiaxHandles, buf)) { + printf + ("Sending message failed - probably Skype crashed. Please run/restart Skype manually and launch skypiax_auth again\n"); + return -1; + } + + snprintf(buf, 512, "#ciapalino PING"); + if (!skypiax_send_message(&SkypiaxHandles, buf)) { + printf + ("Sending message failed - probably Skype crashed. Please run/restart Skype manually and launch skypiax_auth again\n"); + return -1; + } + + pthread_t thread; + int rc = 0; + pthread_attr_t pta; + thread_parm_t *parm = NULL; + + rc = pthread_attr_init(&pta); + + parm = malloc(sizeof(thread_parm_t)); + parm->value = 5; + rc = pthread_create(&thread, NULL, threadfunc, (void *) parm); + + while (1) { + char s[512]; + + memset(s, '\0', 512); + fgets(s, sizeof(s) - 1, stdin); + s[strlen(s) - 1] = '\0'; + + //printf("\tSENT\t\t==>\t%s\n", s); + + if (!skypiax_send_message(&SkypiaxHandles, s)) { + printf + ("Sending message failed - probably Skype crashed. Please run/restart Skype manually and launch skypiax_auth again\n"); + return -1; + } + } + } else { + printf + ("Skype client not found on display '%s'. Please run/restart Skype manually and launch skypiax_auth again\n\n\n", + dispname); + return -1; + } + return 0; + +}