Used a GLib loop.

[cascardo/pubsub-bot.git] / status.c

diff --git a/status.c b/status.c
index 6af0d44..28f9a91 100644 (file)
--- a/status.c
+++ b/status.c
@@ -17,10 +17,18 @@
  */
 
 
+#include <glib.h>
 #include <iksemel.h>
 #include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
+#include <unistd.h>
+
+static char * server = "vespa.holoscopio.com";
+static char * username = "pubsub";
+static char * password = "pubsub";
+static char * pbservice = "pubsub.vespa.holoscopio.com";
+static char * authed_jid = "vespa";
 
 iks *
 createiq (char *type, char *to, char *qnam, char *xmlns, iks **query)
@@ -43,7 +51,7 @@ catnode (iksparser *parser, char *node)
 {
   iks *iq;
   iks *query;
-  iq = createiq ("get", "pubsub.jabber-br.org", "query",
+  iq = createiq ("get", pbservice, "query",
                  "http://jabber.org/protocol/disco#info", &query);
   if (node != NULL)
     iks_insert_attrib (query, "node", node);
@@ -56,7 +64,7 @@ listnode (iksparser *parser, char *node)
 {
   iks *iq;
   iks *query;
-  iq = createiq ("get", "pubsub.jabber-br.org", "query",
+  iq = createiq ("get", pbservice, "query",
                  "http://jabber.org/protocol/disco#items", &query);
   if (node != NULL)
     iks_insert_attrib (query, "node", node);
@@ -69,7 +77,7 @@ createnode (iksparser *parser, char *node)
 {
   iks *iq;
   iks *query;
-  iq = createiq ("set", "pubsub.jabber-br.org", "pubsub",
+  iq = createiq ("set", pbservice, "pubsub",
                  "http://jabber.org/protocol/pubsub", &query);
   iks_insert_attrib (iks_insert (query, "create"), "node", node);
   iks_send (parser, iq);
@@ -81,7 +89,7 @@ getnode (iksparser *parser, char *node)
 {
   iks *iq;
   iks *query;
-  iq = createiq ("get", "pubsub.jabber-br.org", "pubsub",
+  iq = createiq ("get", pbservice, "pubsub",
                  "http://jabber.org/protocol/pubsub", &query);
   iks_insert_attrib (iks_insert (query, "items"), "node", node);
   iks_send (parser, iq);
@@ -93,7 +101,7 @@ vcard (iksparser *parser)
 {
   iks *iq;
   iks *query;
-  iq = createiq ("get", "pubsub.jabber-br.org", "vCard", "vcard-temp", &query);
+  iq = createiq ("get", pbservice, "vCard", "vcard-temp", &query);
   iks_send (parser, iq);
   iks_delete (iq);
 }
@@ -116,7 +124,7 @@ pushmood (iksparser *parser, char *node, char *line)
   iks *publish;
   iks *item;
   iks *mood;
-  iq = createiq ("set", "pubsub.jabber-br.org", "pubsub",
+  iq = createiq ("set", pbservice, "pubsub",
                  "http://jabber.org/protocol/pubsub", &query);
   publish = iks_insert (query, "publish");
   iks_insert_attrib (publish, "node", node);
@@ -127,6 +135,37 @@ pushmood (iksparser *parser, char *node, char *line)
   iks_delete (iq);
 }
 
+iks *
+createtune (char *line)
+{
+  iks *tune;
+  tune = iks_new ("tune");
+  iks_insert_attrib (tune, "xmlns", "http://jabber.org/protocol/tune");
+  iks_insert_cdata (iks_insert (tune, "artist"), line, 0);
+  return tune;
+}
+
+void
+pushtune (iksparser *parser, char *node, char *line)
+{
+  iks *iq;
+  iks *query;
+  iks *publish;
+  iks *item;
+  iks *tune;
+  iq = createiq ("set", pbservice, "pubsub",
+                 "http://jabber.org/protocol/pubsub", &query);
+  publish = iks_insert (query, "publish");
+  iks_insert_attrib (publish, "node", node);
+  item = iks_insert (publish, "item");
+  tune = createtune (line);
+  iks_insert_node (item, tune);
+  printf ("debug: %s\n", iks_string (iks_stack (iq), iq));
+  iks_send (parser, iq);
+  iks_delete (iq);
+}
+
+
 void
 process_mood (iksparser *parser, char *cmdline)
 {
@@ -144,12 +183,18 @@ process_mood (iksparser *parser, char *cmdline)
     createnode (parser, cmdline);
   else if (!strcmp (cmd, "get"))
     getnode (parser, cmdline);
-  else if (!strcmp (cmd, "push"))
+  else if (!strcmp (cmd, "mood"))
     {
       char *node;
-      node = strsep (&cmdline, " ");
+      node = "http://jabber.org/protocol/mood";
       pushmood (parser, node, cmdline);
     }
+  else if (!strcmp (cmd, "tune"))
+    {
+      char *node;
+      node = "http://jabber.org/protocol/tune";
+      pushtune (parser, node, cmdline);
+    }
   free (orig_cmdline);
 }
 
@@ -240,7 +285,7 @@ xmpp_tls_hook (iksparser *parser, iks *node)
 int
 xmpp_sasl_hook (iksparser *parser, iks* node)
 {
-  iks_start_sasl (parser, IKS_SASL_DIGEST_MD5, "pubsub", "pubsub");
+  iks_start_sasl (parser, IKS_SASL_DIGEST_MD5, username, password);
   return 0;
 }
 
@@ -291,13 +336,15 @@ xmpp_other_hook (iksparser *parser, iks *node, char *ns)
   if (!iks_strcmp (ns, "urn:ietf:params:xml:ns:xmpp-sasl"))
     {
       if (!iks_strcmp (iks_name (node), "success"))
-        iks_send_header (parser, "jabber-br.org");
+        iks_send_header (parser, server);
+      else if (!iks_strcmp (iks_name (node), "failure"))
+        printf ("failture to authenticate: %s\n",
+                iks_string (iks_stack (node), node));
       return 0;
     }
   return 1;
 }
 
-const char * jid = "cascardo@jabber-br.org";
 
 static int
 hook (void *data, int type, iks *node)
@@ -316,7 +363,7 @@ hook (void *data, int type, iks *node)
     {
       char *from;
       from = iks_find_attrib (node, "from");
-      if (!iks_strncmp (from, jid, iks_strlen (jid)))
+      if (!iks_strncmp (from, authed_jid, iks_strlen (authed_jid)))
         {
           char *body = iks_find_cdata (node, "body");
           if (body != NULL)
@@ -360,13 +407,51 @@ hook (void *data, int type, iks *node)
   return IKS_OK;
 }
 
+gboolean
+handler (GIOChannel *channel, GIOCondition cond, gpointer data)
+{
+  iksparser *parser = data;
+  iks_recv (parser, 0);
+  return TRUE;
+}
+
+void
+loop (iksparser *parser)
+{
+  GIOChannel *channel;
+  channel = g_io_channel_unix_new (iks_fd (parser));
+  g_io_add_watch (channel, G_IO_IN, handler, parser);
+  g_main_loop_run (g_main_loop_new (g_main_context_default (), TRUE));
+}
+
 int
 main (int argc, char **argv)
 {
   iksparser *parser;
+  int c;
+  while ((c = getopt (argc, argv, "s:u:p:i:a:")) != -1)
+    {
+      switch (c)
+        {
+        case 's':
+          server = optarg;
+          break;
+        case 'u':
+          username = optarg;
+          break;
+        case 'p':
+          password = optarg;
+          break;
+        case 'i':
+          pbservice = optarg;
+          break;
+        case 'a':
+          authed_jid = optarg;
+          break;
+        }
+    }
   parser = iks_stream_new ("jabber:client", &parser, hook);
-  iks_connect_tcp (parser, "jabber-br.org", 5222);
-  while (1)
-    iks_recv (parser, -1);
+  iks_connect_tcp (parser, server, 5222);
+  loop (parser);
   return 0;
 }