-fix SQL

src/exchangedb/0003-aml_history.sql

@@ -32,8 +32,8 @@ BEGIN
       ',new_status INT4 NOT NULL DEFAULT(0)'
       ',decision_time INT8 NOT NULL DEFAULT(0)'
       ',justification VARCHAR NOT NULL'
-      ',decider_pub BYTEA PRIMARY KEY CHECK (LENGTH(decider_pub)=32)'
+      ',decider_pub BYTEA CHECK (LENGTH(decider_pub)=32)'
-      ',decider_sig BYTEA PRIMARY KEY CHECK (LENGTH(decider_sig)=64)'
+      ',decider_sig BYTEA CHECK (LENGTH(decider_sig)=64)'
     ') %s ;'
     ,table_name
     ,'PARTITION BY HASH (h_payto)'

src/exchangedb/0003-aml_staff.sql

@@ -18,7 +18,7 @@
 CREATE TABLE aml_staff
   (aml_staff_uuid BIGINT GENERATED BY DEFAULT AS IDENTITY UNIQUE
   ,decider_pub BYTEA PRIMARY KEY CHECK (LENGTH(decider_pub)=32)
-  ,master_sig BYTEA PRIMARY KEY CHECK (LENGTH(master_sig)=64)
+  ,master_sig BYTEA CHECK (LENGTH(master_sig)=64)
   ,decider_name VARCHAR NOT NULL
   ,is_active BOOLEAN NOT NULL
   ,last_change INT8 NOT NULL

src/exchangedb/0003-purse_deletion.sql

@@ -51,7 +51,7 @@ COMMENT ON FUNCTION create_table_purse_deletion
 
 
 CREATE OR REPLACE FUNCTION constrain_table_purse_deletion(
-  IN partition_suffix VARCHAR
+  IN partition_suffix VARCHAR DEFAULT NULL
 )
 RETURNS void
 LANGUAGE plpgsql
@@ -68,8 +68,7 @@ BEGIN
 END $$;
 
 
-CREATE OR REPLACE FUNCTION create_table_purse_requests_was_deleted (
+CREATE OR REPLACE FUNCTION master_table_purse_requests_was_deleted (
-  IN partition_suffix VARCHAR
 )
 RETURNS void
 LANGUAGE plpgsql
@@ -77,18 +76,13 @@ AS $$
 DECLARE
   table_name VARCHAR DEFAULT 'purse_requests';
 BEGIN
-  table_name = concat_ws('_', table_name, partition_suffix);
   EXECUTE FORMAT (
-    'ALTER TABLE ' || table_name ||
+    'ALTER TABLE exchange.' || table_name ||
     ' ADD COLUMN'
     ' was_deleted BOOLEAN NOT NULL DEFAULT(FALSE)'
   );
-  PERFORM comment_partitioned_column(
+  COMMENT ON COLUMN purse_requests.was_deleted
-     'TRUE if the purse was explicitly deleted (purse must have an entry in the purse_deletion table)'
+    IS 'TRUE if the purse was explicitly deleted (purse must have an entry in the purse_deletion table)';
-    ,'was_deleted'
-    ,table_name
-    ,partition_suffix
-  );
 END $$;
 
 
@@ -111,6 +105,6 @@ INSERT INTO exchange_tables
     ,FALSE),
     ('purse_requests_was_deleted'
     ,'exchange-0003'
-    ,'create'
+    ,'master'
     ,TRUE
     ,FALSE);

src/exchangedb/Makefile.am

@@ -27,6 +27,7 @@ sql_DATA = \
   versioning.sql \
   exchange-0001.sql \
   exchange-0002.sql \
+  exchange-0003.sql \
   drop.sql \
   procedures.sql
 

src/exchangedb/drop.sql

@@ -20,6 +20,7 @@ BEGIN;
 
 SELECT _v.unregister_patch('exchange-0001');
 SELECT _v.unregister_patch('exchange-0002');
+SELECT _v.unregister_patch('exchange-0003');
 
 DROP SCHEMA exchange CASCADE;
 

src/exchangedb/exchange_do_purse_deposit.sql

@@ -83,6 +83,19 @@ THEN
 END IF;
 
 
+-- Check if purse was deleted, if so, abort and prevent deposit.
+PERFORM
+  FROM exchange.purse_deletion
+  WHERE purse_pub = in_purse_pub;
+IF FOUND
+THEN
+  out_late=TRUE;
+  out_balance_ok=FALSE;
+  out_conflict=FALSE;
+  RETURN;
+END IF;
+
+
 -- Debit the coin
 -- Check and update balance of the coin.
 UPDATE known_coins

src/lib/exchange_api_handle.c

@@ -1276,7 +1276,7 @@ TALER_EXCHANGE_check_keys_current (struct TALER_EXCHANGE_Handle *exchange,
   {
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "Forcing re-download of all exchange keys\n");
-    GNUNET_break (GNUNET_YES == force_download);
+    GNUNET_break (force_download);
     exchange->state = MHS_INIT;
   }
   if ( (! force_download) &&