1 files changed, 211 insertions, 8 deletions

diff --git a/src/gnunet_chat_file.c b/src/gnunet_chat_file.c
index fdfbe4c..063448e 100644
--- a/src/gnunet_chat_file.c
+++ b/src/gnunet_chat_file.c
@@ -39,10 +39,6 @@ file_create_from_message (struct GNUNET_CHAT_Handle *handle,
   GNUNET_memcpy(&(file->key), &(message->key), sizeof(file->key));
   GNUNET_memcpy(&(file->hash), &(message->hash), sizeof(file->hash));
 
-  file->published = 0;
-  file->downloaded = 0;
-  file->unindexed = 0;
-
   file->meta = GNUNET_CONTAINER_meta_data_create();
 
   file->uri = GNUNET_FS_uri_parse(message->uri, NULL);
@@ -50,6 +46,17 @@ file_create_from_message (struct GNUNET_CHAT_Handle *handle,
   file->publish = NULL;
   file->unindex = NULL;
 
+  file->upload_head = NULL;
+  file->upload_tail = NULL;
+
+  file->download_head = NULL;
+  file->download_tail = NULL;
+
+  file->unindex_head = NULL;
+  file->unindex_tail = NULL;
+
+  file->user_pointer = NULL;
+
   return file;
 }
 
@@ -67,10 +74,6 @@ file_create_from_disk (struct GNUNET_CHAT_Handle *handle,
   GNUNET_memcpy(&(file->key), key, sizeof(file->key));
   GNUNET_memcpy(&(file->hash), hash, sizeof(file->hash));
 
-  file->published = 0;
-  file->downloaded = 0;
-  file->unindexed = 0;
-
   file->meta = GNUNET_CONTAINER_meta_data_create();
 
   file->uri = NULL;
@@ -78,12 +81,65 @@ file_create_from_disk (struct GNUNET_CHAT_Handle *handle,
   file->publish = NULL;
   file->unindex = NULL;
 
+  file->upload_head = NULL;
+  file->upload_tail = NULL;
+
+  file->download_head = NULL;
+  file->download_tail = NULL;
+
+  file->unindex_head = NULL;
+  file->unindex_tail = NULL;
+
+  file->user_pointer = NULL;
+
   return file;
 }
 
 void
 file_destroy (struct GNUNET_CHAT_File* file)
 {
+  struct GNUNET_CHAT_FileUpload *upload;
+  while (file->upload_head)
+  {
+    upload = file->upload_head;
+
+    GNUNET_CONTAINER_DLL_remove(
+        file->upload_head,
+        file->upload_tail,
+        upload
+    );
+
+    GNUNET_free(upload);
+  }
+
+  struct GNUNET_CHAT_FileDownload *download;
+  while (file->download_head)
+  {
+    download = file->download_head;
+
+    GNUNET_CONTAINER_DLL_remove(
+       file->download_head,
+       file->download_tail,
+       download
+    );
+
+    GNUNET_free(download);
+  }
+
+  struct GNUNET_CHAT_FileUnindex *unindex;
+  while (file->unindex_head)
+  {
+    unindex = file->unindex_head;
+
+    GNUNET_CONTAINER_DLL_remove(
+       file->unindex_head,
+       file->unindex_tail,
+       unindex
+    );
+
+    GNUNET_free(unindex);
+  }
+
   if (file->uri)
     GNUNET_FS_uri_destroy(file->uri);
 
@@ -95,3 +151,150 @@ file_destroy (struct GNUNET_CHAT_File* file)
 
   GNUNET_free(file);
 }
+
+void
+file_bind_upload (struct GNUNET_CHAT_File* file,
+                  GNUNET_CHAT_FileUploadCallback cb, void *cls)
+{
+  struct GNUNET_CHAT_FileUpload *upload = GNUNET_new(
+      struct GNUNET_CHAT_FileUpload
+  );
+
+  upload->callback = cb;
+  upload->cls = cls;
+
+  GNUNET_CONTAINER_DLL_insert(
+      file->upload_head,
+      file->upload_tail,
+      upload
+  );
+}
+
+void
+file_bind_downlaod (struct GNUNET_CHAT_File* file,
+                    GNUNET_CHAT_FileDownloadCallback cb, void *cls)
+{
+  struct GNUNET_CHAT_FileDownload *download = GNUNET_new(
+      struct GNUNET_CHAT_FileDownload
+  );
+
+  download->callback = cb;
+  download->cls = cls;
+
+  GNUNET_CONTAINER_DLL_insert(
+      file->download_head,
+      file->download_tail,
+      download
+  );
+}
+
+void
+file_bind_unindex (struct GNUNET_CHAT_File* file,
+                   GNUNET_CHAT_FileUnindexCallback cb, void *cls)
+{
+  struct GNUNET_CHAT_FileUnindex *unindex = GNUNET_new(
+      struct GNUNET_CHAT_FileUnindex
+  );
+
+  unindex->callback = cb;
+  unindex->cls = cls;
+
+  GNUNET_CONTAINER_DLL_insert(
+      file->unindex_head,
+      file->unindex_tail,
+      unindex
+  );
+}
+
+void
+file_update_upload (struct GNUNET_CHAT_File* file, uint64_t completed,
+                    uint64_t size)
+{
+  struct GNUNET_CHAT_FileUpload *upload = file->upload_head;
+
+  while (upload)
+  {
+    if (upload->callback)
+      upload->callback(upload->cls, file, completed, size);
+
+    upload = upload->next;
+  }
+
+  if (completed < size)
+    return;
+
+  while (file->upload_head)
+  {
+    upload = file->upload_head;
+
+    GNUNET_CONTAINER_DLL_remove(
+      file->upload_head,
+      file->upload_tail,
+      upload
+    );
+
+    GNUNET_free(upload);
+  }
+}
+
+void
+file_update_download (struct GNUNET_CHAT_File* file, uint64_t completed,
+                      uint64_t size)
+{
+  struct GNUNET_CHAT_FileDownload *download = file->download_head;
+
+  while (download)
+  {
+    if (download->callback)
+      download->callback(download->cls, file, completed, size);
+
+    download = download->next;
+  }
+
+  if (completed < size)
+    return;
+
+  while (file->download_head)
+  {
+    download = file->download_head;
+
+    GNUNET_CONTAINER_DLL_remove(
+      file->download_head,
+      file->download_tail,
+      download
+    );
+
+    GNUNET_free(download);
+  }
+}
+
+void
+file_update_unindex (struct GNUNET_CHAT_File* file, uint64_t completed,
+                     uint64_t size)
+{
+  struct GNUNET_CHAT_FileUnindex *unindex = file->unindex_head;
+
+  while (unindex)
+  {
+    if (unindex->callback)
+      unindex->callback(unindex->cls, file, completed, size);
+
+    unindex = unindex->next;
+  }
+
+  if (completed < size)
+    return;
+
+  while (file->unindex_head)
+  {
+    unindex = file->unindex_head;
+
+    GNUNET_CONTAINER_DLL_remove(
+      file->unindex_head,
+      file->unindex_tail,
+      unindex
+    );
+
+    GNUNET_free(unindex);
+  }
+}