🔧 add deces-updates index

matchID-project · May 1, 2021 · f6d38df · f6d38df
1 parent 7886751
commit f6d38df
Show file tree

Hide file tree

Showing 2 changed files with 66 additions and 1 deletion.
diff --git a/backend/src/server.ts b/backend/src/server.ts
@@ -19,7 +19,7 @@ import "./controllers/status.controller";
 import "./controllers/job.controller";
 import "./controllers/auth.controller";
 
-const log = (json:any) => {
+export const log = (json:any) => {
   loggerStream.write(JSON.stringify({
     "backend": {
       "server-date": new Date(Date.now()).toISOString(),
@@ -28,6 +28,7 @@ const log = (json:any) => {
   }));
 }
 
+
 export const app = express();
 
 morgan.token('fwd-addr', (req: any) => {
@@ -122,3 +123,7 @@ app.use((
 
 // app.use(`${process.env.BACKEND_PROXY_PATH}/search`, bulk);
 app.use(`${process.env.BACKEND_PROXY_PATH}/docs`, documentation);
+
+import { initUpdateIndex } from './updatedIds';
+
+initUpdateIndex();
diff --git a/backend/src/updatedIds.ts b/backend/src/updatedIds.ts
@@ -1,5 +1,65 @@
 import { readFileSync, readdirSync, statSync } from 'fs';
 import path from "path";
+import axios from 'axios';
+import { log } from './server';
+
+const updateIndex = 'deces-updates';
+const modelIndex = 'deces';
+let updateIndexCreated = false;
+
+export const initUpdateIndex =  async (): Promise<boolean> => {
+  if (updateIndexCreated) { return true }
+  try {
+    const test = await axios(`http://elasticsearch:9200/${updateIndex}/_settings`);
+    if (test.status === 200) {
+      updateIndexCreated = true;
+      return true;
+    }
+  } catch(e) {
+    // create index
+    const settingsResponse = await axios(`http://elasticsearch:9200/${modelIndex}/_settings`);
+    if (settingsResponse.status !== 200) {
+      log({msg: 'failed initiating missing update index', error: "coudn't retrive settings from model index"});
+      return false;
+    }
+    const analysis = settingsResponse.data && settingsResponse.data[modelIndex] &&
+      settingsResponse.data[modelIndex].settings.index && settingsResponse.data[modelIndex].settings.index.analysis;
+    if (!analysis) {
+      log({msg: 'failed initiating missing update index', error: "coudn't retrive settings from model index"});
+      return false
+    };
+    const mappingsResponse = await axios(`http://elasticsearch:9200/${modelIndex}/_mappings`);
+    if (mappingsResponse.status !== 200) {
+      log({msg: 'failed initiating missing update index', error: "coudn't retrive mappings from model index"});
+      return false;
+    }
+    const mappings = mappingsResponse.data && mappingsResponse.data[modelIndex] &&
+      mappingsResponse.data[modelIndex].mappings;
+    if (!mappings) {
+      log({msg: 'failed initiating missing update index', error: "coudn't retrive mappings from model index"});
+      return false;
+    };
+    try {
+      const createIndexResponse = await axios(`http://elasticsearch:9200/${updateIndex}/`, {
+        method: 'PUT',
+        data: {
+          settings: { index: { analysis}},
+          mappings
+        },
+        headers: {
+          'Content-Type': 'application/x-ndjson',
+          'Cache-Control': 'no-cache'
+        }
+      });
+      updateIndexCreated = true;
+      log({msg: "initiated update index as didn't exists"});
+      return true;
+    } catch(e) {
+      log({msg: 'failed initiating missing update index', error: e.message});
+      return false;
+    }
+  }
+}
 
 const walk = (directory: string): string[]=> {
   const fileList: string[] = [];