keep track of where money exiting the system came from

part of #59
liberapay · Mar 5, 2016 · fd4a3b0 · fd4a3b0
1 parent 034de67
commit fd4a3b0
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/liberapay/billing/exchanges.py b/liberapay/billing/exchanges.py
@@ -284,12 +284,22 @@ def propagate_exchange(cursor, participant, exchange, route, error, amount):
             raise NotEnoughWithdrawableMoney(Money(withdrawable, 'EUR'))
         for b in bundles:
             if x >= b.amount:
+                cursor.run("""
+                    INSERT INTO e2e_transfers
+                                (origin, withdrawal, amount)
+                         VALUES (%s, %s, %s)
+                """, (b.origin, exchange.id, b.amount))
                 cursor.run("DELETE FROM cash_bundles WHERE id = %s", (b.id,))
                 x -= b.amount
                 if x == 0:
                     break
             else:
                 assert x > 0
+                cursor.run("""
+                    INSERT INTO e2e_transfers
+                                (origin, withdrawal, amount)
+                         VALUES (%s, %s, %s)
+                """, (b.origin, exchange.id, x))
                 cursor.run("""
                     UPDATE cash_bundles
                        SET amount = (amount - %s)

diff --git a/sql/branch.sql b/sql/branch.sql
@@ -0,0 +1,6 @@
+CREATE TABLE e2e_transfers
+( id           bigserial      PRIMARY KEY
+, origin       bigint         NOT NULL REFERENCES exchanges
+, withdrawal   bigint         NOT NULL REFERENCES exchanges
+, amount       numeric(35,2)  NOT NULL CHECK (amount > 0)
+);