-work on DB plugin logic for taler-merchant-exchange

1 files changed, 45 insertions, 0 deletions

diff --git a/src/include/taler_merchantdb_plugin.h b/src/include/taler_merchantdb_plugin.h
index f0ae6589..62dcf5e7 100644
--- a/src/include/taler_merchantdb_plugin.h
+++ b/src/include/taler_merchantdb_plugin.h
@@ -712,6 +712,32 @@ typedef void
 
 
 /**
+ * Function called with information about wire transfers
+ * that taler-merchant-exchange still needs to process.
+ *
+ * @param cls closure
+ * @param rowid row of the transfer in the merchant database
+ * @param instance_id instance that received the transfer
+ * @param exchange_url base URL of the exchange that initiated the transfer
+ * @param payto_uri account of the merchant that received the transfer
+ * @param wtid wire transfer subject identifying the aggregation
+ * @param execution_time when did the merchant observe the transfer
+ * @param total total amount that was wired
+ * @param next_attempt when should we next try to interact with the exchange
+ */
+typedef void
+(*TALER_MERCHANTDB_OpenTransferCallback)(
+  void *cls,
+  uint64_t rowid,
+  const char *instance_id,
+  const char *exchange_url,
+  const char *payto_uri,
+  const struct TALER_WireTransferIdentifierRawP *wtid,
+  const struct TALER_Amount *total,
+  struct GNUNET_TIME_Absolute next_attempt);
+
+
+/**
  * Function called with detailed information about a wire transfer and
  * the underlying deposits that are being aggregated.
  *
@@ -1927,6 +1953,25 @@ struct TALER_MERCHANTDB_Plugin
 
 
   /**
+   * Retrieve wire transfer details of wire details
+   * that taler-merchant-exchange still needs to
+   * investigate.
+   *
+   * @param cls closure
+   * @param limit maximum number of results to return
+   * @param cb function called with the wire transfer data
+   * @param cb_cls closure for @a cb
+   * @return transaction status
+   */
+  enum GNUNET_DB_QueryStatus
+  (*select_open_transfers)(
+    void *cls,
+    uint64_t limit,
+    TALER_MERCHANTDB_OpenTransferCallback cb,
+    void *cb_cls);
+
+
+  /**
    * Insert wire transfer details for a deposit.
    *
    * @param cls closure