fix: elastic search update

Author: winverse

packages/velog-server/src/services/PostApiService/index.ts

@@ -51,7 +51,7 @@ export class PostApiService implements Service {
     private readonly turnstileService: TurnstileService,
   ) {}
   public async write(input: WritePostInput, signedUserId?: string, ip = ''): Promise<Post> {
-    const { data, post, userId, series_id } = await this.initializePostProcess<'write'>({
+    const { data, post, series_id } = await this.initializePostProcess<'write'>({
       input,
       signedUserId,
       type: 'write',
@@ -62,14 +62,8 @@ export class PostApiService implements Service {
       await this.seriesService.appendToSeries(series_id, post.id)
     }
 
-    try {
-      await Promise.all([
-        data.is_temp ? null : this.searchService.searchSync.update(post.id),
-        this.graphcdn.purgeRecentPosts(),
-        this.graphcdn.purgeUser(userId),
-      ])
-    } catch (error) {
-      console.log(error)
+    if (!data.is_temp) {
+      await this.searchService.searchSync.update(post.id)
     }
 
     return post
@@ -110,6 +104,13 @@ export class PostApiService implements Service {
       ])
     }
 
+    await this.db.post.update({
+      where: {
+        id: post.id,
+      },
+      data,
+    })
+
     try {
       await Promise.all([
         data.is_temp ? null : this.searchService.searchSync.update(post.id),
@@ -131,13 +132,6 @@ export class PostApiService implements Service {
       })
     }
 
-    await this.db.post.update({
-      where: {
-        id: post.id,
-      },
-      data,
-    })
-
     return { ...post, url_slug: data.url_slug }
   }
   private async initializePostProcess<T extends 'write' | 'edit'>({

packages/velog-server/src/services/SearchService/index.ts

@@ -54,11 +54,13 @@ export class SearchService implements Service {
     const serialized = this.serializePost(postWithTags)
 
     try {
-      return this.elasticSearch.client.index({
+      const result = await this.elasticSearch.client.index({
         id: postId,
         index: 'posts',
         body: serialized,
       })
+
+      return result
     } catch (error) {
       console.log('elasticsearch post update', error)
       throw error