Implement suggestion from Adam Slattery, (don't default to killing closing bug #1190.
[oweals/busybox.git] / dpkg.c
diff --git a/dpkg.c b/dpkg.c
index b0f6adcd3bc58d9e4aebe6d20ead0a87a879959f..01ddc7b7b77a867aa9de1d6cef97e161e4a935e2 100644 (file)
--- a/dpkg.c
+++ b/dpkg.c
 
 #include "busybox.h"
 
-
 #define DEPENDSMAX     64      /* maximum number of depends we can handle */
 
 /* Should we do full dependency checking? */
-#define DODEPENDS 1
+//#define DODEPENDS 0
 
 /* Should we do debugging? */
-#define DODEBUG 1
+//#define DODEBUG 0
 
 #ifdef DODEBUG
 #define SYSTEM(x) do_system(x)
 #endif
 
 /* from dpkg-deb.c */
-extern int deb_extract(int optflags, const char *dir_name, const char *deb_filename);
-static const int dpkg_deb_contents = 1;
-static const int dpkg_deb_control = 2;
-//     const int dpkg_deb_info = 4;
-static const int dpkg_deb_extract = 8;
-static const int dpkg_deb_verbose_extract = 16;
-static const int dpkg_deb_list = 32;
 
 static const char statusfile[] = "/var/lib/dpkg/status.udeb";
 static const char new_statusfile[] = "/var/lib/dpkg/status.udeb.new";
 static const char bak_statusfile[] = "/var/lib/dpkg/status.udeb.bak";
 
-static const char dpkgcidir[] = "/var/lib/dpkg/tmp.ci/";
-
 static const char infodir[] = "/var/lib/dpkg/info/";
 static const char udpkg_quiet[] = "UDPKG_QUIET";
 
-//static const int status_wantstart    = 0;
-//static const int status_wantunknown  = (1 << 0);
-static const int status_wantinstall    = (1 << 1);
-//static const int status_wanthold     = (1 << 2);
-//static const int status_wantdeinstall        = (1 << 3);
-//static const int status_wantpurge    = (1 << 4);
-static const int status_wantmask       = 31;
-
-//static const int status_flagstart    = 5;
-static const int status_flagok = (1 << 5);     /* 32 */
-//static const int status_flagreinstreq        = (1 << 6); 
-//static const int status_flaghold     = (1 << 7);
-//static const int status_flagholdreinstreq    = (1 << 8);
-static const int status_flagmask       = 480;
-
-//static const int status_statusstart  = 9;
-//static const int status_statusnoninstalled   = (1 << 9); /* 512 */
-static const int status_statusunpacked = (1 << 10);
-static const int status_statushalfconfigured   = (1 << 11); 
-static const int status_statusinstalled        = (1 << 12);
-static const int status_statushalfinstalled    = (1 << 13);
-//static const int status_statusconfigfiles    = (1 << 14);
-//static const int status_statuspostinstfailed = (1 << 15);
-//static const int status_statusremovalfailed  = (1 << 16);
-static const int status_statusmask =  130560; /* i assume status_statusinstalled is supposed to be included */
-
-static const char *statuswords[][10] = {
-       { (char *) 0, "unknown", "install", "hold", "deinstall", "purge", 0 },
-       { (char *) 5, "ok", "reinstreq", "hold", "hold-reinstreq", 0 },
-       { (char *) 9, "not-installed", "unpacked", "half-configured",
-               "installed", "half-installed", "config-files",
-               "post-inst-failed", "removal-failed", 0 }
-};
+//static const int status_want_unknown = 1;
+static const int state_want_install    = 2;
+//static const int state_want_hold     = 3;
+//static const int state_want_deinstall        = 4;
+//static const int state_want_purge    = 5;
+
+static const int state_flag_ok = 1;
+//static const int state_flag_reinstreq = 2; 
+//static const int state_flag_hold     = 3;
+//static const int state_flag_holdreinstreq = 4;
+
+//static const int state_statusnoninstalled = 1;
+static const int state_status_unpacked = 2;
+static const int state_status_halfconfigured = 3; 
+static const int state_status_installed        = 4;
+static const int state_status_halfinstalled    = 5;
+//static const int state_statusconfigfiles     = 6;
+//static const int state_statuspostinstfailed  = 7;
+//static const int state_statusremovalfailed   = 8;
+
+static const char *state_words_want[] = { "unknown", "install", "hold", "deinstall", "purge", 0 };
+static const char *state_words_flag[] = { "ok", "reinstreq", "hold", "hold-reinstreq", 0 };
+static const char *state_words_status[] = { "not-installed", "unpacked", "half-configured", "installed", 
+               "half-installed", "config-files", "post-inst-failed", "removal-failed", 0 };
 
 static const int color_white   = 0;
 static const int color_grey    = 1;
 static const int color_black   = 2;
 
-/* data structures */
+/* data structures */ 
 typedef struct package_s {
-       char *file;
+       char *filename;
        char *package;
-       char *version;
+       unsigned char state_want;
+       unsigned char state_flag;
+       unsigned char state_status;
        char *depends;
        char *provides;
        char *description;
+       char *priority;
+       char *section;
+       char *installed_size;
+       char *maintainer;
+       char *source;
+       char *version;
+       char *pre_depends;
+       char *replaces;
+       char *recommends;
+       char *suggests;
+       char *conflicts;
+       char *conffiles;
+       char *long_description;
+       char *architecture;
+       char *md5sum;
        int installer_menu_item;
-       unsigned long status;
        char color; /* for topo-sort */
        struct package_s *requiredfor[DEPENDSMAX]; 
        unsigned short requiredcount;
@@ -118,37 +115,6 @@ static int package_compare(const void *p1, const void *p2)
                ((package_t *)p2)->package);
 }
 
