refactor chat service: replace dummy user provider with user client for user retrieval

Author: sevetis

come-back/chat-service/cmd/main.go

@@ -1,8 +1,10 @@
 package main
 
 import (
+	"chat-service/internal/client"
 	"chat-service/internal/controller"
 	"chat-service/internal/repository"
+	"fmt"
 	"log"
 	"os"
 
@@ -18,8 +20,9 @@ func main() {
 	repository.InitDB(os.Getenv("MYSQL_DSN"))
 	controller.InitRedis()
 
-	userProvider := &controller.HTTPUserProvider{}
-	chatCtrl := controller.NewChatController(userProvider)
+	chatCtrl := controller.NewChatController(
+		*client.NewUserClient(fmt.Sprintf("http://user-service:%s", os.Getenv("USER_PORT"))),
+	)
 
 	router := gin.Default()
 	router.GET("/api/history", chatCtrl.GetChatHistory)

come-back/chat-service/internal/client/user_client.go

@@ -0,0 +1,38 @@
+package client
+
+import (
+	"chat-service/internal/model"
+	"encoding/json"
+	"fmt"
+	"net/http"
+)
+
+type UserClient struct {
+	Host string
+}
+
+func NewUserClient(host string) *UserClient {
+	return &UserClient{
+		Host: host,
+	}
+}
+
+func (uc *UserClient) GetUserByID(userID uint) (model.User, error) {
+	url := fmt.Sprintf("%s/api/user/%d", uc.Host, userID)
+	resp, err := http.Get(url)
+	if err != nil {
+		return model.User{}, fmt.Errorf("failed to get user: %w", err)
+	}
+
+	defer resp.Body.Close()
+	if resp.StatusCode != http.StatusOK {
+		return model.User{}, fmt.Errorf("failed to get user, status code: %d", resp.StatusCode)
+	}
+
+	var user model.User
+	if err := json.NewDecoder(resp.Body).Decode(&user); err != nil {
+		return model.User{}, fmt.Errorf("failed to decode user response: %w", err)
+	}
+
+	return user, nil
+}

come-back/chat-service/internal/controller/chat.go

@@ -9,24 +9,19 @@ import (
 	"strconv"
 	"time"
 
+	"chat-service/internal/client"
 	"chat-service/internal/model"
 
 	"github.com/gin-gonic/gin"
 	"github.com/gorilla/websocket"
 )
 
 type ChatController struct {
-	UserProvider model.UserProvider
+	UserClient client.UserClient
 }
 
-func NewChatController(userProvider model.UserProvider) *ChatController {
-	return &ChatController{UserProvider: userProvider}
-}
-
-type HTTPUserProvider struct{}
-
-func (h *HTTPUserProvider) GetUserByID(id uint) (model.User, error) {
-	return model.User{ID: id, Username: "temp_user"}, nil
+func NewChatController(userClinet client.UserClient) *ChatController {
+	return &ChatController{UserClient: userClinet}
 }
 
 func init() {
@@ -38,7 +33,7 @@ func (cc *ChatController) HandleChat(c *gin.Context) {
 	userID, exists := c.Get("user_id")
 	if exists {
 		var err error
-		user, err = cc.UserProvider.GetUserByID(userID.(uint))
+		user, err = cc.UserClient.GetUserByID(userID.(uint))
 		if err != nil {
 			c.JSON(http.StatusInternalServerError, gin.H{"error": "failed to get user"})
 			return

come-back/post-service/go.mod

@@ -34,17 +34,10 @@ require (
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
 	github.com/ugorji/go/codec v1.2.12 // indirect
 	golang.org/x/arch v0.8.0 // indirect
-<<<<<<< HEAD
 	golang.org/x/crypto v0.35.0 // indirect
 	golang.org/x/net v0.25.0 // indirect
 	golang.org/x/sys v0.30.0 // indirect
 	golang.org/x/text v0.22.0 // indirect
-=======
-	golang.org/x/crypto v0.23.0 // indirect
-	golang.org/x/net v0.25.0 // indirect
-	golang.org/x/sys v0.20.0 // indirect
-	golang.org/x/text v0.20.0 // indirect
->>>>>>> 9e60d1e (split post service)
 	google.golang.org/protobuf v1.34.1 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )

come-back/post-service/go.sum

@@ -76,28 +76,16 @@ github.com/ugorji/go/codec v1.2.12/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZ
 golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8=
 golang.org/x/arch v0.8.0 h1:3wRIsP3pM4yUptoR96otTUOXI367OS0+c9eeRi9doIc=
 golang.org/x/arch v0.8.0/go.mod h1:FEVrYAQjsQXMVJ1nsMoVVXPZg6p2JE2mx8psSWTDQys=
-<<<<<<< HEAD
 golang.org/x/crypto v0.35.0 h1:b15kiHdrGCHrP6LvwaQ3c03kgNhhiMgvlhxHQhmg2Xs=
 golang.org/x/crypto v0.35.0/go.mod h1:dy7dXNW32cAb/6/PRuTNsix8T+vJAqvuIy5Bli/x0YQ=
-=======
-golang.org/x/crypto v0.23.0 h1:dIJU/v2J8Mdglj/8rJ6UUOM3Zc9zLZxVZwwxMooUSAI=
-golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8=
->>>>>>> 9e60d1e (split post service)
 golang.org/x/net v0.25.0 h1:d/OCCoBEUq33pjydKrGQhw7IlUPI2Oylr+8qLx49kac=
 golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM=
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-<<<<<<< HEAD
 golang.org/x/sys v0.30.0 h1:QjkSwP/36a20jFYWkSue1YwXzLmsV5Gfq7Eiy72C1uc=
 golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/text v0.22.0 h1:bofq7m3/HAFvbF51jz3Q9wLg3jkvSPuiZu/pD1XwgtM=
 golang.org/x/text v0.22.0/go.mod h1:YRoo4H8PVmsu+E3Ou7cqLVH8oXWIHVoX0jqUWALQhfY=
-=======
-golang.org/x/sys v0.20.0 h1:Od9JTbYCk261bKm4M/mw7AklTlFYIa0bIp9BgSm1S8Y=
-golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
-golang.org/x/text v0.20.0 h1:gK/Kv2otX8gz+wn7Rmb3vT96ZwuoxnQlY+HlJVj7Qug=
-golang.org/x/text v0.20.0/go.mod h1:D4IsuqiFMhST5bX19pQ9ikHC2GsaKyk/oF+pn3ducp4=
->>>>>>> 9e60d1e (split post service)
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 google.golang.org/protobuf v1.34.1 h1:9ddQBjfCyZPOHPUiPxpYESBLc+T8P3E+Vo4IbKZgFWg=