libopkg: add some checks for NULL strings
[oweals/opkg-lede.git] / libopkg / opkg.c
index 96ec7d410e93e83b8d503bb88ced061db3051bcd..b4aff139b3b53b66721e988ae4244c4412c4dde9 100644 (file)
 
 #include "opkg_install.h"
 #include "opkg_configure.h"
+#include "opkg_download.h"
+
+#include "sprintf_alloc.h"
+#include "file_util.h"
+
+#include <libbb/libbb.h>
 
 struct _opkg_t
 {
   args_t *args;
   opkg_conf_t *conf;
+  opkg_option_t *options;
 };
 
 /** Private Functions ***/
@@ -42,19 +49,19 @@ opkg_configure_packages(opkg_conf_t *conf, char *pkg_name)
   pkg_t *pkg;
   int r, err = 0;
 
-  all = pkg_vec_alloc();
-  pkg_hash_fetch_available(&conf->pkg_hash, all);
+  all = pkg_vec_alloc ();
+  pkg_hash_fetch_available (&conf->pkg_hash, all);
 
   for (i = 0; i < all->len; i++)
   {
     pkg = all->pkgs[i];
 
-    if (pkg_name && fnmatch(pkg_name, pkg->name, 0))
+    if (pkg_name && fnmatch (pkg_name, pkg->name, 0))
       continue;
 
     if (pkg->state_status == SS_UNPACKED)
     {
-      r = opkg_configure(conf, pkg);
+      r = opkg_configure (conf, pkg);
       if (r == 0)
       {
         pkg->state_status = SS_INSTALLED;
@@ -69,7 +76,7 @@ opkg_configure_packages(opkg_conf_t *conf, char *pkg_name)
     }
   }
 
-  pkg_vec_free(all);
+  pkg_vec_free (all);
   return err;
 }
 
@@ -82,8 +89,14 @@ opkg_new ()
 {
   opkg_t *opkg;
   opkg = malloc (sizeof (opkg_t));
+
+  opkg->args = malloc (sizeof (args_t));
   args_init (opkg->args);
+
+  opkg->conf = malloc (sizeof (opkg_conf_t));
   opkg_conf_init (opkg->conf, opkg->args);
+
+  opkg_init_options_array (opkg->conf, &opkg->options);
   return opkg;
 }
 
@@ -94,14 +107,139 @@ opkg_free (opkg_t *opkg)
   args_deinit (opkg->args);
 }
 
+int
+opkg_read_config_files (opkg_t *opkg)
+{
+  args_t *a = opkg->args;
+  opkg_conf_t *c = opkg->conf;
+
+  /* Unfortunatly, the easiest way to re-read the config files right now is to
+   * throw away opkg->conf and start again */
+
+  /* copy the settings we need to keep */
+  a->autoremove = c->autoremove;
+  a->force_depends = c->force_depends;
+  a->force_defaults = c->force_defaults;
+  a->force_overwrite = c->force_overwrite;
+  a->force_downgrade = c->force_downgrade;
+  a->force_reinstall = c->force_reinstall;
+  a->force_removal_of_dependent_packages = c->force_removal_of_dependent_packages;
+  a->force_removal_of_essential_packages = c->force_removal_of_essential_packages;
+  a->nodeps = c->nodeps;
+  a->noaction = c->noaction;
+  a->query_all = c->query_all;
+  a->multiple_providers = c->multiple_providers;
+  a->verbosity = c->verbosity;
+
+  if (c->offline_root)
+  {
+    if (a->offline_root) free (a->offline_root);
+    a->offline_root = strdup (c->offline_root);
+  }
+
+  if (c->offline_root_pre_script_cmd)
+  {
+    if (a->offline_root_pre_script_cmd) free (a->offline_root_pre_script_cmd);
+    a->offline_root_pre_script_cmd = strdup (c->offline_root_pre_script_cmd);
+  }
+
+  if (c->offline_root_post_script_cmd)
+  {
+    if (a->offline_root_post_script_cmd) free (a->offline_root_post_script_cmd);
+    a->offline_root_post_script_cmd = strdup (c->offline_root_post_script_cmd);
+  }
+
+  /* throw away old opkg_conf and start again */
+  opkg_conf_deinit (opkg->conf);
+  opkg_conf_init (opkg->conf, opkg->args);
+
+  free (opkg->options);
+  opkg_init_options_array (opkg->conf, &opkg->options);
+
+  return 0;
+}
+
 void
 opkg_get_option (opkg_t *opkg, char *option, void **value)
 {
+  int i = 0;
+  opkg_option_t *options = opkg->options;
+
+  /* can't store a value in a NULL pointer! */
+  if (!value)
+    return;
+
+  /* look up the option
+   * TODO: this would be much better as a hash table
+   */
+  while (options[i].name)
+  {
+    if (strcmp (options[i].name, option) != 0)
+    {
+      i++;
+      continue;
+    }
+  }
+
+  /* get the option */
+  switch (options[i].type)
+  {
+  case OPKG_OPT_TYPE_BOOL:
+    *((int *) value) = *((int *) options[i].value);
+    return;
+
+  case OPKG_OPT_TYPE_INT:
+    *((int *) value) = *((int *) options[i].value);
+    return;
+
+  case OPKG_OPT_TYPE_STRING:
+    *((char **)value) = strdup (options[i].value);
+    return;
+  }
+
 }
 
 void
 opkg_set_option (opkg_t *opkg, char *option, void *value)
 {
+  int i = 0;
+  opkg_option_t *options = opkg->options;
+
+  /* NULL values are not defined */
+  if (!value)
+    return;
+
+  /* look up the option
+   * TODO: this would be much better as a hash table
+   */
+  while (options[i].name)
+  {
+    if (strcmp (options[i].name, option) == 0)
+    {
+      break;
+    }
+    i++;
+  }
+
+  /* set the option */
+  switch (options[i].type)
+  {
+  case OPKG_OPT_TYPE_BOOL:
+    if (*((int *) value) == 0)
+      *((int *)options[i].value) = 0;
+    else
+      *((int *)options[i].value) = 1;
+    return;
+
+  case OPKG_OPT_TYPE_INT:
+    *((int *) options[i].value) = *((int *) value);
+    return;
+
+  case OPKG_OPT_TYPE_STRING:
+    *((char **)options[i].value) = strdup (value);
+    return;
+  }
+
 }
 
 int
