aboutsummaryrefslogtreecommitdiffstats
path: root/facebook/facebook-data.c
diff options
context:
space:
mode:
Diffstat (limited to 'facebook/facebook-data.c')
-rw-r--r--facebook/facebook-data.c404
1 files changed, 404 insertions, 0 deletions
diff --git a/facebook/facebook-data.c b/facebook/facebook-data.c
new file mode 100644
index 0000000..443e00f
--- /dev/null
+++ b/facebook/facebook-data.c
@@ -0,0 +1,404 @@
+/*
+ * Copyright 2014-2015 James Geboski <jgeboski@gmail.com>
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include <string.h>
+
+#include "facebook-api.h"
+#include "facebook-data.h"
+
+struct _FbDataPrivate
+{
+ FbApi *api;
+ struct im_connection *ic;
+ GQueue *msgs;
+ GQueue *tids;
+ GHashTable *evs;
+ GHashTable *gcs;
+};
+
+static const gchar *fb_props_strs[] = {
+ "cid",
+ "did",
+ "stoken",
+ "token"
+};
+
+G_DEFINE_TYPE(FbData, fb_data, G_TYPE_OBJECT);
+
+static void
+fb_data_dispose(GObject *obj)
+{
+ FbDataPrivate *priv = FB_DATA(obj)->priv;
+ GHashTableIter iter;
+ gpointer ptr;
+
+ g_object_unref(priv->api);
+ g_hash_table_iter_init(&iter, priv->evs);
+
+ while (g_hash_table_iter_next(&iter, NULL, &ptr)) {
+ g_hash_table_iter_remove(&iter);
+ b_event_remove(GPOINTER_TO_UINT(ptr));
+ }
+
+ g_hash_table_iter_init(&iter, priv->gcs);
+
+ while (g_hash_table_iter_next(&iter, NULL, &ptr)) {
+ g_hash_table_iter_remove(&iter);
+ imcb_chat_free(ptr);
+ }
+
+ g_queue_free_full(priv->msgs, (GDestroyNotify) fb_api_message_free);
+ g_queue_free_full(priv->tids, g_free);
+
+ g_hash_table_destroy(priv->evs);
+ g_hash_table_destroy(priv->gcs);
+}
+
+static void
+fb_data_class_init(FbDataClass *klass)
+{
+ GObjectClass *gklass = G_OBJECT_CLASS(klass);
+
+ gklass->dispose = fb_data_dispose;
+ g_type_class_add_private(klass, sizeof (FbDataPrivate));
+}
+
+static void
+fb_data_init(FbData *fata)
+{
+ FbDataPrivate *priv;
+
+ priv = G_TYPE_INSTANCE_GET_PRIVATE(fata, FB_TYPE_DATA, FbDataPrivate);
+ fata->priv = priv;
+
+ priv->api = fb_api_new();
+ priv->msgs = g_queue_new();
+ priv->tids = g_queue_new();
+ priv->evs = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, NULL);
+ priv->gcs = g_hash_table_new(g_direct_hash, g_direct_equal);
+}
+
+FbData *
+fb_data_new(account_t *acct)
+{
+ FbData *fata;
+ FbDataPrivate *priv;
+
+ fata = g_object_new(FB_TYPE_DATA, NULL);
+ priv = fata->priv;
+
+ priv->ic = imcb_new(acct);
+ priv->ic->proto_data = fata;
+ return fata;
+}
+
+gboolean
+fb_data_load(FbData *fata)
+{
+ account_t *acct;
+ const gchar *str;
+ FbDataPrivate *priv;
+ FbId id;
+ gboolean ret = TRUE;
+ guint i;
+ guint64 uint;
+ GValue val = G_VALUE_INIT;
+
+ g_return_val_if_fail(FB_IS_DATA(fata), FALSE);
+ priv = fata->priv;
+ acct = priv->ic->acc;
+
+ for (i = 0; i < G_N_ELEMENTS(fb_props_strs); i++) {
+ str = set_getstr(&acct->set, fb_props_strs[i]);
+
+ if (str == NULL) {
+ ret = FALSE;
+ }
+
+ g_value_init(&val, G_TYPE_STRING);
+ g_value_set_string(&val, str);
+ g_object_set_property(G_OBJECT(priv->api), fb_props_strs[i],
+ &val);
+ g_value_unset(&val);
+ }
+
+ str = set_getstr(&acct->set, "mid");
+
+ if (str != NULL) {
+ uint = g_ascii_strtoull(str, NULL, 10);
+ g_value_init(&val, G_TYPE_UINT64);
+ g_value_set_uint64(&val, uint);
+ g_object_set_property(G_OBJECT(priv->api), "mid", &val);
+ g_value_unset(&val);
+ } else {
+ ret = FALSE;
+ }
+
+ str = set_getstr(&acct->set, "uid");
+
+ if (str != NULL) {
+ id = FB_ID_FROM_STR(str);
+ g_value_init(&val, FB_TYPE_ID);
+ g_value_set_int64(&val, id);
+ g_object_set_property(G_OBJECT(priv->api), "uid", &val);
+ g_value_unset(&val);
+ } else {
+ ret = FALSE;
+ }
+
+ fb_api_rehash(priv->api);
+ return ret;
+}
+
+void
+fb_data_save(FbData *fata)
+{
+ account_t *acct;
+ const gchar *str;
+ FbDataPrivate *priv;
+ gchar *dup;
+ guint i;
+ guint64 uint;
+ GValue val = G_VALUE_INIT;
+
+ g_return_if_fail(FB_IS_DATA(fata));
+ priv = fata->priv;
+ acct = priv->ic->acc;
+
+ for (i = 0; i < G_N_ELEMENTS(fb_props_strs); i++) {
+ g_value_init(&val, G_TYPE_STRING);
+ g_object_get_property(G_OBJECT(priv->api), fb_props_strs[i],
+ &val);
+ str = g_value_get_string(&val);
+ set_setstr(&acct->set, fb_props_strs[i], (gchar *) str);
+ g_value_unset(&val);
+ }
+
+ g_value_init(&val, G_TYPE_UINT64);
+ g_object_get_property(G_OBJECT(priv->api), "mid", &val);
+ uint = g_value_get_uint64(&val);
+ g_value_unset(&val);
+
+ dup = g_strdup_printf("%" G_GINT64_FORMAT, uint);
+ set_setstr(&acct->set, "mid", dup);
+ g_free(dup);
+
+ g_value_init(&val, G_TYPE_INT64);
+ g_object_get_property(G_OBJECT(priv->api), "uid", &val);
+ uint = g_value_get_int64(&val);
+ g_value_unset(&val);
+
+ dup = g_strdup_printf("%" FB_ID_FORMAT, uint);
+ set_setstr(&acct->set, "uid", dup);
+ g_free(dup);
+}
+
+void
+fb_data_add_groupchat(FbData *fata, struct groupchat *gc)
+{
+ FbDataPrivate *priv;
+
+ g_return_if_fail(FB_IS_DATA(fata));
+ priv = fata->priv;
+
+ g_hash_table_replace(priv->gcs, gc, gc);
+}
+
+void
+fb_data_remove_groupchat(FbData *fata, struct groupchat *gc)
+{
+ FbDataPrivate *priv;
+
+ g_return_if_fail(FB_IS_DATA(fata));
+ priv = fata->priv;
+
+ g_hash_table_remove(priv->gcs, gc);
+}
+
+void
+fb_data_add_thread_head(FbData *fata, FbId tid)
+{
+ FbDataPrivate *priv;
+ FbId *dtid;
+
+ g_return_if_fail(FB_IS_DATA(fata));
+ priv = fata->priv;
+
+ dtid = g_memdup(&tid, sizeof tid);
+ g_queue_push_head(priv->tids, dtid);
+}
+
+void
+fb_data_add_thread_tail(FbData *fata, FbId tid)
+{
+ FbDataPrivate *priv;
+ FbId *dtid;
+
+ g_return_if_fail(FB_IS_DATA(fata));
+ priv = fata->priv;
+
+ dtid = g_memdup(&tid, sizeof tid);
+ g_queue_push_tail(priv->tids, dtid);
+}
+
+void
+fb_data_clear_threads(FbData *fata)
+{
+ FbDataPrivate *priv;
+ GList *l;
+ GList *n;
+
+ g_return_if_fail(FB_IS_DATA(fata));
+ priv = fata->priv;
+
+ l = priv->tids->head;
+
+ while (l != NULL) {
+ n = l->next;
+ g_queue_delete_link(priv->tids, l);
+ g_free(l->data);
+ l = n;
+ }
+}
+
+FbId
+fb_data_get_thread(FbData *fata, guint n)
+{
+ FbDataPrivate *priv;
+ FbId *tid;
+
+ g_return_val_if_fail(FB_IS_DATA(fata), 0);
+ priv = fata->priv;
+
+ tid = g_queue_peek_nth(priv->tids, n);
+
+ if (tid == NULL) {
+ return 0;
+ }
+
+ return *tid;
+}
+
+void
+fb_data_add_timeout(FbData *fata, const gchar *name, guint interval,
+ b_event_handler func, gpointer data)
+{
+ FbDataPrivate *priv;
+ gchar *key;
+ guint id;
+
+ g_return_if_fail(FB_IS_DATA(fata));
+ priv = fata->priv;
+
+ fb_data_clear_timeout(fata, name, TRUE);
+
+ key = g_strdup(name);
+ id = b_timeout_add(interval, func, data);
+ g_hash_table_replace(priv->evs, key, GUINT_TO_POINTER(id));
+}
+
+void
+fb_data_clear_timeout(FbData *fata, const gchar *name, gboolean remove)
+{
+ FbDataPrivate *priv;
+ gpointer ptr;
+ guint id;
+
+ g_return_if_fail(FB_IS_DATA(fata));
+ priv = fata->priv;
+
+ ptr = g_hash_table_lookup(priv->evs, name);
+ id = GPOINTER_TO_UINT(ptr);
+
+ if ((id > 0) && remove) {
+ b_event_remove(id);
+ }
+
+ g_hash_table_remove(priv->evs, name);
+}
+
+FbApi *
+fb_data_get_api(FbData *fata)
+{
+ FbDataPrivate *priv;
+
+ g_return_val_if_fail(FB_IS_DATA(fata), NULL);
+ priv = fata->priv;
+
+ return priv->api;
+}
+
+struct im_connection *
+fb_data_get_connection(FbData *fata)
+{
+ FbDataPrivate *priv;
+
+ g_return_val_if_fail(FB_IS_DATA(fata), NULL);
+ priv = fata->priv;
+
+ return priv->ic;
+}
+
+void
+fb_data_add_message(FbData *fata, FbApiMessage *msg)
+{
+ FbDataPrivate *priv;
+
+ g_return_if_fail(FB_IS_DATA(fata));
+ priv = fata->priv;
+
+ g_queue_push_tail(priv->msgs, msg);
+}
+
+void
+fb_data_remove_message(FbData *fata, FbApiMessage *msg)
+{
+ FbDataPrivate *priv;
+
+ g_return_if_fail(FB_IS_DATA(fata));
+ priv = fata->priv;
+
+ g_queue_remove(priv->msgs, msg);
+}
+
+GSList *
+fb_data_take_messages(FbData *fata, FbId uid)
+{
+ FbApiMessage *msg;
+ FbDataPrivate *priv;
+ GList *l;
+ GList *prev;
+ GSList *msgs = NULL;
+
+ g_return_val_if_fail(FB_IS_DATA(fata), NULL);
+ priv = fata->priv;
+ l = priv->msgs->tail;
+
+ while (l != NULL) {
+ msg = l->data;
+ prev = l->prev;
+
+ if (msg->uid == uid) {
+ msgs = g_slist_prepend(msgs, msg);
+ g_queue_delete_link(priv->msgs, l);
+ }
+
+ l = prev;
+ }
+
+ return msgs;
+}
generated by cgit v1.2.3 (git 2.25.1) at 2025-04-27 16:03:37 +0000