merchant

commit 51a18d564fdd823be141db77b4e80de506eb5348
parent 8a399a783e27162be096aa3b1e0a4d2c44db0e63
Author: Marcello Stanisci <marcello.stanisci@inria.fr>
Date:   Thu,  8 Dec 2016 17:50:58 +0100

Baking hashes to contracts mapping

Diffstat:
M
src/backenddb/plugin_merchantdb_postgres.c
 | 
56
++++++++++++++++++++++++++++++++++++++++++++++++++++++++
M
src/include/taler_merchantdb_plugin.h
 | 
14
++++++++++++++

2 files changed, 70 insertions(+), 0 deletions(-)
diff --git a/src/backenddb/plugin_merchantdb_postgres.c b/src/backenddb/plugin_merchantdb_postgres.c
@@ -154,6 +154,13 @@ postgres_initialize (void *cls)
 
   /* Setup tables */
   PG_EXEC (pg,
+           "CREATE TABLE IF NOT EXISTS merchant_contract_maps ("
+           ",h_contract BYTEA NOT NULL CHECK (LENGTH(h_contract)=64)"
+           ",plain_contract BYTEA NOT NULL"
+	   ",PRIMARY KEY (h_contract)"
+           ");");
+
+  PG_EXEC (pg,
            "CREATE TABLE IF NOT EXISTS merchant_transactions ("
            " transaction_id INT8"
            ",exchange_uri VARCHAR NOT NULL"
@@ -262,6 +269,15 @@ postgres_initialize (void *cls)
               5);
 
   PG_PREPARE (pg,
+              "insert_map",
+              "INSERT INTO merchant_contract_maps"
+              "(h_contract"
+              ",plain_contract)"
+              " VALUES "
+              "($1, $2)",
+              2);
+
+  PG_PREPARE (pg,
               "find_transactions_by_date",
               "SELECT"
               " transaction_id"
@@ -367,6 +383,45 @@ postgres_initialize (void *cls)
 
 
 /**
+ * Insert a hash to contract map into the database
+ *
+ * @param cls closure
+ * @param h_contract hashcode of @a contract
+ * @param contract contract to store
+ * @return #GNUNET_OK on success, #GNUNET_SYSERR upon error
+ */
+static int
+postgres_store_map (void *cls,
+                    struct GNUNET_HashCode *h_contract,
+                    const json_t *contract)
+{
+  struct PostgresClosure *pg = cls;
+  PGresult *result;
+  int ret;
+
+  struct GNUNET_PQ_QueryParam params[] = {
+    GNUNET_PQ_query_param_auto_from_type (h_contract),
+    TALER_PQ_query_param_json (contract),
+    GNUNET_PQ_query_param_end
+  };
+
+  result = GNUNET_PQ_exec_prepared (pg->conn,
+                                    "insert_map",
+                                    params);
+  if (PGRES_COMMAND_OK != PQresultStatus (result))
+  {
+    ret = GNUNET_SYSERR;
+    BREAK_DB_ERR (result);
+  }
+  else
+  {
+    ret = GNUNET_OK;
+  }
+  PQclear (result);
+  return ret;
+}
+
+/**
  * Insert transaction data into the database.
  *
  * @param cls closure
@@ -1229,6 +1284,7 @@ libtaler_plugin_merchantdb_postgres_init (void *cls)
   plugin->find_transfers_by_id = &postgres_find_transfers_by_id;
   plugin->find_deposits_by_wtid = &postgres_find_deposits_by_wtid;
   plugin->find_proof_by_wtid = &postgres_find_proof_by_wtid;
+  plugin->store_map = &postgres_store_map;
 
   return plugin;
 }
diff --git a/src/include/taler_merchantdb_plugin.h b/src/include/taler_merchantdb_plugin.h
@@ -150,6 +150,20 @@ struct TALER_MERCHANTDB_Plugin
 
 
   /**
+   * Insert a hash to contract map into the database
+   *
+   * @param cls closure
+   * @param h_contract hashcode of @a contract
+   * @param contract contract to store
+   * @return #GNUNET_OK on success, #GNUNET_SYSERR upon error
+   */
+  int
+  (*store_map) (void *cls,
+               struct GNUNET_HashCode *h_contract,
+               const json_t *contract);
+
+
+  /**
    * Insert transaction data into the database.
    *
    * @param cls closure