XuqmGroup-RNSDK/src/im/imSDK.ts

import { getConfig } from '../core/config'
import { apiRequest, getToken, saveToken } from '../core/http'
import { ImClient } from './imClient'
import type { ChatType, ImEventListener, ImGroup, ImMessage, MsgType } from './types'

let client: ImClient | null = null
const DEFAULT_IM_WS_URL = 'wss://dev.xuqinmin.com/ws/im'

export const ImSDK = {
  async login(userId: string, nickname?: string, avatar?: string): Promise<void> {
    const config = getConfig()
    const res = await apiRequest<{ token: string }>('/api/im/auth/login', {
      method: 'POST',
      params: {
        appId: config.appKey,
        userId,
        ...(nickname ? { nickname } : {}),
        ...(avatar ? { avatar } : {}),
      },
    })
    await saveToken(res.token)
    client = new ImClient(DEFAULT_IM_WS_URL, res.token, config.appKey)
    client.connect()
  },

  async reconnect(): Promise<void> {
    const config = getConfig()
    const token = await getToken()
    if (!token) throw new Error('ImSDK: token not found')
    client = new ImClient(DEFAULT_IM_WS_URL, token, config.appKey)
    client.connect()
  },

  async fetchHistory(toId: string, page = 0, size = 20): Promise<ImMessage[]> {
    const config = getConfig()
    const res = await apiRequest<{ content?: ImMessage[] } | ImMessage[]>(`/api/im/messages/history/${encodeURIComponent(toId)}`, {
      params: {
        appId: config.appKey,
        page: String(page),
        size: String(size),
      },
    })
    return Array.isArray(res) ? res : (res.content ?? [])
  },

  async sendMessage(
    toId: string,
    chatType: ChatType,
    msgType: MsgType,
    content: string,
    mentionedUserIds?: string,
  ): Promise<ImMessage> {
    const config = getConfig()
    return apiRequest<ImMessage>('/api/im/messages/send', {
      method: 'POST',
      params: { appId: config.appKey },
      body: {
        toId,
        chatType,
        msgType,
        content,
        mentionedUserIds: mentionedUserIds ?? '',
      },
    })
  },

  async revokeMessage(messageId: string): Promise<ImMessage> {
    const config = getConfig()
    return apiRequest<ImMessage>(`/api/im/messages/${encodeURIComponent(messageId)}/revoke`, {
      method: 'POST',
      params: { appId: config.appKey },
    })
  },

  async editMessage(messageId: string, content: string): Promise<ImMessage> {
    const config = getConfig()
    return apiRequest<ImMessage>(`/api/im/messages/${encodeURIComponent(messageId)}`, {
      method: 'PUT',
      params: { appId: config.appKey },
      body: { content },
    })
  },

  addListener(listener: ImEventListener) {
    client?.addListener(listener)
  },

  removeListener(listener: ImEventListener) {
    client?.removeListener(listener)
  },

  disconnect() {
    client?.disconnect()
    client = null
  },

  subscribeGroup(groupId: string) {
    client?.subscribeGroup(groupId)
  },

  isConnected() {
    return client?.isConnected() ?? false
  },

  async createGroup(name: string, memberIds: string[]): Promise<ImGroup> {
    const config = getConfig()
    return apiRequest<ImGroup>('/api/im/groups', {
      method: 'POST',
      params: { appId: config.appKey },
      body: { name, memberIds },
    })
  },

  async listGroups(): Promise<ImGroup[]> {
    const config = getConfig()
    const res = await apiRequest<ImGroup[] | { content?: ImGroup[] }>('/api/im/groups', {
      params: { appId: config.appKey },
    })
    return Array.isArray(res) ? res : (res.content ?? [])
  },

  async fetchGroupHistory(groupId: string, page = 0, size = 50): Promise<ImMessage[]> {
    const config = getConfig()
    const res = await apiRequest<{ content?: ImMessage[] } | ImMessage[]>(
      `/api/im/messages/history/${encodeURIComponent(groupId)}`,
      {
        params: {
          appId: config.appKey,
          page: String(page),
          size: String(size),
        },
      },
    )
    return Array.isArray(res) ? res : (res.content ?? [])
  },
}