feature/1093 Alter DB Schema for Settlements (#501)

* Added migrations and seeds * WIP * Remove unused code (#504) * Remove unused code * Update dependencies * Maintenance update (#505) - Upgraded Event-SDK - Version bump * Upgraded central-services-stream for #1114KafkaErrorLocalQueuefull fix (#511) * package.json and package-lock * Changes following peer review * Added settlementWindowContent.settlementId Co-authored-by: Steven Oderayi <oderayi@gmail.com> Co-authored-by: Miguel de Barros <miguel@debarros.me>
mojaloop · Jan 6, 2020 · 2e21103 · 2e21103
1 parent 76bc1f5
commit 2e21103
Show file tree

Hide file tree

Showing 166 changed files with 2,505 additions and 1,201 deletions.
diff --git a/.env b/.env
@@ -1,9 +1,6 @@
-POSTGRES_USER=central_ledger
-POSTGRES_PASSWORD=cVq8iFqaLuHy8jjKuA
-SIDE_SERVICE=central-ledger
-SIDE_POSTGRES_USER=sidecar
-SIDE_POSTGRES_PASSWORD=6dauAWcoeJuyRTFXH9
-DB_HOST=postgres
-DB_PORT=5432
-DB_USER=kms
-DB_PASSWORD=kms
+DB_USER=central_ledger
+DB_PASS=password
+DB_NAME=central_ledger
+DB_HOST=localhost
+DB_PORT=3306
+CLEDG_DATABASE_URI=mysql://$DB_USER:$DB_PASS@$DB_HOST:$DB_PORT/$DB_NAME
diff --git a/migrations/100100_event.js b/migrations/100100_event.js
@@ -18,13 +18,14 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = async (knex, Promise) => {
+exports.up = async (knex) => {
   return await knex.schema.hasTable('event').then(function(exists) {
     if (!exists) {
       return knex.schema.createTable('event', (t) => {
@@ -37,6 +38,6 @@ exports.up = async (knex, Promise) => {
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.dropTableIfExists('event')
 }
diff --git a/migrations/110100_contactType.js b/migrations/110100_contactType.js
@@ -18,13 +18,14 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = async (knex, Promise) => {
+exports.up = async (knex) => {
   return await knex.schema.hasTable('contactType').then(function(exists) {
     if (!exists) {
       return knex.schema.createTable('contactType', (t) => {
@@ -38,6 +39,6 @@ exports.up = async (knex, Promise) => {
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.dropTableIfExists('contactType')
 }
diff --git a/migrations/110101_contactType-indexes.js b/migrations/110101_contactType-indexes.js
@@ -18,19 +18,20 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = function (knex, Promise) {
+exports.up = function (knex) {
   return knex.schema.table('contactType', (t) => {
     t.unique('name')
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.table('contactType', (t) => {
     t.dropUnique('name')
   })

diff --git a/migrations/110200_currency.js b/migrations/110200_currency.js
@@ -18,13 +18,14 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = async (knex, Promise) => {
+exports.up = async (knex) => {
   return await knex.schema.hasTable('currency').then(function(exists) {
     if (!exists) {
       return knex.schema.createTable('currency', (t) => {
@@ -37,6 +38,6 @@ exports.up = async (knex, Promise) => {
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.dropTableIfExists('currency')
 }
diff --git a/migrations/110201_currency-scale.js b/migrations/110201_currency-scale.js
@@ -18,13 +18,14 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = async (knex, Promise) => {
+exports.up = async (knex) => {
   return await knex.schema.hasTable('currency').then(function(exists) {
     if (exists) {
       return knex.schema.alterTable('currency', (t) => {
@@ -34,6 +35,6 @@ exports.up = async (knex, Promise) => {
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.dropTableIfExists('currency')
 }
diff --git a/migrations/110300_endpointType.js b/migrations/110300_endpointType.js
@@ -18,13 +18,14 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = async (knex, Promise) => {
+exports.up = async (knex) => {
   return await knex.schema.hasTable('endpointType').then(function(exists) {
     if (!exists) {
       return knex.schema.createTable('endpointType', (t) => {
@@ -38,6 +39,6 @@ exports.up = async (knex, Promise) => {
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.dropTableIfExists('endpointType')
 }
diff --git a/migrations/110301_endpointType-indexes.js b/migrations/110301_endpointType-indexes.js
@@ -18,19 +18,20 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = function (knex, Promise) {
+exports.up = function (knex) {
   return knex.schema.table('endpointType', (t) => {
     t.unique('name')
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.table('endpointType', (t) => {
     t.dropUnique('name')
   })

diff --git a/migrations/110400_ledgerEntryType.js b/migrations/110400_ledgerEntryType.js
@@ -18,13 +18,14 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = async (knex, Promise) => {
+exports.up = async (knex) => {
   return await knex.schema.hasTable('ledgerEntryType').then(function(exists) {
     if (!exists) {
       return knex.schema.createTable('ledgerEntryType', (t) => {
@@ -38,6 +39,6 @@ exports.up = async (knex, Promise) => {
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.dropTableIfExists('ledgerEntryType')
 }
diff --git a/migrations/110401_ledgerEntryType-indexes.js b/migrations/110401_ledgerEntryType-indexes.js
@@ -18,19 +18,20 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = function (knex, Promise) {
+exports.up = function (knex) {
   return knex.schema.table('ledgerEntryType', (t) => {
     t.unique('name')
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.table('ledgerEntryType', (t) => {
     t.dropUnique('name')
   })

diff --git a/migrations/110450_ledgerAccountType.js b/migrations/110450_ledgerAccountType.js
@@ -18,13 +18,14 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = async (knex, Promise) => {
+exports.up = async (knex) => {
   return await knex.schema.hasTable('ledgerAccountType').then(function(exists) {
     if (!exists) {
       return knex.schema.createTable('ledgerAccountType', (t) => {
@@ -38,6 +39,6 @@ exports.up = async (knex, Promise) => {
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.dropTableIfExists('ledgerAccountType')
 }
diff --git a/migrations/110451_ledgerAccountType-indexes.js b/migrations/110451_ledgerAccountType-indexes.js
@@ -18,19 +18,20 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = function (knex, Promise) {
+exports.up = function (knex) {
   return knex.schema.table('ledgerAccountType', (t) => {
     t.unique('name')
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.table('ledgerAccountType', (t) => {
     t.dropUnique('name')
   })

diff --git a/migrations/110500_participantLimitType.js b/migrations/110500_participantLimitType.js
@@ -18,13 +18,14 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = async (knex, Promise) => {
+exports.up = async (knex) => {
   return await knex.schema.hasTable('participantLimitType').then(function(exists) {
     if (!exists) {
       return knex.schema.createTable('participantLimitType', (t) => {
@@ -38,6 +39,6 @@ exports.up = async (knex, Promise) => {
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.dropTableIfExists('participantLimitType')
 }
diff --git a/migrations/110501_participantLimitType-indexes.js b/migrations/110501_participantLimitType-indexes.js
@@ -18,19 +18,20 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = function (knex, Promise) {
+exports.up = function (knex) {
   return knex.schema.table('participantLimitType', (t) => {
     t.unique('name')
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.table('participantLimitType', (t) => {
     t.dropUnique('name')
   })

diff --git a/migrations/110600_transferParticipantRoleType.js b/migrations/110600_transferParticipantRoleType.js
@@ -18,13 +18,14 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = async (knex, Promise) => {
+exports.up = async (knex) => {
   return await knex.schema.hasTable('transferParticipantRoleType').then(function(exists) {
     if (!exists) {
       return knex.schema.createTable('transferParticipantRoleType', (t) => {
@@ -38,6 +39,6 @@ exports.up = async (knex, Promise) => {
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.dropTableIfExists('transferParticipantRoleType')
 }
diff --git a/migrations/110601_transferParticipantRoleType-indexes.js b/migrations/110601_transferParticipantRoleType-indexes.js
@@ -18,19 +18,20 @@
  * Gates Foundation
  - Name Surname <name.surname@gatesfoundation.com>
 
- * Georgi Georgiev <georgi.georgiev@modusbox.com>
+ * ModusBox
+ - Georgi Georgiev <georgi.georgiev@modusbox.com>
  --------------
  ******/
 
 'use strict'
 
-exports.up = function (knex, Promise) {
+exports.up = function (knex) {
   return knex.schema.table('transferParticipantRoleType', (t) => {
     t.unique('name')
   })
 }
 
-exports.down = function (knex, Promise) {
+exports.down = function (knex) {
   return knex.schema.table('transferParticipantRoleType', (t) => {
     t.dropUnique('name')
   })