From fb641313ddea2a2ca0c66c2d3fca039d0dd77432 Mon Sep 17 00:00:00 2001 From: yoneyan Date: Wed, 17 Mar 2021 22:58:22 +0900 Subject: [PATCH] [refactoring] #48 --- pkg/api/core/support/ticket/v0/admin.go | 21 ++++++++++++---- pkg/api/core/support/ticket/v0/ticket.go | 32 ++++++++++++++++++------ 2 files changed, 41 insertions(+), 12 deletions(-) diff --git a/pkg/api/core/support/ticket/v0/admin.go b/pkg/api/core/support/ticket/v0/admin.go index 8b3893a4..88e6cb68 100644 --- a/pkg/api/core/support/ticket/v0/admin.go +++ b/pkg/api/core/support/ticket/v0/admin.go @@ -228,8 +228,12 @@ func GetAdminWebSocket(c *gin.Context) { } // WebSocket送信 - support.Clients[&support.WebSocket{TicketID: uint(id), UserID: resultAdmin.AdminID, - GroupID: ticketResult.Ticket[0].GroupID, Socket: conn}] = true + support.Clients[&support.WebSocket{ + TicketID: uint(id), + UserID: resultAdmin.AdminID, + GroupID: ticketResult.Ticket[0].GroupID, + Socket: conn, + }] = true //WebSocket受信 for { @@ -237,8 +241,12 @@ func GetAdminWebSocket(c *gin.Context) { err = conn.ReadJSON(&msg) if err != nil { log.Printf("error: %v", err) - delete(support.Clients, &support.WebSocket{TicketID: uint(id), UserID: resultAdmin.AdminID, - GroupID: ticketResult.Ticket[0].GroupID, Socket: conn}) + delete(support.Clients, &support.WebSocket{ + TicketID: uint(id), + UserID: resultAdmin.AdminID, + GroupID: ticketResult.Ticket[0].GroupID, + Socket: conn, + }) break } @@ -272,7 +280,10 @@ func GetAdminWebSocket(c *gin.Context) { log.Println(resultTicket.Err) } if len(resultTicket.Ticket) != 0 { - resultUser := dbUser.Get(user.GIDAndLevel, &core.User{GroupID: resultTicket.Ticket[0].GroupID, Level: 1}) + resultUser := dbUser.Get(user.GIDAndLevel, &core.User{ + GroupID: resultTicket.Ticket[0].GroupID, + Level: 1, + }) if resultUser.Err != nil { log.Println(resultUser.Err) } diff --git a/pkg/api/core/support/ticket/v0/ticket.go b/pkg/api/core/support/ticket/v0/ticket.go index 334a9042..4598df16 100644 --- a/pkg/api/core/support/ticket/v0/ticket.go +++ b/pkg/api/core/support/ticket/v0/ticket.go @@ -187,8 +187,13 @@ func GetWebSocket(c *gin.Context) { } // WebSocket送信 - support.Clients[&support.WebSocket{TicketID: uint(id), Admin: false, - UserID: result.User.ID, GroupID: result.Group.ID, Socket: conn}] = true + support.Clients[&support.WebSocket{ + TicketID: uint(id), + Admin: false, + UserID: result.User.ID, + GroupID: result.Group.ID, + Socket: conn, + }] = true //WebSocket受信 for { @@ -196,12 +201,20 @@ func GetWebSocket(c *gin.Context) { err = conn.ReadJSON(&msg) if err != nil { log.Printf("error: %v", err) - delete(support.Clients, &support.WebSocket{TicketID: uint(id), Admin: false, UserID: result.User.ID, - GroupID: result.Group.ID, Socket: conn}) + delete(support.Clients, &support.WebSocket{ + TicketID: uint(id), + Admin: false, + UserID: result.User.ID, + GroupID: result.Group.ID, + Socket: conn, + }) break } // 入力されたデータをTokenにて認証 - resultGroup := auth.GroupAuthentication(0, core.Token{UserToken: msg.UserToken, AccessToken: msg.AccessToken}) + resultGroup := auth.GroupAuthentication(0, core.Token{ + UserToken: msg.UserToken, + AccessToken: msg.AccessToken, + }) if resultGroup.Err != nil { log.Println(resultGroup.Err) return @@ -225,8 +238,13 @@ func GetWebSocket(c *gin.Context) { msg.UserToken = "" //ユーザ側に送信 - controller.SendChatUser(controllerInterface.Chat{CreatedAt: msg.CreatedAt, - UserID: result.User.ID, GroupID: resultGroup.Group.ID, Admin: msg.Admin, Message: msg.Message}) + controller.SendChatUser(controllerInterface.Chat{ + CreatedAt: msg.CreatedAt, + UserID: result.User.ID, + GroupID: resultGroup.Group.ID, + Admin: msg.Admin, + Message: msg.Message, + }) userName := "不明"