feat: sqs로 event message 핸들

Author: umi0410

config/config.go

@@ -44,6 +44,9 @@ type KhumuConfig struct {
 	Sns struct {
 		TopicArn string `yaml:"topic_arn"`
 	} `yaml:"sns"`
+	Sqs struct {
+		QueueURL string
+	}
 	Redis struct {
 		Addr string `yaml:"addr"`
 	} `yaml:"redis"`

container/container.go

@@ -10,24 +10,36 @@ import (
 	"github.com/khu-dev/khumu-comment/usecase"
 	"go.uber.org/dig"
 	"log"
+	"os"
 )
 
-func Build() *dig.Container {
+func Build(termSig <-chan os.Signal) *dig.Container {
 	c := dig.New()
 
-	// Provide DB Connection
+	// os의 signal을 받아서 종료할 수 있게해주는 channel
+	err := c.Provide(func() <-chan os.Signal {
+		return termSig
+	})
 
-	err := c.Provide(repository.NewEnt)
+	// Provide DB Connection
+	err = c.Provide(repository.NewEnt)
 	if err != nil {
 		log.Panic(err)
 	}
 
+	// 캐시에 동기적으로 write할 지 비동기적으로 write할지
 	err = c.Provide(func() repository.SynchronousCacheWrite { return false })
 	if err != nil {
 		log.Panic(err)
 	}
 	// sns
-	err = c.Provide(message.NewSnsClient)
+	err = c.Provide(message.NewSnsMessagePublisher)
+	if err != nil {
+		log.Panic(err)
+	}
+
+	// sqs
+	err = c.Provide(message.NewSqsMessageHandler)
 	if err != nil {
 		log.Panic(err)
 	}

data/comment.go

@@ -15,20 +15,20 @@ type CommentInput struct {
 }
 
 type CommentOutput struct {
-	ID                       int                    `json:"id"`
-	Kind                     string                 `json:"kind"`
-	State                    string                 `json:"state"`
-	Author                   *SimpleKhumuUserOutput `json:"author"`
-	Article                  *int                   `json:"article"`
-	StudyArticle             *int                   `json:"study_article"`
-	Parent                   *int                   `json:"parent"`
-	Content                  string                 `json:"content"`
-	Children                 []*CommentOutput       `json:"children"`
-	IsAuthor                 bool                   `json:"is_author"`
-	IsWrittenByArticleAuthor bool                   `json:"is_written_by_article_author"`
-	LikeCommentCount         int                    `json:"like_comment_count"`
-	Liked                    bool                   `json:"liked"`
-	CreatedAt                string                 `json:"created_at"`
+	ID                       int                 `json:"id"`
+	Kind                     string              `json:"kind"`
+	State                    string              `json:"state"`
+	Author                   *SimpleKhumuUserDto `json:"author"`
+	Article                  *int                `json:"article"`
+	StudyArticle             *int                `json:"study_article"`
+	Parent                   *int                `json:"parent"`
+	Content                  string              `json:"content"`
+	Children                 []*CommentOutput    `json:"children"`
+	IsAuthor                 bool                `json:"is_author"`
+	IsWrittenByArticleAuthor bool                `json:"is_written_by_article_author"`
+	LikeCommentCount         int                 `json:"like_comment_count"`
+	Liked                    bool                `json:"liked"`
+	CreatedAt                string              `json:"created_at"`
 }
 
 type LikeCommentInput struct {

data/khumuuser.go

@@ -1,6 +1,14 @@
 package data
 
-type SimpleKhumuUserOutput struct {
+// 댓글 DTO의 작성자로 제공될 타입
+type SimpleKhumuUserDto struct {
+	Username string `json:"username"`
+	Nickname string `json:"nickname"`
+	Status   string `json:"status"`
+}
+
+// command-center 에게 이벤트로서 전달받는 KhumuUser 타입
+type CommandCenterKhumuUserDto struct {
 	Username string `json:"username"`
 	Nickname string `json:"nickname"`
 	Status   string `json:"status"`

data/mapper/comment.go

@@ -27,6 +27,11 @@ func CommentModelToOutput(src *ent.Comment, dest *data.CommentOutput) *data.Comm
 	dest.Content = src.Content
 	dest.Kind = src.Kind
 	dest.State = src.State
+	if src.Edges.Author != nil {
+		if src.Edges.Article != nil && src.Edges.Article.Edges.Author != nil {
+			dest.IsWrittenByArticleAuthor = src.Edges.Author.ID == src.Edges.Article.Edges.Author.ID
+		}
+	}
 	// children은 그냥 빈 배열로 저장.
 	// 필요한 경우
 	dest.Children = []*data.CommentOutput{}

data/mapper/khumuuser.go

@@ -7,13 +7,13 @@ import (
 
 // 새로운 SimpleKhumuUserOutput을 생성한다
 // 원래 KhumuUser 참조 X
-func KhumuUserModelToSimpleOutput(src *ent.KhumuUser, dest *data.SimpleKhumuUserOutput) *data.SimpleKhumuUserOutput {
+func KhumuUserModelToSimpleOutput(src *ent.KhumuUser, dest *data.SimpleKhumuUserDto) *data.SimpleKhumuUserDto {
 	if src == nil {
 		return nil
 	}
 
 	if dest == nil {
-		dest = &data.SimpleKhumuUserOutput{}
+		dest = &data.SimpleKhumuUserDto{}
 	}
 
 	if src.Status == "deleted" {