#include "platform.h"
#include <gnunet_util_lib.h>
#include <gnunet_gnsrecord_lib.h>
#include <gnunet_identity_service.h>
#include <gnunet_namestore_service.h>

Include dependency graph for gnunet-gns-import.c:

Functions
static int	run_process_and_wait (enum GNUNET_OS_InheritStdioFlags std_inheritance, struct GNUNET_DISK_PipeHandle pipe_stdin, struct GNUNET_DISK_PipeHandle pipe_stdout, enum GNUNET_OS_ProcessStatusType st, unsigned long code, const char *filename,...)

static void	check_pkey (unsigned int rd_len, const struct GNUNET_GNSRECORD_Data rd, char pk, int *found_rec)

static void	zone_iterator (void cls, const struct GNUNET_CRYPTO_EcdsaPrivateKey zone_key, const char rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data rd)
	Process a record that was stored in the namestore. More...

static void	zone_iteration_error (void *cls)

static void	zone_iteration_finished (void *cls)

static void	get_ego (void cls, struct GNUNET_IDENTITY_Ego ego, void *ctx, const char identifier)
	Get master-zone and private-zone keys. More...

static void	shutdown_task (void *cls)
	Task run on shutdown. More...

static void	run (void cls, char const args, const char cfgfile, const struct GNUNET_CONFIGURATION_Handle *c)
	Main function that will be run. More...

int	main (int argc, char const argv)
	The main function for gnunet-gns. More...

Variables
static const struct GNUNET_CONFIGURATION_Handle *	cfg
	Configuration we are using. More...

static struct GNUNET_IDENTITY_Handle *	sh
	Handle to IDENTITY service. More...

struct GNUNET_NAMESTORE_ZoneIterator *	list_it
	Zone iterator for master zone. More...

static struct GNUNET_NAMESTORE_Handle *	ns
	Handle to the namestore. More...

static char *	master_zone_pkey
	String version of PKEY for master-zone. More...

static struct GNUNET_CRYPTO_EcdsaPrivateKey	master_pk
	Binary version of PKEY for master-zone. More...

static char *	private_zone_pkey
	String version of PKEY for private-zone. More...

static char *	pin_zone_pkey
	String version of PKEY for pin-zone. More...

static int	found_private_rec = GNUNET_NO
	Set to GNUNET_YES if private record was found;. More...

static int	found_pin_rec = GNUNET_NO
	Set to GNUNET_YES if pin record was found;. More...

static int	ret
	Exit code. More...

Function Documentation

◆ run_process_and_wait()

static int run_process_and_wait	(	enum GNUNET_OS_InheritStdioFlags	std_inheritance,
		struct GNUNET_DISK_PipeHandle *	pipe_stdin,
		struct GNUNET_DISK_PipeHandle *	pipe_stdout,
		enum GNUNET_OS_ProcessStatusType *	st,
		unsigned long *	code,
		const char *	filename,
			...
	)

static

Definition at line 90 of file gnunet-gns-import.c.

{
  static struct GNUNET_OS_Process *p;
  int arglen;
  char *arg;
  char *args;
  char *argp;
  va_list ap, apc1, apc2;
 
  va_start (ap, filename);
  va_copy (apc1, ap);
  va_copy (apc2, ap);
  arglen = 0;
  while (NULL != (arg = va_arg (apc1, char *)))
    arglen += strlen (arg) + 1;
  va_end (apc1);
  args = argp = GNUNET_malloc (arglen);
  while (NULL != (arg = va_arg (apc2, char *)))
  {
    strcpy (argp, arg);
    argp += strlen (arg);
    *argp = ' ';
    argp += 1;
  }
  va_end (apc2);
  if (arglen > 0)
    argp[-1] = '\0';
  p = GNUNET_OS_start_process_va (std_inheritance,
                                  pipe_stdin,
                                  pipe_stdout,
                                  NULL,
                                  filename, ap);
  va_end (ap);
  if (NULL == p)
  {
    ret = 3;
    fprintf (stderr, "Failed to run `%s'\n", args);
    GNUNET_free (args);
    return 1;
  }
 
  if (GNUNET_OK != GNUNET_OS_process_wait (p))
  {
    ret = 4;
    fprintf (stderr, "Failed to wait for `%s'\n", args);
    GNUNET_free (args);
    return 1;
  }
 
  switch (GNUNET_OS_process_status (p, st, code))
  {
  case GNUNET_OK:
    break;
 
  case GNUNET_NO:
    ret = 5;
    fprintf (stderr, "`%s' is still running\n", args);
    GNUNET_free (args);
    return 1;
 
  default:
  case GNUNET_SYSERR:
    ret = 6;
    fprintf (stderr, "Failed to check the status of `%s'\n", args);
    GNUNET_free (args);
    return 1;
  }
  return 0;
}

