mirror of
https://github.com/signalwire/freeswitch.git
synced 2025-07-26 19:57:42 +00:00
skypiax: added configs/client.c, will be the basis for farming out :-)
git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@12825 d0543943-73ff-0310-b7d9-9358b9ac24b2
This commit is contained in:
Giovanni Maruzzelli
parent
b3e27324f8
commit
dd55e006ae
282
src/mod/endpoints/mod_skypiax/configs/client.c
Normal file
282
src/mod/endpoints/mod_skypiax/configs/client.c
Normal file
@ -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;
|
||||||
|
|
||||||
|
}
|
||||||
Loading…
x
Reference in New Issue
Block a user