[Pkg-gnupg-commit] [gnupg2] 115/292: dirmngr: add VERSIONCHECK command

Daniel Kahn Gillmor dkg at fifthhorseman.net
Mon Nov 21 06:31:32 UTC 2016


This is an automated email from the git hooks/post-receive script.

dkg pushed a commit to branch master
in repository gnupg2.

commit f99c5fa1c970dc1122ac62371eb8d758f380ed57
Author: Kai Michaelis <kai at gnupg.org>
Date:   Thu Oct 13 17:43:47 2016 +0200

    dirmngr: add VERSIONCHECK command
    
    Given an application name and version VERSIONCHECK fetches the software
    version list from version.gnupg.org, verifies the signature and returns
    whenever the given version is older (UPDATE), current (CURRENT) or newer
    (ROLLBACK).
---
 dirmngr/server.c | 227 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 227 insertions(+)

diff --git a/dirmngr/server.c b/dirmngr/server.c
index e5cf2c3..22d6f2d 100644
--- a/dirmngr/server.c
+++ b/dirmngr/server.c
@@ -54,6 +54,7 @@
 #include "mbox-util.h"
 #include "zb32.h"
 #include "server-help.h"
+#include "../common/exectool.h"
 
 /* To avoid DoS attacks we limit the size of a certificate to
    something reasonable.  The DoS was actually only an issue back when
@@ -2340,6 +2341,231 @@ cmd_reloaddirmngr (assuan_context_t ctx, char *line)
 }
 
 
+

+/* Returns -1 if version a is less than b, 0 if the versions are equal and 1 otherwise.
+ * Versions are compared as period-separated tuples starting at the front. Elements are
+ * interpreted as decimals first. If this fails strcmp is used. Comparison continues
+ * until two elements are found the be unequal of the end is reached. */
+static int
+cmp_version(const char* a, const char* b)
+{
+  char *a_dup, *b_dup, *strtok_internal_a = NULL, *strtok_internal_b = NULL, *a_comp, *b_comp;
+  int ret = 0;
+
+  assert (a && b);
+
+  a_dup = xstrdup (a);
+  b_dup = xstrdup (b);
+  a_comp = strtok_r (a_dup, ".", &strtok_internal_a);
+  b_comp = strtok_r (b_dup, ".", &strtok_internal_b);
+
+  while (a_comp || b_comp)
+    {
+      if (a_comp && *a_comp && b_comp && *b_comp)
+        {
+          char* a_end;
+          char* b_end;
+          int a_ver = strtol (a_comp, &a_end, 10);
+          int b_ver = strtol (b_comp, &b_end, 10);
+
+          if (!*a_end && !*b_end)
+            {
+              if (a_ver != b_ver)
+                {
+                  ret = a_ver - b_ver;
+                  break;
+                }
+            }
+          else
+            {
+              int r = strcmp (a_comp, b_comp);
+              if (r != 0)
+                {
+                  ret = r;
+                  break;
+                }
+            }
+        }
+      else
+        {
+          if ((!a_comp || !*a_comp) && b_comp && *b_comp)
+            ret = -1;
+          else if (a_comp && *a_comp && (!b_comp || !*b_comp))
+            ret = 1;
+          else
+            ret = 0;
+          break;
+        }
+
+      a_comp = strtok_r (NULL, ".", &strtok_internal_a);
+      b_comp = strtok_r (NULL, ".", &strtok_internal_b);
+    }
+
+  xfree (a_dup);
+  xfree (b_dup);
+  return ret;
+}
+
+static int
+fetch_into_tmpfile(const char* url, ctrl_t ctrl, estream_t* strm_out, char** path)
+{
+  gpg_error_t err = 0;
+  char* filename = xmalloc (128);
+  int fd = -1;
+  estream_t file;
+  estream_t strm;
+  size_t len = 0;
+  char buf[1024];
+
+  if (!strm_out)
+    {
+      err = (GPG_ERR_INV_ARG);
+      goto leave;
+    }
+
+  snprintf (filename ,128 ,"%s%s%s" ,P_tmpdir ,DIRSEP_S ,"dirmngr_fetch_XXXXXX");
+
+  if ((fd = mkstemp (filename)) < 0)
+    {
+      err = gpg_err_code_from_syserror ();
+      goto leave;
+    }
+
+  file = es_fdopen (fd, "w+");
+
+  if ((err = ks_http_fetch (ctrl, url, &strm)))
+    goto leave;
+
+  while (!es_read (strm, buf, 1024, &len))
+    {
+      if (!len)
+        break;
+      if ((err = es_write (file, buf, len, NULL)))
+        {
+          log_error ("error writing message to pipe: %s\n", gpg_strerror (err));
+          es_free (strm);
+          goto leave;
+        }
+    }
+
+  es_rewind (file);
+  es_fclose (strm);
+  *strm_out = file;
+
+  if (path)
+    {
+    *path = filename;
+    filename = NULL;
+    }
+
+leave:
+  if (filename)
+    xfree (filename);
+  return err;
+}
+
+static const char hlp_versioncheck[] =
+  "VERSIONCHECK <name> <version>"
+  "\n"
+  "Checks the internet to find whenever a new program version is available."
+  "\n"
+  "<name> program name i.e. \"gnupg\""
+  "<version> current version of the program i.e. \"2.0.2\"";
+static gpg_error_t
+cmd_versioncheck (assuan_context_t ctx, char *line)
+{
+  gpg_error_t err;
+  char* strtok_internal = NULL;
+  char* name = strtok_r (line, " ", &strtok_internal);
+  char* version = strtok_r (NULL, " ", &strtok_internal);
+  ctrl_t ctrl = assuan_get_pointer (ctx);
+  estream_t swdb;
+  estream_t swdb_sig;
+  char* swdb_path = NULL;
+  char* swdb_sig_path = NULL;
+  char* buf = NULL;
+  size_t len = 0;
+  const size_t name_len = (name ? strlen (name) : 0);
+  const size_t version_len = (version ? strlen (version) : 0);
+  const char *argv[8];
+  char keyring_path[128];
+
+  if (!name || name_len == 0)
+    {
+      err = set_error (GPG_ERR_ASS_PARAMETER, "No program name given");
+      goto out;
+    }
+
+  if (!version || version_len == 0)
+    {
+      err = set_error (GPG_ERR_ASS_PARAMETER, "No program version given");
+      goto out;
+    }
+
+  if ((err = fetch_into_tmpfile ("https://versions.gnupg.org/swdb.lst", ctrl, &swdb, &swdb_path)))
+    goto out;
+
+  if ((err = fetch_into_tmpfile ("https://versions.gnupg.org/swdb.lst.sig", ctrl, &swdb_sig, &swdb_sig_path)))
+    goto out;
+
+  snprintf(keyring_path, 128, "%s%s%s", gnupg_datadir (), DIRSEP_S, "distsigkey.gpg");
+
+  argv[0] = "--batch";
+  argv[1] = "--no-default-keyring";
+  argv[2] = "--keyring";
+  argv[3] = keyring_path;
+  argv[4] = "--verify";
+  argv[5] = swdb_sig_path;
+  argv[6] = "-";
+  argv[7] = NULL;
+
+  if ((err = gnupg_exec_tool_stream(gnupg_module_name (GNUPG_MODULE_NAME_GPG),
+                                    argv, swdb, NULL, NULL, NULL, NULL)))
+    goto out;
+
+  es_fseek (swdb, 0, SEEK_SET);
+
+  while (es_getline (&buf, &len, swdb) > 0)
+    {
+      if (len > name_len + 5 &&
+          strncmp (buf, name, name_len) == 0 &&
+          strncmp (buf + name_len, "_ver ", 5) == 0)
+        {
+          const char* this_ver_start = buf + name_len + 5;
+          char* this_ver_end = strchr (this_ver_start, '\n');
+          int cmp;
+
+          if (this_ver_end)
+            *this_ver_end = 0;
+
+          err = assuan_write_status (ctx, "LINE", buf);
+
+          cmp = cmp_version(this_ver_start,version);
+
+          if (cmp < 0)
+            err = assuan_send_data (ctx, "ROLLBACK", strlen ("ROLLBACK"));
+          else if (cmp == 0)
+            err = assuan_send_data (ctx, "CURRENT", strlen ("CURRENT"));
+          else
+            err = assuan_send_data (ctx, "UPDATE", strlen ("UPDATE"));
+
+          goto out;
+        }
+    }
+
+  err = assuan_send_data (ctx, "NOT_FOUND", strlen ("NOT_FOUND"));
+
+  out:
+  es_fclose (swdb);
+  es_fclose (swdb_sig);
+  xfree(buf);
+  unlink(swdb_path);
+  unlink(swdb_sig_path);
+  xfree(swdb_path);
+  xfree(swdb_sig_path);
+  return leave_cmd (ctx, err);
+}
+
 
 

 /* Tell the assuan library about our commands. */
@@ -2370,6 +2596,7 @@ register_commands (assuan_context_t ctx)
     { "GETINFO",    cmd_getinfo,    hlp_getinfo },
     { "KILLDIRMNGR",cmd_killdirmngr,hlp_killdirmngr },
     { "RELOADDIRMNGR",cmd_reloaddirmngr,hlp_reloaddirmngr },
+    { "VERSIONCHECK",cmd_versioncheck,hlp_versioncheck },
     { NULL, NULL }
   };
   int i, j, rc;

-- 
Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/pkg-gnupg/gnupg2.git



More information about the Pkg-gnupg-commit mailing list