-/*
- * NOTE: this was handled by a "rm -rf" shell command
- * Maybe theis behaviour should be integrated into the rm applet
- * (i dont appreciate the rm applets recursive action fn)-bug1
- */
-static int remove_dir(const char *dirname)
-{
-       struct dirent *fp;
-       DIR *dp = opendir(dirname);
-       while ((fp = readdir(dp)) != NULL) {
-               struct stat statbuf;
-               char *filename;
-
-               filename = (char *) xcalloc(1, strlen(dirname) + strlen(fp->d_name) + 2);
-               strcpy(filename, dirname);
-               strcat(filename, fp->d_name);
-               lstat(filename, &statbuf);
-
-               if ((strcmp(fp->d_name, ".") != 0) && (strcmp(fp->d_name, "..") != 0)) {
-                       if (S_ISDIR(statbuf.st_mode)) {
-                               remove_dir(strcat(filename, "/"));
-                       }
-                       else if (remove(filename) == -1) {
-                               perror_msg(filename);
-                       }
-               }
-       }
-       remove(dirname);
-       return EXIT_SUCCESS;
-}
-
 #ifdef DODEPENDS
 #include <ctype.h>
 
@@ -271,10 +237,9 @@ static package_t *depends_resolve(package_t *pkgs, void *status)
                while (dependsvec[i] != 0) {
                        /* Check for dependencies; first look for installed packages */
                        dependpkg.package = dependsvec[i];
-                       if ((found = tfind(&dependpkg, &status, package_compare)) == 0 ||
-                           ((chk = *(package_t **)found) &&
-                            (chk->status & (status_flagok | status_statusinstalled)) != 
-                             (status_flagok | status_statusinstalled))) {
+                       if (((found = tfind(&dependpkg, &status, package_compare)) == 0) ||
+                           ((chk = *(package_t **)found) && (chk->state_flag & state_flag_ok) &&
+                               (chk->state_status & state_status_installed))) {
 
                                /* if it fails, we look through the list of packages we are going to 
                                 * install */
@@ -282,7 +247,7 @@ static package_t *depends_resolve(package_t *pkgs, void *status)
                                        if (strcmp(chk->package, dependsvec[i]) == 0 || (chk->provides && 
                                             strncmp(chk->provides, dependsvec[i], strlen(dependsvec[i])) == 0)) {
                                                if (chk->requiredcount >= DEPENDSMAX) {
-                                                       fprintf(stderr, "Too many dependencies for %s\n", chk->package);
+                                                       error_msg("Too many dependencies for %s", chk->package);
                                                        return 0;
                                                }
                                                if (chk != pkg) {
@@ -292,7 +257,7 @@ static package_t *depends_resolve(package_t *pkgs, void *status)
                                        }
                                }
                                if (chk == 0) {
-                                       fprintf(stderr, "%s depends on %s, but it is not going to be installed\n", pkg->package, dependsvec[i]);
+                                       error_msg("%s depends on %s, but it is not going to be installed", pkg->package, dependsvec[i]);
                                        return 0;
                                }
                        }
@@ -318,117 +283,212 @@ static package_t *depends_resolve(package_t *pkgs, void *status)
  *    replacing any pre-existing entries. when a merge happens, status info 
  *    read using the status_read function is written back to the status file
  */
-static unsigned long status_parse(const char *line)
+static unsigned char status_parse(const char *line, const char **status_words)
 {
-       char *p;
-       int i, j;
-       unsigned long l = 0;
-
-       for (i = 0; i < 3; i++) {
-               if ((p = strchr(line, ' ')) != NULL) {
-                       *p = 0;
-               }
-               j = 1;
-               while (statuswords[i][j] != 0) {
-                       if (strcmp(line, statuswords[i][j]) == 0) {
-                               l |= (1 << ((int)statuswords[i][0] + j - 1));
-                               break;
-                       }
-                       j++;
-               }
-               /* parse error */
-               if (statuswords[i][j] == 0) {
-                       return 0;
-               }
-               line = p+1;
-       }
-
-       return l;
-}
+       unsigned char status_num;
+       int i = 0;
 
-static const char *status_print(unsigned long flags)
-{
-       /* this function returns a static buffer... */
-       static char buf[256];
-       int i, j;
-
-       buf[0] = 0;
-       for (i = 0; i < 3; i++) {
-               j = 1;
-               while (statuswords[i][j] != 0) {
-                       if ((flags & (1 << ((int)statuswords[i][0] + j - 1))) != 0)     {
-                               strcat(buf, statuswords[i][j]);
-                               if (i < 2) strcat(buf, " ");
-                               break;
-                       }
-                       j++;
-               }
-               if (statuswords[i][j] == 0) {
-                       fprintf(stderr, "corrupted status flag!!\n");
-                       return NULL;
+       while (status_words[i] != 0) {
+               if (strncmp(line, status_words[i], strlen(status_words[i])) == 0) {
+                       status_num = (char)i;
+                       return(status_num);
                }
+               i++;
        }
-
-       return buf;
+       /* parse error */
+       error_msg("Invalid status word");
+       return(0);
 }
 
 /*
- * Read a control file (or a stanza of a status file) and parse it,
+ * Read the buffered control file and parse it,
  * filling parsed fields into the package structure
  */
-static int control_read(FILE *file, package_t *p)
+static int fill_package_struct(package_t *package, const char *package_buffer)
 {
-       char *line;
+       char *field = NULL;
+       int field_start = 0;
+       int field_length = 0;
 
-       while ((line = get_line_from_file(file)) != NULL) {
-               line[strlen(line) - 1] = '\0';
+       while ((field = read_package_field(&package_buffer[field_start])) != NULL) {
+               field_length = strlen(field);
+               field_start += (field_length + 1);
 
-               if (strlen(line) == 0) {
+               if (strlen(field) == 0) {
+                       printf("empty line: *this shouldnt happen i dont think*\n");
                        break;
-               } else
-                       if (strstr(line, "Package: ") == line) {
-                               p->package = xstrdup(line + 9);
-               } else
-                       if (strstr(line, "Status: ") == line) {
-                               p->status = status_parse(line + 8);
-               } else
-                       if (strstr(line, "Depends: ") == line) {
-                               p->depends = xstrdup(line + 9);
-               } else
-                       if (strstr(line, "Provides: ") == line) {
-                               p->provides = xstrdup(line + 10);
-               } else
-                       if (strstr(line, "Description: ") == line) {
-                               p->description = xstrdup(line + 13);
+               }
+
+               /* these are common to both installed and uninstalled packages */
+               if (strstr(field, "Package: ") == field) {
+                       package->package = strdup(field + 9);
+               }
+               else if (strstr(field, "Depends: ") == field) {
+                       package->depends = strdup(field + 9);
+               }
+               else if (strstr(field, "Provides: ") == field) {
+                       package->provides = strdup(field + 10);
+               }
                /* This is specific to the Debian Installer. Ifdef? */
-               } else
-                       if (strstr(line, "installer-menu-item: ") == line) {
-                               p->installer_menu_item = atoi(line + 21);
+               else if (strstr(field, "installer-menu-item: ") == field) {
+                       package->installer_menu_item = atoi(field + 21);
+               }
+               else if (strstr(field, "Description: ") == field) {
+                       package->description = strdup(field + 13);
+               }
+               else if (strstr(field, "Priority: ") == field) {
+                       package->priority = strdup(field + 10);
+               }
+               else if (strstr(field, "Section: ") == field) {
+                       package->section = strdup(field + 9);
+               }
+               else if (strstr(field, "Installed-Size: ") == field) {
+                       package->installed_size = strdup(field + 16);
+               }
+               else if (strstr(field, "Maintainer: ") == field) {
+                       package->maintainer = strdup(field + 12);
+               }
+               else if (strstr(field, "Version: ") == field) {
+                       package->version = strdup(field + 9);
+               }
+               else if (strstr(field, "Suggests: ") == field) {
+                       package->suggests = strdup(field + 10);
+               }
+               else if (strstr(field, "Recommends: ") == field) {
+                       package->recommends = strdup(field + 12);
+               }
+/*             else if (strstr(field, "Conffiles: ") == field) {
+                       package->conffiles = read_block(file);
+                               package->conffiles = xcalloc(1, 1);
+                               while ((field = strtok(NULL, "\n")) != NULL) {
+                                       package->long_description = xrealloc(package->conffiles, 
+                                       strlen(package->conffiles) + strlen(field) + 1);
+                                       strcat(package->conffiles, field);
+                               }
+                       }
+*/
+               /* These are only in available file */
+               else if (strstr(field, "Architecture: ") == field) {
+                       package->architecture = strdup(field + 14);
+               }
+               else if (strstr(field, "Filename: ") == field) {
+                       package->filename = strdup(field + 10);
+               }
+               else if (strstr(field, "MD5sum ") == field) {
+                       package->md5sum = strdup(field + 7);
+               }
+
+               /* This is only needed for status file */
+               if (strstr(field, "Status: ") == field) {
+                       char *word_pointer;
+
+                       word_pointer = strchr(field, ' ') + 1;
+                       package->state_want = status_parse(word_pointer, state_words_want);
+                       word_pointer = strchr(word_pointer, ' ') + 1;
+                       package->state_flag = status_parse(word_pointer, state_words_flag);
+                       word_pointer = strchr(word_pointer, ' ') + 1;
+                       package->state_status = status_parse(word_pointer, state_words_status);
+               } else {
+                       package->state_want = status_parse("purge", state_words_want);
+                       package->state_flag = status_parse("ok", state_words_flag);
+                       package->state_status = status_parse("not-installed", state_words_status);
                }
-               /* TODO: localized descriptions */
+
+               free(field);
        }
-       free(line);
        return EXIT_SUCCESS;
 }
 
+extern void write_package(FILE *out_file, package_t *pkg)
+{
+       if (pkg->package) {
+               fprintf(out_file, "Package: %s\n", pkg->package);
+       }
+       if ((pkg->state_want != 0) || (pkg->state_flag != 0)|| (pkg->state_status != 0)) {
+               fprintf(out_file, "Status: %s %s %s\n", 
+                       state_words_want[pkg->state_want - 1],
+                       state_words_flag[pkg->state_flag - 1],
+                       state_words_status[pkg->state_status - 1]);
+       }
+       if (pkg->depends) {
+               fprintf(out_file, "Depends: %s\n", pkg->depends);
+       }
+       if (pkg->provides) {
+               fprintf(out_file, "Provides: %s\n", pkg->provides);
+       }
+       if (pkg->priority) {
+               fprintf(out_file, "Priority: %s\n", pkg->priority);
+       }
+       if (pkg->section) {
+               fprintf(out_file, "Section: %s\n", pkg->section);
+       }
+       if (pkg->section) {
+               fprintf(out_file, "Installed-Size: %s\n", pkg->installed_size);
+       }
+       if (pkg->maintainer) {
+               fprintf(out_file, "Maintainer: %s\n", pkg->maintainer);
+       }
+       if (pkg->source) {
+               fprintf(out_file, "Source: %s\n", pkg->source);
+       }
+       if (pkg->version) {
+               fprintf(out_file, "Version: %s\n", pkg->version);
+       }
+       if (pkg->pre_depends) {
+               fprintf(out_file, "Pre-depends: %s\n", pkg->pre_depends);
+       }
+       if (pkg->replaces) {
+               fprintf(out_file, "Replaces: %s\n", pkg->replaces);
+       }
+       if (pkg->recommends) {
+               fprintf(out_file, "Recommends: %s\n", pkg->recommends);
+       }
+       if (pkg->suggests) {
+               fprintf(out_file, "Suggests: %s\n", pkg->suggests);
+       }
+       if (pkg->conflicts) {
+               fprintf(out_file, "Conflicts: %s\n", pkg->conflicts);
+       }
+       if (pkg->conffiles) {
+               fprintf(out_file, "Conf-files: %s\n", pkg->conffiles);
+       }
+       if (pkg->architecture) {
+               fprintf(out_file, "Architecture: %s\n", pkg->architecture);
+       }
+       if (pkg->filename) {
+               fprintf(out_file, "Filename: %s\n", pkg->filename);
+       }
+       if (pkg->md5sum) {
+               fprintf(out_file, "MD5sum: %s\n", pkg->md5sum);
+       }
+       if (pkg->installer_menu_item) {
+               fprintf(out_file, "installer-main-menu %d\n", pkg->installer_menu_item);
+       }
+       if (pkg->description) {
+               fprintf(out_file, "Description: %s\n", pkg->description);
+       }
+       fputc('\n', out_file);
+       pkg = pkg->next;
+}
+
 static void *status_read(void)
 {
        FILE *f;
        void *status = 0;
        package_t *m = 0, *p = 0, *t = 0;
-
-       if ((f = fopen(statusfile, "r")) == NULL) {
-               perror_msg(statusfile);
-               return 0;
-       }
+       char *package_control_buffer = NULL;
 
        if (getenv(udpkg_quiet) == NULL) {
                printf("(Reading database...)\n");
        }
 
-       while (!feof(f)) {
+       if ((f = wfopen(statusfile, "r")) == NULL) {
+               return(NULL);
+       }
+
+       while ( (package_control_buffer = fgets_str(f, "\n\n")) != NULL) {
                m = (package_t *)xcalloc(1, sizeof(package_t));
-               control_read(f, m);
+               fill_package_struct(m, package_control_buffer);
                if (m->package) {
                        /*
                         * If there is an item in the tree by this name,
@@ -445,22 +505,22 @@ static void *status_read(void)
                                 */
                                p = (package_t *)xcalloc(1, sizeof(package_t));
                                p->package = xstrdup(m->provides);
-
                                t = *(package_t **)tsearch(p, &status, package_compare);
                                if (t != p) {
                                        free(p->package);
                                        free(p);
-                               }
-                               else {
+                               } else {
                                        /*
                                         * Pseudo package status is the
                                         * same as the status of the
                                         * package providing it 
                                         * FIXME: (not quite right, if 2
                                         * packages of different statuses
-                                        * provide it).
-                                        */
-                                       t->status = m->status;
+                                        * provide it).
+                                        */
+                                       t->state_want = m->state_want;
+                                       t->state_flag = m->state_flag;
+                                       t->state_status = m->state_status;
                                }
                        }
                }
@@ -485,12 +545,13 @@ static int status_merge(void *status, package_t *pkgs)
        if (getenv(udpkg_quiet) == NULL) {
                printf("(Updating database...)\n");
        }
+
        /*
         * Dont use wfopen here, handle errors ourself
         */
        if ((fin = fopen(statusfile, "r")) != NULL) {
                while (((line = get_line_from_file(fin)) != NULL) && !feof(fin)) { 
-                       line[strlen(line) - 1] = '\0'; /* trim newline */
+                       chomp(line); /* trim newline */
                        /* If we see a package header, find out if it's a package
                         * that we have processed. if so, we skip that block for
                         * now (write it at the end).
@@ -517,11 +578,12 @@ static int status_merge(void *status, package_t *pkgs)
                                continue;
                        }
                        if (strstr(line, "Status: ") == line && statpkg != 0) {
-                               snprintf(line, sizeof(line), "Status: %s",
-                                       status_print(statpkg->status));
+                               snprintf(line, sizeof(line), "Status: %s %s %s",
+                                       state_words_want[statpkg->state_want - 1], 
+                                       state_words_flag[statpkg->state_flag - 1], 
+                                       state_words_status[statpkg->state_status - 1]);
                        }
-                       fputs(line, fout);
-                       fputc('\n', fout);
+                       fprintf(fout, "%s\n", line);
                }
                fclose(fin);
        }
@@ -529,17 +591,7 @@ static int status_merge(void *status, package_t *pkgs)
 
        // Print out packages we processed.
        for (pkg = pkgs; pkg != 0; pkg = pkg->next) {
-               fprintf(fout, "Package: %s\nStatus: %s\n", 
-                       pkg->package, status_print(pkg->status));
-               if (pkg->depends)
-                       fprintf(fout, "Depends: %s\n", pkg->depends);
-               if (pkg->provides)
-                       fprintf(fout, "Provides: %s\n", pkg->provides);
-               if (pkg->installer_menu_item)
-                       fprintf(fout, "installer-menu-item: %i\n", pkg->installer_menu_item);
-               if (pkg->description)
-                       fprintf(fout, "Description: %s\n", pkg->description);
-               fputc('\n', fout);
+               write_package(fout, pkg);
        }
        fclose(fout);
 
@@ -548,10 +600,11 @@ static int status_merge(void *status, package_t *pkgs)
         */
        if (rename(statusfile, bak_statusfile) == -1) {
                struct stat stat_buf;   
-               error_msg("Couldnt create backup status file");
                if (stat(statusfile, &stat_buf) == 0) {
+                       error_msg("Couldnt create backup status file");
                        return(EXIT_FAILURE);
                }
+               error_msg("No status file found, creating new one");
        }
 
        if (rename(new_statusfile, statusfile) == -1) {
@@ -578,143 +631,70 @@ static int dpkg_doconfigure(package_t *pkg)
        char buf[1024];
 
        DPRINTF("Configuring %s\n", pkg->package);
-       pkg->status &= status_statusmask;
+       pkg->state_status = 0;
        snprintf(postinst, sizeof(postinst), "%s%s.postinst", infodir, pkg->package);
 
        if (is_file(postinst)) {
                snprintf(buf, sizeof(buf), "%s configure", postinst);
                if ((r = do_system(buf)) != 0) {
-                       fprintf(stderr, "postinst exited with status %d\n", r);
-                       pkg->status |= status_statushalfconfigured;
+                       error_msg("postinst exited with status %d\n", r);
+                       pkg->state_status = state_status_halfconfigured;
                        return 1;
                }
        }
-       pkg->status |= status_statusinstalled;
+       pkg->state_status = state_status_installed;
        
        return 0;
 }
 
 static int dpkg_dounpack(package_t *pkg)
 {
-       int r = 0, i;
-       char *cwd;
-       char *src_file = NULL;
-       char *dst_file = NULL;
-//     char *lst_file = NULL;
-       char *adminscripts[] = { "prerm", "postrm", "preinst", "postinst",
-                       "conffiles", "md5sums", "shlibs", "templates" };
+       FILE *out_stream;
+       char *info_prefix;
+       int status = TRUE;
+       int r = 0;
 
        DPRINTF("Unpacking %s\n", pkg->package);
 
-       cwd = getcwd(0, 0);
-       chdir("/");
-       deb_extract(dpkg_deb_extract, "/", pkg->file);
-
-       /* Installs the package scripts into the info directory */
-       for (i = 0; i < sizeof(adminscripts) / sizeof(adminscripts[0]); i++) {
-               struct stat src_stat_buf;
-               int src_fd = 0, dst_fd = 0;
-
-               /* The full path of the current location of the admin file */
-               src_file = xrealloc(src_file, strlen(dpkgcidir) + strlen(pkg->package) + strlen(adminscripts[i]) + 1);
-               sprintf(src_file, "%s%s/%s", dpkgcidir, pkg->package, adminscripts[i]);
-
-               /* the full path of where we want the file to be copied to */
-               dst_file = xrealloc(dst_file, strlen(infodir) + strlen(pkg->package) + strlen(adminscripts[i]) + 1);
-               sprintf(dst_file, "%s%s.%s", infodir, pkg->package, adminscripts[i]);
-
-               /*
-                * copy admin file to permanent home
-                * NOTE: Maybe merge this behaviour into libb/copy_file.c
-                */
-               if (lstat(src_file, &src_stat_buf) == 0) {
-                       if ((src_fd = open(src_file, O_RDONLY)) != -1) {
-                               if ((dst_fd = open(dst_file, O_WRONLY | O_CREAT, 0644)) == -1) {
-                                       perror_msg("Opening %s", dst_file);
-                               }
-                               copy_file_chunk(src_fd, dst_fd, src_stat_buf.st_size);
-                               close(src_fd);
-                               close(dst_fd);
-                       } else {
-                               error_msg("couldnt open [%s]\n", src_file);
-                       }
-               }
-       }
-
-       /* 
-        * create the list file 
-        * FIXME: currently this dumps the lst to stdout instead of a file
-        */
-/*     lst_file = (char *) xmalloc(strlen(infodir) + strlen(pkg->package) + 6);
-       strcpy(lst_file, infodir);
-       strcat(lst_file, pkg->package);
-       strcat(lst_file, ".list");
-       deb_extract(dpkg_deb_list, NULL, pkg->file);
-*/
-
-       pkg->status &= status_wantmask;
-       pkg->status |= status_wantinstall;
-       pkg->status &= status_flagmask;
-       pkg->status |= status_flagok;
-       pkg->status &= status_statusmask;
-
-       if (r == 0) {
-               pkg->status |= status_statusunpacked;
+       /* extract the data file */
+       deb_extract(pkg->filename, stdout, (extract_data_tar_gz | extract_all_to_fs), "/", NULL);
+
+       /* extract the control files */
+       info_prefix = (char *) malloc(strlen(pkg->package) + strlen(infodir) + 2 + 5 + 1);
+       sprintf(info_prefix, "%s/%s.", infodir, pkg->package);
+       deb_extract(pkg->package, stdout, (extract_control_tar_gz | extract_all_to_fs), info_prefix, NULL);
+
+       /* Create the list file */
+       strcat(info_prefix, "list");
+       out_stream = wfopen(info_prefix, "w");                  
+       deb_extract(pkg->package, out_stream, (extract_data_tar_gz | extract_list), NULL, NULL);
+       fclose(out_stream);
+
+       pkg->state_want = state_want_install;
+       pkg->state_flag = state_flag_ok;
+       if (status == TRUE) {
+               pkg->state_status = state_status_unpacked;
        } else {
-               pkg->status |= status_statushalfinstalled;
+               pkg->state_status = state_status_halfinstalled;
        }
-       chdir(cwd);
+
        return r;
 }
 
 /*
- * Extract and parse the control.tar.gz from the specified package
+ * Extract and parse the control file from control.tar.gz
  */
-static int dpkg_unpackcontrol(package_t *pkg)
+static int dpkg_read_control(package_t *pkg)
 {
-       char *tmp_name;
-       FILE *file;
-       int length;
-
-       /* clean the temp directory (dpkgcidir) be recreating it */
-       remove_dir(dpkgcidir);
-       if (mkdir(dpkgcidir, S_IRWXU) != 0) {
-               perror("mkdir");
-               return EXIT_FAILURE;
-       }
-
-       /*
-        * Get the package name from the file name,
-        * first remove the directories
-        */
-       if ((tmp_name = strrchr(pkg->file, '/')) == NULL) {
-               tmp_name = pkg->file;
-       } else {
-               tmp_name++;
-       }
-       /* now remove trailing version numbers etc */
-       length = strcspn(tmp_name, "_.");
-       pkg->package = (char *) xcalloc(1, length + 1);
-       /* store the package name */
-       strncpy(pkg->package, tmp_name, length);
-
-       /* work out the full extraction path */
-       tmp_name = (char *) xcalloc(1, strlen(dpkgcidir) + strlen(pkg->package) + 9);
-       strcpy(tmp_name, dpkgcidir);
-       strcat(tmp_name, pkg->package);
-
-       /* extract control.tar.gz to the full extraction path */
-       deb_extract(dpkg_deb_control, tmp_name, pkg->file);
+       FILE *pkg_file;
+       char *control_buffer = NULL;
 
-       /* parse the extracted control file */
-       strcat(tmp_name, "/control");
-       if ((file = wfopen(tmp_name, "r")) == NULL) {
+       if ((pkg_file = wfopen(pkg->filename, "r")) == NULL) {
                return EXIT_FAILURE;
        }
-       if (control_read(file, pkg) == EXIT_FAILURE) {
-               return EXIT_FAILURE;
-       }
-
+       control_buffer = deb_extract(pkg->filename, stdout, (extract_control_tar_gz | extract_one_to_buffer), NULL, "./control");
+       fill_package_struct(pkg, control_buffer);
        return EXIT_SUCCESS;
 }
 
@@ -724,15 +704,12 @@ static int dpkg_unpack(package_t *pkgs, void *status)
        package_t *pkg;
 
        for (pkg = pkgs; pkg != 0; pkg = pkg->next) {
-               if (dpkg_unpackcontrol(pkg) == EXIT_FAILURE) {
-                       return EXIT_FAILURE;
-               }
+               dpkg_read_control(pkg);
                if ((r = dpkg_dounpack(pkg)) != 0 ) {
                        break;
                }
        }
        status_merge(status, pkgs);
-       remove_dir(dpkgcidir);
 
        return r;
 }
@@ -747,7 +724,7 @@ static int dpkg_configure(package_t *pkgs, void *status)
                found = tfind(pkg, &status, package_compare);
 
                if (found == 0) {
-                       fprintf(stderr, "Trying to configure %s, but it is not installed\n", pkg->package);
+                       error_msg("Trying to configure %s, but it is not installed", pkg->package);
                        r = 1;
                } 
                /* configure the package listed in the status file;
@@ -768,9 +745,7 @@ static int dpkg_install(package_t *pkgs, void *status)
 
        /* Stage 1: parse all the control information */
        for (p = pkgs; p != 0; p = p->next) {
-               if (dpkg_unpackcontrol(p) == EXIT_FAILURE) {
-                       return(EXIT_FAILURE);
-               }
+               dpkg_read_control(p);
        }
 
        /* Stage 2: resolve dependencies */
@@ -782,28 +757,26 @@ static int dpkg_install(package_t *pkgs, void *status)
        
        /* Stage 3: install */
        for (p = ordered; p != 0; p = p->next) {
-               p->status &= status_wantmask;
-               p->status |= status_wantinstall;
+               p->state_want = state_want_install;
 
                /* for now the flag is always set to ok... this is probably
                 * not what we want
                 */
-               p->status &= status_flagmask;
-               p->status |= status_flagok;
+               p->state_flag = state_flag_ok;
 
                DPRINTF("Installing %s\n", p->package);
                if (dpkg_dounpack(p) != 0) {
-                       perror_msg(p->file);
+                       perror_msg(p->filename);
                }
+
                if (dpkg_doconfigure(p) != 0) {
-                       perror_msg(p->file);
+                       perror_msg(p->filename);
                }
        }
 
        if (ordered != 0) {
                status_merge(status, pkgs);
        }
-       remove_dir(dpkgcidir);
 
        return 0;
 }
@@ -832,7 +805,7 @@ extern int dpkg_main(int argc, char **argv)
 
        package_t *p, *packages = NULL;
        void *status = NULL;
-       char opt = 0;
+       int opt = 0;
        int optflag = 0;
 
        while ((opt = getopt(argc, argv, "iruc")) != -1) {
@@ -856,7 +829,7 @@ extern int dpkg_main(int argc, char **argv)
                if (optflag & arg_configure) {
                        p->package = xstrdup(argv[optind]);
                } else {
-                       p->file = xstrdup(argv[optind]);
+                       p->filename = xstrdup(argv[optind]);
                }
                p->next = packages;
                packages = p;
@@ -864,8 +837,7 @@ extern int dpkg_main(int argc, char **argv)
                optind++;
        }
 
-       create_path(dpkgcidir, 0755);
-       create_path(infodir, 0755);
+       make_directory((char *)infodir, S_IRWXU, FILEUTILS_RECUR);
 
        status = status_read();