feat: DB Migration CredentialStatus

packages/daf-cli/src/setup.ts

@@ -12,6 +12,7 @@ import { TrustGraphActionHandler, TrustGraphServiceController } from 'daf-trust-
 import { DIDCommActionHandler, DIDCommMessageHandler } from 'daf-did-comm'
 import { UrlMessageHandler } from 'daf-url'
 import { createConnection } from 'typeorm'
+const fs = require('fs')
 
 import ws from 'ws'
 
@@ -21,7 +22,6 @@ const dataStoreFilename = process.env.DAF_DATA_STORE ?? defaultPath + 'database-
 const infuraProjectId = process.env.DAF_INFURA_ID ?? '5ffc47f65c4042ce847ef66a3fa70d4c'
 
 if (!process.env.DAF_IDENTITY_STORE || process.env.DAF_DATA_STORE) {
-  const fs = require('fs')
   if (!fs.existsSync(defaultPath)) {
     fs.mkdirSync(defaultPath)
   }
@@ -42,12 +42,17 @@ if (process.env.DAF_TG_URI) TrustGraphServiceController.defaultUri = process.env
 if (process.env.DAF_TG_WSURI) TrustGraphServiceController.defaultWsUri = process.env.DAF_TG_WSURI
 TrustGraphServiceController.webSocketImpl = ws
 
+const migrationsRun = fs.existsSync(dataStoreFilename)
+const synchronize = !migrationsRun
+
 const dbConnection = createConnection({
   type: 'sqlite',
   database: dataStoreFilename,
-  synchronize: true,
+  migrationsRun,
+  synchronize,
   logging: process.env.DEBUG_DAF_DB ? true : false,
   entities: [...Daf.Entities],
+  migrations: [...Daf.migrations],
 })
 
 const identityProviders = [

packages/daf-core/src/index.ts

@@ -29,3 +29,5 @@ import { Message } from './entities/message'
 export const Entities = [Key, Identity, Message, Claim, Credential, Presentation]
 
 export { KeyType, Key, Identity, Message, Claim, Credential, Presentation }
+
+export { migrations } from './migrations'

packages/daf-core/src/migrations/CredentialStatus1587985317000.ts

@@ -0,0 +1,15 @@
+import {MigrationInterface, QueryRunner } from "typeorm";
+
+export class CredentialStatus1587985317000 implements MigrationInterface {
+
+  async up(queryRunner: QueryRunner): Promise<void> {
+    if (!queryRunner.hasColumn('credential', 'credentialStatus')) {
+      await queryRunner.query('ALTER TABLE credential ADD credentialStatus TEXT NULL')
+    }
+  }
+
+  async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query('ALTER TABLE credential DROP credentialStatus')
+  }
+
+}

packages/daf-core/src/migrations/index.ts

@@ -0,0 +1,5 @@
+import { CredentialStatus1587985317000 } from './CredentialStatus1587985317000'
+
+export const migrations = [
+  CredentialStatus1587985317000
+]