References find_typedefs::arg, consensus-simulation::args, filename, GNUNET_free, GNUNET_malloc, GNUNET_NO, GNUNET_OK, GNUNET_OS_process_status(), GNUNET_OS_process_wait(), GNUNET_OS_start_process_va(), GNUNET_SYSERR, p, ret, and st.

Referenced by run(), and zone_iteration_error().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ check_pkey()

static void check_pkey	(	unsigned int	rd_len,
		const struct GNUNET_GNSRECORD_Data *	rd,
		char *	pk,
		int *	found_rec
	)

static

Definition at line 167 of file gnunet-gns-import.c.

{
  int i;
  struct GNUNET_CRYPTO_PublicKey pubkey;
 
  for (i = 0; i < rd_len; i++)
  {
    char *s;
    if (sizeof (uint32_t) > rd[i].data_size)
      continue;
    if (GNUNET_OK != GNUNET_GNSRECORD_identity_from_data (rd[i].data,
                                                          rd[i].data_size,
                                                          rd[i].record_type,
                                                          &pubkey))
      continue;
    s = GNUNET_GNSRECORD_value_to_string (rd[i].record_type,
                                          rd[i].data,
                                          rd[i].data_size);
    if (NULL == s)
      continue;
    if (0 == strcmp (s, pk))
      *found_rec = GNUNET_YES;
    GNUNET_free (s);
  }
}

References data, data_size, GNUNET_free, GNUNET_GNSRECORD_identity_from_data(), GNUNET_GNSRECORD_value_to_string(), GNUNET_OK, GNUNET_YES, pk, pubkey, and rd.

Referenced by zone_iterator().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ zone_iterator()

static void zone_iterator	(	void *	cls,
		const struct GNUNET_CRYPTO_EcdsaPrivateKey *	zone_key,
		const char *	rname,
		unsigned int	rd_len,
		const struct GNUNET_GNSRECORD_Data *	rd
	)

static

Process a record that was stored in the namestore.

Parameters

cls	closure
zone_key	private key of the zone
rname	name that is being mapped (at most 255 characters long)
rd_len	number of entries in rd array
rd	array of records with data to store

Definition at line 205 of file gnunet-gns-import.c.

{
  if (NULL != rname)
  {
    if (0 == strcmp (rname, "private"))
      check_pkey (rd_len, rd, private_zone_pkey, &found_private_rec);
    else if (0 == strcmp (rname, "pin"))
      check_pkey (rd_len, rd, pin_zone_pkey, &found_pin_rec);
  }
  GNUNET_NAMESTORE_zone_iterator_next (list_it);
}

References check_pkey(), found_pin_rec, found_private_rec, GNUNET_NAMESTORE_zone_iterator_next(), list_it, pin_zone_pkey, private_zone_pkey, and rd.

Referenced by get_ego().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ zone_iteration_error()

static void zone_iteration_error ( void * cls )

static

Definition at line 222 of file gnunet-gns-import.c.

{
  enum GNUNET_OS_ProcessStatusType st;
  unsigned long code;
 
  if (! found_private_rec)
  {
    if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                   NULL, NULL, &st, &code,
                                   "gnunet-namestore",
                                   "gnunet-namestore", "-z", "master-zone",
                                   "-a", "-e", "never", "-n", "private", "-p",
                                   "-t", "PKEY", "-V",
                                   private_zone_pkey, NULL))
    {
      ret = 8;
      return;
    }
  }
  if (! found_pin_rec)
  {
    if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                   NULL, NULL, &st, &code,
                                   "gnunet-namestore",
                                   "gnunet-namestore", "-z", "master-zone",
                                   "-a", "-e", "never", "-n", "pin", "-p", "-t",
                                   "PKEY", "-V", pin_zone_pkey,
                                   NULL))
    {
      ret = 10;
      return;
    }
  }
  list_it = NULL;
  GNUNET_SCHEDULER_shutdown ();
}

