feat: add elastic search connection method

Author: winverse

apps/server/src/lib/elasticSearch/ElasticSearchService.ts

@@ -7,18 +7,29 @@ import { Post } from '@packages/database/velog-rds'
 import { UserService } from '@services/UserService/index.js'
 
 interface Service {
-  get client(): Client
+  getClient(): Client
   keywordSearch(input: KeywordSearchArgs): Promise<{ count: number; posts: Post[] }>
 }
 
 @injectable()
 @singleton()
 export class ElasticSearchService implements Service {
+  public client!: Client
   constructor(
     private readonly userService: UserService,
     private readonly buildQueryService: BuildQueryService,
   ) {}
-  public get client(): Client {
+  public connection(): Promise<Client> {
+    return new Promise((resolve) => {
+      const client = new Client({ node: ENV.esHost })
+      this.client = client
+      resolve(client)
+    })
+  }
+  public getClient(): Client {
+    if (this.client) {
+      return this.client
+    }
     return new Client({ node: ENV.esHost })
   }
   public get buildQuery() {

apps/server/src/main.mts

@@ -6,6 +6,7 @@ import { startClosing } from '@plugins/global/keepAlivePlugin.mjs'
 import { DbService } from '@lib/db/DbService.js'
 import { RedisService } from '@lib/redis/RedisService.js'
 import { DiscordService } from '@lib/discord/DiscordService.js'
+import { ElasticSearchService } from '@lib/elasticSearch/ElasticSearchService.js'
 
 async function main() {
   app.listen({ port: ENV.port, host: '::' })
@@ -19,6 +20,9 @@ async function main() {
   const discord = container.resolve(DiscordService)
   await discord.connection()
 
+  const elasticSearch = container.resolve(ElasticSearchService)
+  elasticSearch.connection()
+
   process.send?.('ready')
   process.on('SIGINT', function () {
     startClosing()

infrastructure/Pulumi.production.yaml

@@ -1,4 +1,4 @@
 config:
   aws:region: ap-northeast-2
   velog:DOCKER_ENV: production
-  velog:target: cron
+  velog:target: server

infrastructure/Pulumi.stage.yaml

@@ -1,4 +1,4 @@
 config:
   aws:region: ap-northeast-2
   velog:DOCKER_ENV: stage
-  velog:target: server,cron
+  velog:target: server