From 4eb55846fdcf668449af01b975bae028066a664e Mon Sep 17 00:00:00 2001
From: Hongbo Wu <hongbo@omnivore.app>
Date: Thu, 14 Jul 2022 16:53:23 +0800
Subject: [PATCH] create elastic index if not exists in testing

---
 packages/api/src/elastic/index.ts | 22 ++++++++++++++++++++--
 1 file changed, 20 insertions(+), 2 deletions(-)

diff --git a/packages/api/src/elastic/index.ts b/packages/api/src/elastic/index.ts
index 1bef4c2a2..ca39b31d6 100644
--- a/packages/api/src/elastic/index.ts
+++ b/packages/api/src/elastic/index.ts
@@ -1,7 +1,7 @@
 import { env } from '../env'
 import { Client } from '@elastic/elasticsearch'
+import { readFileSync } from 'fs'
 
-export const INDEX_NAME = 'pages'
 export const INDEX_ALIAS = 'pages_alias'
 export const client = new Client({
   node: env.elastic.url,
@@ -13,6 +13,20 @@ export const client = new Client({
   },
 })
 
+const createIndex = async (): Promise<void> => {
+  // read index settings from file
+  const indexSettings = readFileSync(
+    __dirname + '/../../../db/elastic_migrations/index_settings.json',
+    'utf8'
+  )
+
+  // create index
+  await client.indices.create({
+    index: INDEX_ALIAS,
+    body: indexSettings,
+  })
+}
+
 export const initElasticsearch = async (): Promise<void> => {
   try {
     const response = await client.info()
@@ -23,7 +37,11 @@ export const initElasticsearch = async (): Promise<void> => {
       index: INDEX_ALIAS,
     })
     if (!indexExists) {
-      throw new Error('elastic index does not exist')
+      console.log('creating index...')
+      await createIndex()
+
+      console.log('refreshing index...')
+      await refreshIndex()
     }
     console.log('elastic client is ready')
   } catch (e) {