From a1efa2863411eaee7b6db6ce0e096077b4a374e1 Mon Sep 17 00:00:00 2001 From: Yehyeok Bang Date: Thu, 1 Feb 2024 15:13:38 +0900 Subject: [PATCH] =?UTF-8?q?feat:=20AI=20=EC=84=9C=EB=B2=84=20=EC=9A=94?= =?UTF-8?q?=EC=B2=AD=20=EC=8B=A4=ED=8C=A8=EC=8B=9C=20=EC=98=88=EC=99=B8=20?= =?UTF-8?q?=EB=A1=9C=EA=B9=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/report/services/report_service.go | 23 ++++++++++++++++++----- 1 file changed, 18 insertions(+), 5 deletions(-) diff --git a/app/report/services/report_service.go b/app/report/services/report_service.go index b1b0605..7edfb92 100644 --- a/app/report/services/report_service.go +++ b/app/report/services/report_service.go @@ -39,14 +39,20 @@ func NewReportService(reportRepository repositories.ReportRepositoryInterface, u } } +var REQUEST_URL string +var client *http.Client + +func init() { + REQUEST_URL = os.Getenv("AI_SERVER_API_URL") + client = &http.Client{} +} + func (service *ReportService) Analysis(c *gin.Context, input types.RequestAnalysis) (string, error) { user, err := service.UserUtil.FindCurrentUser(c) if err != nil { return "Not Found User", err } - REQUEST_URL := os.Getenv("AI_SERVER_API_URL") - u, _ := url.Parse(REQUEST_URL) q := u.Query() @@ -55,7 +61,16 @@ func (service *ReportService) Analysis(c *gin.Context, input types.RequestAnalys message := "Video submitted successfully" - go Predict(*service, u.String(), *user, input) + errCh := make(chan error, 1) + go func() { + errCh <- Predict(*service, u.String(), *user, input) + }() + + defer func() { + if err := <-errCh; err != nil { + fmt.Println(err, " [", user.ID, ", ", input.VideoURL, "]") + } + }() return message, nil } @@ -100,8 +115,6 @@ func HandleRequest(url string) (types.ResponseAnalysis, error) { return types.ResponseAnalysis{}, err } - client := &http.Client{} - response, err := client.Do(req) if err != nil { return types.ResponseAnalysis{}, err