Add support for manually syncing state channel models to the db

Author: Jannis

packages/common-ts/package.json

@@ -15,9 +15,9 @@
     "test:watch": "jest --watch --passWithNoTests --detectOpenHandles --verbose"
   },
   "dependencies": {
-    "@connext/client": "^7.0.0-alpha.13",
-    "@connext/store": "^7.0.0-alpha.13",
-    "@connext/types": "^7.0.0-alpha.13",
+    "@connext/client": "^7.0.0-alpha.18",
+    "@connext/store": "^7.0.0-alpha.18",
+    "@connext/types": "^7.0.0-alpha.18",
     "@graphprotocol/contracts": "^0.3.2-beta",
     "@urql/core": "^1.12.1",
     "cross-fetch": "^3.0.5",
@@ -29,7 +29,7 @@
     "pg-hstore": "^2.3.3",
     "pino": "^6.3.2",
     "prom-client": "^11.5.3",
-    "sequelize": "5.21.13"
+    "sequelize": "^6.3.1"
   },
   "devDependencies": {
     "@types/bs58": "^4.0.1",

packages/common-ts/src/state-channels/index.ts

@@ -1,7 +1,9 @@
 import * as connext from '@connext/client'
-import { Sequelize } from 'sequelize'
+import { Sequelize, ModelCtor, Model } from 'sequelize'
 import { ILogger, IConnextClient } from '@connext/types'
 import { getPostgresStore } from '@connext/store'
+import { getSequelizeModelDefinitionData } from '@connext/store/dist/wrappers/sequelizeStorage'
+import { storeDefaults } from '@connext/store/dist/constants'
 
 interface StateChannelOptions {
   sequelize: Sequelize
@@ -14,6 +16,16 @@ interface StateChannelOptions {
   storePrefix?: string // for multiple channels to share a sequelize instance
 }
 
+export const defineStateChannelStoreModels = async (
+  sequelize: Sequelize,
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any
+): Promise<void> => {
+  sequelize.define(
+    storeDefaults.DATABASE_TABLE_NAME,
+    getSequelizeModelDefinitionData(sequelize.getDialect() as 'postgres' | 'sqlite'),
+  )
+}
+
 export const createStateChannel = async (
   options: StateChannelOptions,
 ): Promise<IConnextClient> => {
@@ -30,5 +42,6 @@ export const createStateChannel = async (
     signer: options.privateKey,
     logLevel: options.logLevel,
     logger: options.logger,
+    skipInitStore: true,
   })
 }

packages/common-ts/src/state-channels/stateChannel.test.ts

@@ -1,7 +1,7 @@
 /* eslint-disable @typescript-eslint/no-explicit-any */
 
 import { connectDatabase } from '../database'
-import { createStateChannel } from '.'
+import { createStateChannel, defineStateChannelStoreModels } from '.'
 import { Wallet } from 'ethers'
 
 // Make global Jest variable available
@@ -11,6 +11,9 @@ declare const __INDRA__: any
 describe('State Channel', () => {
   test('creates a state channel', async () => {
     const sequelize = await connectDatabase(__DATABASE__)
+    await defineStateChannelStoreModels(sequelize)
+    await sequelize.sync()
+
     if (
       !__INDRA__.ethereumProvider ||
       !__INDRA__.connextNode ||