1 files changed, 97 insertions, 0 deletions

diff --git a/src/gnunet_chat_context_intern.c b/src/gnunet_chat_context_intern.c
index c4a3d5b..f8c61e1 100644
--- a/src/gnunet_chat_context_intern.c
+++ b/src/gnunet_chat_context_intern.c
@@ -78,3 +78,100 @@ cont_context_write_records (void *cls,
         emsg
     );
 }
+
+void
+error_context_write_records (void *cls)
+{
+  struct GNUNET_CHAT_Context *context = cls;
+
+  handle_send_internal_message(
+      context->handle,
+      context,
+      GNUNET_CHAT_FLAG_WARNING,
+      _("Failed opening records!")
+  );
+}
+
+void
+monitor_context_write_records (void *cls,
+                               const struct GNUNET_IDENTITY_PrivateKey *zone,
+                               const char *label,
+                               GNUNET_UNUSED unsigned int rd_count,
+                               GNUNET_UNUSED const struct GNUNET_GNSRECORD_Data *rd)
+{
+  struct GNUNET_CHAT_Context *context = cls;
+
+  const struct GNUNET_HashCode *hash = GNUNET_MESSENGER_room_get_key(
+      context->room
+  );
+
+  struct GNUNET_MESSENGER_RoomEntryRecord room;
+  GNUNET_CRYPTO_get_peer_identity(context->handle->cfg, &(room.door));
+
+  GNUNET_memcpy(
+      &(room.key),
+      hash,
+      sizeof(room.key)
+  );
+
+  struct GNUNET_TIME_Absolute expiration = GNUNET_TIME_absolute_get_forever_();
+
+  const char *nick = context->nick;
+  const char *topic = context->topic;
+
+  if (topic)
+  {
+    struct GNUNET_HashCode topic_hash;
+    GNUNET_CRYPTO_hash(topic, strlen(topic), &topic_hash);
+
+    if (0 != GNUNET_CRYPTO_hash_cmp(&topic_hash, hash))
+      topic = NULL;
+  }
+
+  unsigned int count = 1;
+
+  struct GNUNET_GNSRECORD_Data data [3];
+  data[0].record_type = GNUNET_GNSRECORD_TYPE_MESSENGER_ROOM_ENTRY;
+  data[0].data = &room;
+  data[0].data_size = sizeof(room);
+  data[0].expiration_time = expiration.abs_value_us;
+  data[0].flags = GNUNET_GNSRECORD_RF_PRIVATE;
+
+  if (nick)
+  {
+    data[count].record_type = GNUNET_GNSRECORD_TYPE_NICK;
+    data[count].data = nick;
+    data[count].data_size = strlen(nick);
+    data[count].expiration_time = expiration.abs_value_us;
+    data[count].flags = (
+      GNUNET_GNSRECORD_RF_PRIVATE |
+      GNUNET_GNSRECORD_RF_SUPPLEMENTAL
+    );
+
+    count++;
+  }
+
+  if (topic)
+  {
+    data[count].record_type = GNUNET_DNSPARSER_TYPE_TXT;
+    data[count].data = topic;
+    data[count].data_size = strlen(topic);
+    data[count].expiration_time = expiration.abs_value_us;
+    data[count].flags = (
+      GNUNET_GNSRECORD_RF_PRIVATE |
+      GNUNET_GNSRECORD_RF_SUPPLEMENTAL
+    );
+
+    count++;
+  }
+
+  GNUNET_NAMESTORE_records_commit(
+      context->handle->namestore,
+      zone,
+      label,
+      count,
+      data,
+      cont_context_write_records,
+      context
+  );
+}