MigrationTest.kt (11080B)
1 /* 2 * This file is part of LibEuFin. 3 * Copyright (C) 2024-2025 Taler Systems S.A. 4 5 * LibEuFin is free software; you can redistribute it and/or modify 6 * it under the terms of the GNU Affero General Public License as 7 * published by the Free Software Foundation; either version 3, or 8 * (at your option) any later version. 9 10 * LibEuFin is distributed in the hope that it will be useful, but 11 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY 12 * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General 13 * Public License for more details. 14 15 * You should have received a copy of the GNU Affero General Public 16 * License along with LibEuFin; see the file COPYING. If not, see 17 * <http://www.gnu.org/licenses/> 18 */ 19 20 import kotlinx.coroutines.runBlocking 21 import org.junit.Test 22 import tech.libeufin.common.db.* 23 import kotlin.io.path.Path 24 import kotlin.io.path.readText 25 import java.util.UUID 26 import kotlin.test.assertTrue 27 28 class MigrationTest { 29 @Test 30 fun test() = runBlocking { 31 val conn = pgDataSource("postgres:///libeufincheck").pgConnection() 32 33 // Drop current schemas 34 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-drop.sql").readText()) 35 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-drop.sql").readText()) 36 37 // libeufin-bank-0001 38 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0001.sql").readText()) 39 conn.execSQLUpdate(""" 40 INSERT INTO customers (login, password_hash) VALUES 41 ('account_1', 'fack_hash'), 42 ('account_2', 'fack_hash'), 43 ('account_3', 'fack_hash'), 44 ('account_4', 'fack_hash'); 45 INSERT INTO bank_accounts (internal_payto_uri, owning_customer_id) VALUES 46 ('payto_1', 1), 47 ('payto_2', 2), 48 ('payto_3', 3), 49 ('payto_4', 4); 50 INSERT INTO bank_account_transactions(creditor_payto_uri, creditor_name, debtor_payto_uri, debtor_name, subject, amount, transaction_date, direction, bank_account_id) VALUES 51 ('payto_1', 'account_1', 'payto_2', 'account_2', 'subject', (0, 0)::taler_amount, 42, 'credit'::direction_enum, 1), 52 ('payto_1', 'account_1', 'payto_2', 'account_2', 'subject', (0, 0)::taler_amount, 42, 'credit'::direction_enum, 1), 53 ('payto_1', 'account_1', 'payto_2', 'account_2', 'subject', (0, 0)::taler_amount, 42, 'credit'::direction_enum, 1); 54 INSERT INTO taler_exchange_incoming(reserve_pub, bank_transaction) VALUES 55 ('\x6ca1ab1a76a484d7424064c51c49c1947405f42f7d185d052dbf6718d845ec6b'::bytea, 1), 56 ('\xa605637a4852684e4957e6177f41311eacf8661a6a74b90178c487fe347b9918'::bytea, 2); 57 INSERT INTO challenges(code, creation_date, expiration_date, retry_counter) VALUES 58 ('secret_code', 42, 42, 42), 59 ('secret_code', 42, 42, 42); 60 INSERT INTO cashout_operations(request_uid, amount_debit, amount_credit, subject, creation_time, bank_account, challenge, local_transaction) VALUES 61 ('\x6ca1ab1a76a484d7424064c51c49c1947405f42f7d185d052dbf6718d845ec6b'::bytea, (0, 0)::taler_amount, (0, 0)::taler_amount, 'subject', 42, 1, 1, 1), 62 ('\xa605637a4852684e4957e6177f41311eacf8661a6a74b90178c487fe347b9918'::bytea, (0, 0)::taler_amount, (0, 0)::taler_amount, 'subject', 42, 1, 2, NULL); 63 INSERT INTO taler_withdrawal_operations(withdrawal_uuid, amount, reserve_pub, wallet_bank_account) VALUES 64 (gen_random_uuid(), (0, 0)::taler_amount, '\x6ca1ab1a76a484d7424064c51c49c1947405f42f7d185d052dbf6718d845ec6b'::bytea, 1), 65 (gen_random_uuid(), (0, 0)::taler_amount, '\xa605637a4852684e4957e6177f41311eacf8661a6a74b90178c487fe347b9918'::bytea, 2); 66 """) 67 68 // libeufin-bank-0002 69 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0002.sql").readText()) 70 71 // libeufin-bank-0003 72 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0003.sql").readText()) 73 74 // libeufin-bank-0004 75 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0004.sql").readText()) 76 77 conn.execSQLUpdate(""" 78 UPDATE bank_accounts SET min_cashout=(0, 1) WHERE bank_account_id=2; 79 UPDATE bank_accounts SET min_cashout=(2, 300) WHERE bank_account_id IN (3, 4); 80 """) 81 82 // libeufin-bank-0005 83 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0005.sql").readText()) 84 85 // libeufin-bank-0006 86 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0006.sql").readText()) 87 88 // libeufin-bank-0007 89 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0007.sql").readText()) 90 91 // libeufin-bank-0008 92 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0008.sql").readText()) 93 94 // libeufin-bank-0009 95 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0009.sql").readText()) 96 97 // libeufin-bank-0010 98 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0010.sql").readText()) 99 100 // libeufin-bank-0011 101 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0011.sql").readText()) 102 103 // libeufin-bank-0012 104 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0012.sql").readText()) 105 106 conn.execSQLUpdate(""" 107 INSERT INTO config(key, value) VALUES 108 ('cashin_ratio', '{"val": 1, "frac": 2}'::jsonb), 109 ('cashin_fee', '{"val": 3, "frac": 4}'::jsonb), 110 ('cashin_tiny_amount', '{"val": 5, "frac": 6}'::jsonb), 111 ('cashin_min_amount', '{"val": 7, "frac": 8}'::jsonb), 112 ('cashin_rounding_mode', '{"mode": "zero"}'::jsonb), 113 ('cashout_ratio', '{"val": 9, "frac": 10}'::jsonb), 114 ('cashout_fee', '{"val": 11, "frac": 12}'::jsonb), 115 ('cashout_tiny_amount', '{"val": 13, "frac": 14}'::jsonb), 116 ('cashout_min_amount', '{"val": 15, "frac": 16}'::jsonb), 117 ('cashout_rounding_mode', '{"mode": "nearest"}'::jsonb); 118 """) 119 120 // libeufin-bank-0013 121 conn.execSQLUpdate(Path("../database-versioning/libeufin-bank-0013.sql").readText()) 122 conn.withStatement( 123 """ 124 SELECT value='{ 125 "cashin": { 126 "fee": { 127 "val": 3, 128 "frac": 4 129 }, 130 "ratio": { 131 "val": 1, 132 "frac": 2 133 }, 134 "min_amount": { 135 "val": 7, 136 "frac": 8 137 }, 138 "tiny_amount": { 139 "val": 5, 140 "frac": 6 141 }, 142 "rounding_mode": "zero" 143 }, 144 "cashout": { 145 "fee": { 146 "val": 11, 147 "frac": 12 148 }, 149 "ratio": { 150 "val": 9, 151 "frac": 10 152 }, 153 "min_amount": { 154 "val": 15, 155 "frac": 16 156 }, 157 "tiny_amount": { 158 "val": 13, 159 "frac": 14 160 }, 161 "rounding_mode": "nearest" 162 } 163 }'::jsonb FROM libeufin_bank.config WHERE key='conversion_rate' 164 """ 165 ) { 166 one { 167 assertTrue(it.getBoolean(1)) 168 } 169 } 170 171 // libeufin-nexus-0001 172 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0001.sql").readText()) 173 conn.execSQLUpdate(""" 174 INSERT INTO outgoing_transactions(amount, execution_time, message_id) VALUES 175 ((0, 0)::taler_amount, 42, 'id'); 176 INSERT INTO initiated_outgoing_transactions(amount, wire_transfer_subject, initiation_time, credit_payto_uri, outgoing_transaction_id, request_uid) VALUES 177 ((0, 0)::taler_amount, 'subject', 42, 'payto_0', 1, 'request_uid'); 178 """) 179 180 // libeufin-nexus-0002 181 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0002.sql").readText()) 182 183 // libeufin-nexus-0003 184 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0003.sql").readText()) 185 186 // libeufin-nexus-0004 187 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0004.sql").readText()) 188 189 // libeufin-nexus-0005 190 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0005.sql").readText()) 191 192 // libeufin-nexus-0006 193 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0006.sql").readText()) 194 195 conn.execSQLUpdate(""" 196 INSERT INTO initiated_outgoing_transactions(amount, wire_transfer_subject, initiation_time, credit_payto_uri, outgoing_transaction_id, request_uid, order_id) VALUES 197 ((42, 0)::taler_amount, 'subject', 0, 'credit_payto', NULL, 'TX0', 'ORDER0'), 198 ((41, 0)::taler_amount, 'subject', 0, 'credit_payto', NULL, 'TX1', NULL); 199 """) 200 201 // libeufin-nexus-0007 202 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0007.sql").readText()) 203 204 // libeufin-nexus-0008 205 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0008.sql").readText()) 206 207 // libeufin-nexus-0009 208 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0009.sql").readText()) 209 210 conn.execSQLUpdate(""" 211 INSERT INTO incoming_transactions(amount, subject, execution_time, debit_payto, bank_id) VALUES 212 ((1, 0)::taler_amount, 'simple', 42, 'debit_payto', 'first'), 213 ((2, 0)::taler_amount, 'reserve', 42, 'debit_payto', 'second'), 214 ((3, 0)::taler_amount, 'kyc', 42, 'debit_payto', 'third'), 215 ((4, 0)::taler_amount, 'simple', 42, 'debit_payto', '${UUID.randomUUID()}'), 216 ((5, 0)::taler_amount, 'reserve', 42, 'debit_payto', '${UUID.randomUUID()}'), 217 ((6, 0)::taler_amount, 'kyc', 42, 'debit_payto', '${UUID.randomUUID()}');; 218 INSERT INTO talerable_incoming_transactions(incoming_transaction_id, type, reserve_public_key, account_pub) VALUES 219 (2, 'reserve', '\x6ca1ab1a76a484d7424064c51c49c1947405f42f7d185d052dbf6718d845ec6b'::bytea, null), 220 (3, 'kyc', null, '\x6ca1ab1a76a484d7424064c51c49c1947405f42f7d185d052dbf6718d845ec6b'::bytea); 221 """) 222 223 // libeufin-nexus-0010 224 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0010.sql").readText()) 225 226 // libeufin-nexus-0011 227 conn.execSQLUpdate(Path("../database-versioning/libeufin-nexus-0011.sql").readText()) 228 } 229 }