References found_pin_rec, found_private_rec, GNUNET_OS_INHERIT_STD_OUT_AND_ERR, GNUNET_SCHEDULER_shutdown(), list_it, pin_zone_pkey, private_zone_pkey, ret, run_process_and_wait(), and st.

Referenced by get_ego().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ zone_iteration_finished()

static void zone_iteration_finished ( void * cls )

static

Definition at line 261 of file gnunet-gns-import.c.

262{

263}

Referenced by get_ego().

Here is the caller graph for this function:

◆ get_ego()

static void get_ego	(	void *	cls,
		struct GNUNET_IDENTITY_Ego *	ego,
		void **	ctx,
		const char *	identifier
	)

static

Get master-zone and private-zone keys.

This function is initially called for all egos and then again whenever a ego's identifier changes or if it is deleted. At the end of the initial pass over all egos, the function is once called with 'NULL' for 'ego'. That does NOT mean that the callback won't be invoked in the future or that there was an error.

When used with 'GNUNET_IDENTITY_create' or 'GNUNET_IDENTITY_get', this function is only called ONCE, and 'NULL' being passed in 'ego' does indicate an error (for example because name is taken or no default value is known). If 'ego' is non-NULL and if '*ctx' is set in those callbacks, the value WILL be passed to a subsequent call to the identity callback of 'GNUNET_IDENTITY_connect' (if that one was not NULL).

When an identity is renamed, this function is called with the (known) ego but the NEW identifier.

When an identity is deleted, this function is called with the (known) ego and "NULL" for the 'identifier'. In this case, the 'ego' is henceforth invalid (and the 'ctx' should also be cleaned up).

Parameters

cls	closure
ego	ego handle
ctx	context for application to store data for this ego (during the lifetime of this process, initially NULL)
identifier	identifier assigned by the user for this ego, NULL if the user just deleted the ego and it must thus no longer be used

Definition at line 299 of file gnunet-gns-import.c.

{
  static struct GNUNET_CRYPTO_EcdsaPublicKey pk;
 
  if (NULL == ego)
  {
    if ((NULL == master_zone_pkey) ||
        (NULL == private_zone_pkey) )
    {
      ret = 11;
      GNUNET_SCHEDULER_shutdown ();
      return;
    }
    list_it = GNUNET_NAMESTORE_zone_iteration_start (ns,
                                                     &master_pk,
                                                     &zone_iteration_error,
                                                     NULL, &zone_iterator, NULL,
                                                     &zone_iteration_finished,
                                                     NULL);
    if (NULL == list_it)
    {
      ret = 12;
      GNUNET_SCHEDULER_shutdown ();
    }
    return;
  }
  GNUNET_IDENTITY_ego_get_public_key (ego, &pk);
  if (NULL != identifier)
  {
    if ((NULL == master_zone_pkey) && (0 == strcmp ("master-zone",
                                                    identifier)) )
    {
      master_zone_pkey = GNUNET_CRYPTO_ecdsa_public_key_to_string (&pk);
      master_pk = *GNUNET_IDENTITY_ego_get_private_key (ego);
    }
    else if ((NULL == private_zone_pkey) && (0 == strcmp ("private-zone",
                                                          identifier)) )
      private_zone_pkey = GNUNET_CRYPTO_ecdsa_public_key_to_string (&pk);
  }
}

References GNUNET_CRYPTO_ecdsa_public_key_to_string(), GNUNET_IDENTITY_ego_get_private_key(), GNUNET_IDENTITY_ego_get_public_key(), GNUNET_NAMESTORE_zone_iteration_start(), GNUNET_SCHEDULER_shutdown(), list_it, master_pk, master_zone_pkey, ns, pk, private_zone_pkey, ret, zone_iteration_error(), zone_iteration_finished(), and zone_iterator().

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ shutdown_task()

static void shutdown_task ( void * cls )

static

Task run on shutdown.

Parameters

cls NULL

Definition at line 350 of file gnunet-gns-import.c.

{
  GNUNET_free (master_zone_pkey);
  master_zone_pkey = NULL;
  GNUNET_free (private_zone_pkey);
  private_zone_pkey = NULL;
  if (NULL != list_it)
  {
    GNUNET_NAMESTORE_zone_iteration_stop (list_it);
    list_it = NULL;
  }
  if (NULL != ns)
  {
    GNUNET_NAMESTORE_disconnect (ns);
    ns = NULL;
  }
  if (NULL != sh)
  {
    GNUNET_IDENTITY_disconnect (sh);
    sh = NULL;
  }
}

