add change request team if it does not exists

Author: Francesca-Bit

src/api/core/ChangeRequestDB.ts

@@ -46,6 +46,7 @@ class ChangeRequestDB {
   logger : Object 
   endStatus:any = { Assigned: true, Error: true }
   availableStatus:any = { Assigned: true, Error: true, Progress: true }
+  errorMessage:any = {'api:UnknownDatabase':true,'api:NoUniqueIdForOrganizationName':true}
 
   constructor(req : Request) {
     this.request = req
@@ -67,6 +68,7 @@ class ChangeRequestDB {
 // maybe I can add a capability at database level
 // admin create the db
 // and add the capability
+  
   async getChangeRequests (changeId: String | false = false, as_list = true) {
     const params : DocParamsGet = { type: 'ChangeRequest', as_list: as_list}
       if (changeId) {
@@ -77,7 +79,8 @@ class ChangeRequestDB {
       return result
     } catch (err:any) {
       // if there is no change request we return an empty array
-      if (typeof err.data === 'object' && err.data['api:error'] && err.data['api:error']['@type'] === 'api:UnknownDatabase') {
+      if (typeof err.data === 'object' && err.data['api:error'] 
+          && this.errorMessage[err.data['api:error']['@type']]) {
         return []
       }
       throw err
@@ -87,8 +90,12 @@ class ChangeRequestDB {
   async createTeam(){
     try{
       await this.accessControl.createOrganization(CROrg)
-    }catch(err){
-      // the team already exists
+    }catch(err:any){
+      if (typeof err.data === 'object' && err.data['api:error'] 
+        && this.errorMessage[err.data['api:error']['@type']]) {
+        return // the team already exists
+      }
+      throw err
     }
   }
 

src/api/paths/api/changes/{org}/{db}/index.ts

@@ -6,12 +6,12 @@ import ChangeRequestDB from "../../../../../core/ChangeRequestDB";
 
     export const GET: Operation = async(req:Request, res:Response) =>{
       try{
-        var dd = new Date()
-          console.log("ChangeRequestDB",dd.toISOString())
+          //var dd = new Date()
+          //console.log("ChangeRequestDB",dd.toISOString())
           const changeR = new ChangeRequestDB(req)
           const result = await changeR.getChangeRequests()
-          var dd1 = new Date()
-          console.log("ChangeRequestDB",dd1.toISOString())
+          //var dd1 = new Date()
+          //console.log("ChangeRequestDB",dd1.toISOString())
           res.status(200).json(result);
       }catch(err:any){
           console.log(err.message)

src/app.ts

@@ -11,7 +11,7 @@ import bodyParser from "body-parser";
 import cors from "cors";
 import {addContextMiddle} from "./api/addContextMiddle"
 import { createProxyMiddleware } from  'http-proxy-middleware'
-
+import TerminusClient , {WOQLClient,WOQL, AccessControl} from "@terminusdb/terminusdb-client"
 declare namespace Express {
   export interface Request {
     context?: object
@@ -66,7 +66,24 @@ app.use(
 );
 
 app.use(addContextMiddle)
-app.listen(3035);
+app.listen(3035,function(){
+  // when we start the server we check if the terminusCR team already exists
+  // if it does not exists we'll create it
+  const endpoint :string = process.env.SERVER_ENDPOINT || "http://127.0.0.1:6363"
+  const key = process.env.USER_KEY || "root"
+  const CROrg = process.env.CR_TEAM_NAME || "terminusCR"
+  const user = process.env.USER_NAME || "admin"
+  const accessControl = new AccessControl(endpoint, { key: key, user: user })
+
+  accessControl.createOrganization(CROrg).then(result=>{
+      console.log("The Change Request team has been created")
+    }).catch((err:any)=>{
+      if (typeof err.data === 'object' && err.data['api:error'] 
+        && err.data['api:error']['@type'] === "api:NoUniqueIdForOrganizationName") {
+        console.log("The Change Request team already exists")
+        }
+      })
+  });
 
 console.log("App running on port http://localhost:3035");
 console.log(