fixed style
[ppastats.git] / src / lp.c
index c0c2b90..e23b77b 100644 (file)
--- a/src/lp.c
+++ b/src/lp.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2011-2012 jeanfi@gmail.com
+ * Copyright (C) 2011-2014 jeanfi@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
 #include <stdio.h>
 #include <string.h>
 
+#include "list.h"
 #include "lp.h"
 
+char *time_to_str(time_t t)
+{
+       char *str;
+       struct tm *tm;
+       size_t ret;
+
+       tm = localtime(&t);
+
+       if (!tm)
+               return NULL;
+
+       str = malloc(strlen("YYYY-MM-DDThh:mm:ss") + 1);
+       ret = strftime(str, strlen("YYYY-MM-DDThh:mm:ss") + 1, "%FT%T", tm);
+
+       if (ret)
+               return str;
+
+       free(str);
+       return NULL;
+}
+
 struct distro_series *distro_series_new(const char *name,
                                        const char *version,
                                        const char *title,
@@ -52,47 +74,47 @@ void distro_series_free(struct distro_series *d)
        }
 }
 
-void
-binary_package_publishing_history_free \
-(struct binary_package_publishing_history *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 binary_package_publishing_history *
-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,
+                     const char *status,
+                     int architecture_specific,
+                     time_t date_created)
 {
-       struct binary_package_publishing_history *b;
+       struct bpph *h;
 
-       b = malloc(sizeof(struct binary_package_publishing_history));
+       h = malloc(sizeof(struct bpph));
 
-       b->binary_package_name = strdup(binary_package_name);
-       b->binary_package_version = strdup(binary_package_version);
-       b->distro_arch_series_link = strdup(distro_arch_series_link);
-       b->self_link = strdup(self_link);
-       b->architecture_specific = architecture_specific;
+       h->binary_package_name = strdup(binary_package_name);
+       h->binary_package_version = strdup(binary_package_version);
+       h->distro_arch_series_link = strdup(distro_arch_series_link);
+       h->self_link = strdup(self_link);
+       h->architecture_specific = architecture_specific;
+       h->status = strdup(status);
+       h->date_created = date_created;
 
-       return b;
+       return h;
 }
 
-void
-binary_package_publishing_history_list_free\
-(struct binary_package_publishing_history **list)
+void bpph_list_free(struct bpph **list)
 {
-       struct binary_package_publishing_history **l_cur = list;
+       struct bpph **l_cur = list;
 
        while (*l_cur) {
-               binary_package_publishing_history_free(*l_cur);
+               bpph_free(*l_cur);
                l_cur++;
        }
 
@@ -171,3 +193,130 @@ 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;
+}
+
+time_t ddts_get_last_date(struct daily_download_total **ddts)
+{
+       struct daily_download_total **cur;
+       time_t t, last_t;
+
+       if (!ddts)
+               return 0;
+
+       last_t = 0;
+       for (cur = ddts; *cur; cur++) {
+               t = mktime(&(*cur)->date);
+               if (t > last_t)
+                       last_t = t;
+       }
+
+       return last_t;
+}
+
+int ddts_length(struct daily_download_total **ddts)
+{
+       int n;
+       struct daily_download_total **cur;
+
+       n = 0;
+
+       if (ddts)
+               for (cur = ddts; *cur; cur++)
+                       n++;
+
+       return n;
+}
+
+
+struct daily_download_total **add_total
+(struct daily_download_total **totals, struct daily_download_total *total)
+{
+       struct daily_download_total **cur;
+       struct daily_download_total *item;
+
+       if (totals) {
+               cur = totals;
+               while (*cur) {
+                       item = *cur;
+
+                       if (item->date.tm_year == total->date.tm_year &&
+                           item->date.tm_mon == total->date.tm_mon &&
+                           item->date.tm_mday == total->date.tm_mday) {
+                               item->count = total->count;
+                               return totals;
+                       }
+
+                       cur++;
+               }
+       }
+
+       item = malloc(sizeof(struct daily_download_total));
+       memcpy(item, total, sizeof(struct daily_download_total));
+
+       return (struct daily_download_total **)
+               list_add((void **)totals, (void *)item);
+}
+
+
+struct daily_download_total **
+ddts_merge(struct daily_download_total **ddts1,
+          struct daily_download_total **ddts2)
+{
+       struct daily_download_total **ddts, **cur, **tmp;
+
+       if (ddts1) {
+               ddts = malloc((ddts_length(ddts1) + 1)
+                             * sizeof(struct daily_download_total *));
+               memcpy(ddts, ddts1, (ddts_length(ddts1) + 1) * sizeof(void *));
+       } else {
+               ddts = malloc(sizeof(struct daily_download_total *));
+               ddts[0] = NULL;
+       }
+
+       if (ddts2)
+               for (cur = ddts2; *cur; cur++) {
+                       tmp = add_total(ddts, *cur);
+                       if (tmp != ddts)
+                               ddts = tmp;
+               }
+
+       return ddts;
+}
+
+int ddts_get_count(struct daily_download_total **ddts)
+{
+       struct daily_download_total **cur;
+       int i;
+
+       i = 0;
+       for (cur = ddts; *cur; cur++)
+               i += (*cur)->count;
+
+       return i;
+}