References GNUNET_free, GNUNET_IDENTITY_disconnect(), GNUNET_NAMESTORE_disconnect(), GNUNET_NAMESTORE_zone_iteration_stop(), list_it, master_zone_pkey, ns, private_zone_pkey, and sh.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ run()

static void run	(	void *	cls,
		char const	args,
		const char *	cfgfile,
		const struct GNUNET_CONFIGURATION_Handle *	c
	)

static

Main function that will be run.

Parameters

cls	closure
args	remaining command-line arguments
cfgfile	name of the configuration file used (for saving, can be NULL!)
c	configuration

Definition at line 383 of file gnunet-gns-import.c.

{
  enum GNUNET_OS_ProcessStatusType st;
  unsigned long code;
 
  cfg = c;
 
  if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_NONE,
                                 NULL, NULL, &st, &code,
                                 "gnunet-arm",
                                 "gnunet-arm", "-I", NULL))
  {
    if (7 == ret)
      fprintf (stderr,
               "GNUnet is not running, please start GNUnet before running import\n");
    return;
  }
 
  if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                 NULL, NULL, &st, &code,
                                 "gnunet-identity",
                                 "gnunet-identity", "-C", "master-zone", NULL))
    return;
 
  if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                 NULL, NULL, &st, &code,
                                 "gnunet-identity",
                                 "gnunet-identity", "-C", "private-zone", NULL))
    return;
 
  if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                 NULL, NULL, &st, &code,
                                 "gnunet-identity",
                                 "gnunet-identity", "-C", "sks-zone", NULL))
    return;
 
  if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                 NULL, NULL, &st, &code,
                                 "gnunet-identity",
                                 "gnunet-identity", "-e", "master-zone", "-s",
                                 "gns-master", NULL))
    return;
 
  if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                 NULL, NULL, &st, &code,
                                 "gnunet-identity",
                                 "gnunet-identity", "-e", "master-zone", "-s",
                                 "namestore", NULL))
    return;
 
  if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                 NULL, NULL, &st, &code,
                                 "gnunet-identity",
                                 "gnunet-identity", "-e", "master-zone", "-s",
                                 "gns-proxy", NULL))
    return;
 
  if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                 NULL, NULL, &st, &code,
                                 "gnunet-identity",
                                 "gnunet-identity", "-e", "master-zone", "-s",
                                 "gns-intercept", NULL))
    return;
 
  if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                 NULL, NULL, &st, &code,
                                 "gnunet-identity",
                                 "gnunet-identity", "-e", "private-zone", "-s",
                                 "gns-private", NULL))
    return;
 
  if (0 != run_process_and_wait (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                 NULL, NULL, &st, &code,
                                 "gnunet-identity",
                                 "gnunet-identity", "-e", "sks-zone", "-s",
                                 "fs-sks", NULL))
    return;
 
  ns = GNUNET_NAMESTORE_connect (cfg);
  sh = GNUNET_IDENTITY_connect (cfg, &get_ego, NULL);
  GNUNET_SCHEDULER_add_shutdown (&shutdown_task, NULL);
}

References cfg, get_ego(), GNUNET_IDENTITY_connect(), GNUNET_NAMESTORE_connect(), GNUNET_OS_INHERIT_STD_NONE, GNUNET_OS_INHERIT_STD_OUT_AND_ERR, GNUNET_SCHEDULER_add_shutdown(), ns, ret, run_process_and_wait(), sh, shutdown_task(), and st.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ main()

int main	(	int	argc,
		char const	argv
	)

The main function for gnunet-gns.

Parameters

argc	number of arguments from the command line
argv	command line arguments

Returns: 0 ok, 1 on error

Definition at line 476 of file gnunet-gns-import.c.

{
  static const struct GNUNET_GETOPT_CommandLineOption options[] = {
    GNUNET_GETOPT_OPTION_END
  };
  int r;
 
  if (GNUNET_OK != GNUNET_STRINGS_get_utf8_args (argc, argv, &argc, &argv))
    return 2;
 
  GNUNET_log_setup ("gnunet-gns-import", "WARNING", NULL);
  ret = 0;
  r = GNUNET_PROGRAM_run (argc, argv, "gnunet-gns-import",
                          _ (
                            "This program will import some GNS authorities into your GNS namestore."),
                          options,
                          &run, NULL);
  GNUNET_free_nz ((void *) argv);
  return GNUNET_OK == r ? ret : 1;
}