WebSVN – Kolibri OS – Diff – /contrib/other/kpm/kpm.c

 #include
 #include
 #include
-#include
-#include
-#include
 #include
 #include
 #include "getopt.h"
 #include "package.h"
 #include "http.h"
-#define BUFFSIZE  (64*1024)
-char conbuf[256];
+#define BUFFSIZE  (64*1024)
-char *make_url(const char *name)
-{
-    static char url_buf[128] = "http://ftp.kolibrios.org/users/Serge/new/OS/";
-    strcpy(&url_buf[44], name);
+extern char conbuf[256];
-    return url_buf;
-};
+#define OPTION_STD_BASE 150
-char *make_tmp_path(const char *path)
+enum option_values
 {
-    static char path_buf[64] = "/tmp0/1/";
+      OPTION_HELP = OPTION_STD_BASE,
-    strcpy(&path_buf[8], path);
+      OPTION_LIST_PACKAGES,
-    return path_buf;
+      OPTION_LIST_INSTALLED
 };
-char *make_cache_path(const char *path)
+static const struct option longopts[] =
-{
-    static char path_buf[64] = "/kolibrios/kpm/cache/";
-    strcpy(&path_buf[21], path);
-    return path_buf;
-};
-int http_load_file(const char *path, const char *url)
-{
-    http_t *http;
-    int     received = 0;
-    int     offset = 0;
-    int     tail;
-    char   *buf;
-    int     fd;
-    int     i;
+{
-    buf = user_alloc(BUFFSIZE);
+    {"list-packages", no_argument, NULL, OPTION_LIST_PACKAGES},
-    for(i = 0; i < 16; i++)
+    {"list-installed",no_argument, NULL, OPTION_LIST_INSTALLED},
-        buf[i*4096] = 0;
-    fd = open(path, O_CREAT|O_WRONLY);
+    {NULL,0,NULL,0}
-    if(fd == -1)
+};
-    {
-        user_free(buf);
-        return 0;
-    };
-    http = http_get(url, NULL,FLAG_STREAM|FLAG_REUSE_BUFFER, NULL);
+int main(int argc, char *argv[])
+{
+    LIST_HEAD(server_list);
-    if(http == NULL)
-        goto err_get;
-    do
-    {
-        if(http_receive_with_retry(http, 500) == 0)
-        {
-            int count;
-//            if(http->flags & 0xffff0000)
-//                break;
-            count = http->content_received - received;
+    LIST_HEAD(download_list);
-            if(count+offset <= BUFFSIZE)
-            {
-                memcpy(buf+offset, http->content_ptr, count);
-                offset+= count;
+    LIST_HEAD(cache_list);
-            }
            else
+    LIST_HEAD(local_list);
-            {
-                tail  = count+offset-BUFFSIZE;
-                count = BUFFSIZE - offset;
+    LIST_HEAD(task_list);
-                if(count)
-                {
-                    memcpy(buf+offset, http->content_ptr, count);
-                    offset = 0;
-                };
+    int   count;
-                write(fd, buf, BUFFSIZE);
+    char *cache_path;
-                if(tail)
+    char *tmp_path;
-                {
-                    memcpy(buf, http->content_ptr+count, tail);
+    if(http_init())
-                    offset = tail;
-                }
-                sprintf(conbuf, "%d bytes loaded\r", http->content_received);
-                con_write_asciiz(conbuf);
+        goto err_init;
-            }
-            received = http->content_received;
-        }
-        else break;
+    set_cwd("/tmp0/1");
+    con_init(80, 25, 80, 250, "Kolibri package manager");
-    }while( (http->flags & FLAG_GOT_ALL_DATA) == 0);
-    if(offset)
-    {
-        write(fd, buf, offset);
-    }
     tmp_path = make_tmp_path("packages.xml");
-//    ftruncate(fd, received);
-    close(fd);
+    count = http_load_file(tmp_path, make_url("packages.xml"));
-    if(http->content_ptr)
-        user_free(http->content_ptr);
+    if(count)
-    http_free(http);
+        build_server_list(&server_list, tmp_path);
-    user_free(buf);
+    while(1)
+    {
+        int val;
+        int index;
+        val = getopt_long_only(argc, argv,"",longopts, &index);
-    return received;
+        if(val == -1)
+            break;
+        switch(val)
 err_get:
-    printf("HTTP GET failed\n");
-    return received;
+            case OPTION_LIST_PACKAGES:
                 sprintf(conbuf,"available packages:\n\n");
                 con_write_asciiz(conbuf);
-int main(int argc, char *argv[])
-{
-    int   count;
+                print_pkg_list(&server_list);
-    char *cache_path;
+                con_exit(0);
-    char *tmp_path;
+                return 0;
+            {
                 sprintf(conbuf,"install package %s-%s\n", pkg->name, pkg->version);
                 con_write_asciiz(conbuf);
             };
-            set_cwd("/tmp0/1");
             do_install(&install_list);
         };
+    }
 #endif
     con_exit(0);
     return 0;
-err_init:
-    printf("HTTP library initialization failed\n");
-    return -1;
-}
-int build_install_list(list_t *list, collection_t *collection)
-{
-    pkg_group_t *gr;
-    int count = 0;
-    list_for_each_entry(gr, &collection->groups, list)
-    {
-        package_t   *pkg, *tmp;
-        list_for_each_entry(tmp, &gr->packages, list)
-        {
-            pkg = (package_t*)malloc(sizeof(package_t));
-            INIT_LIST_HEAD(&pkg->file_list);
-            pkg->id       = tmp->id;
-            pkg->name     = strdup(tmp->name);
-            pkg->version  = strdup(tmp->version);
-            pkg->filename = strdup(tmp->filename);
-            pkg->description = strdup(tmp->description);
-            list_add_tail(&pkg->list, list);
-            count++;
-        }
-    };
-    return count;
-}
-int build_download_list(list_t *download, list_t *src)
-{
-    int count = 0;
-    char *cache_path;
-    package_t   *pkg, *tmp;
-    fileinfo_t  info;
-    list_for_each_entry(tmp, src, list)
-    {
-        cache_path = make_cache_path(tmp->filename);
-        if( get_fileinfo(cache_path, &info) != 0)
-        {
-            pkg = (package_t*)malloc(sizeof(package_t));
-            INIT_LIST_HEAD(&pkg->file_list);
-            pkg->id       = tmp->id;
-            pkg->name     = strdup(tmp->name);
-            pkg->version  = strdup(tmp->version);
-            pkg->filename = strdup(tmp->filename);
-            pkg->description = strdup(tmp->description);
-            list_add_tail(&pkg->list, download);
-            count++;
-        };
-    }
-    return count;
-};
-void do_download(list_t *download_list)
-{
-    package_t   *pkg, *tmp;
-    char        *cache_path;
-    int         count;
-    list_for_each_entry_safe(pkg, tmp, download_list, list)
-    {
-        sprintf(conbuf,"package %s-%s\n", pkg->name, pkg->version);
-        con_write_asciiz(conbuf);
-        cache_path = make_cache_path(pkg->filename);
-        count = http_load_file(cache_path, make_url(pkg->filename));
-        sprintf(conbuf,"%s %d bytes loaded\n",cache_path, count);
-        con_write_asciiz(conbuf);
-        if( !test_archive(cache_path))
-            list_del_pkg(pkg);
-        else
-            unlink(cache_path);
-    };
-}
-void remove_missing_packages(list_t *install, list_t *missed)
-{
-    package_t   *mpkg, *mtmp, *ipkg, *itmp;
-    list_for_each_entry_safe(mpkg, mtmp, missed, list)
-    {
-        list_for_each_entry_safe(ipkg, itmp, install, list)
-        {
-            if(ipkg->id == mpkg->id)
-            {
-                sprintf(conbuf,"skip missing package %s-%s\n", ipkg->name, ipkg->version);
-                con_write_asciiz(conbuf);

Subversion Repositories Kolibri OS

(root)/contrib/other/kpm/kpm.c – Rev 5731 → 5737