@@ -109,7 +247,7 @@ opkg_install_package (opkg_t *opkg, char *package_name)
 {
   int err;
 
-  pkg_info_preinstall_check(opkg->conf);
+  pkg_info_preinstall_check (opkg->conf);
 
   if (opkg->conf->multiple_providers)
   {
@@ -152,5 +290,140 @@ opkg_upgrade_all (opkg_t *opkg)
 int
 opkg_update_package_lists (opkg_t *opkg)
 {
-  return 1;
+  char *tmp;
+  int err;
+  char *lists_dir;
+  pkg_src_list_elt_t *iter;
+  pkg_src_t *src;
+
+
+  sprintf_alloc (&lists_dir, "%s",
+                 (opkg->conf->restrict_to_default_dest)
+                 ? opkg->conf->default_dest->lists_dir
+                 : opkg->conf->lists_dir);
+
+  if (!file_is_dir (lists_dir))
+  {
+    if (file_exists (lists_dir))
+    {
+      /* XXX: Error: file exists but is not a directory */
+      free (lists_dir);
+      return 1;
+    }
+
+    err = file_mkdir_hier (lists_dir, 0755);
+    if (err)
+    {
+      /* XXX: Error: failed to create directory */
+      free (lists_dir);
+      return 1;
+    }
+  }
+
+  tmp = strdup ("/tmp/opkg.XXXXXX");
+
+  if (mkdtemp (tmp) == NULL)
+  {
+    /* XXX: Error: could not create temporary file name */
+    free (lists_dir);
+    free (tmp);
+    return 1;
+  }
+
+
+  for (iter = opkg->conf->pkg_src_list.head; iter; iter = iter->next)
+  {
+    char *url, *list_file_name;
+
+    src = iter->data;
+
+    if (src->extra_data)  /* debian style? */
+      sprintf_alloc (&url, "%s/%s/%s", src->value, src->extra_data,
+                     src->gzip ? "Packages.gz" : "Packages");
+    else
+      sprintf_alloc (&url, "%s/%s", src->value, src->gzip ? "Packages.gz" : "Packages");
+
+    sprintf_alloc (&list_file_name, "%s/%s", lists_dir, src->name);
+    if (src->gzip)
+    {
+      char *tmp_file_name;
+      FILE *in, *out;
+
+      sprintf_alloc (&tmp_file_name, "%s/%s.gz", tmp, src->name);
+
+      /* XXX: Note: downloading url */
+      err = opkg_download (opkg->conf, url, tmp_file_name);
+
+      if (err == 0)
+      {
+        /* XXX: Note: Inflating downloaded file */
+        in = fopen (tmp_file_name, "r");
+        out = fopen (list_file_name, "w");
+        if (in && out)
+          unzip (in, out);
+        else
+          err = 1;
+        if (in)
+          fclose (in);
+        if (out)
+          fclose (out);
+        unlink (tmp_file_name);
+      }
+    }
+    else
+      err = opkg_download (opkg->conf, url, list_file_name);
+
+    if (err)
+    {
+      /* XXX: Error: download error */
+    }
+    free (url);
+
+#ifdef HAVE_GPGME
+    /* download detached signitures to verify the package lists */
+    /* get the url for the sig file */
+    if (src->extra_data)  /* debian style? */
+      sprintf_alloc (&url, "%s/%s/%s", src->value, src->extra_data,
+                     "Packages.sig");
+    else
+      sprintf_alloc (&url, "%s/%s", src->value, "Packages.sig");
+
+    /* create temporary file for it */
+    char *tmp_file_name;
+
+    sprintf_alloc (&tmp_file_name, "%s/%s", tmp, "Packages.sig");
+
+    err = opkg_download (opkg->conf, url, tmp_file_name);
+    if (err)
+    {
+      /* XXX: Warning: Download failed */
+    }
+    else
+    {
+      int err;
+      err = opkg_verify_file (opkg->conf, list_file_name, tmp_file_name);
+      if (err == 0)
+      {
+        /* XXX: Notice: Signature check passed */
+      }
+      else
+      {
+        /* XXX: Warning: Signature check failed */
+      }
+    }
+    unlink (tmp_file_name);
+    free (tmp_file_name);
+    free (url);
+#else
+    /* XXX: Note: Signiture check for %s skipped because GPG support was not
+     * enabled in this build
+     */
+#endif
+    free (list_file_name);
+  }
+  rmdir (tmp);
+  free (tmp);
+  free (lists_dir);
+
+  return 0;
 }