1 files changed, 151 insertions, 0 deletions

diff --git a/src/gnunet/social/socialapp.cpp b/src/gnunet/social/socialapp.cpp
new file mode 100644
index 0000000..e739574
--- /dev/null
+++ b/src/gnunet/social/socialapp.cpp
@@ -0,0 +1,151 @@
+#include "socialapp.h"
+#include "app.h"
+
+#include "host.h"
+#include "guest.h"
+
+
+SocialApp::SocialApp (struct GNUNET_CONFIGURATION_Handle *config,
+                      QObject *parent)
+  : QObject (parent)
+{
+  m_config = config;
+  m_app =
+    GNUNET_SOCIAL_app_connect (m_config, APP_NAME,
+                               egoCallback,
+                               hostPlaceCallback,
+                               guestPlaceCallback,
+                               this);
+}
+
+
+SocialApp::~SocialApp ()
+{
+  GNUNET_SOCIAL_app_disconnect (m_app);
+}
+
+
+void
+SocialApp::egoCallback (void *cls,
+                        struct GNUNET_SOCIAL_Ego *ego,
+                        const struct GNUNET_CRYPTO_EcdsaPublicKey *egoPubKey,
+                        const char *name)
+{
+  SocialApp *s = (SocialApp *) cls;
+  s->addEgo (new Ego (*egoPubKey, QString::fromLatin1 (name), ego));
+}
+
+
+void
+SocialApp::addEgo (Ego *ego)
+{
+  m_egos += ego;
+  emit egoAdded (ego);
+}
+
+void
+SocialApp::addPlace (Place *place)
+{
+  m_places += place;
+  place->setIndex (m_places.count () - 1);
+  emit placeAdded (place);
+}
+
+void
+SocialApp::hostPlaceCallback (void *cls,
+                              struct GNUNET_SOCIAL_HostConnection *hconn,
+                              struct GNUNET_SOCIAL_Ego *ego,
+                              const struct GNUNET_CRYPTO_EddsaPublicKey *placePubKey,
+                              enum GNUNET_SOCIAL_AppPlaceState placeState)
+{
+  SocialApp *s = (SocialApp *) cls;
+  s->addPlace (new Host (s->m_app, ego, hconn, s));
+}
+
+
+void
+SocialApp::guestPlaceCallback (void *cls,
+                               struct GNUNET_SOCIAL_GuestConnection *gconn,
+                               struct GNUNET_SOCIAL_Ego *ego,
+                               const struct GNUNET_CRYPTO_EddsaPublicKey *placePubKey,
+                               enum GNUNET_SOCIAL_AppPlaceState placeState)
+{
+  SocialApp *s = (SocialApp *) cls;
+  s->addPlace (new Guest (s->m_app, ego, gconn, s));
+}
+
+
+Ego *
+SocialApp::findEgo (const QString pubKeyStr)
+{
+  QListIterator<Ego *> it (m_egos);
+  while (it.hasNext ())
+  {
+    Ego *ego = it.next ();
+    if (ego->pubKeyString () == pubKeyStr)
+      return ego;
+  }
+  return 0;
+}
+
+
+void
+SocialApp::createPlace (GNUNET_SOCIAL_Ego *ego)
+{
+  addPlace (new Host (m_app, ego, GNUNET_PSYC_CHANNEL_PRIVATE, this));
+}
+
+
+void
+SocialApp::createPlaceSlot (QString egoPubKeyStr)
+{
+  GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Creating a New Place.\n");
+
+  Ego *ego = findEgo (egoPubKeyStr);
+  if (!ego) // FIXME: fall back to last added ego for now
+  {
+    Q_ASSERT (!m_egos.isEmpty ());
+    ego = m_egos.last ();
+  }
+
+  createPlace (ego->ego ());
+}
+
+
+void
+SocialApp::enterPlace (GNUNET_SOCIAL_Ego *ego,
+                           GNUNET_CRYPTO_EddsaPublicKey *pubKey,
+                           GNUNET_PeerIdentity *peerId)
+{
+  addPlace (new Guest (m_app, ego, pubKey, peerId, 0, NULL, NULL, this));
+}
+
+
+void
+SocialApp::enterPlaceSlot (QString egoPubKeyStr, QString pubKeyStr, QString peerIdStr)
+{
+  GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Entering place %s as guest.\n",
+              pubKeyStr.toStdString ().c_str ());
+
+  GNUNET_CRYPTO_EddsaPublicKey pubKey;
+  if (GNUNET_OK !=
+      GNUNET_CRYPTO_eddsa_public_key_from_string (pubKeyStr.toStdString ().c_str (),
+                                                  pubKeyStr.length (),
+                                                  &pubKey))
+    return; // Failed conversion
+
+  GNUNET_PeerIdentity peerId;
+  if (GNUNET_OK != GNUNET_CRYPTO_eddsa_public_key_from_string (peerIdStr.toStdString ().c_str (),
+                                                               peerIdStr.length (),
+                                                               &peerId.public_key))
+    return; // Failed conversion
+
+  Ego *ego = findEgo (egoPubKeyStr);
+  if (!ego) // FIXME: fall back to last added ego for now
+  {
+    Q_ASSERT (!m_egos.isEmpty ());
+    ego = m_egos.last ();
+  }
+
+  enterPlace (ego->ego (), &pubKey, &peerId);
+}