msb-public
/
Open-IM-Server
mirror of https://github.com/OpenIMSDK/Open-IM-Server
2
0
Code Issues Projects Releases Wiki Activity

feat: change api

Browse Source
pull/2969/head
icey-yu 9 months ago
parent 6952c4b1b3
commit 44933d71ee
10 changed files with 125 additions and 125 deletions
Show Stats Download Patch File Download Diff File

2
go.mod
Unescape View File

@ -15,7 +15,7 @@ require (
github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0
github.com/mitchellh/mapstructure v1.5.0
github.com/openimsdk/protocol v0.0.72-alpha.66
github.com/openimsdk/tools v0.0.50-alpha.54
github.com/openimsdk/tools v0.0.50-alpha.57
github.com/pkg/errors v0.9.1 // indirect
github.com/prometheus/client_golang v1.18.0
github.com/stretchr/testify v1.9.0

4
go.sum
Unescape View File

@ -349,8 +349,8 @@ github.com/openimsdk/gomake v0.0.15-alpha.2 h1:5Q8yl8ezy2yx+q8/ucU/t4kJnDfCzNOrk
github.com/openimsdk/gomake v0.0.15-alpha.2/go.mod h1:PndCozNc2IsQIciyn9mvEblYWZwJmAI+06z94EY+csI=
github.com/openimsdk/protocol v0.0.72-alpha.66 h1:5KoDY6M4T+pXg449ScF6hqeQ+WenBwNyUJn/t8W0oBQ=
github.com/openimsdk/protocol v0.0.72-alpha.66/go.mod h1:Iet+piS/jaS+kWWyj6EEr36mk4ISzIRYjoMSVA4dq2M=
github.com/openimsdk/tools v0.0.50-alpha.54 h1:SwHzd1R4aB0HSBuxjXorW87reeA1yLTZxjssuGJ1g1c=
github.com/openimsdk/tools v0.0.50-alpha.54/go.mod h1:muCtxguNJv8lFwLei27UASu2Nvg4ERSeN0R4K5tivk0=
github.com/openimsdk/tools v0.0.50-alpha.57 h1:oIKV6vYhqp7TRmZ6Pe+r9RNl1D5s7aB/kE9yQVEWcSY=
github.com/openimsdk/tools v0.0.50-alpha.57/go.mod h1:muCtxguNJv8lFwLei27UASu2Nvg4ERSeN0R4K5tivk0=
github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM=
github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs=
github.com/pierrec/lz4/v4 v4.1.21 h1:yOVMLb6qSIDP67pl/5F7RepeKYu/VmTyEXvuMI5d9mQ=

8
internal/api/auth.go
Unescape View File

@ -27,17 +27,17 @@ func NewAuthApi() AuthApi {
}
func (o *AuthApi) GetAdminToken(c *gin.Context) {
a2r.CallV2(auth.GetAdminTokenCaller.Invoke, c)
a2r.CallV2(c, auth.GetAdminTokenCaller.Invoke)
}
func (o *AuthApi) GetUserToken(c *gin.Context) {
a2r.CallV2(auth.GetUserTokenCaller.Invoke, c)
a2r.CallV2(c, auth.GetUserTokenCaller.Invoke)
}
func (o *AuthApi) ParseToken(c *gin.Context) {
a2r.CallV2(auth.ParseTokenCaller.Invoke, c)
a2r.CallV2(c, auth.ParseTokenCaller.Invoke)
}
func (o *AuthApi) ForceLogout(c *gin.Context) {
a2r.CallV2(auth.ForceLogoutCaller.Invoke, c)
a2r.CallV2(c, auth.ForceLogoutCaller.Invoke)
}

22
internal/api/conversation.go
Unescape View File

@ -27,45 +27,45 @@ func NewConversationApi() ConversationApi {
}
func (o *ConversationApi) GetAllConversations(c *gin.Context) {
a2r.CallV2(conversation.GetAllConversationsCaller.Invoke, c)
a2r.CallV2(c, conversation.GetAllConversationsCaller.Invoke)
}
func (o *ConversationApi) GetSortedConversationList(c *gin.Context) {
a2r.CallV2(conversation.GetSortedConversationListCaller.Invoke, c)
a2r.CallV2(c, conversation.GetSortedConversationListCaller.Invoke)
}
func (o *ConversationApi) GetConversation(c *gin.Context) {
a2r.CallV2(conversation.GetConversationCaller.Invoke, c)
a2r.CallV2(c, conversation.GetConversationCaller.Invoke)
}
func (o *ConversationApi) GetConversations(c *gin.Context) {
a2r.CallV2(conversation.GetConversationsCaller.Invoke, c)
a2r.CallV2(c, conversation.GetConversationsCaller.Invoke)
}
func (o *ConversationApi) SetConversations(c *gin.Context) {
a2r.CallV2(conversation.SetConversationsCaller.Invoke, c)
a2r.CallV2(c, conversation.SetConversationsCaller.Invoke)
}
func (o *ConversationApi) GetConversationOfflinePushUserIDs(c *gin.Context) {
a2r.CallV2(conversation.GetConversationOfflinePushUserIDsCaller.Invoke, c)
a2r.CallV2(c, conversation.GetConversationOfflinePushUserIDsCaller.Invoke)
}
func (o *ConversationApi) GetFullOwnerConversationIDs(c *gin.Context) {
a2r.CallV2(conversation.GetFullOwnerConversationIDsCaller.Invoke, c)
a2r.CallV2(c, conversation.GetFullOwnerConversationIDsCaller.Invoke)
}
func (o *ConversationApi) GetIncrementalConversation(c *gin.Context) {
a2r.CallV2(conversation.GetIncrementalConversationCaller.Invoke, c)
a2r.CallV2(c, conversation.GetIncrementalConversationCaller.Invoke)
}
func (o *ConversationApi) GetOwnerConversation(c *gin.Context) {
a2r.CallV2(conversation.GetOwnerConversationCaller.Invoke, c)
a2r.CallV2(c, conversation.GetOwnerConversationCaller.Invoke)
}
func (o *ConversationApi) GetNotNotifyConversationIDs(c *gin.Context) {
a2r.CallV2(conversation.GetNotNotifyConversationIDsCaller.Invoke, c)
a2r.CallV2(c, conversation.GetNotNotifyConversationIDsCaller.Invoke)
}
func (o *ConversationApi) GetPinnedConversationIDs(c *gin.Context) {
a2r.CallV2(conversation.GetPinnedConversationIDsCaller.Invoke, c)
a2r.CallV2(c, conversation.GetPinnedConversationIDsCaller.Invoke)
}

42
internal/api/friend.go
Unescape View File

@ -28,87 +28,87 @@ func NewFriendApi() FriendApi {
}
func (o *FriendApi) ApplyToAddFriend(c *gin.Context) {
a2r.CallV2(relation.ApplyToAddFriendCaller.Invoke, c)
a2r.CallV2(c, relation.ApplyToAddFriendCaller.Invoke)
}
func (o *FriendApi) RespondFriendApply(c *gin.Context) {
a2r.CallV2(relation.RespondFriendApplyCaller.Invoke, c)
a2r.CallV2(c, relation.RespondFriendApplyCaller.Invoke)
}
func (o *FriendApi) DeleteFriend(c *gin.Context) {
a2r.CallV2(relation.DeleteFriendCaller.Invoke, c)
a2r.CallV2(c, relation.DeleteFriendCaller.Invoke)
}
func (o *FriendApi) GetFriendApplyList(c *gin.Context) {
a2r.CallV2(relation.GetPaginationFriendsApplyToCaller.Invoke, c)
a2r.CallV2(c, relation.GetPaginationFriendsApplyToCaller.Invoke)
}
func (o *FriendApi) GetDesignatedFriendsApply(c *gin.Context) {
a2r.CallV2(relation.GetDesignatedFriendsApplyCaller.Invoke, c)
a2r.CallV2(c, relation.GetDesignatedFriendsApplyCaller.Invoke)
}
func (o *FriendApi) GetSelfApplyList(c *gin.Context) {
a2r.CallV2(relation.GetPaginationFriendsApplyFromCaller.Invoke, c)
a2r.CallV2(c, relation.GetPaginationFriendsApplyFromCaller.Invoke)
}
func (o *FriendApi) GetFriendList(c *gin.Context) {
a2r.CallV2(relation.GetPaginationFriendsCaller.Invoke, c)
a2r.CallV2(c, relation.GetPaginationFriendsCaller.Invoke)
}
func (o *FriendApi) GetDesignatedFriends(c *gin.Context) {
a2r.CallV2(relation.GetDesignatedFriendsCaller.Invoke, c)
a2r.CallV2(c, relation.GetDesignatedFriendsCaller.Invoke)
}
func (o *FriendApi) SetFriendRemark(c *gin.Context) {
a2r.CallV2(relation.SetFriendRemarkCaller.Invoke, c)
a2r.CallV2(c, relation.SetFriendRemarkCaller.Invoke)
}
func (o *FriendApi) AddBlack(c *gin.Context) {
a2r.CallV2(relation.AddBlackCaller.Invoke, c)
a2r.CallV2(c, relation.AddBlackCaller.Invoke)
}
func (o *FriendApi) GetPaginationBlacks(c *gin.Context) {
a2r.CallV2(relation.GetPaginationBlacksCaller.Invoke, c)
a2r.CallV2(c, relation.GetPaginationBlacksCaller.Invoke)
}
func (o *FriendApi) GetSpecifiedBlacks(c *gin.Context) {
a2r.CallV2(relation.GetSpecifiedBlacksCaller.Invoke, c)
a2r.CallV2(c, relation.GetSpecifiedBlacksCaller.Invoke)
}
func (o *FriendApi) RemoveBlack(c *gin.Context) {
a2r.CallV2(relation.RemoveBlackCaller.Invoke, c)
a2r.CallV2(c, relation.RemoveBlackCaller.Invoke)
}
func (o *FriendApi) ImportFriends(c *gin.Context) {
a2r.CallV2(relation.ImportFriendsCaller.Invoke, c)
a2r.CallV2(c, relation.ImportFriendsCaller.Invoke)
}
func (o *FriendApi) IsFriend(c *gin.Context) {
a2r.CallV2(relation.IsFriendCaller.Invoke, c)
a2r.CallV2(c, relation.IsFriendCaller.Invoke)
}
func (o *FriendApi) GetFriendIDs(c *gin.Context) {
a2r.CallV2(relation.GetFriendIDsCaller.Invoke, c)
a2r.CallV2(c, relation.GetFriendIDsCaller.Invoke)
}
func (o *FriendApi) GetSpecifiedFriendsInfo(c *gin.Context) {
a2r.CallV2(relation.GetSpecifiedFriendsInfoCaller.Invoke, c)
a2r.CallV2(c, relation.GetSpecifiedFriendsInfoCaller.Invoke)
}
func (o *FriendApi) UpdateFriends(c *gin.Context) {
a2r.CallV2(relation.UpdateFriendsCaller.Invoke, c)
a2r.CallV2(c, relation.UpdateFriendsCaller.Invoke)
}
func (o *FriendApi) GetIncrementalFriends(c *gin.Context) {
a2r.CallV2(relation.GetIncrementalFriendsCaller.Invoke, c)
a2r.CallV2(c, relation.GetIncrementalFriendsCaller.Invoke)
}
// GetIncrementalBlacks is temporarily unused.
// Deprecated: This function is currently unused and may be removed in future versions.
func (o *FriendApi) GetIncrementalBlacks(c *gin.Context) {
a2r.CallV2(relation.GetIncrementalBlacksCaller.Invoke, c)
a2r.CallV2(c, relation.GetIncrementalBlacksCaller.Invoke)
}
func (o *FriendApi) GetFullFriendUserIDs(c *gin.Context) {
a2r.CallV2(relation.GetFullFriendUserIDsCaller.Invoke, c)
a2r.CallV2(c, relation.GetFullFriendUserIDsCaller.Invoke)
}

64
internal/api/group.go
Unescape View File

@ -27,101 +27,101 @@ func NewGroupApi() GroupApi {
}
func (o *GroupApi) CreateGroup(c *gin.Context) {
a2r.CallV2(group.CreateGroupCaller.Invoke, c)
a2r.CallV2(c, group.CreateGroupCaller.Invoke)
}
func (o *GroupApi) SetGroupInfo(c *gin.Context) {
a2r.CallV2(group.SetGroupInfoCaller.Invoke, c)
a2r.CallV2(c, group.SetGroupInfoCaller.Invoke)
}
func (o *GroupApi) SetGroupInfoEx(c *gin.Context) {
a2r.CallV2(group.SetGroupInfoExCaller.Invoke, c)
a2r.CallV2(c, group.SetGroupInfoExCaller.Invoke)
}
func (o *GroupApi) JoinGroup(c *gin.Context) {
a2r.CallV2(group.JoinGroupCaller.Invoke, c)
a2r.CallV2(c, group.JoinGroupCaller.Invoke)
}
func (o *GroupApi) QuitGroup(c *gin.Context) {
a2r.CallV2(group.QuitGroupCaller.Invoke, c)
a2r.CallV2(c, group.QuitGroupCaller.Invoke)
}
func (o *GroupApi) ApplicationGroupResponse(c *gin.Context) {
a2r.CallV2(group.GroupApplicationResponseCaller.Invoke, c)
a2r.CallV2(c, group.GroupApplicationResponseCaller.Invoke)
}
func (o *GroupApi) TransferGroupOwner(c *gin.Context) {
a2r.CallV2(group.TransferGroupOwnerCaller.Invoke, c)
a2r.CallV2(c, group.TransferGroupOwnerCaller.Invoke)
}
func (o *GroupApi) GetRecvGroupApplicationList(c *gin.Context) {
a2r.CallV2(group.GetGroupApplicationListCaller.Invoke, c)
a2r.CallV2(c, group.GetGroupApplicationListCaller.Invoke)
}
func (o *GroupApi) GetUserReqGroupApplicationList(c *gin.Context) {
a2r.CallV2(group.GetUserReqApplicationListCaller.Invoke, c)
a2r.CallV2(c, group.GetUserReqApplicationListCaller.Invoke)
}
func (o *GroupApi) GetGroupUsersReqApplicationList(c *gin.Context) {
a2r.CallV2(group.GetGroupUsersReqApplicationListCaller.Invoke, c)
a2r.CallV2(c, group.GetGroupUsersReqApplicationListCaller.Invoke)
}
func (o *GroupApi) GetSpecifiedUserGroupRequestInfo(c *gin.Context) {
a2r.CallV2(group.GetSpecifiedUserGroupRequestInfoCaller.Invoke, c)
a2r.CallV2(c, group.GetSpecifiedUserGroupRequestInfoCaller.Invoke)
}
func (o *GroupApi) GetGroupsInfo(c *gin.Context) {
a2r.CallV2(group.GetGroupsInfoCaller.Invoke, c)
a2r.CallV2(c, group.GetGroupsInfoCaller.Invoke)
//a2r.Call(group.GroupClient.GetGroupsInfo, o.Client, c, a2r.NewNilReplaceOption(group.GroupClient.GetGroupsInfo))
}
func (o *GroupApi) KickGroupMember(c *gin.Context) {
a2r.CallV2(group.KickGroupMemberCaller.Invoke, c)
a2r.CallV2(c, group.KickGroupMemberCaller.Invoke)
}
func (o *GroupApi) GetGroupMembersInfo(c *gin.Context) {
a2r.CallV2(group.GetGroupMembersInfoCaller.Invoke, c)
a2r.CallV2(c, group.GetGroupMembersInfoCaller.Invoke)
//a2r.Call(group.GroupClient.GetGroupMembersInfo, o.Client, c, a2r.NewNilReplaceOption(group.GroupClient.GetGroupMembersInfo))
}
func (o *GroupApi) GetGroupMemberList(c *gin.Context) {
a2r.CallV2(group.GetGroupMemberListCaller.Invoke, c)
a2r.CallV2(c, group.GetGroupMemberListCaller.Invoke)
}
func (o *GroupApi) InviteUserToGroup(c *gin.Context) {
a2r.CallV2(group.InviteUserToGroupCaller.Invoke, c)
a2r.CallV2(c, group.InviteUserToGroupCaller.Invoke)
}
func (o *GroupApi) GetJoinedGroupList(c *gin.Context) {
a2r.CallV2(group.GetJoinedGroupListCaller.Invoke, c)
a2r.CallV2(c, group.GetJoinedGroupListCaller.Invoke)
}
func (o *GroupApi) DismissGroup(c *gin.Context) {
a2r.CallV2(group.DismissGroupCaller.Invoke, c)
a2r.CallV2(c, group.DismissGroupCaller.Invoke)
}
func (o *GroupApi) MuteGroupMember(c *gin.Context) {
a2r.CallV2(group.MuteGroupMemberCaller.Invoke, c)
a2r.CallV2(c, group.MuteGroupMemberCaller.Invoke)
}
func (o *GroupApi) CancelMuteGroupMember(c *gin.Context) {
a2r.CallV2(group.CancelMuteGroupMemberCaller.Invoke, c)
a2r.CallV2(c, group.CancelMuteGroupMemberCaller.Invoke)
}
func (o *GroupApi) MuteGroup(c *gin.Context) {
a2r.CallV2(group.MuteGroupCaller.Invoke, c)
a2r.CallV2(c, group.MuteGroupCaller.Invoke)
}
func (o *GroupApi) CancelMuteGroup(c *gin.Context) {
a2r.CallV2(group.CancelMuteGroupCaller.Invoke, c)
a2r.CallV2(c, group.CancelMuteGroupCaller.Invoke)
}
func (o *GroupApi) SetGroupMemberInfo(c *gin.Context) {
a2r.CallV2(group.SetGroupMemberInfoCaller.Invoke, c)
a2r.CallV2(c, group.SetGroupMemberInfoCaller.Invoke)
}
func (o *GroupApi) GetGroupAbstractInfo(c *gin.Context) {
a2r.CallV2(group.GetGroupAbstractInfoCaller.Invoke, c)
a2r.CallV2(c, group.GetGroupAbstractInfoCaller.Invoke)
}
// func (g *Group) SetGroupMemberNickname(c *gin.Context) {
@ -133,33 +133,33 @@ func (o *GroupApi) GetGroupAbstractInfo(c *gin.Context) {
//}
func (o *GroupApi) GroupCreateCount(c *gin.Context) {
a2r.CallV2(group.GroupCreateCountCaller.Invoke, c)
a2r.CallV2(c, group.GroupCreateCountCaller.Invoke)
}
func (o *GroupApi) GetGroups(c *gin.Context) {
a2r.CallV2(group.GetGroupsCaller.Invoke, c)
a2r.CallV2(c, group.GetGroupsCaller.Invoke)
}
func (o *GroupApi) GetGroupMemberUserIDs(c *gin.Context) {
a2r.CallV2(group.GetGroupMemberUserIDsCaller.Invoke, c)
a2r.CallV2(c, group.GetGroupMemberUserIDsCaller.Invoke)
}
func (o *GroupApi) GetIncrementalJoinGroup(c *gin.Context) {
a2r.CallV2(group.GetIncrementalJoinGroupCaller.Invoke, c)
a2r.CallV2(c, group.GetIncrementalJoinGroupCaller.Invoke)
}
func (o *GroupApi) GetIncrementalGroupMember(c *gin.Context) {
a2r.CallV2(group.GetIncrementalGroupMemberCaller.Invoke, c)
a2r.CallV2(c, group.GetIncrementalGroupMemberCaller.Invoke)
}
func (o *GroupApi) GetIncrementalGroupMemberBatch(c *gin.Context) {
a2r.CallV2(group.BatchGetIncrementalGroupMemberCaller.Invoke, c)
a2r.CallV2(c, group.BatchGetIncrementalGroupMemberCaller.Invoke)
}
func (o *GroupApi) GetFullGroupMemberUserIDs(c *gin.Context) {
a2r.CallV2(group.GetFullGroupMemberUserIDsCaller.Invoke, c)
a2r.CallV2(c, group.GetFullGroupMemberUserIDsCaller.Invoke)
}
func (o *GroupApi) GetFullJoinGroupIDs(c *gin.Context) {
a2r.CallV2(group.GetFullJoinGroupIDsCaller.Invoke, c)
a2r.CallV2(c, group.GetFullJoinGroupIDsCaller.Invoke)
}

40
internal/api/msg.go
Unescape View File

@ -105,51 +105,51 @@ func (m *MessageApi) newUserSendMsgReq(_ *gin.Context, params *apistruct.SendMsg
}
func (m *MessageApi) GetSeq(c *gin.Context) {
a2r.CallV2(msg.GetMaxSeqCaller.Invoke, c)
a2r.CallV2(c, msg.GetMaxSeqCaller.Invoke)
}
func (m *MessageApi) PullMsgBySeqs(c *gin.Context) {
a2r.CallV2(msg.PullMessageBySeqsCaller.Invoke, c)
a2r.CallV2(c, msg.PullMessageBySeqsCaller.Invoke)
}
func (m *MessageApi) RevokeMsg(c *gin.Context) {
a2r.CallV2(msg.RevokeMsgCaller.Invoke, c)
a2r.CallV2(c, msg.RevokeMsgCaller.Invoke)
}
func (m *MessageApi) MarkMsgsAsRead(c *gin.Context) {
a2r.CallV2(msg.MarkMsgsAsReadCaller.Invoke, c)
a2r.CallV2(c, msg.MarkMsgsAsReadCaller.Invoke)
}
func (m *MessageApi) MarkConversationAsRead(c *gin.Context) {
a2r.CallV2(msg.MarkConversationAsReadCaller.Invoke, c)
a2r.CallV2(c, msg.MarkConversationAsReadCaller.Invoke)
}
func (m *MessageApi) GetConversationsHasReadAndMaxSeq(c *gin.Context) {
a2r.CallV2(msg.GetConversationsHasReadAndMaxSeqCaller.Invoke, c)
a2r.CallV2(c, msg.GetConversationsHasReadAndMaxSeqCaller.Invoke)
}
func (m *MessageApi) SetConversationHasReadSeq(c *gin.Context) {
a2r.CallV2(msg.SetConversationHasReadSeqCaller.Invoke, c)
a2r.CallV2(c, msg.SetConversationHasReadSeqCaller.Invoke)
}
func (m *MessageApi) ClearConversationsMsg(c *gin.Context) {
a2r.CallV2(msg.ClearConversationsMsgCaller.Invoke, c)
a2r.CallV2(c, msg.ClearConversationsMsgCaller.Invoke)
}
func (m *MessageApi) UserClearAllMsg(c *gin.Context) {
a2r.CallV2(msg.UserClearAllMsgCaller.Invoke, c)
a2r.CallV2(c, msg.UserClearAllMsgCaller.Invoke)
}
func (m *MessageApi) DeleteMsgs(c *gin.Context) {
a2r.CallV2(msg.DeleteMsgsCaller.Invoke, c)
a2r.CallV2(c, msg.DeleteMsgsCaller.Invoke)
}
func (m *MessageApi) DeleteMsgPhysicalBySeq(c *gin.Context) {
a2r.CallV2(msg.DeleteMsgPhysicalBySeqCaller.Invoke, c)
a2r.CallV2(c, msg.DeleteMsgPhysicalBySeqCaller.Invoke)
}
func (m *MessageApi) DeleteMsgPhysical(c *gin.Context) {
a2r.CallV2(msg.DeleteMsgPhysicalCaller.Invoke, c)
a2r.CallV2(c, msg.DeleteMsgPhysicalCaller.Invoke)
}
func (m *MessageApi) getSendMsgReq(c *gin.Context, req apistruct.SendMsg) (sendMsgReq *msg.SendMsgReq, err error) {
@ -355,33 +355,33 @@ func (m *MessageApi) BatchSendMsg(c *gin.Context) {
}
func (m *MessageApi) CheckMsgIsSendSuccess(c *gin.Context) {
a2r.CallV2(msg.GetSendMsgStatusCaller.Invoke, c)
a2r.CallV2(c, msg.GetSendMsgStatusCaller.Invoke)
}
func (m *MessageApi) GetUsersOnlineStatus(c *gin.Context) {
a2r.CallV2(msg.GetSendMsgStatusCaller.Invoke, c)
a2r.CallV2(c, msg.GetSendMsgStatusCaller.Invoke)
}
func (m *MessageApi) GetActiveUser(c *gin.Context) {
a2r.CallV2(msg.GetActiveUserCaller.Invoke, c)
a2r.CallV2(c, msg.GetActiveUserCaller.Invoke)
}
func (m *MessageApi) GetActiveGroup(c *gin.Context) {
a2r.CallV2(msg.GetActiveGroupCaller.Invoke, c)
a2r.CallV2(c, msg.GetActiveGroupCaller.Invoke)
}
func (m *MessageApi) SearchMsg(c *gin.Context) {
a2r.CallV2(msg.SearchMessageCaller.Invoke, c)
a2r.CallV2(c, msg.SearchMessageCaller.Invoke)
}
func (m *MessageApi) GetServerTime(c *gin.Context) {
a2r.CallV2(msg.GetServerTimeCaller.Invoke, c)
a2r.CallV2(c, msg.GetServerTimeCaller.Invoke)
}
func (m *MessageApi) GetStreamMsg(c *gin.Context) {
a2r.CallV2(msg.GetStreamMsgCaller.Invoke, c)
a2r.CallV2(c, msg.GetStreamMsgCaller.Invoke)
}
func (m *MessageApi) AppendStreamMsg(c *gin.Context) {
a2r.CallV2(msg.AppendStreamMsgCaller.Invoke, c)
a2r.CallV2(c, msg.AppendStreamMsgCaller.Invoke)
}

2
internal/api/statistics.go
Unescape View File

@ -27,5 +27,5 @@ func NewStatisticsApi() StatisticsApi {
}
func (s *StatisticsApi) UserRegister(c *gin.Context) {
a2r.CallV2(user.UserRegisterCountCaller.Invoke, c)
a2r.CallV2(c, user.UserRegisterCountCaller.Invoke)
}

26
internal/api/third.go
Unescape View File

@ -40,11 +40,11 @@ func NewThirdApi(grafanaUrl string) ThirdApi {
}
func (o *ThirdApi) FcmUpdateToken(c *gin.Context) {
a2r.CallV2(third.FcmUpdateTokenCaller.Invoke, c)
a2r.CallV2(c, third.FcmUpdateTokenCaller.Invoke)
}
func (o *ThirdApi) SetAppBadge(c *gin.Context) {
a2r.CallV2(third.SetAppBadgeCaller.Invoke, c)
a2r.CallV2(c, third.SetAppBadgeCaller.Invoke)
}
// #################### s3 ####################
@ -79,44 +79,44 @@ func setURLPrefix(c *gin.Context, urlPrefix *string) error {
}
func (o *ThirdApi) PartLimit(c *gin.Context) {
a2r.CallV2(third.PartLimitCaller.Invoke, c)
a2r.CallV2(c, third.PartLimitCaller.Invoke)
}
func (o *ThirdApi) PartSize(c *gin.Context) {
a2r.CallV2(third.PartSizeCaller.Invoke, c)
a2r.CallV2(c, third.PartSizeCaller.Invoke)
}
func (o *ThirdApi) InitiateMultipartUpload(c *gin.Context) {
opt := setURLPrefixOption(third.ThirdClient.InitiateMultipartUpload, func(req *third.InitiateMultipartUploadReq) error {
return setURLPrefix(c, &req.UrlPrefix)
})
a2r.CallV2(third.InitiateMultipartUploadCaller.Invoke, c, opt)
a2r.CallV2(c, third.InitiateMultipartUploadCaller.Invoke, opt)
}
func (o *ThirdApi) AuthSign(c *gin.Context) {
a2r.CallV2(third.AuthSignCaller.Invoke, c)
a2r.CallV2(c, third.AuthSignCaller.Invoke)
}
func (o *ThirdApi) CompleteMultipartUpload(c *gin.Context) {
opt := setURLPrefixOption(third.ThirdClient.CompleteMultipartUpload, func(req *third.CompleteMultipartUploadReq) error {
return setURLPrefix(c, &req.UrlPrefix)
})
a2r.CallV2(third.CompleteMultipartUploadCaller.Invoke, c, opt)
a2r.CallV2(c, third.CompleteMultipartUploadCaller.Invoke, opt)
}
func (o *ThirdApi) AccessURL(c *gin.Context) {
a2r.CallV2(third.AccessURLCaller.Invoke, c)
a2r.CallV2(c, third.AccessURLCaller.Invoke)
}
func (o *ThirdApi) InitiateFormData(c *gin.Context) {
a2r.CallV2(third.InitiateFormDataCaller.Invoke, c)
a2r.CallV2(c, third.InitiateFormDataCaller.Invoke)
}
func (o *ThirdApi) CompleteFormData(c *gin.Context) {
opt := setURLPrefixOption(third.ThirdClient.CompleteFormData, func(req *third.CompleteFormDataReq) error {
return setURLPrefix(c, &req.UrlPrefix)
})
a2r.CallV2(third.CompleteFormDataCaller.Invoke, c, opt)
a2r.CallV2(c, third.CompleteFormDataCaller.Invoke, opt)
}
func (o *ThirdApi) ObjectRedirect(c *gin.Context) {
@ -158,15 +158,15 @@ func (o *ThirdApi) ObjectRedirect(c *gin.Context) {
// #################### logs ####################.
func (o *ThirdApi) UploadLogs(c *gin.Context) {
a2r.CallV2(third.UploadLogsCaller.Invoke, c)
a2r.CallV2(c, third.UploadLogsCaller.Invoke)
}
func (o *ThirdApi) DeleteLogs(c *gin.Context) {
a2r.CallV2(third.DeleteLogsCaller.Invoke, c)
a2r.CallV2(c, third.DeleteLogsCaller.Invoke)
}
func (o *ThirdApi) SearchLogs(c *gin.Context) {
a2r.CallV2(third.SearchLogsCaller.Invoke, c)
a2r.CallV2(c, third.SearchLogsCaller.Invoke)
}
func (o *ThirdApi) GetPrometheus(c *gin.Context) {

40
internal/api/user.go
Unescape View File

@ -39,35 +39,35 @@ func NewUserApi(discov discovery.SvcDiscoveryRegistry, messageGateWayRpcName str
}
func (u *UserApi) UserRegister(c *gin.Context) {
a2r.CallV2(user.UserRegisterCaller.Invoke, c)
a2r.CallV2(c, user.UserRegisterCaller.Invoke)
}
// UpdateUserInfo is deprecated. Use UpdateUserInfoEx
func (u *UserApi) UpdateUserInfo(c *gin.Context) {
a2r.CallV2(user.UpdateUserInfoCaller.Invoke, c)
a2r.CallV2(c, user.UpdateUserInfoCaller.Invoke)
}
func (u *UserApi) UpdateUserInfoEx(c *gin.Context) {
a2r.CallV2(user.UpdateUserInfoExCaller.Invoke, c)
a2r.CallV2(c, user.UpdateUserInfoExCaller.Invoke)
}
func (u *UserApi) SetGlobalRecvMessageOpt(c *gin.Context) {
a2r.CallV2(user.SetGlobalRecvMessageOptCaller.Invoke, c)
a2r.CallV2(c, user.SetGlobalRecvMessageOptCaller.Invoke)
}
func (u *UserApi) GetUsersPublicInfo(c *gin.Context) {
a2r.CallV2(user.GetDesignateUsersCaller.Invoke, c)
a2r.CallV2(c, user.GetDesignateUsersCaller.Invoke)
}
func (u *UserApi) GetAllUsersID(c *gin.Context) {
a2r.CallV2(user.GetAllUserIDCaller.Invoke, c)
a2r.CallV2(c, user.GetAllUserIDCaller.Invoke)
}
func (u *UserApi) AccountCheck(c *gin.Context) {
a2r.CallV2(user.AccountCheckCaller.Invoke, c)
a2r.CallV2(c, user.AccountCheckCaller.Invoke)
}
func (u *UserApi) GetUsers(c *gin.Context) {
a2r.CallV2(user.GetPaginationUsersCaller.Invoke, c)
a2r.CallV2(c, user.GetPaginationUsersCaller.Invoke)
}
// GetUsersOnlineStatus Get user online status.
@ -128,7 +128,7 @@ func (u *UserApi) GetUsersOnlineStatus(c *gin.Context) {
}
func (u *UserApi) UserRegisterCount(c *gin.Context) {
a2r.CallV2(user.UserRegisterCountCaller.Invoke, c)
a2r.CallV2(c, user.UserRegisterCountCaller.Invoke)
}
// GetUsersOnlineTokenDetail Get user online token details.
@ -194,52 +194,52 @@ func (u *UserApi) GetUsersOnlineTokenDetail(c *gin.Context) {
// SubscriberStatus Presence status of subscribed users.
func (u *UserApi) SubscriberStatus(c *gin.Context) {
a2r.CallV2(user.SubscribeOrCancelUsersStatusCaller.Invoke, c)
a2r.CallV2(c, user.SubscribeOrCancelUsersStatusCaller.Invoke)
}
// GetUserStatus Get the online status of the user.
func (u *UserApi) GetUserStatus(c *gin.Context) {
a2r.CallV2(user.GetUserStatusCaller.Invoke, c)
a2r.CallV2(c, user.GetUserStatusCaller.Invoke)
}
// GetSubscribeUsersStatus Get the online status of subscribers.
func (u *UserApi) GetSubscribeUsersStatus(c *gin.Context) {
a2r.CallV2(user.GetSubscribeUsersStatusCaller.Invoke, c)
a2r.CallV2(c, user.GetSubscribeUsersStatusCaller.Invoke)
}
// ProcessUserCommandAdd user general function add.
func (u *UserApi) ProcessUserCommandAdd(c *gin.Context) {
a2r.CallV2(user.ProcessUserCommandAddCaller.Invoke, c)
a2r.CallV2(c, user.ProcessUserCommandAddCaller.Invoke)
}
// ProcessUserCommandDelete user general function delete.
func (u *UserApi) ProcessUserCommandDelete(c *gin.Context) {
a2r.CallV2(user.ProcessUserCommandDeleteCaller.Invoke, c)
a2r.CallV2(c, user.ProcessUserCommandDeleteCaller.Invoke)
}
// ProcessUserCommandUpdate user general function update.
func (u *UserApi) ProcessUserCommandUpdate(c *gin.Context) {
a2r.CallV2(user.ProcessUserCommandUpdateCaller.Invoke, c)
a2r.CallV2(c, user.ProcessUserCommandUpdateCaller.Invoke)
}
// ProcessUserCommandGet user general function get.
func (u *UserApi) ProcessUserCommandGet(c *gin.Context) {
a2r.CallV2(user.ProcessUserCommandGetCaller.Invoke, c)
a2r.CallV2(c, user.ProcessUserCommandGetCaller.Invoke)
}
// ProcessUserCommandGet user general function get all.
func (u *UserApi) ProcessUserCommandGetAll(c *gin.Context) {
a2r.CallV2(user.ProcessUserCommandGetAllCaller.Invoke, c)
a2r.CallV2(c, user.ProcessUserCommandGetAllCaller.Invoke)
}
func (u *UserApi) AddNotificationAccount(c *gin.Context) {
a2r.CallV2(user.AddNotificationAccountCaller.Invoke, c)
a2r.CallV2(c, user.AddNotificationAccountCaller.Invoke)
}
func (u *UserApi) UpdateNotificationAccountInfo(c *gin.Context) {
a2r.CallV2(user.UpdateNotificationAccountInfoCaller.Invoke, c)
a2r.CallV2(c, user.UpdateNotificationAccountInfoCaller.Invoke)
}
func (u *UserApi) SearchNotificationAccount(c *gin.Context) {
a2r.CallV2(user.SearchNotificationAccountCaller.Invoke, c)
a2r.CallV2(c, user.SearchNotificationAccountCaller.Invoke)
}

Write Preview
Loading…
Cancel
Save