load bpph from cache and merge it the http request result

[ppastats.git] / src / lp.c

diff --git a/src/lp.c b/src/lp.c
index 99cf9b2..bd9ba5d 100644 (file)
--- a/src/lp.c
+++ b/src/lp.c
@@ -21,6 +21,7 @@
 #include <stdio.h>
 #include <string.h>
 
+#include "list.h"
 #include "lp.h"
 
 struct distro_series *distro_series_new(const char *name,
@@ -52,23 +53,23 @@ void distro_series_free(struct distro_series *d)
        }
 }
 
-void binary_package_publishing_history_free(struct bpph *b)
+void bpph_free(struct bpph *b)
 {
        if (b) {
                free(b->binary_package_name);
                free(b->binary_package_version);
                free(b->distro_arch_series_link);
                free(b->self_link);
+               free(b->status);
                free(b);
        }
 }
 
-struct bpph *
-binary_package_publishing_history_new(const char *binary_package_name,
-                                     const char *binary_package_version,
-                                     const char *distro_arch_series_link,
-                                     const char *self_link,
-                                     int architecture_specific)
+struct bpph *bpph_new(const char *binary_package_name,
+                     const char *binary_package_version,
+                     const char *distro_arch_series_link,
+                     const char *self_link,
+                     int architecture_specific)
 {
        struct bpph *h;
 
@@ -79,18 +80,18 @@ binary_package_publishing_history_new(const char *binary_package_name,
        h->distro_arch_series_link = strdup(distro_arch_series_link);
        h->self_link = strdup(self_link);
        h->architecture_specific = architecture_specific;
+       h->status = NULL;
+       h->date_created.tm_isdst = -1;
 
        return h;
 }
 
-void
-binary_package_publishing_history_list_free\
-(struct bpph **list)
+void bpph_list_free(struct bpph **list)
 {
        struct bpph **l_cur = list;
 
        while (*l_cur) {
-               binary_package_publishing_history_free(*l_cur);
+               bpph_free(*l_cur);
                l_cur++;
        }
 
@@ -169,3 +170,30 @@ void daily_download_total_list_free(struct daily_download_total **list)
        }
 }
 
+struct bpph **bpph_list_add(struct bpph **list, struct bpph *new)
+{
+       struct bpph **cur, *bpph;
+
+       if (list)
+               for (cur = list; *cur; cur++) {
+                       bpph = *cur;
+
+                       if (!strcmp(bpph->self_link, new->self_link))
+                               return list;
+               }
+
+       return (struct bpph **)list_add((void **)list, new);
+}
+
+struct bpph **bpph_list_append_list(struct bpph **list1, struct bpph **list2)
+{
+       struct bpph **cur;
+
+       if (!list2)
+               return list1;
+
+       for (cur = list2; *cur; cur++)
+               list1 = bpph_list_add(list1, *cur);
+
+       return list1;
+}