feat(im-sdk): 添加 Flutter IM SDK 和 Go 服务端 SDK

- 实现了完整的 Flutter IM SDK，支持消息发送、历史记录、会话管理、好友功能和群组操作
- 添加了 Go 服务端 SDK 骨架，包含登录、消息发送、撤回、编辑等核心功能
- 实现了认证和授权机制，支持 token 管理和请求签名验证
- 添加了会话列表、好友申请、群组管理和消息搜索功能
- 提供了用户资料管理、头像上传和账户导入导出功能
- 实现了消息撤回、编辑和已读状态管理功能
- 添加了群组加入申请、审批和成员管理功能
- 提供了消息历史分页查询和定位功能
- 实现了会话置顶、免打扰和草稿保存功能
- 添加了用户和群组搜索功能，支持关键词检索

src/im/ImClient.ts

@@ -49,7 +49,14 @@ export class ImClient {
       try {
         const frame = JSON.parse(event.data as string)
         if (frame.type === 'MESSAGE') {
-          this.emit('message', this.normalizeMessage(frame.payload as ImMessage))
+          const message = this.normalizeMessage(frame.payload as ImMessage)
+          if (message.status === 'READ') {
+            this.emit('read', message)
+          }
+          if (message.revoked || message.status === 'REVOKED' || message.msgType === 'REVOKED') {
+            this.emit('revoke', { msgId: message.id, operatorId: message.fromId ?? message.fromUserId })
+          }
+          this.emit('message', message)
         } else if (frame.type === 'REVOKE') {
           this.emit('revoke', frame.payload as { msgId: string; operatorId: string })
         }

src/im/api.ts

@@ -3,7 +3,10 @@ import { http } from '../core/http'
 import type {
   ChatType,
   ConversationView,
+  FriendRequest,
   HistoryQuery,
+  GroupJoinRequest,
+  ImGroup,
   ImMessage,
   PageResult,
   UserProfile,
@@ -45,6 +48,54 @@ export function fetchGroupHistory(groupId: string, query: HistoryQuery = {}): Pr
   )
 }
 
+export async function locateHistoryPage(
+  toId: string,
+  messageId: string,
+  pageSize = 20,
+  maxPages = 20,
+): Promise<ImMessage[] | null> {
+  for (let page = 0; page < Math.max(maxPages, 1); page += 1) {
+    const result = await fetchHistory(toId, { page, size: pageSize })
+    if (result.content.some((item) => item.id === messageId)) {
+      return result.content
+    }
+    if (result.content.length < pageSize) return null
+  }
+  return null
+}
+
+export async function locateGroupHistoryPage(
+  groupId: string,
+  messageId: string,
+  pageSize = 20,
+  maxPages = 20,
+): Promise<ImMessage[] | null> {
+  for (let page = 0; page < Math.max(maxPages, 1); page += 1) {
+    const result = await fetchGroupHistory(groupId, { page, size: pageSize })
+    if (result.content.some((item) => item.id === messageId)) {
+      return result.content
+    }
+    if (result.content.length < pageSize) return null
+  }
+  return null
+}
+
+export function editMessage(messageId: string, content: string): Promise<ImMessage> {
+  return http.put<ImMessage>(
+    `/api/im/messages/${encodeURIComponent(messageId)}`,
+    { content },
+    appQuery(),
+  )
+}
+
+export function revokeMessage(messageId: string): Promise<ImMessage> {
+  return http.post<ImMessage>(
+    `/api/im/messages/${encodeURIComponent(messageId)}/revoke`,
+    undefined,
+    appQuery(),
+  )
+}
+
 export function markRead(targetId: string, chatType: ChatType = 'SINGLE'): Promise<void> {
   return http.put<void>(
     `/api/im/conversations/${encodeURIComponent(targetId)}/read`,
@@ -100,3 +151,99 @@ export function updateProfile(
     appQuery({ nickname, avatar, gender }),
   )
 }
+
+export function listFriends(): Promise<string[]> {
+  return http.get<string[]>('/api/im/friends', appQuery())
+}
+
+export function listGroups(): Promise<ImGroup[]> {
+  return http.get<ImGroup[]>('/api/im/groups', appQuery())
+}
+
+export function searchUsers(keyword: string, size = 20): Promise<UserProfile[]> {
+  return http.get<UserProfile[]>('/api/im/admin/users/search', appQuery({ keyword, size }))
+}
+
+export function searchGroups(keyword: string, size = 20): Promise<ImGroup[]> {
+  return http.get<ImGroup[]>('/api/im/admin/groups/search', appQuery({ keyword, size }))
+}
+
+export function searchMessages(
+  keyword: string | null = null,
+  chatType: ChatType | null = null,
+  msgType: string | null = null,
+  startTime: string | number | Date | null = null,
+  endTime: string | number | Date | null = null,
+  page = 0,
+  size = 20,
+): Promise<PageResult<ImMessage>> {
+  return http.get<PageResult<ImMessage>>(
+    '/api/im/admin/messages/search',
+    appQuery({ keyword, chatType, msgType, startTime, endTime, page, size }),
+  )
+}
+
+export function getGroupInfo(groupId: string): Promise<ImGroup> {
+  return http.get<ImGroup>(`/api/im/groups/${encodeURIComponent(groupId)}`, appQuery())
+}
+
+export function listGroupMembers(groupId: string): Promise<UserProfile[]> {
+  return http.get<UserProfile[]>(`/api/im/groups/${encodeURIComponent(groupId)}/members`, appQuery())
+}
+
+export function searchGroupMembers(groupId: string, keyword: string, size = 20): Promise<UserProfile[]> {
+  return http.get<UserProfile[]>(`/api/im/groups/${encodeURIComponent(groupId)}/members/search`, appQuery({ keyword, size }))
+}
+
+export function sendFriendRequest(toUserId: string, remark?: string): Promise<FriendRequest> {
+  return http.post<FriendRequest>(
+    '/api/im/friend-requests',
+    undefined,
+    appQuery({
+      toUserId,
+      ...(remark ? { remark } : {}),
+    }),
+  )
+}
+
+export function listFriendRequests(direction: 'incoming' | 'outgoing' = 'incoming'): Promise<FriendRequest[]> {
+  return http.get<FriendRequest[]>('/api/im/friend-requests', appQuery({ direction }))
+}
+
+export function acceptFriendRequest(requestId: string): Promise<FriendRequest> {
+  return http.post<FriendRequest>(`/api/im/friend-requests/${encodeURIComponent(requestId)}/accept`, undefined, appQuery())
+}
+
+export function rejectFriendRequest(requestId: string): Promise<FriendRequest> {
+  return http.post<FriendRequest>(`/api/im/friend-requests/${encodeURIComponent(requestId)}/reject`, undefined, appQuery())
+}
+
+export function sendGroupJoinRequest(groupId: string, remark?: string): Promise<GroupJoinRequest> {
+  return http.post<GroupJoinRequest>(
+    `/api/im/groups/${encodeURIComponent(groupId)}/join-requests`,
+    undefined,
+    appQuery({
+      ...(remark ? { remark } : {}),
+    }),
+  )
+}
+
+export function listGroupJoinRequests(groupId: string): Promise<GroupJoinRequest[]> {
+  return http.get<GroupJoinRequest[]>(`/api/im/groups/${encodeURIComponent(groupId)}/join-requests`, appQuery())
+}
+
+export function acceptGroupJoinRequest(groupId: string, requestId: string): Promise<GroupJoinRequest> {
+  return http.post<GroupJoinRequest>(
+    `/api/im/groups/${encodeURIComponent(groupId)}/join-requests/${encodeURIComponent(requestId)}/accept`,
+    undefined,
+    appQuery(),
+  )
+}
+
+export function rejectGroupJoinRequest(groupId: string, requestId: string): Promise<GroupJoinRequest> {
+  return http.post<GroupJoinRequest>(
+    `/api/im/groups/${encodeURIComponent(groupId)}/join-requests/${encodeURIComponent(requestId)}/reject`,
+    undefined,
+    appQuery(),
+  )
+}

src/im/useIm.ts

@@ -2,10 +2,25 @@ import { ref, shallowRef, onUnmounted } from 'vue'
 import { ImClient } from './ImClient'
 import {
   deleteConversation,
+  acceptFriendRequest,
+  acceptGroupJoinRequest,
+  getGroupInfo,
   fetchGroupHistory,
   fetchHistory,
+  editMessage,
+  locateGroupHistoryPage,
+  locateHistoryPage,
+  revokeMessage,
+  listFriendRequests,
+  listFriends,
+  listGroupJoinRequests,
+  listGroups,
   listConversations,
   markRead,
+  rejectFriendRequest,
+  rejectGroupJoinRequest,
+  sendFriendRequest,
+  sendGroupJoinRequest,
   setConversationMuted,
   setConversationPinned,
   setDraft,
@@ -37,6 +52,20 @@ export function useIm() {
     messages.value = [...messages.value, message]
   }
 
+  function markMessageRevoked(msgId: string) {
+    const index = messages.value.findIndex((item) => item.id === msgId)
+    if (index < 0) return
+    const next = [...messages.value]
+    next[index] = {
+      ...next[index],
+      status: 'REVOKED',
+      msgType: 'REVOKED',
+      revoked: true,
+      content: '',
+    }
+    messages.value = next
+  }
+
   async function refreshConversations() {
     const items = await listConversations()
     conversations.value = [...items].sort((a, b) => {
@@ -45,6 +74,14 @@ export function useIm() {
     })
   }
 
+  function markConversationRead(targetId: string, chatType: ChatType = 'SINGLE') {
+    conversations.value = conversations.value.map((item) =>
+      item.targetId === targetId && item.chatType === chatType
+        ? { ...item, unreadCount: 0 }
+        : item,
+    )
+  }
+
   async function loadHistory(toId: string, query: HistoryQuery = {}): Promise<PageResult<ImMessage>> {
     return fetchHistory(toId, query)
   }
@@ -53,6 +90,14 @@ export function useIm() {
     return fetchGroupHistory(groupId, query)
   }
 
+  function jumpToMessagePage(toId: string, messageId: string, pageSize = 20, maxPages = 20) {
+    return locateHistoryPage(toId, messageId, pageSize, maxPages)
+  }
+
+  function jumpToGroupMessagePage(groupId: string, messageId: string, pageSize = 20, maxPages = 20) {
+    return locateGroupHistoryPage(groupId, messageId, pageSize, maxPages)
+  }
+
   function connect() {
     const im = new ImClient()
     im.on('connected', () => {
@@ -64,6 +109,14 @@ export function useIm() {
       upsertMessage(msg)
       void refreshConversations().catch(() => {})
     })
+    im.on('read', (msg) => {
+      upsertMessage(msg)
+      void refreshConversations().catch(() => {})
+    })
+    im.on('revoke', ({ msgId }) => {
+      markMessageRevoked(msgId)
+      void refreshConversations().catch(() => {})
+    })
     im.on('error', (e) => { error.value = e })
     im.connect()
     client.value = im
@@ -78,7 +131,19 @@ export function useIm() {
   }
 
   function revoke(msgId: string) {
-    client.value?.revoke(msgId)
+    return revokeMessage(msgId).then((message) => {
+      upsertMessage(message)
+      void refreshConversations().catch(() => {})
+      return message
+    })
+  }
+
+  function edit(msgId: string, content: string) {
+    return editMessage(msgId, content).then((message) => {
+      upsertMessage(message)
+      void refreshConversations().catch(() => {})
+      return message
+    })
   }
 
   function disconnect() {
@@ -88,6 +153,8 @@ export function useIm() {
   }
 
   function setConversationRead(targetId: string, chatType: ChatType = 'SINGLE') {
+    markConversationRead(targetId, chatType)
+    void refreshConversations().catch(() => {})
     return markRead(targetId, chatType)
   }
 
@@ -107,12 +174,57 @@ export function useIm() {
     return deleteConversation(targetId, chatType)
   }
 
+  function getFriends() {
+    return listFriends()
+  }
+
+  function getGroups() {
+    return listGroups()
+  }
+
+  function getGroup(groupId: string) {
+    return getGroupInfo(groupId)
+  }
+
+  function sendFriend(toUserId: string, remark?: string) {
+    return sendFriendRequest(toUserId, remark)
+  }
+
+  function loadFriendRequests(direction: 'incoming' | 'outgoing' = 'incoming') {
+    return listFriendRequests(direction)
+  }
+
+  function approveFriendRequest(requestId: string) {
+    return acceptFriendRequest(requestId)
+  }
+
+  function declineFriendRequest(requestId: string) {
+    return rejectFriendRequest(requestId)
+  }
+
+  function sendGroupJoin(groupId: string, remark?: string) {
+    return sendGroupJoinRequest(groupId, remark)
+  }
+
+  function loadGroupJoinRequests(groupId: string) {
+    return listGroupJoinRequests(groupId)
+  }
+
+  function approveGroupJoinRequest(groupId: string, requestId: string) {
+    return acceptGroupJoinRequest(groupId, requestId)
+  }
+
+  function declineGroupJoinRequest(groupId: string, requestId: string) {
+    return rejectGroupJoinRequest(groupId, requestId)
+  }
+
   onUnmounted(disconnect)
 
   return {
     connect,
     send,
     revoke,
+    edit,
     disconnect,
     messages,
     conversations,
@@ -121,10 +233,23 @@ export function useIm() {
     refreshConversations,
     loadHistory,
     loadGroupHistory,
+    jumpToMessagePage,
+    jumpToGroupMessagePage,
     setConversationRead,
     setConversationPinnedState,
     setConversationMutedState,
     setConversationDraft,
     removeConversation,
+    getFriends,
+    getGroups,
+    getGroup,
+    sendFriend,
+    loadFriendRequests,
+    approveFriendRequest,
+    declineFriendRequest,
+    sendGroupJoin,
+    loadGroupJoinRequests,
+    approveGroupJoinRequest,
+    declineGroupJoinRequest,
   }
 }

src/index.ts

@@ -2,12 +2,30 @@ export { init, setToken, setUserId, getToken, getUserId, getConfig } from './cor
 export { http } from './core/http'
 export { ImClient } from './im/ImClient'
 export {
+  acceptFriendRequest,
+  acceptGroupJoinRequest,
   deleteConversation,
+  getGroupInfo,
   fetchGroupHistory,
   fetchHistory,
+  editMessage,
+  locateGroupHistoryPage,
+  locateHistoryPage,
+  revokeMessage,
+  listFriendRequests,
+  listFriends,
+  listGroupJoinRequests,
+  listGroups,
   listConversations,
   markRead,
   getProfile,
+  searchGroups,
+  searchMessages,
+  searchUsers,
+  rejectFriendRequest,
+  rejectGroupJoinRequest,
+  sendFriendRequest,
+  sendGroupJoinRequest,
   setConversationMuted,
   setConversationPinned,
   setDraft,
@@ -22,6 +40,9 @@ export type {
   ImMessage,
   ConversationView,
   HistoryQuery,
+  ImGroup,
+  FriendRequest,
+  GroupJoinRequest,
   PageResult,
   UserProfile,
   SendMessageParams,

src/types/index.ts

@@ -84,6 +84,40 @@ export interface UserProfile {
   createdAt?: string | number | null
 }
 
+export interface ImGroup {
+  id: string
+  appId?: string
+  name: string
+  groupType?: string
+  creatorId: string
+  memberIds: string
+  adminIds: string
+  announcement?: string | null
+  createdAt?: string | number | null
+}
+
+export interface FriendRequest {
+  id: string
+  appId?: string
+  fromUserId: string
+  toUserId: string
+  remark?: string | null
+  status: 'PENDING' | 'ACCEPTED' | 'REJECTED'
+  createdAt: string | number
+  reviewedAt?: string | number | null
+}
+
+export interface GroupJoinRequest {
+  id: string
+  appId?: string
+  groupId: string
+  requesterId: string
+  remark?: string | null
+  status: 'PENDING' | 'ACCEPTED' | 'REJECTED'
+  createdAt: string | number
+  reviewedAt?: string | number | null
+}
+
 export interface SendMessageParams {
   messageId?: string
   toId: string
@@ -96,6 +130,7 @@ export interface SendMessageParams {
 
 export interface ImEventMap {
   message: (msg: ImMessage) => void
+  read: (msg: ImMessage) => void
   revoke: (data: { msgId: string; operatorId: string }) => void
   connected: () => void
   disconnected: (code: number, reason: string) => void