[WIP]ユーザーリストを取得するAPI

server/domain/user_list.go

@@ -0,0 +1,5 @@
+package domain
+
+type UserList struct {
+	MembersId  []int
+}

server/infrastructure/router.go

@@ -23,6 +23,8 @@ func init() {
 
 	messageController := controller.NewMessageController(logger, mongoHandler)
 
+	userListConntroller := controller.NewUserListController(logger, mongoHandler)
+
 	tokenController := controller.NewTokenController(logger, jwt, mongoHandler)
 
 	// ------------------------------
@@ -41,6 +43,8 @@ func init() {
 
 	v1.POST("/channels", func(c *gin.Context) { channelController.CreateChannel(c) })
 
+	v1.POST("/getusers", func(c *ginn.Context) { userListConntroller.get})
+
 	router.GET("/", func(c *gin.Context) {
 		c.JSON(200, gin.H{
 			"msg": "hello world",

server/interfaces/controller/user_list_controller.go

@@ -0,0 +1,38 @@
+package controller
+
+import (
+	"github.com/kindai-csg/D-Chat/interfaces"
+	"github.com/kindai-csg/D-Chat/interfaces/database"
+	"github.com/kindai-csg/D-Chat/interfaces/gateway"
+	"github.com/kindai-csg/D-Chat/usecase"
+)
+
+type UserListController struct {
+	logger     interfaces.Logger
+	interactor usecase.UserListInteractor
+}
+
+func NewUserListController(logger interfaces.Logger, mongoHandler database.MongoHandler) *UserListController {
+	userListController := UserListController{
+		logger:     logger,
+		interactor: *usecase.NewUserListInteractor(database.NewUserListRepository(mongoHandler)),
+	}
+	return &userListController
+}
+
+func (controller *UserListController) getUserList(c Context) {
+	input := gateway.UserListInput{}
+	err := c.ShouldBindJSON(&input)
+	if err != nil {
+		controller.logger.Error(err.Error())
+		c.JSON(400, gateway.UserListOutput{false, "Parameter is invalid."})
+		return
+	}
+	userList, err = controller.interactor.GetUserList(input.GetUserList())
+	if err != nil {
+		controller.logger.Error(err.Error())
+		c.JSON(500, gateway.UserListOutput{false, "Failed to get user list."})
+		return
+	}
+	c.JSON(200, gateway.UserListOutput{true, "success!"})
+}

server/interfaces/database/user_list_repository.go

@@ -0,0 +1,68 @@
+package database
+
+import (
+	"crypto/md5"
+	"encoding/base64"
+	"errors"
+	"strings"
+
+	"github.com/kindai-csg/D-Chat/domain"
+	"github.com/kindai-csg/D-Chat/domain/enum"
+)
+
+type UserListRepository struct {
+	mongoHandler   MongoHandler
+	collectionName string
+}
+
+func NewUserListRepository(mongoHandler MongoHandler) *UserListRepository {
+	userListRepository := UserListRepository{
+		mongoHandler:   mongoHandler,
+		collectionName: "Users",
+	}
+	//userListRepository.createIndex()
+	return &userListRepository
+}
+/*
+func (repository *UserListRepository) createIndex() {
+	repository.mongoHandler.CreateIndex(repository.collectionName, []KV{{"user_id", 1}}, []KV{{"unique", true}})
+	repository.mongoHandler.CreateIndex(repository.collectionName, []KV{{"mail", 1}}, []KV{{"unique", true}})
+}
+*/
+func (repository *UserListRepository) GetUserList(userList domain.UserList) (domain.UserList, error) {
+	query := []KV{}
+	for i := range userList.MembersId {
+		query = append(query, {"user_id", i})
+	}
+	raw, err := repository.mongoHandler.Find(repository.collectionName, query)
+	if err != nil {
+		return nil, err
+	}
+	users := []domain.User{}
+	for _, kv := range raw {
+		for _, u := range kv {
+			user := domain.User{}
+			switch u.Key {
+			case "_id":
+
+				user.Id = u.Value.(string)
+			case "user_id":
+				user.UserId = u.Value.(string)
+			case "password":
+				user.Password = u.Value.(string)
+			case "mail":
+				user.Mail = u.Value.(string)
+			case "bio":
+				user.Bio = u.Value.(string)
+			case "status":
+				user.Status = u.Value.(string)
+			case "status_text":
+				user.StatusText = u.Value.(string)
+			case "auth":
+				user.Auth = u.Value.(domain.AuthType)
+			}
+			users = append(users, user)
+		}
+	}
+	return users, nil
+}

server/interfaces/gateway/user_list_input.go

@@ -0,0 +1,11 @@
+package gateway
+
+type UserListInput struct {
+	MembersId  string   `json:"members_id"`
+}
+
+func (userList *UserListInput) GetUserList() domain.UserList {
+	return domain.UserList{
+		MembersId:   userList.MembersId,
+	}
+}

server/usecase/user_list_interactor.go

@@ -0,0 +1,24 @@
+package usecase
+
+import (
+	"github.com/kindai-csg/D-Chat/domain"
+)
+
+type UserListInteractor struct {
+	UserListRepository UserListRepository
+}
+
+func NewUserListInteractor(userListRepository UserListRepository) *UserListInteractor {
+	userListInteractor := UserListInteractor{
+		UserListRepository: userListRepository,
+	}
+	return &userListInteractor
+}
+
+func (interactor *UserListInteractor) GetUserList(userList domain.UserList) (domain.UserList, error) {
+	userList, err := interactor.UserListRepository.GetUserList(userList)
+	if err != nil {
+		return nil, err
+	}
+	return userList, nil
+}

server/usecase/user_list_repository.go

@@ -0,0 +1,7 @@
+package usecase
+
+import "github.com/kindai-csg/D-Chat/domain"
+
+type UserListRepository interface {
+	GetUserList(domain.UserList) (domain.UserList, error)
+}