depolymerization

depolymerizer-bitcoin-procedures.sql (5783B)

---

 --
 -- This file is part of TALER
 -- Copyright (C) 2025 Taler Systems SA
 --
 -- TALER is free software; you can redistribute it and/or modify it under the
 -- terms of the GNU General Public License as published by the Free Software
 -- Foundation; either version 3, or (at your option) any later version.
 --
 -- TALER is distributed in the hope that it will be useful, but WITHOUT ANY
 -- WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
 -- A PARTICULAR PURPOSE.  See the GNU General Public License for more details.
 --
 -- You should have received a copy of the GNU General Public License along with
 -- TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
 
 SET search_path TO depolymerizer_bitcoin;
 
 -- Remove all existing functions
 DO
 $do$
 DECLARE
   _sql text;
 BEGIN
   SELECT INTO _sql
         string_agg(format('DROP %s %s CASCADE;'
                         , CASE prokind
                             WHEN 'f' THEN 'FUNCTION'
                             WHEN 'p' THEN 'PROCEDURE'
                           END
                         , oid::regprocedure)
                   , E'\n')
   FROM   pg_proc
   WHERE  pronamespace = 'depolymerizer_bitcoin'::regnamespace;
 
   IF _sql IS NOT NULL THEN
     EXECUTE _sql;
   END IF;
 END
 $do$;
 
 CREATE FUNCTION taler_transfer(
   IN in_amount taler_amount,
   IN in_exchange_base_url TEXT,
   IN in_credit_acc TEXT,
   IN in_credit_name TEXT,
   IN in_request_uid BYTEA,
   IN in_wtid BYTEA,
   IN in_now INT8,
   -- Error status
   OUT out_request_uid_reuse BOOLEAN,
   OUT out_wtid_reuse BOOLEAN,
   -- Success return
   OUT out_transfer_row_id INT8,
   OUT out_created_at INT8
 )
 LANGUAGE plpgsql AS $$
 BEGIN
 -- Check for idempotence and conflict
 SELECT (amount != in_amount
           OR credit_acc != in_credit_acc
           OR credit_name != in_credit_name
           OR exchange_url != in_exchange_base_url
           OR wtid != in_wtid)
         ,id, created
   INTO out_request_uid_reuse, out_transfer_row_id, out_created_at
   FROM tx_out
   WHERE request_uid = in_request_uid;
 IF FOUND THEN
   out_wtid_reuse=FALSE;
   RETURN;
 END IF;
 out_request_uid_reuse=FALSE;
 
 -- Register exchange
 INSERT INTO tx_out (
   amount,
   exchange_url,
   credit_acc,
   credit_name,
   request_uid,
   wtid,
   created,
   status
 ) VALUES (
   in_amount,
   in_exchange_base_url,
   in_credit_acc,
   in_credit_name,
   in_request_uid,
   in_wtid,
   in_now,
   'requested'
 ) ON CONFLICT (wtid) DO NOTHING
   RETURNING id, created INTO out_transfer_row_id, out_created_at;
 out_wtid_reuse=NOT FOUND;
 IF out_wtid_reuse THEN
   RETURN;
 END IF;
 -- Notify new transaction
 PERFORM pg_notify('taler_out', out_transfer_row_id || '');
 END $$;
 COMMENT ON FUNCTION taler_transfer IS 'Create an outgoing taler transaction and register it';
 
 CREATE FUNCTION register_tx_in(
   IN in_amount taler_amount,
   IN in_debit_acc TEXT,
   IN in_reserve_pub BYTEA,
   IN in_received INT8,
   IN in_txid BYTEA,
   -- Error status
   OUT out_reserve_pub_reuse BOOLEAN,
   -- Success return
   OUT out_tx_row_id INT8,
   OUT out_valued_at INT8,
   OUT out_new BOOLEAN
 )
 LANGUAGE plpgsql AS $$
 BEGIN
 -- Check for idempotence and conflict
 SELECT (amount != in_amount OR debit_acc != in_debit_acc OR txid != in_txid), id, received
   INTO out_reserve_pub_reuse, out_tx_row_id, out_valued_at
   FROM tx_in
   WHERE reserve_pub = in_reserve_pub;
 out_new=NOT FOUND;
 IF FOUND THEN
   RETURN;
 END IF;
 out_reserve_pub_reuse=false;
 
 -- Insert new incoming transaction
 INSERT INTO tx_in (
   txid,
   amount,
   debit_acc,
   reserve_pub,
   received
 ) VALUES (
   in_txid,
   in_amount,
   in_debit_acc,
   in_reserve_pub,
   in_received
 ) RETURNING id, received INTO out_tx_row_id, out_valued_at;
 PERFORM pg_notify('taler_in', out_tx_row_id || '');
 END $$;
 COMMENT ON FUNCTION register_tx_in IS 'Register an incoming transaction idempotently';
 
 CREATE FUNCTION sync_out(
   IN in_txid BYTEA,
   IN in_replace_txid BYTEA,
   IN in_amount taler_amount,
   IN in_exchange_base_url TEXT,
   IN in_credit_acc TEXT,
   IN in_wtid BYTEA,
   IN in_created INT8,
   -- Success return
   OUT out_new BOOLEAN,
   OUT out_replaced BOOLEAN,
   OUT out_recovered BOOLEAN
 )
 LANGUAGE plpgsql AS $$
 DECLARE
   local_id INT8;
 BEGIN
 -- Check replacement
 IF in_replace_txid IS NOT NULL THEN
   UPDATE tx_out SET txid=in_txid, status='status' WHERE txid=in_replace_txid;
   IF FOUND THEN
     out_new=FALSE;
     out_replaced=FALSE;
     out_recovered=FALSE;
     RETURN;
   END IF;
 END IF;
 out_replaced=FALSE;
 out_new=NOT EXISTS(SELECT FROM tx_out WHERE wtid = in_wtid);
 
 IF out_new THEN
   INSERT INTO tx_out (
     amount,
     wtid,
     credit_acc,
     exchange_url,
     status,
     txid,
     created,
     request_uid
   ) VALUES (
     in_amount,
     in_wtid,
     in_credit_acc,
     in_exchange_base_url,
     'sent',
     in_txid,
     in_created,
     NULL
   ) RETURNING id INTO local_id;
   out_recovered=FALSE;
   PERFORM pg_notify('taler_out', local_id || '');
 ELSE 
   UPDATE tx_out SET txid=in_txid, status='sent' WHERE status='requested' AND wtid=in_wtid;
   out_recovered=FOUND;
 END IF;
 END $$;
 COMMENT ON FUNCTION sync_out IS 'Sync a debit blockchain state with local state';
 
 CREATE FUNCTION sync_bounce(
   IN in_txid BYTEA,
   IN in_bounced BYTEA,
   IN in_created INT8,
   -- Success return
   OUT out_new BOOLEAN,
   OUT out_recovered BOOLEAN
 )
 LANGUAGE plpgsql AS $$
 BEGIN
 out_new=NOT EXISTS(SELECT FROM bounce WHERE bounced = in_bounced);
 
 IF out_new THEN
   INSERT INTO bounce (
     created,
     bounced,
     txid,
     status
   ) VALUES (
     in_created,
     in_bounced,
     in_txid,
     'sent'
   );
   out_recovered=false;
 ELSE 
   UPDATE bounce SET txid=in_txid, status='sent' WHERE status!='sent' AND bounced=in_bounced;
   out_recovered=FOUND;
 END IF;
 END $$;
 COMMENT ON FUNCTION sync_bounce IS 'Sync a bounce blockchain state with local state';