feat(backend): backend tenant graphql resolvers

packages/backend/jest.setup.ts

@@ -34,6 +34,10 @@ const setup = async (globalConfig): Promise<void> => {
         POSTGRES_PORT
       )}/testing`
 
+      process.env.TENANT_TEST_DATABASE_URL = `postgresql://postgres:password@localhost:${postgresContainer.getMappedPort(
+        POSTGRES_PORT
+      )}/tenant_testing`
+
       global.__BACKEND_POSTGRES__ = postgresContainer
     }
 
@@ -49,6 +53,18 @@ const setup = async (globalConfig): Promise<void> => {
       }
     })
 
+    const tenantDb = knex({
+      client: 'postgresql',
+      connection: process.env.TENANT_TEST_DATABASE_URL,
+      pool: {
+        min: 2,
+        max: 10
+      },
+      migrations: {
+        tableName: 'knex_migrations'
+      }
+    })
+
     // node pg defaults to returning bigint as string. This ensures it parses to bigint
     db.client.driver.types.setTypeParser(
       db.client.driver.types.builtins.INT8,
@@ -59,14 +75,29 @@ const setup = async (globalConfig): Promise<void> => {
       directory: __dirname + '/migrations'
     })
 
+    tenantDb.client.driver.types.setTypeParser(
+      tenantDb.client.driver.types.builtins.INT8,
+      'text',
+      BigInt
+    )
+    await tenantDb.migrate.latest({
+      directory: __dirname + '/migrations'
+    })
+
     for (let i = 1; i <= workers; i++) {
       const workerDatabaseName = `testing_${i}`
+      const tenantWorkerDatabaseName = `tenant_testing_${i}`
 
       await db.raw(`DROP DATABASE IF EXISTS ${workerDatabaseName}`)
+      await tenantDb.raw(`DROP DATABASE IF EXISTS ${tenantWorkerDatabaseName}`)
       await db.raw(`CREATE DATABASE ${workerDatabaseName} TEMPLATE testing`)
+      await tenantDb.raw(
+        `CREATE DATABASE ${tenantWorkerDatabaseName} TEMPLATE tenant_testing`
+      )
     }
 
     global.__BACKEND_KNEX__ = db
+    global.__BACKEND_TENANT_KNEX__ = tenantDb
   }
 
   const setupRedis = async () => {

packages/backend/jest.teardown.js

@@ -3,7 +3,12 @@ module.exports = async () => {
     { directory: __dirname + '/migrations' },
     true
   )
+  await global.__BACKEND_TENANT_KNEX__.migrate.rollback(
+    { directory: __dirname + '/migrations' },
+    true
+  )
   await global.__BACKEND_KNEX__.destroy()
+  await global.__BACKEND_TENANT_KNEX__.destroy()
   if (global.__BACKEND_POSTGRES__) {
     await global.__BACKEND_POSTGRES__.stop()
   }

packages/backend/knexfile.js

@@ -33,6 +33,22 @@ module.exports = {
     }
   },
 
+  tenant_testing: {
+    client: 'postgresql',
+    connection: {
+      database: 'tenant_testing',
+      user: 'postgres',
+      password: 'password'
+    },
+    pool: {
+      min: 2,
+      max: 10
+    },
+    migrations: {
+      tableName: 'knex_migrations'
+    }
+  },
+
   production: {
     client: 'postgresql',
     connection: process.env.DATABASE_URL,

packages/backend/scripts/init.sh

@@ -3,6 +3,8 @@ set -e
 
 psql -v ON_ERROR_STOP=1 --username "$POSTGRES_USER" --dbname "$POSTGRES_DB" <<-EOSQL
     DROP DATABASE IF EXISTS TESTING;
+    DROP DATABASE IF EXISTS TENANT_TESTING;
     CREATE DATABASE testing;
+    CREATE DATABASE tenant_testing;
     CREATE DATABASE development;
 EOSQL