X-Git-Url: https://repo.or.cz/w/wmaker-crm.git/blobdiff_plain/59fc927dc9f183802621138534fa6eaafe5593ba..688a56e8ab67b56550e2874d9d7423f0d435bfd9:/WINGs/Examples/server.c

diff --git a/WINGs/Examples/server.c b/WINGs/Examples/server.c
dissimilarity index 94%
index d0d0e454..e747a1f5 100644
--- a/WINGs/Examples/server.c
+++ b/WINGs/Examples/server.c
@@ -1,740 +1,661 @@
-/*
- *  WINGs server.c: example how to create a network server using WMConnection
- *
- *  Copyright (c) 2001-2003 Dan Pascu
- *
- */
-
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <unistd.h>
-#include <string.h>
-
-#include <WINGs/WINGs.h>
-
-
-#define _(P)         P
-#define MAXCMD_SIZE  512
-
-
-char *SEConnectionShouldBeRemovedNotification = "SEConnectionShouldBeRemovedNotification";
-
-
-
-
-static void didReceiveInput(ConnectionDelegate *self, WMConnection *cPtr);
-
-static void connectionDidDie(ConnectionDelegate *self, WMConnection *cPtr);
-
-static void connectionDidTimeout(ConnectionDelegate *self, WMConnection *cPtr);
-
-
-extern char *SEConnectionShouldBeRemovedNotification;
-
-static WMUserDefaults *timeDB = NULL;
-static char *ServerAddress = NULL;
-static char *ServerPort = NULL;
-static WMArray *allowedHostList = NULL;
-static WMArray *clientConnections = NULL;
-static WMConnection *serverPtr = NULL;
-
-
-
-static ConnectionDelegate socketDelegate = {
-    NULL,                 /* client data */
-    NULL,                 /* canResumeSending */
-    NULL,                 /* didCatchException */
-    connectionDidDie,     /* didDie */
-    NULL,                 /* didInitialize */
-    didReceiveInput,      /* didReceiveInput */
-    connectionDidTimeout  /* didTimeout */
-};
-
-
-
-void
-wAbort(Bool foo)
-{
-    exit(1);
-}
-
-
-static void
-printHelp(char *progname)
-{
-    printf(_("usage: %s [options]\n\n"), progname);
-    puts(_(" --help				print this message"));
-    puts(_(" --listen [address:]port	only listen on the specified address/port"));
-    puts(_(" --allow host1[,host2...]	only allow connections from listed hosts\n"));
-    puts(_(" By default server listens on all interfaces and port 34567, unless"
-           " something\nelse is specified with the --listen option. If address is"
-           " omitted or the keyword\n'Any' is used, it will listen on all interfaces else"
-           " only on the specified one.\n\nFor example --listen localhost: will"
-           " listen on the default port 34567, but only\non connections comming"
-           " in through the loopback interface.\n\n Also by default the server"
-           " listens to incoming connections from any host,\nunless a list of"
-           " hosts is given with the --allow option, in which case it will\nreject"
-           " connections not comming from those hosts.\nThe list of hosts is comma"
-           " separated and should NOT contain ANY spaces."));
-}
-
-
-static void
-enqueueConnectionForRemoval(WMConnection *cPtr)
-{
-    WMNotification *notif;
-
-    /*don't release notif here. it will be released by queue after processing */
-    notif = WMCreateNotification(SEConnectionShouldBeRemovedNotification,
-                                 cPtr, NULL);
-    WMEnqueueNotification(WMGetDefaultNotificationQueue(), notif, WMPostASAP);
-}
-
-
-static int
-sendMessage(WMConnection *cPtr, char *message)
-{
-    WMData *aData;
-    int res;
-
-    if (WMGetConnectionState(cPtr)!=WCConnected)
-        return -1;
-
-    aData = WMCreateDataWithBytes(message, strlen(message));
-    res = WMSendConnectionData(cPtr, aData);
-    WMReleaseData(aData);
-
-    return res;
-}
-
-
-static Bool
-enqueueMessage(WMConnection *cPtr, char *message)
-{
-    WMData *aData;
-    Bool res;
-
-    if (WMGetConnectionState(cPtr)!=WCConnected)
-        return False;
-
-    aData = WMCreateDataWithBytes(message, strlen(message));
-    res = WMEnqueueConnectionData(cPtr, aData);
-    WMReleaseData(aData);
-
-    return res;
-}
-
-
-static char*
-findDelimiter(char *data, const char *endPtr)
-{
-    wassertrv(data < endPtr, NULL);
-
-    while (data<endPtr && *data!='\n' && *data!='\r' && *data!=';' && *data!='\0')
-        data++;
-
-    if (data < endPtr)
-        return data;
-
-    return NULL;
-}
-
-
-static WMArray*
-getAvailableMessages(WMConnection *cPtr)
-{
-    char *ptr, *crtPos, *buffer;
-    const char *bytes, *endPtr;
-    WMData *aData, *receivedData, *holdData;
-    WMRange range;
-    WMArray *messages;
-    int length;
-
-    receivedData = WMGetConnectionAvailableData(cPtr);
-    if (!receivedData)
-        return NULL;
-    if ((length=WMGetDataLength(receivedData))==0) {
-        WMReleaseData(receivedData);
-        return NULL;
-    }
-
-    holdData = (WMData*)WMGetConnectionClientData(cPtr);
-    if (holdData) {
-        WMAppendData(holdData, receivedData);
-        WMReleaseData(receivedData);
-        WMSetConnectionClientData(cPtr, NULL);
-        aData = holdData;
-    } else {
-        aData = receivedData;
-    }
-
-    length = WMGetDataLength(aData);
-    bytes = (char*)WMDataBytes(aData);
-    endPtr = bytes + length;
-
-    messages = WMCreateArrayWithDestructor(1, wfree);
-    crtPos = (char*)bytes;
-    while (crtPos<endPtr && (ptr = findDelimiter(crtPos, endPtr))!=NULL) {
-        range.position = (crtPos - bytes);
-        range.count = (ptr - crtPos);
-        if (range.count > MAXCMD_SIZE) {
-            /* Hmmm... The message is too long. Possibly that someone is
-             * flooding us, or there is a dumb client which do not know
-             * who is talking to. */
-            sendMessage(cPtr, "Command too long\n\r");
-            WMFreeArray(messages);
-            WMReleaseData(aData);
-            WMCloseConnection(cPtr);
-            enqueueConnectionForRemoval(cPtr);
-            return NULL;
-        }
-        buffer = wmalloc(range.count+1);
-        WMGetDataBytesWithRange(aData, buffer, range);
-        buffer[range.count] = '\0';
-        WMAddToArray(messages, buffer);
-        crtPos = ptr;
-        while (crtPos<endPtr && (*crtPos=='\n' || *crtPos=='\r' ||
-                                 *crtPos=='\t' || *crtPos=='\0' ||
-                                 *crtPos==';' || *crtPos==' ')) {
-            crtPos++;
-        }
-    }
-
-    if (crtPos<endPtr) {
-        range.position = (crtPos - bytes);
-        range.count = (endPtr - crtPos);
-        if (range.count > MAXCMD_SIZE) {
-            /* Flooooooding!!!! */
-            sendMessage(cPtr, "Message too long\n\r");
-            WMFreeArray(messages);
-            WMReleaseData(aData);
-            WMCloseConnection(cPtr);
-            enqueueConnectionForRemoval(cPtr);
-            return NULL;
-        }
-        holdData = WMGetSubdataWithRange(aData, range);
-        WMSetConnectionClientData(cPtr, holdData);
-    }
-    WMReleaseData(aData);
-
-    if (WMGetArrayItemCount(messages)==0) {
-        WMFreeArray(messages);
-        messages = NULL;
-    }
-    return messages;
-}
-
-
-
-static void
-complainAboutBadArgs(WMConnection *cPtr, char *cmdName, char *badArgs)
-{
-    char *buf = wmalloc(strlen(cmdName) + strlen(badArgs) + 100);
-
-    sprintf(buf, _("Invalid parameters '%s' for command %s. Use HELP for"
-                   " a list of commands.\n"), badArgs, cmdName);
-    sendMessage(cPtr, buf);
-    wfree(buf);
-}
-
-
-static void
-sendUpdateMessage(WMConnection *cPtr, char *id, int time)
-{
-    char *buf = wmalloc(strlen(id) + 100);
-
-    sprintf(buf, "%s has %i minutes left\n", id, time);
-    sendMessage(cPtr, buf);
-    wfree(buf);
-}
-
-
-static void
-showId(WMConnection *cPtr)
-{
-    sendMessage(cPtr, "Server example based on WMConnection\n");
-}
-
-
-static void
-showHelp(WMConnection *cPtr)
-{
-    char *buf = wmalloc(strlen(WMGetApplicationName()) + 16);
-
-    sprintf(buf, _("%s commands:\n\n"), WMGetApplicationName());
-
-    enqueueMessage(cPtr, _("\n"));
-    enqueueMessage(cPtr, buf);
-    enqueueMessage(cPtr, _("GET <id>\t- return time left (in minutes) "
-                           "for user with id <id>\n"));
-    enqueueMessage(cPtr, _("SET <id> <time>\t- set time limit to <time> "
-                           "minutes for user with id <id>\n"));
-    enqueueMessage(cPtr, _("ADD <id> <time>\t- add <time> minutes "
-                           "for user with id <id>\n"));
-    enqueueMessage(cPtr, _("SUB <id> <time>\t- subtract <time> minutes "
-                           "for user with id <id>\n"));
-    enqueueMessage(cPtr, _("REMOVE <id>\t- remove time limitations for "
-                           "user with id <id>\n"));
-    enqueueMessage(cPtr, _("LIST\t\t- list all users and their "
-                           "corresponding time limit\n"));
-    enqueueMessage(cPtr, _("ID\t\t- returns the Time Manager "
-                           "identification string\n"));
-    enqueueMessage(cPtr, _("EXIT\t\t- exits session\n"));
-    enqueueMessage(cPtr, _("QUIT\t\t- exits session\n"));
-    enqueueMessage(cPtr, _("HELP\t\t- show this message\n\n"));
-    /* Just flush the queue we made before */
-    WMFlushConnection(cPtr);
-    wfree(buf);
-}
-
-
-static void
-listUsers(WMConnection *cPtr)
-{
-    WMPropList *userList;
-    char *id;
-    int i, time;
-
-    userList = WMGetUDKeys(timeDB);
-
-    for (i=0; i<WMGetPropListItemCount(userList); i++) {
-        id = WMGetFromPLString(WMGetFromPLArray(userList, i));
-        time = WMGetUDIntegerForKey(timeDB, id);
-        sendUpdateMessage(cPtr, id, time);
-    }
-
-    WMReleasePropList(userList);
-}
-
-
-static void
-setTimeForUser(WMConnection *cPtr, char *cmdArgs)
-{
-    char *id;
-    int i, time;
-
-    id = wmalloc(strlen(cmdArgs));
-    if (sscanf(cmdArgs, "%s %d", id, &time)!=2) {
-        complainAboutBadArgs(cPtr, "SET", cmdArgs);
-        wfree(id);
-        return;
-    }
-    if (time<0)
-        time = 0;
-
-    WMSetUDIntegerForKey(timeDB, time, id);
-
-    for (i=0; i<WMGetArrayItemCount(clientConnections); i++) {
-        cPtr = WMGetFromArray(clientConnections, i);
-        sendUpdateMessage(cPtr, id, time);
-    }
-    wfree(id);
-}
-
-
-static void
-addTimeToUser(WMConnection *cPtr, char *cmdArgs)
-{
-    char *id;
-    int i, time, newTime;
-
-    id = wmalloc(strlen(cmdArgs));
-    if (sscanf(cmdArgs, "%s %d", id, &time)!=2) {
-        complainAboutBadArgs(cPtr, "ADD", cmdArgs);
-        wfree(id);
-        return;
-    }
-
-    newTime = WMGetUDIntegerForKey(timeDB, id) + time;
-    if (newTime<0)
-        newTime = 0;
-
-    WMSetUDIntegerForKey(timeDB, newTime, id);
-
-    for (i=0; i<WMGetArrayItemCount(clientConnections); i++) {
-        cPtr = WMGetFromArray(clientConnections, i);
-        sendUpdateMessage(cPtr, id, newTime);
-    }
-    wfree(id);
-}
-
-
-static void
-subTimeFromUser(WMConnection *cPtr, char *cmdArgs)
-{
-    char *id;
-    int i, time, newTime;
-
-    id = wmalloc(strlen(cmdArgs));
-    if (sscanf(cmdArgs, "%s %d", id, &time)!=2) {
-        complainAboutBadArgs(cPtr, "SUB", cmdArgs);
-        wfree(id);
-        return;
-    }
-
-    newTime = WMGetUDIntegerForKey(timeDB, id) - time;
-    if (newTime<0)
-        newTime = 0;
-
-    WMSetUDIntegerForKey(timeDB, newTime, id);
-
-    for (i=0; i<WMGetArrayItemCount(clientConnections); i++) {
-        cPtr = WMGetFromArray(clientConnections, i);
-        sendUpdateMessage(cPtr, id, newTime);
-    }
-    wfree(id);
-}
-
-
-static void
-removeTimeForUser(WMConnection *cPtr, char *cmdArgs)
-{
-    char *ptr;
-    int i;
-
-    if (cmdArgs[0]=='\0') {
-        sendMessage(cPtr, _("Missing parameter for command REMOVE."
-                            " Use HELP for a list of commands.\n"));
-        return;
-    }
-
-    ptr = cmdArgs;
-    while (*ptr && *ptr!=' ' && *ptr!='\t')
-        ptr++;
-    *ptr = '\0';
-
-    WMRemoveUDObjectForKey(timeDB, cmdArgs);
-
-    for (i=0; i<WMGetArrayItemCount(clientConnections); i++) {
-        cPtr = WMGetFromArray(clientConnections, i);
-        sendUpdateMessage(cPtr, cmdArgs, -1);
-    }
-}
-
-
-static void
-getTimeForUser(WMConnection *cPtr, char *cmdArgs)
-{
-    char *ptr;
-    int time;
-
-    if (cmdArgs[0]=='\0') {
-        sendMessage(cPtr, _("Missing parameter for command GET."
-                            " Use HELP for a list of commands.\n"));
-        return;
-    }
-
-    ptr = cmdArgs;
-    while (*ptr && *ptr!=' ' && *ptr!='\t')
-        ptr++;
-    *ptr = '\0';
-
-    if (WMGetUDObjectForKey(timeDB, cmdArgs)!=NULL)
-        time = WMGetUDIntegerForKey(timeDB, cmdArgs);
-    else
-        time = -1;
-
-    sendUpdateMessage(cPtr, cmdArgs, time);
-}
-
-
-static void
-handleConnection(WMConnection *cPtr)
-{
-    char *command, *ptr, *cmdArgs, *buffer;
-    WMArray *commands;
-    int i;
-
-    commands = getAvailableMessages(cPtr);
-    if (!commands)
-        return;
-
-    for (i=0; i<WMGetArrayItemCount(commands); i++) {
-        command = WMGetFromArray(commands, i);
-        while (*command && (*command==' ' || *command=='\t'))
-            command++;
-        ptr = command;
-        while(*ptr && *ptr!=' ' && *ptr!='\t')
-            ptr++;
-        if (*ptr) {
-            *ptr = '\0';
-            ptr++;
-        }
-        while (*ptr && (*ptr==' ' || *ptr=='\t'))
-            ptr++;
-
-        cmdArgs = ptr;
-
-        fprintf(stderr, "Command: '%s', args: '%s'\n", command, cmdArgs);
-
-        if (strcasecmp(command, "quit")==0 || strcasecmp(command, "exit")==0) {
-            sendMessage(cPtr, "Bye\n");
-            WMCloseConnection(cPtr);
-            enqueueConnectionForRemoval(cPtr);
-            WMFreeArray(commands);
-            return;
-        } else if (strcasecmp(command, "id")==0) {
-            showId(cPtr);
-        } else if (strcasecmp(command, "help")==0) {
-            showHelp(cPtr);
-        } else if (strcasecmp(command, "list")==0) {
-            listUsers(cPtr);
-        } else if (strcasecmp(command, "set")==0) {
-            setTimeForUser(cPtr, cmdArgs);
-        } else if (strcasecmp(command, "add")==0) {
-            addTimeToUser(cPtr, cmdArgs);
-        } else if (strcasecmp(command, "sub")==0) {
-            subTimeFromUser(cPtr, cmdArgs);
-        } else if (strcasecmp(command, "remove")==0) {
-            removeTimeForUser(cPtr, cmdArgs);
-        } else if (strcasecmp(command, "get")==0) {
-            getTimeForUser(cPtr, cmdArgs);
-        } else {
-            buffer = wmalloc(strlen(command) + 100);
-            sprintf(buffer, _("Unknown command '%s'. Try HELP for"
-                              " a list of commands.\n"), command);
-            sendMessage(cPtr, buffer);
-            wfree(buffer);
-        }
-    }
-
-    WMFreeArray(commands);
-}
-
-
-static Bool
-isAllowedToConnect(WMConnection *cPtr)
-{
-    WMHost *hPtr;
-    int i;
-
-    if (allowedHostList == NULL)
-        return True; /* No list. Allow all by default */
-
-    hPtr = WMGetHostWithAddress(WMGetConnectionAddress(cPtr));
-    for (i=0; i<WMGetArrayItemCount(allowedHostList); i++) {
-        if (WMIsHostEqualToHost(hPtr, WMGetFromArray(allowedHostList, i))) {
-            WMReleaseHost(hPtr);
-            return True;
-        }
-    }
-
-    WMReleaseHost(hPtr);
-
-    return False;
-}
-
-
-static void
-didReceiveInput(ConnectionDelegate *self, WMConnection *cPtr)
-{
-    if (cPtr == serverPtr) {
-        WMConnection *newPtr = WMAcceptConnection(cPtr);
-
-        if (newPtr) {
-            if (isAllowedToConnect(newPtr)) {
-                WMSetConnectionDelegate(newPtr, &socketDelegate);
-                WMSetConnectionSendTimeout(newPtr, 120);
-                WMAddToArray(clientConnections, newPtr);
-            } else {
-                sendMessage(newPtr, "Sorry, you are not allowed to connect.\n");
-                WMDestroyConnection(newPtr);
-            }
-        }
-    } else {
-        /* Data arriving on an already-connected socket */
-        handleConnection(cPtr);
-    }
-}
-
-
-static void
-connectionDidTimeout(ConnectionDelegate *self, WMConnection *cPtr)
-{
-    WMHost *hPtr;
-
-    if (cPtr == serverPtr) {
-        wfatal(_("The server listening socket did timeout. Exiting."));
-        exit(1);
-    }
-
-    hPtr = WMGetHostWithAddress(WMGetConnectionAddress(cPtr));
-    wwarning(_("Connection with %s did timeout. Closing connection."),
-             WMGetHostName(hPtr));
-    WMReleaseHost(hPtr);
-
-    enqueueConnectionForRemoval(cPtr);
-}
-
-
-static void
-connectionDidDie(ConnectionDelegate *self, WMConnection *cPtr)
-{
-    if (cPtr == serverPtr) {
-        /* trouble. server listening port itself died!!! */
-        wfatal(_("The server listening socket died. Exiting."));
-        exit(1);
-    }
-
-    enqueueConnectionForRemoval(cPtr);
-}
-
-
-static void
-removeConnection(void *observer, WMNotification *notification)
-{
-    WMConnection *cPtr = (WMConnection*)WMGetNotificationObject(notification);
-    WMData *data;
-
-    WMRemoveFromArray(clientConnections, cPtr);
-    if ((data = (WMData*)WMGetConnectionClientData(cPtr))!=NULL)
-        WMReleaseData(data);
-    WMDestroyConnection(cPtr);
-}
-
-static void
-updatedDomain(void *observer, WMNotification *notification)
-{
-    wmessage("defaults domain file changed on disk. synchronizing.");
-}
-
-
-#if 0
-static Bool
-isDifferent(char *str1, char *str2)
-{
-    if ((!str1 && !str2) || (str1 && str2 && strcmp(str1, str2)==0))
-        return False;
-
-    return True;
-}
-#endif
-
-
-int
-main(int argc, char **argv)
-{
-    int i;
-
-    wsetabort(wAbort);
-
-    WMInitializeApplication("server", &argc, argv);
-
-    if (argc>1) {
-        for (i=1; i<argc; i++) {
-            if (strcmp(argv[i], "--help")==0) {
-                printHelp(argv[0]);
-                exit(0);
-            } else if (strcmp(argv[i], "--listen")==0) {
-                char *p;
-
-                if ((p = strchr(argv[++i], ':')) != NULL) {
-                    *p = 0;
-                    ServerAddress = wstrdup(argv[i]);
-                    ServerPort = wstrdup(p+1);
-                    *p = ':';
-                    if (ServerAddress[0] == 0) {
-                        wfree(ServerAddress);
-                        ServerAddress = NULL;
-                    }
-                    if (ServerPort[0] == 0) {
-                        wfree(ServerPort);
-                        ServerPort = "34567";
-                    }
-                } else if (argv[i][0]!=0) {
-                    ServerPort = argv[i];
-                }
-            } else if (strcmp(argv[i], "--allow")==0) {
-                char *p, *ptr;
-                int done;
-                WMHost *hPtr;
-
-                ptr = argv[++i];
-                done = 0;
-                while (!done) {
-                    if ((p = strchr(ptr, ',')) != NULL) {
-                        *p = 0;
-                    }
-                    if (*ptr != 0) {
-                        hPtr = WMGetHostWithName(ptr);
-                        if (hPtr) {
-                            if (!allowedHostList)
-                                allowedHostList = WMCreateArray(4);
-                            WMAddToArray(allowedHostList, hPtr);
-                        } else {
-                            wwarning(_("Unknown host '%s'. Ignored."), ptr);
-                        }
-                    }
-
-                    if (p!=NULL) {
-                        *p = ',';
-                        ptr = p+1;
-                    } else {
-                        done = 1;
-                    }
-                }
-            } else {
-                printf(_("%s: invalid argument '%s'\n"), argv[0], argv[i]);
-                printf(_("Try '%s --help' for more information\n"), argv[0]);
-                exit(1);
-            }
-        }
-    }
-
-    timeDB = WMGetDefaultsFromPath("./UserTime.plist");
-    WMAddNotificationObserver(updatedDomain, NULL,
-                              WMUserDefaultsDidChangeNotification, NULL);
-
-    clientConnections = WMCreateArray(4);
-
-    /* A NULL ServerAddress means to listen on any address the host has.
-     * Else if ServerAddress points to a specific address (like "localhost",
-     * "host.domain.com" or "192.168.1.1"), then it will only listen on that
-     * interface and ignore incoming connections on the others. */
-    if (ServerAddress && strcasecmp(ServerAddress, "Any")==0)
-        ServerAddress = NULL;
-    if (ServerPort==NULL)
-        ServerPort = "34567";
-
-    printf("Server will listen on '%s:%s'\n", ServerAddress?ServerAddress:"Any",
-           ServerPort);
-    printf("This server will allow connections from:");
-    if (allowedHostList) {
-        int i;
-        char *hName;
-
-        for (i=0; i<WMGetArrayItemCount(allowedHostList); i++) {
-            hName = WMGetHostName(WMGetFromArray(allowedHostList, i));
-            printf("%s'%s'", i==0?" ":", ", hName);
-        }
-        printf(".\n");
-    } else {
-        printf(" any host.\n");
-    }
-
-    serverPtr = WMCreateConnectionAsServerAtAddress(ServerAddress, ServerPort,
-                                                    NULL);
-
-    if (!serverPtr) {
-        wfatal("could not create server on `%s:%s`. Exiting.",
-               ServerAddress ? ServerAddress : "localhost", ServerPort);
-        exit(1);
-    }
-
-    WMSetConnectionDelegate(serverPtr, &socketDelegate);
-
-    WMAddNotificationObserver(removeConnection, NULL,
-                              SEConnectionShouldBeRemovedNotification, NULL);
-
-    while (1) {
-        /* The ASAP notification queue is called at the end of WHandleEvents()
-         * There's where died connections we get while running through
-         * WHandleEvents() get removed. */
-        WHandleEvents();
-    }
-
-    return 0;
-}
-
-
+/*
+ *  WINGs server.c: example how to create a network server using WMConnection
+ *
+ *  Copyright (c) 2001-2003 Dan Pascu
+ *
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <string.h>
+
+#include <WINGs/WINGs.h>
+
+#define _(P)         P
+#define MAXCMD_SIZE  512
+
+char *SEConnectionShouldBeRemovedNotification = "SEConnectionShouldBeRemovedNotification";
+
+static void didReceiveInput(ConnectionDelegate * self, WMConnection * cPtr);
+
+static void connectionDidDie(ConnectionDelegate * self, WMConnection * cPtr);
+
+static void connectionDidTimeout(ConnectionDelegate * self, WMConnection * cPtr);
+
+extern char *SEConnectionShouldBeRemovedNotification;
+
+static WMUserDefaults *timeDB = NULL;
+static char *ServerAddress = NULL;
+static char *ServerPort = NULL;
+static WMArray *allowedHostList = NULL;
+static WMArray *clientConnections = NULL;
+static WMConnection *serverPtr = NULL;
+
+static ConnectionDelegate socketDelegate = {
+	NULL,			/* client data */
+	NULL,			/* canResumeSending */
+	NULL,			/* didCatchException */
+	connectionDidDie,	/* didDie */
+	NULL,			/* didInitialize */
+	didReceiveInput,	/* didReceiveInput */
+	connectionDidTimeout	/* didTimeout */
+};
+
+void wAbort(Bool foo)
+{
+	exit(1);
+}
+
+static void printHelp(char *progname)
+{
+	printf(_("usage: %s [options]\n\n"), progname);
+	puts(_(" --help				print this message"));
+	puts(_(" --listen [address:]port	only listen on the specified address/port"));
+	puts(_(" --allow host1[,host2...]	only allow connections from listed hosts\n"));
+	puts(_(" By default server listens on all interfaces and port 34567, unless"
+	       " something\nelse is specified with the --listen option. If address is"
+	       " omitted or the keyword\n'Any' is used, it will listen on all interfaces else"
+	       " only on the specified one.\n\nFor example --listen localhost: will"
+	       " listen on the default port 34567, but only\non connections comming"
+	       " in through the loopback interface.\n\n Also by default the server"
+	       " listens to incoming connections from any host,\nunless a list of"
+	       " hosts is given with the --allow option, in which case it will\nreject"
+	       " connections not comming from those hosts.\nThe list of hosts is comma"
+	       " separated and should NOT contain ANY spaces."));
+}
+
+static void enqueueConnectionForRemoval(WMConnection * cPtr)
+{
+	WMNotification *notif;
+
+	/*don't release notif here. it will be released by queue after processing */
+	notif = WMCreateNotification(SEConnectionShouldBeRemovedNotification, cPtr, NULL);
+	WMEnqueueNotification(WMGetDefaultNotificationQueue(), notif, WMPostASAP);
+}
+
+static int sendMessage(WMConnection * cPtr, char *message)
+{
+	WMData *aData;
+	int res;
+
+	if (WMGetConnectionState(cPtr) != WCConnected)
+		return -1;
+
+	aData = WMCreateDataWithBytes(message, strlen(message));
+	res = WMSendConnectionData(cPtr, aData);
+	WMReleaseData(aData);
+
+	return res;
+}
+
+static Bool enqueueMessage(WMConnection * cPtr, char *message)
+{
+	WMData *aData;
+	Bool res;
+
+	if (WMGetConnectionState(cPtr) != WCConnected)
+		return False;
+
+	aData = WMCreateDataWithBytes(message, strlen(message));
+	res = WMEnqueueConnectionData(cPtr, aData);
+	WMReleaseData(aData);
+
+	return res;
+}
+
+static char *findDelimiter(char *data, const char *endPtr)
+{
+	wassertrv(data < endPtr, NULL);
+
+	while (data < endPtr && *data != '\n' && *data != '\r' && *data != ';' && *data != '\0')
+		data++;
+
+	if (data < endPtr)
+		return data;
+
+	return NULL;
+}
+
+static WMArray *getAvailableMessages(WMConnection * cPtr)
+{
+	char *ptr, *crtPos, *buffer;
+	const char *bytes, *endPtr;
+	WMData *aData, *receivedData, *holdData;
+	WMRange range;
+	WMArray *messages;
+	int length;
+
+	receivedData = WMGetConnectionAvailableData(cPtr);
+	if (!receivedData)
+		return NULL;
+	if ((length = WMGetDataLength(receivedData)) == 0) {
+		WMReleaseData(receivedData);
+		return NULL;
+	}
+
+	holdData = (WMData *) WMGetConnectionClientData(cPtr);
+	if (holdData) {
+		WMAppendData(holdData, receivedData);
+		WMReleaseData(receivedData);
+		WMSetConnectionClientData(cPtr, NULL);
+		aData = holdData;
+	} else {
+		aData = receivedData;
+	}
+
+	length = WMGetDataLength(aData);
+	bytes = (char *)WMDataBytes(aData);
+	endPtr = bytes + length;
+
+	messages = WMCreateArrayWithDestructor(1, wfree);
+	crtPos = (char *)bytes;
+	while (crtPos < endPtr && (ptr = findDelimiter(crtPos, endPtr)) != NULL) {
+		range.position = (crtPos - bytes);
+		range.count = (ptr - crtPos);
+		if (range.count > MAXCMD_SIZE) {
+			/* Hmmm... The message is too long. Possibly that someone is
+			 * flooding us, or there is a dumb client which do not know
+			 * who is talking to. */
+			sendMessage(cPtr, "Command too long\n\r");
+			WMFreeArray(messages);
+			WMReleaseData(aData);
+			WMCloseConnection(cPtr);
+			enqueueConnectionForRemoval(cPtr);
+			return NULL;
+		}
+		buffer = wmalloc(range.count + 1);
+		WMGetDataBytesWithRange(aData, buffer, range);
+		buffer[range.count] = '\0';
+		WMAddToArray(messages, buffer);
+		crtPos = ptr;
+		while (crtPos < endPtr && (*crtPos == '\n' || *crtPos == '\r' ||
+					   *crtPos == '\t' || *crtPos == '\0' ||
+					   *crtPos == ';' || *crtPos == ' ')) {
+			crtPos++;
+		}
+	}
+
+	if (crtPos < endPtr) {
+		range.position = (crtPos - bytes);
+		range.count = (endPtr - crtPos);
+		if (range.count > MAXCMD_SIZE) {
+			/* Flooooooding!!!! */
+			sendMessage(cPtr, "Message too long\n\r");
+			WMFreeArray(messages);
+			WMReleaseData(aData);
+			WMCloseConnection(cPtr);
+			enqueueConnectionForRemoval(cPtr);
+			return NULL;
+		}
+		holdData = WMGetSubdataWithRange(aData, range);
+		WMSetConnectionClientData(cPtr, holdData);
+	}
+	WMReleaseData(aData);
+
+	if (WMGetArrayItemCount(messages) == 0) {
+		WMFreeArray(messages);
+		messages = NULL;
+	}
+	return messages;
+}
+
+static void complainAboutBadArgs(WMConnection * cPtr, char *cmdName, char *badArgs)
+{
+	char *buf = wmalloc(strlen(cmdName) + strlen(badArgs) + 100);
+
+	sprintf(buf, _("Invalid parameters '%s' for command %s. Use HELP for"
+		       " a list of commands.\n"), badArgs, cmdName);
+	sendMessage(cPtr, buf);
+	wfree(buf);
+}
+
+static void sendUpdateMessage(WMConnection * cPtr, char *id, int time)
+{
+	char *buf = wmalloc(strlen(id) + 100);
+
+	sprintf(buf, "%s has %i minutes left\n", id, time);
+	sendMessage(cPtr, buf);
+	wfree(buf);
+}
+
+static void showId(WMConnection * cPtr)
+{
+	sendMessage(cPtr, "Server example based on WMConnection\n");
+}
+
+static void showHelp(WMConnection * cPtr)
+{
+	char *buf = wmalloc(strlen(WMGetApplicationName()) + 16);
+
+	sprintf(buf, _("%s commands:\n\n"), WMGetApplicationName());
+
+	enqueueMessage(cPtr, _("\n"));
+	enqueueMessage(cPtr, buf);
+	enqueueMessage(cPtr, _("GET <id>\t- return time left (in minutes) " "for user with id <id>\n"));
+	enqueueMessage(cPtr, _("SET <id> <time>\t- set time limit to <time> " "minutes for user with id <id>\n"));
+	enqueueMessage(cPtr, _("ADD <id> <time>\t- add <time> minutes " "for user with id <id>\n"));
+	enqueueMessage(cPtr, _("SUB <id> <time>\t- subtract <time> minutes " "for user with id <id>\n"));
+	enqueueMessage(cPtr, _("REMOVE <id>\t- remove time limitations for " "user with id <id>\n"));
+	enqueueMessage(cPtr, _("LIST\t\t- list all users and their " "corresponding time limit\n"));
+	enqueueMessage(cPtr, _("ID\t\t- returns the Time Manager " "identification string\n"));
+	enqueueMessage(cPtr, _("EXIT\t\t- exits session\n"));
+	enqueueMessage(cPtr, _("QUIT\t\t- exits session\n"));
+	enqueueMessage(cPtr, _("HELP\t\t- show this message\n\n"));
+	/* Just flush the queue we made before */
+	WMFlushConnection(cPtr);
+	wfree(buf);
+}
+
+static void listUsers(WMConnection * cPtr)
+{
+	WMPropList *userList;
+	char *id;
+	int i, time;
+
+	userList = WMGetUDKeys(timeDB);
+
+	for (i = 0; i < WMGetPropListItemCount(userList); i++) {
+		id = WMGetFromPLString(WMGetFromPLArray(userList, i));
+		time = WMGetUDIntegerForKey(timeDB, id);
+		sendUpdateMessage(cPtr, id, time);
+	}
+
+	WMReleasePropList(userList);
+}
+
+static void setTimeForUser(WMConnection * cPtr, char *cmdArgs)
+{
+	char *id;
+	int i, time;
+
+	id = wmalloc(strlen(cmdArgs));
+	if (sscanf(cmdArgs, "%s %d", id, &time) != 2) {
+		complainAboutBadArgs(cPtr, "SET", cmdArgs);
+		wfree(id);
+		return;
+	}
+	if (time < 0)
+		time = 0;
+
+	WMSetUDIntegerForKey(timeDB, time, id);
+
+	for (i = 0; i < WMGetArrayItemCount(clientConnections); i++) {
+		cPtr = WMGetFromArray(clientConnections, i);
+		sendUpdateMessage(cPtr, id, time);
+	}
+	wfree(id);
+}
+
+static void addTimeToUser(WMConnection * cPtr, char *cmdArgs)
+{
+	char *id;
+	int i, time, newTime;
+
+	id = wmalloc(strlen(cmdArgs));
+	if (sscanf(cmdArgs, "%s %d", id, &time) != 2) {
+		complainAboutBadArgs(cPtr, "ADD", cmdArgs);
+		wfree(id);
+		return;
+	}
+
+	newTime = WMGetUDIntegerForKey(timeDB, id) + time;
+	if (newTime < 0)
+		newTime = 0;
+
+	WMSetUDIntegerForKey(timeDB, newTime, id);
+
+	for (i = 0; i < WMGetArrayItemCount(clientConnections); i++) {
+		cPtr = WMGetFromArray(clientConnections, i);
+		sendUpdateMessage(cPtr, id, newTime);
+	}
+	wfree(id);
+}
+
+static void subTimeFromUser(WMConnection * cPtr, char *cmdArgs)
+{
+	char *id;
+	int i, time, newTime;
+
+	id = wmalloc(strlen(cmdArgs));
+	if (sscanf(cmdArgs, "%s %d", id, &time) != 2) {
+		complainAboutBadArgs(cPtr, "SUB", cmdArgs);
+		wfree(id);
+		return;
+	}
+
+	newTime = WMGetUDIntegerForKey(timeDB, id) - time;
+	if (newTime < 0)
+		newTime = 0;
+
+	WMSetUDIntegerForKey(timeDB, newTime, id);
+
+	for (i = 0; i < WMGetArrayItemCount(clientConnections); i++) {
+		cPtr = WMGetFromArray(clientConnections, i);
+		sendUpdateMessage(cPtr, id, newTime);
+	}
+	wfree(id);
+}
+
+static void removeTimeForUser(WMConnection * cPtr, char *cmdArgs)
+{
+	char *ptr;
+	int i;
+
+	if (cmdArgs[0] == '\0') {
+		sendMessage(cPtr, _("Missing parameter for command REMOVE."
+				    " Use HELP for a list of commands.\n"));
+		return;
+	}
+
+	ptr = cmdArgs;
+	while (*ptr && *ptr != ' ' && *ptr != '\t')
+		ptr++;
+	*ptr = '\0';
+
+	WMRemoveUDObjectForKey(timeDB, cmdArgs);
+
+	for (i = 0; i < WMGetArrayItemCount(clientConnections); i++) {
+		cPtr = WMGetFromArray(clientConnections, i);
+		sendUpdateMessage(cPtr, cmdArgs, -1);
+	}
+}
+
+static void getTimeForUser(WMConnection * cPtr, char *cmdArgs)
+{
+	char *ptr;
+	int time;
+
+	if (cmdArgs[0] == '\0') {
+		sendMessage(cPtr, _("Missing parameter for command GET." " Use HELP for a list of commands.\n"));
+		return;
+	}
+
+	ptr = cmdArgs;
+	while (*ptr && *ptr != ' ' && *ptr != '\t')
+		ptr++;
+	*ptr = '\0';
+
+	if (WMGetUDObjectForKey(timeDB, cmdArgs) != NULL)
+		time = WMGetUDIntegerForKey(timeDB, cmdArgs);
+	else
+		time = -1;
+
+	sendUpdateMessage(cPtr, cmdArgs, time);
+}
+
+static void handleConnection(WMConnection * cPtr)
+{
+	char *command, *ptr, *cmdArgs, *buffer;
+	WMArray *commands;
+	int i;
+
+	commands = getAvailableMessages(cPtr);
+	if (!commands)
+		return;
+
+	for (i = 0; i < WMGetArrayItemCount(commands); i++) {
+		command = WMGetFromArray(commands, i);
+		while (*command && (*command == ' ' || *command == '\t'))
+			command++;
+		ptr = command;
+		while (*ptr && *ptr != ' ' && *ptr != '\t')
+			ptr++;
+		if (*ptr) {
+			*ptr = '\0';
+			ptr++;
+		}
+		while (*ptr && (*ptr == ' ' || *ptr == '\t'))
+			ptr++;
+
+		cmdArgs = ptr;
+
+		fprintf(stderr, "Command: '%s', args: '%s'\n", command, cmdArgs);
+
+		if (strcasecmp(command, "quit") == 0 || strcasecmp(command, "exit") == 0) {
+			sendMessage(cPtr, "Bye\n");
+			WMCloseConnection(cPtr);
+			enqueueConnectionForRemoval(cPtr);
+			WMFreeArray(commands);
+			return;
+		} else if (strcasecmp(command, "id") == 0) {
+			showId(cPtr);
+		} else if (strcasecmp(command, "help") == 0) {
+			showHelp(cPtr);
+		} else if (strcasecmp(command, "list") == 0) {
+			listUsers(cPtr);
+		} else if (strcasecmp(command, "set") == 0) {
+			setTimeForUser(cPtr, cmdArgs);
+		} else if (strcasecmp(command, "add") == 0) {
+			addTimeToUser(cPtr, cmdArgs);
+		} else if (strcasecmp(command, "sub") == 0) {
+			subTimeFromUser(cPtr, cmdArgs);
+		} else if (strcasecmp(command, "remove") == 0) {
+			removeTimeForUser(cPtr, cmdArgs);
+		} else if (strcasecmp(command, "get") == 0) {
+			getTimeForUser(cPtr, cmdArgs);
+		} else {
+			buffer = wmalloc(strlen(command) + 100);
+			sprintf(buffer, _("Unknown command '%s'. Try HELP for" " a list of commands.\n"), command);
+			sendMessage(cPtr, buffer);
+			wfree(buffer);
+		}
+	}
+
+	WMFreeArray(commands);
+}
+
+static Bool isAllowedToConnect(WMConnection * cPtr)
+{
+	WMHost *hPtr;
+	int i;
+
+	if (allowedHostList == NULL)
+		return True;	/* No list. Allow all by default */
+
+	hPtr = WMGetHostWithAddress(WMGetConnectionAddress(cPtr));
+	for (i = 0; i < WMGetArrayItemCount(allowedHostList); i++) {
+		if (WMIsHostEqualToHost(hPtr, WMGetFromArray(allowedHostList, i))) {
+			WMReleaseHost(hPtr);
+			return True;
+		}
+	}
+
+	WMReleaseHost(hPtr);
+
+	return False;
+}
+
+static void didReceiveInput(ConnectionDelegate * self, WMConnection * cPtr)
+{
+	if (cPtr == serverPtr) {
+		WMConnection *newPtr = WMAcceptConnection(cPtr);
+
+		if (newPtr) {
+			if (isAllowedToConnect(newPtr)) {
+				WMSetConnectionDelegate(newPtr, &socketDelegate);
+				WMSetConnectionSendTimeout(newPtr, 120);
+				WMAddToArray(clientConnections, newPtr);
+			} else {
+				sendMessage(newPtr, "Sorry, you are not allowed to connect.\n");
+				WMDestroyConnection(newPtr);
+			}
+		}
+	} else {
+		/* Data arriving on an already-connected socket */
+		handleConnection(cPtr);
+	}
+}
+
+static void connectionDidTimeout(ConnectionDelegate * self, WMConnection * cPtr)
+{
+	WMHost *hPtr;
+
+	if (cPtr == serverPtr) {
+		wfatal(_("The server listening socket did timeout. Exiting."));
+		exit(1);
+	}
+
+	hPtr = WMGetHostWithAddress(WMGetConnectionAddress(cPtr));
+	wwarning(_("Connection with %s did timeout. Closing connection."), WMGetHostName(hPtr));
+	WMReleaseHost(hPtr);
+
+	enqueueConnectionForRemoval(cPtr);
+}
+
+static void connectionDidDie(ConnectionDelegate * self, WMConnection * cPtr)
+{
+	if (cPtr == serverPtr) {
+		/* trouble. server listening port itself died!!! */
+		wfatal(_("The server listening socket died. Exiting."));
+		exit(1);
+	}
+
+	enqueueConnectionForRemoval(cPtr);
+}
+
+static void removeConnection(void *observer, WMNotification * notification)
+{
+	WMConnection *cPtr = (WMConnection *) WMGetNotificationObject(notification);
+	WMData *data;
+
+	WMRemoveFromArray(clientConnections, cPtr);
+	if ((data = (WMData *) WMGetConnectionClientData(cPtr)) != NULL)
+		WMReleaseData(data);
+	WMDestroyConnection(cPtr);
+}
+
+static void updatedDomain(void *observer, WMNotification * notification)
+{
+	wmessage("defaults domain file changed on disk. synchronizing.");
+}
+
+#if 0
+static Bool isDifferent(char *str1, char *str2)
+{
+	if ((!str1 && !str2) || (str1 && str2 && strcmp(str1, str2) == 0))
+		return False;
+
+	return True;
+}
+#endif
+
+int main(int argc, char **argv)
+{
+	int i;
+
+	wsetabort(wAbort);
+
+	WMInitializeApplication("server", &argc, argv);
+
+	if (argc > 1) {
+		for (i = 1; i < argc; i++) {
+			if (strcmp(argv[i], "--help") == 0) {
+				printHelp(argv[0]);
+				exit(0);
+			} else if (strcmp(argv[i], "--listen") == 0) {
+				char *p;
+
+				if ((p = strchr(argv[++i], ':')) != NULL) {
+					*p = 0;
+					ServerAddress = wstrdup(argv[i]);
+					ServerPort = wstrdup(p + 1);
+					*p = ':';
+					if (ServerAddress[0] == 0) {
+						wfree(ServerAddress);
+						ServerAddress = NULL;
+					}
+					if (ServerPort[0] == 0) {
+						wfree(ServerPort);
+						ServerPort = "34567";
+					}
+				} else if (argv[i][0] != 0) {
+					ServerPort = argv[i];
+				}
+			} else if (strcmp(argv[i], "--allow") == 0) {
+				char *p, *ptr;
+				int done;
+				WMHost *hPtr;
+
+				ptr = argv[++i];
+				done = 0;
+				while (!done) {
+					if ((p = strchr(ptr, ',')) != NULL) {
+						*p = 0;
+					}
+					if (*ptr != 0) {
+						hPtr = WMGetHostWithName(ptr);
+						if (hPtr) {
+							if (!allowedHostList)
+								allowedHostList = WMCreateArray(4);
+							WMAddToArray(allowedHostList, hPtr);
+						} else {
+							wwarning(_("Unknown host '%s'. Ignored."), ptr);
+						}
+					}
+
+					if (p != NULL) {
+						*p = ',';
+						ptr = p + 1;
+					} else {
+						done = 1;
+					}
+				}
+			} else {
+				printf(_("%s: invalid argument '%s'\n"), argv[0], argv[i]);
+				printf(_("Try '%s --help' for more information\n"), argv[0]);
+				exit(1);
+			}
+		}
+	}
+
+	timeDB = WMGetDefaultsFromPath("./UserTime.plist");
+	WMAddNotificationObserver(updatedDomain, NULL, WMUserDefaultsDidChangeNotification, NULL);
+
+	clientConnections = WMCreateArray(4);
+
+	/* A NULL ServerAddress means to listen on any address the host has.
+	 * Else if ServerAddress points to a specific address (like "localhost",
+	 * "host.domain.com" or "192.168.1.1"), then it will only listen on that
+	 * interface and ignore incoming connections on the others. */
+	if (ServerAddress && strcasecmp(ServerAddress, "Any") == 0)
+		ServerAddress = NULL;
+	if (ServerPort == NULL)
+		ServerPort = "34567";
+
+	printf("Server will listen on '%s:%s'\n", ServerAddress ? ServerAddress : "Any", ServerPort);
+	printf("This server will allow connections from:");
+	if (allowedHostList) {
+		int i;
+		char *hName;
+
+		for (i = 0; i < WMGetArrayItemCount(allowedHostList); i++) {
+			hName = WMGetHostName(WMGetFromArray(allowedHostList, i));
+			printf("%s'%s'", i == 0 ? " " : ", ", hName);
+		}
+		printf(".\n");
+	} else {
+		printf(" any host.\n");
+	}
+
+	serverPtr = WMCreateConnectionAsServerAtAddress(ServerAddress, ServerPort, NULL);
+
+	if (!serverPtr) {
+		wfatal("could not create server on `%s:%s`. Exiting.",
+		       ServerAddress ? ServerAddress : "localhost", ServerPort);
+		exit(1);
+	}
+
+	WMSetConnectionDelegate(serverPtr, &socketDelegate);
+
+	WMAddNotificationObserver(removeConnection, NULL, SEConnectionShouldBeRemovedNotification, NULL);
+
+	while (1) {
+		/* The ASAP notification queue is called at the end of WHandleEvents()
+		 * There's where died connections we get while running through
+		 * WHandleEvents() get removed. */
+		WHandleEvents();
+	}
+
+	return 0;
+}