Skip to content

Commit

Permalink
Merge pull request #169 from icey-yu/feat-gen
Browse files Browse the repository at this point in the history
feat: gen rpc_caller magefile
  • Loading branch information
icey-yu authored Dec 13, 2024
2 parents 9a0dcae + 6435879 commit 3585a35
Show file tree
Hide file tree
Showing 13 changed files with 879 additions and 1 deletion.
5 changes: 4 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,4 +5,7 @@ go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@latest
```

More to read [regenerate-grpc-code](https://grpc.io/docs/languages/go/quickstart/#regenerate-grpc-code).
More to read [regenerate-grpc-code](https://grpc.io/docs/languages/go/quickstart/#regenerate-grpc-code).


- Run `mage` to gen rpc_caller.
24 changes: 24 additions & 0 deletions auth/auth_caller.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
package auth

import (
"github.com/openimsdk/protocol/rpccall"
"google.golang.org/grpc"
)

func InitAuth(conn *grpc.ClientConn) {
GetAdminTokenCaller.SetConn(conn)
GetUserTokenCaller.SetConn(conn)
ForceLogoutCaller.SetConn(conn)
ParseTokenCaller.SetConn(conn)
InvalidateTokenCaller.SetConn(conn)
KickTokensCaller.SetConn(conn)
}

var (
GetAdminTokenCaller = rpccall.NewRpcCaller[GetAdminTokenReq, GetAdminTokenResp](Auth_GetAdminToken_FullMethodName)
GetUserTokenCaller = rpccall.NewRpcCaller[GetUserTokenReq, GetUserTokenResp](Auth_GetUserToken_FullMethodName)
ForceLogoutCaller = rpccall.NewRpcCaller[ForceLogoutReq, ForceLogoutResp](Auth_ForceLogout_FullMethodName)
ParseTokenCaller = rpccall.NewRpcCaller[ParseTokenReq, ParseTokenResp](Auth_ParseToken_FullMethodName)
InvalidateTokenCaller = rpccall.NewRpcCaller[InvalidateTokenReq, InvalidateTokenResp](Auth_InvalidateToken_FullMethodName)
KickTokensCaller = rpccall.NewRpcCaller[KickTokensReq, KickTokensResp](Auth_KickTokens_FullMethodName)
)
58 changes: 58 additions & 0 deletions conversation/conversation_caller.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,58 @@
package conversation

import (
"github.com/openimsdk/protocol/rpccall"
"google.golang.org/grpc"
)

func InitConversation(conn *grpc.ClientConn) {
GetConversationCaller.SetConn(conn)
GetSortedConversationListCaller.SetConn(conn)
GetAllConversationsCaller.SetConn(conn)
GetConversationsCaller.SetConn(conn)
SetConversationCaller.SetConn(conn)
GetRecvMsgNotNotifyUserIDsCaller.SetConn(conn)
CreateSingleChatConversationsCaller.SetConn(conn)
CreateGroupChatConversationsCaller.SetConn(conn)
SetConversationMaxSeqCaller.SetConn(conn)
SetConversationMinSeqCaller.SetConn(conn)
GetConversationIDsCaller.SetConn(conn)
SetConversationsCaller.SetConn(conn)
GetUserConversationIDsHashCaller.SetConn(conn)
GetConversationsByConversationIDCaller.SetConn(conn)
GetConversationOfflinePushUserIDsCaller.SetConn(conn)
GetConversationNotReceiveMessageUserIDsCaller.SetConn(conn)
UpdateConversationCaller.SetConn(conn)
GetFullOwnerConversationIDsCaller.SetConn(conn)
GetIncrementalConversationCaller.SetConn(conn)
GetOwnerConversationCaller.SetConn(conn)
GetConversationsNeedClearMsgCaller.SetConn(conn)
GetNotNotifyConversationIDsCaller.SetConn(conn)
GetPinnedConversationIDsCaller.SetConn(conn)
}

var (
GetConversationCaller = rpccall.NewRpcCaller[GetConversationReq, GetConversationResp](Conversation_GetConversation_FullMethodName)
GetSortedConversationListCaller = rpccall.NewRpcCaller[GetSortedConversationListReq, GetSortedConversationListResp](Conversation_GetSortedConversationList_FullMethodName)
GetAllConversationsCaller = rpccall.NewRpcCaller[GetAllConversationsReq, GetAllConversationsResp](Conversation_GetAllConversations_FullMethodName)
GetConversationsCaller = rpccall.NewRpcCaller[GetConversationsReq, GetConversationsResp](Conversation_GetConversations_FullMethodName)
SetConversationCaller = rpccall.NewRpcCaller[SetConversationReq, SetConversationResp](Conversation_SetConversation_FullMethodName)
GetRecvMsgNotNotifyUserIDsCaller = rpccall.NewRpcCaller[GetRecvMsgNotNotifyUserIDsReq, GetRecvMsgNotNotifyUserIDsResp](Conversation_GetRecvMsgNotNotifyUserIDs_FullMethodName)
CreateSingleChatConversationsCaller = rpccall.NewRpcCaller[CreateSingleChatConversationsReq, CreateSingleChatConversationsResp](Conversation_CreateSingleChatConversations_FullMethodName)
CreateGroupChatConversationsCaller = rpccall.NewRpcCaller[CreateGroupChatConversationsReq, CreateGroupChatConversationsResp](Conversation_CreateGroupChatConversations_FullMethodName)
SetConversationMaxSeqCaller = rpccall.NewRpcCaller[SetConversationMaxSeqReq, SetConversationMaxSeqResp](Conversation_SetConversationMaxSeq_FullMethodName)
SetConversationMinSeqCaller = rpccall.NewRpcCaller[SetConversationMinSeqReq, SetConversationMinSeqResp](Conversation_SetConversationMinSeq_FullMethodName)
GetConversationIDsCaller = rpccall.NewRpcCaller[GetConversationIDsReq, GetConversationIDsResp](Conversation_GetConversationIDs_FullMethodName)
SetConversationsCaller = rpccall.NewRpcCaller[SetConversationsReq, SetConversationsResp](Conversation_SetConversations_FullMethodName)
GetUserConversationIDsHashCaller = rpccall.NewRpcCaller[GetUserConversationIDsHashReq, GetUserConversationIDsHashResp](Conversation_GetUserConversationIDsHash_FullMethodName)
GetConversationsByConversationIDCaller = rpccall.NewRpcCaller[GetConversationsByConversationIDReq, GetConversationsByConversationIDResp](Conversation_GetConversationsByConversationID_FullMethodName)
GetConversationOfflinePushUserIDsCaller = rpccall.NewRpcCaller[GetConversationOfflinePushUserIDsReq, GetConversationOfflinePushUserIDsResp](Conversation_GetConversationOfflinePushUserIDs_FullMethodName)
GetConversationNotReceiveMessageUserIDsCaller = rpccall.NewRpcCaller[GetConversationNotReceiveMessageUserIDsReq, GetConversationNotReceiveMessageUserIDsResp](Conversation_GetConversationNotReceiveMessageUserIDs_FullMethodName)
UpdateConversationCaller = rpccall.NewRpcCaller[UpdateConversationReq, UpdateConversationResp](Conversation_UpdateConversation_FullMethodName)
GetFullOwnerConversationIDsCaller = rpccall.NewRpcCaller[GetFullOwnerConversationIDsReq, GetFullOwnerConversationIDsResp](Conversation_GetFullOwnerConversationIDs_FullMethodName)
GetIncrementalConversationCaller = rpccall.NewRpcCaller[GetIncrementalConversationReq, GetIncrementalConversationResp](Conversation_GetIncrementalConversation_FullMethodName)
GetOwnerConversationCaller = rpccall.NewRpcCaller[GetOwnerConversationReq, GetOwnerConversationResp](Conversation_GetOwnerConversation_FullMethodName)
GetConversationsNeedClearMsgCaller = rpccall.NewRpcCaller[GetConversationsNeedClearMsgReq, GetConversationsNeedClearMsgResp](Conversation_GetConversationsNeedClearMsg_FullMethodName)
GetNotNotifyConversationIDsCaller = rpccall.NewRpcCaller[GetNotNotifyConversationIDsReq, GetNotNotifyConversationIDsResp](Conversation_GetNotNotifyConversationIDs_FullMethodName)
GetPinnedConversationIDsCaller = rpccall.NewRpcCaller[GetPinnedConversationIDsReq, GetPinnedConversationIDsResp](Conversation_GetPinnedConversationIDs_FullMethodName)
)
88 changes: 88 additions & 0 deletions group/group_caller.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,88 @@
package group

import (
"github.com/openimsdk/protocol/rpccall"
"google.golang.org/grpc"
)

func InitGroup(conn *grpc.ClientConn) {
CreateGroupCaller.SetConn(conn)
JoinGroupCaller.SetConn(conn)
QuitGroupCaller.SetConn(conn)
GetGroupsInfoCaller.SetConn(conn)
SetGroupInfoCaller.SetConn(conn)
SetGroupInfoExCaller.SetConn(conn)
GetGroupApplicationListCaller.SetConn(conn)
GetUserReqApplicationListCaller.SetConn(conn)
GetGroupUsersReqApplicationListCaller.SetConn(conn)
GetSpecifiedUserGroupRequestInfoCaller.SetConn(conn)
TransferGroupOwnerCaller.SetConn(conn)
GroupApplicationResponseCaller.SetConn(conn)
GetGroupMemberListCaller.SetConn(conn)
GetGroupMembersInfoCaller.SetConn(conn)
KickGroupMemberCaller.SetConn(conn)
GetJoinedGroupListCaller.SetConn(conn)
InviteUserToGroupCaller.SetConn(conn)
GetGroupsCaller.SetConn(conn)
GetGroupMembersCMSCaller.SetConn(conn)
DismissGroupCaller.SetConn(conn)
MuteGroupMemberCaller.SetConn(conn)
CancelMuteGroupMemberCaller.SetConn(conn)
MuteGroupCaller.SetConn(conn)
CancelMuteGroupCaller.SetConn(conn)
SetGroupMemberInfoCaller.SetConn(conn)
GetGroupAbstractInfoCaller.SetConn(conn)
GetUserInGroupMembersCaller.SetConn(conn)
GetGroupMemberUserIDsCaller.SetConn(conn)
GetGroupMemberRoleLevelCaller.SetConn(conn)
GetGroupInfoCacheCaller.SetConn(conn)
GetGroupMemberCacheCaller.SetConn(conn)
GroupCreateCountCaller.SetConn(conn)
NotificationUserInfoUpdateCaller.SetConn(conn)
GetIncrementalGroupMemberCaller.SetConn(conn)
BatchGetIncrementalGroupMemberCaller.SetConn(conn)
GetIncrementalJoinGroupCaller.SetConn(conn)
GetFullGroupMemberUserIDsCaller.SetConn(conn)
GetFullJoinGroupIDsCaller.SetConn(conn)
}

var (
CreateGroupCaller = rpccall.NewRpcCaller[CreateGroupReq, CreateGroupResp](Group_CreateGroup_FullMethodName)
JoinGroupCaller = rpccall.NewRpcCaller[JoinGroupReq, JoinGroupResp](Group_JoinGroup_FullMethodName)
QuitGroupCaller = rpccall.NewRpcCaller[QuitGroupReq, QuitGroupResp](Group_QuitGroup_FullMethodName)
GetGroupsInfoCaller = rpccall.NewRpcCaller[GetGroupsInfoReq, GetGroupsInfoResp](Group_GetGroupsInfo_FullMethodName)
SetGroupInfoCaller = rpccall.NewRpcCaller[SetGroupInfoReq, SetGroupInfoResp](Group_SetGroupInfo_FullMethodName)
SetGroupInfoExCaller = rpccall.NewRpcCaller[SetGroupInfoExReq, SetGroupInfoExResp](Group_SetGroupInfoEx_FullMethodName)
GetGroupApplicationListCaller = rpccall.NewRpcCaller[GetGroupApplicationListReq, GetGroupApplicationListResp](Group_GetGroupApplicationList_FullMethodName)
GetUserReqApplicationListCaller = rpccall.NewRpcCaller[GetUserReqApplicationListReq, GetUserReqApplicationListResp](Group_GetUserReqApplicationList_FullMethodName)
GetGroupUsersReqApplicationListCaller = rpccall.NewRpcCaller[GetGroupUsersReqApplicationListReq, GetGroupUsersReqApplicationListResp](Group_GetGroupUsersReqApplicationList_FullMethodName)
GetSpecifiedUserGroupRequestInfoCaller = rpccall.NewRpcCaller[GetSpecifiedUserGroupRequestInfoReq, GetSpecifiedUserGroupRequestInfoResp](Group_GetSpecifiedUserGroupRequestInfo_FullMethodName)
TransferGroupOwnerCaller = rpccall.NewRpcCaller[TransferGroupOwnerReq, TransferGroupOwnerResp](Group_TransferGroupOwner_FullMethodName)
GroupApplicationResponseCaller = rpccall.NewRpcCaller[GroupApplicationResponseReq, GroupApplicationResponseResp](Group_GroupApplicationResponse_FullMethodName)
GetGroupMemberListCaller = rpccall.NewRpcCaller[GetGroupMemberListReq, GetGroupMemberListResp](Group_GetGroupMemberList_FullMethodName)
GetGroupMembersInfoCaller = rpccall.NewRpcCaller[GetGroupMembersInfoReq, GetGroupMembersInfoResp](Group_GetGroupMembersInfo_FullMethodName)
KickGroupMemberCaller = rpccall.NewRpcCaller[KickGroupMemberReq, KickGroupMemberResp](Group_KickGroupMember_FullMethodName)
GetJoinedGroupListCaller = rpccall.NewRpcCaller[GetJoinedGroupListReq, GetJoinedGroupListResp](Group_GetJoinedGroupList_FullMethodName)
InviteUserToGroupCaller = rpccall.NewRpcCaller[InviteUserToGroupReq, InviteUserToGroupResp](Group_InviteUserToGroup_FullMethodName)
GetGroupsCaller = rpccall.NewRpcCaller[GetGroupsReq, GetGroupsResp](Group_GetGroups_FullMethodName)
GetGroupMembersCMSCaller = rpccall.NewRpcCaller[GetGroupMembersCMSReq, GetGroupMembersCMSResp](Group_GetGroupMembersCMS_FullMethodName)
DismissGroupCaller = rpccall.NewRpcCaller[DismissGroupReq, DismissGroupResp](Group_DismissGroup_FullMethodName)
MuteGroupMemberCaller = rpccall.NewRpcCaller[MuteGroupMemberReq, MuteGroupMemberResp](Group_MuteGroupMember_FullMethodName)
CancelMuteGroupMemberCaller = rpccall.NewRpcCaller[CancelMuteGroupMemberReq, CancelMuteGroupMemberResp](Group_CancelMuteGroupMember_FullMethodName)
MuteGroupCaller = rpccall.NewRpcCaller[MuteGroupReq, MuteGroupResp](Group_MuteGroup_FullMethodName)
CancelMuteGroupCaller = rpccall.NewRpcCaller[CancelMuteGroupReq, CancelMuteGroupResp](Group_CancelMuteGroup_FullMethodName)
SetGroupMemberInfoCaller = rpccall.NewRpcCaller[SetGroupMemberInfoReq, SetGroupMemberInfoResp](Group_SetGroupMemberInfo_FullMethodName)
GetGroupAbstractInfoCaller = rpccall.NewRpcCaller[GetGroupAbstractInfoReq, GetGroupAbstractInfoResp](Group_GetGroupAbstractInfo_FullMethodName)
GetUserInGroupMembersCaller = rpccall.NewRpcCaller[GetUserInGroupMembersReq, GetUserInGroupMembersResp](Group_GetUserInGroupMembers_FullMethodName)
GetGroupMemberUserIDsCaller = rpccall.NewRpcCaller[GetGroupMemberUserIDsReq, GetGroupMemberUserIDsResp](Group_GetGroupMemberUserIDs_FullMethodName)
GetGroupMemberRoleLevelCaller = rpccall.NewRpcCaller[GetGroupMemberRoleLevelReq, GetGroupMemberRoleLevelResp](Group_GetGroupMemberRoleLevel_FullMethodName)
GetGroupInfoCacheCaller = rpccall.NewRpcCaller[GetGroupInfoCacheReq, GetGroupInfoCacheResp](Group_GetGroupInfoCache_FullMethodName)
GetGroupMemberCacheCaller = rpccall.NewRpcCaller[GetGroupMemberCacheReq, GetGroupMemberCacheResp](Group_GetGroupMemberCache_FullMethodName)
GroupCreateCountCaller = rpccall.NewRpcCaller[GroupCreateCountReq, GroupCreateCountResp](Group_GroupCreateCount_FullMethodName)
NotificationUserInfoUpdateCaller = rpccall.NewRpcCaller[NotificationUserInfoUpdateReq, NotificationUserInfoUpdateResp](Group_NotificationUserInfoUpdate_FullMethodName)
GetIncrementalGroupMemberCaller = rpccall.NewRpcCaller[GetIncrementalGroupMemberReq, GetIncrementalGroupMemberResp](Group_GetIncrementalGroupMember_FullMethodName)
BatchGetIncrementalGroupMemberCaller = rpccall.NewRpcCaller[BatchGetIncrementalGroupMemberReq, BatchGetIncrementalGroupMemberResp](Group_BatchGetIncrementalGroupMember_FullMethodName)
GetIncrementalJoinGroupCaller = rpccall.NewRpcCaller[GetIncrementalJoinGroupReq, GetIncrementalJoinGroupResp](Group_GetIncrementalJoinGroup_FullMethodName)
GetFullGroupMemberUserIDsCaller = rpccall.NewRpcCaller[GetFullGroupMemberUserIDsReq, GetFullGroupMemberUserIDsResp](Group_GetFullGroupMemberUserIDs_FullMethodName)
GetFullJoinGroupIDsCaller = rpccall.NewRpcCaller[GetFullJoinGroupIDsReq, GetFullJoinGroupIDsResp](Group_GetFullJoinGroupIDs_FullMethodName)
)
Loading

0 comments on commit 3585a35

Please sign in to comment.