feat: connect to envelop database

Author: wa0x6e

.env.example

@@ -3,6 +3,7 @@ NETWORK=testnet
 MAINTENANCE=
 HUB_DATABASE_URL=mysql://...
 SEQ_DATABASE_URL=mysql://...
+ENVELOP_DATABASE_URL=mysql://
 RELAYER_PK=0x123...
 DEFAULT_NETWORK=1
 SHUTTER_URL=https://...

src/helpers/mysql.ts

@@ -33,7 +33,21 @@ sequencerConfig.connectTimeout = 60e3;
 sequencerConfig.acquireTimeout = 60e3;
 sequencerConfig.timeout = 60e3;
 sequencerConfig.charset = 'utf8mb4';
-bluebird.promisifyAll([Pool, Connection]);
 const sequencerDB = mysql.createPool(sequencerConfig);
 
-export { hubDB as default, sequencerDB };
+// @ts-ignore
+const envelopConfig = parse(process.env.ENVELOP_DATABASE_URL);
+envelopConfig.connectionLimit = connectionLimit;
+envelopConfig.multipleStatements = true;
+envelopConfig.database = envelopConfig.path[0];
+envelopConfig.host = envelopConfig.hosts[0].name;
+envelopConfig.port = envelopConfig.hosts[0].port;
+envelopConfig.connectTimeout = 60e3;
+envelopConfig.acquireTimeout = 60e3;
+envelopConfig.timeout = 60e3;
+envelopConfig.charset = 'utf8mb4';
+const envelopDB = mysql.createPool(envelopConfig);
+
+bluebird.promisifyAll([Pool, Connection]);
+
+export { hubDB as default, sequencerDB, envelopDB };

test/.env.test

@@ -1,5 +1,6 @@
 HUB_DATABASE_URL=mysql://root:[email protected]:3306/snapshot_sequencer_test
 SEQ_DATABASE_URL=mysql://root:[email protected]:3306/snapshot_sequencer_test
+ENVELOP_DATABASE_URL=mysql://root:[email protected]:3306/snapshot_sequencer_test
 NETWORK=mainnet
 RELAYER_PK=01686849e86499c1860ea0afc97f29c11018cbac049abf843df875c60054076e
 NODE_ENV=test

test/schema_envelop.sql

@@ -0,0 +1,11 @@
+CREATE TABLE subscribers (
+  email VARCHAR(256) NOT NULL,
+  address VARCHAR(256) NOT NULL,
+  subscriptions JSON DEFAULT NULL,
+  created BIGINT NOT NULL,
+  verified BIGINT NOT NULL DEFAULT 0,
+  PRIMARY KEY (email, address),
+  UNIQUE KEY idx_address_email (address, email),
+  INDEX created (created),
+  INDEX verified (verified)
+);

test/setupDb.ts

@@ -1,9 +1,9 @@
-import mysql from 'mysql';
-import Pool from 'mysql/lib/Pool';
-import Connection from 'mysql/lib/Connection';
+import fs from 'fs';
 import bluebird from 'bluebird';
 import parse from 'connection-string';
-import fs from 'fs';
+import mysql from 'mysql';
+import Connection from 'mysql/lib/Connection';
+import Pool from 'mysql/lib/Pool';
 
 // @ts-ignore
 const config = parse(process.env.HUB_DATABASE_URL);
@@ -19,6 +19,8 @@ if (!dbName.endsWith('_test')) {
   process.exit(1);
 }
 
+const schemaFiles = ['./test/schema.sql', './test/schema_envelop.sql'];
+
 async function run() {
   const splitToken = ');';
 
@@ -30,8 +32,9 @@ async function run() {
   console.info(`- Creating new database: ${dbName}`);
   await db.queryAsync(`CREATE DATABASE ${dbName}`);
 
-  const schema = fs
-    .readFileSync('./test/schema.sql', 'utf8')
+  const schema = schemaFiles
+    .map(file => fs.readFileSync(file, 'utf8'))
+    .join(' ')
     .replaceAll('CREATE TABLE ', `CREATE TABLE ${dbName}.`)
     .split(splitToken)
     .filter(s => s.trim().length > 0);