From 7a5e79d4193511dbaa7a2d1c801dd82e8f4201ff Mon Sep 17 00:00:00 2001 From: XuqmGroup Date: Sun, 3 May 2026 00:11:06 +0800 Subject: [PATCH] =?UTF-8?q?feat(im):=20=E6=B7=BB=E5=8A=A0=E5=8D=B3?= =?UTF-8?q?=E6=97=B6=E6=B6=88=E6=81=AFSDK=E6=A0=B8=E5=BF=83=E5=8A=9F?= =?UTF-8?q?=E8=83=BD=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 实现了聊天消息发送功能，支持文本、图片、视频、音频、文件等多种消息类型 - 集成了文件上传下载功能，支持多媒体文件的传输和管理 - 添加了群组管理功能，包括创建群组、成员管理、权限控制等操作 - 实现了好友系统，支持好友添加、删除、分组等功能 - 集成了黑名单管理，提供用户屏蔽和解除屏蔽功能 - 添加了会话管理功能，支持对话列表、未读消息统计等 - 实现了历史消息查询和搜索功能 - 添加了实时连接状态管理和自动重连机制 --- src/core/http.ts | 16 ++++++++++++++++ src/im/ImClient.ts | 1 + src/im/api.ts | 44 +++++++++++++++++++++++++++++++++++++++++++- src/im/useIm.ts | 3 +++ src/index.ts | 4 ++++ src/types/index.ts | 2 +- 6 files changed, 68 insertions(+), 2 deletions(-) diff --git a/src/core/http.ts b/src/core/http.ts index a9ae9ef..876a410 100644 --- a/src/core/http.ts +++ b/src/core/http.ts @@ -42,6 +42,22 @@ async function request( return json.data } +export async function uploadFile(file: File): Promise<{ url: string; thumbnailUrl?: string; hash: string; size: number; originalName: string; mimeType: string; ext: string }> { + const token = _tokenGetter() + const formData = new FormData() + formData.append('file', file) + + const res = await fetch(`${_baseUrl}/api/file/upload`, { + method: 'POST', + headers: token ? { Authorization: `Bearer ${token}` } : {}, + body: formData, + }) + + const json: ApiResponse = await res.json() + if (json.code !== 200) throw new Error(json.message) + return json.data as { url: string; thumbnailUrl?: string; hash: string; size: number; originalName: string; mimeType: string; ext: string } +} + export const http = { get: (path: string, query?: Record) => request('GET', path, undefined, query), post: (path: string, body?: unknown, query?: Record) => request('POST', path, body, query), diff --git a/src/im/ImClient.ts b/src/im/ImClient.ts index cf6d5c5..6fdd89a 100644 --- a/src/im/ImClient.ts +++ b/src/im/ImClient.ts @@ -140,6 +140,7 @@ export class ImClient { // Don't return early — also emit as message for consistency with old behavior } this.emit('message', message) + this.emit('conversations') } catch { // ignore malformed frames } diff --git a/src/im/api.ts b/src/im/api.ts index 3a05062..88b7c61 100644 --- a/src/im/api.ts +++ b/src/im/api.ts @@ -1,5 +1,5 @@ import { getConfig } from '../core/sdk' -import { http } from '../core/http' +import { http, uploadFile } from '../core/http' import type { BlacklistCheckResult, BlacklistEntry, @@ -39,6 +39,48 @@ export function sendMessage(params: { toId: string; chatType: ChatType; msgType: return http.post('/api/im/messages/send', params, appQuery()) } +export async function sendImageMessage(toId: string, chatType: ChatType, file: File, width?: number, height?: number): Promise { + const result = await uploadFile(file) + const content = JSON.stringify({ + url: result.url, + ...(width !== undefined ? { width } : {}), + ...(height !== undefined ? { height } : {}), + ...(result.thumbnailUrl ? { thumbnailUrl: result.thumbnailUrl } : {}), + }) + return sendMessage({ toId, chatType, msgType: 'IMAGE', content }) +} + +export async function sendVideoMessage(toId: string, chatType: ChatType, file: File, width?: number, height?: number, duration?: number): Promise { + const result = await uploadFile(file) + const content = JSON.stringify({ + url: result.url, + ...(width !== undefined ? { width } : {}), + ...(height !== undefined ? { height } : {}), + ...(duration !== undefined ? { duration } : {}), + ...(result.thumbnailUrl ? { thumbnailUrl: result.thumbnailUrl } : {}), + }) + return sendMessage({ toId, chatType, msgType: 'VIDEO', content }) +} + +export async function sendFileMessage(toId: string, chatType: ChatType, file: File): Promise { + const result = await uploadFile(file) + const content = JSON.stringify({ + url: result.url, + name: result.originalName, + size: result.size, + }) + return sendMessage({ toId, chatType, msgType: 'FILE', content }) +} + +export async function sendAudioMessage(toId: string, chatType: ChatType, file: File, duration?: number): Promise { + const result = await uploadFile(file) + const content = JSON.stringify({ + url: result.url, + ...(duration !== undefined ? { duration } : {}), + }) + return sendMessage({ toId, chatType, msgType: 'AUDIO', content }) +} + export function createGroup(params: { name: string; memberIds: string[]; groupType?: string; avatar?: string; announcement?: string }): Promise { return http.post('/api/im/groups', params, appQuery()) } diff --git a/src/im/useIm.ts b/src/im/useIm.ts index 862ac1a..3e7f17c 100644 --- a/src/im/useIm.ts +++ b/src/im/useIm.ts @@ -174,6 +174,9 @@ export function useIm(): UseImReturn { markMessageRevoked(msgId) void refreshConversations().catch(() => {}) }) + im.on('conversations', () => { + void refreshConversations().catch(() => {}) + }) im.on('error', (e) => { error.value = e }) im.connect() client.value = im diff --git a/src/index.ts b/src/index.ts index 7a79124..6589f9c 100644 --- a/src/index.ts +++ b/src/index.ts @@ -41,6 +41,10 @@ export { sendFriendRequest, sendGroupJoinRequest, sendMessage, + sendImageMessage, + sendVideoMessage, + sendFileMessage, + sendAudioMessage, setConversationGroup, setConversationHidden, setConversationMuted, diff --git a/src/types/index.ts b/src/types/index.ts index 82567d8..cd77efb 100644 --- a/src/types/index.ts +++ b/src/types/index.ts @@ -1,6 +1,5 @@ export interface SDKConfig { appKey: string - appSecret: string debug?: boolean baseUrl?: string wsUrl?: string @@ -170,6 +169,7 @@ export interface ImEventMap { connected: () => void disconnected: (code: number, reason: string) => void error: (err: Event) => void + conversations: () => void } export interface ApiResponse {