fix(im): 将频道消息的 pull 改成 pullChannelMessageList

im
YunaiV 2026-06-18 19:58:41 -07:00
parent 61c9e1acf2
commit dcafe6efdc
4 changed files with 12 additions and 9 deletions

View File

@ -12,7 +12,10 @@ export interface ImChannelMessageRespVO {
} }
// 拉取当前用户应收的频道消息(离线增量);按 minId 游标分页 // 拉取当前用户应收的频道消息(离线增量);按 minId 游标分页
export const pullChannelMessages = (params: { minId: number; size?: number }, signal?: AbortSignal) => { export const pullChannelMessageList = (
params: { minId: number; size?: number },
signal?: AbortSignal
) => {
return request.get<ImChannelMessageRespVO[]>({ return request.get<ImChannelMessageRespVO[]>({
url: '/im/channel/message/pull', url: '/im/channel/message/pull',
params, params,

View File

@ -39,7 +39,7 @@ export const sendGroupMessage = (data: ImGroupMessageSendReqVO) => {
} }
// 拉取群聊消息(增量) // 拉取群聊消息(增量)
export const pullGroupMessages = ( export const pullGroupMessageList = (
params: { minId: number | string; size: number }, params: { minId: number | string; size: number },
signal?: AbortSignal signal?: AbortSignal
) => { ) => {

View File

@ -35,7 +35,7 @@ export const sendPrivateMessage = (data: ImPrivateMessageSendReqVO) => {
} }
// 拉取私聊消息(增量) // 拉取私聊消息(增量)
export const pullPrivateMessages = ( export const pullPrivateMessageList = (
params: { minId: number | string; size: number }, params: { minId: number | string; size: number },
signal?: AbortSignal signal?: AbortSignal
) => { ) => {

View File

@ -7,16 +7,16 @@ import { getFriendDisplayName, getGroupDisplayName } from '../../utils/user'
import { useGroupStore } from '../store/groupStore' import { useGroupStore } from '../store/groupStore'
import { useGroupRequestStore } from '../store/groupRequestStore' import { useGroupRequestStore } from '../store/groupRequestStore'
import { import {
pullPrivateMessages as apiPullPrivateMessages, pullPrivateMessageList as apiPullPrivateMessageList,
getPrivateMaxReadMessageId as apiGetPrivateMaxReadMessageId, getPrivateMaxReadMessageId as apiGetPrivateMaxReadMessageId,
type ImPrivateMessageRespVO type ImPrivateMessageRespVO
} from '@/api/im/message/private' } from '@/api/im/message/private'
import { import {
pullGroupMessages as apiPullGroupMessages, pullGroupMessageList as apiPullGroupMessageList,
type ImGroupMessageRespVO type ImGroupMessageRespVO
} from '@/api/im/message/group' } from '@/api/im/message/group'
import { import {
pullChannelMessages as apiPullChannelMessages, pullChannelMessageList as apiPullChannelMessageList,
type ImChannelMessageRespVO type ImChannelMessageRespVO
} from '@/api/im/message/channel' } from '@/api/im/message/channel'
import { import {
@ -182,12 +182,12 @@ export const useMessagePuller = () => {
isActive: isStillValid, isActive: isStillValid,
fetchPage: ({ minId, size }) => { fetchPage: ({ minId, size }) => {
if (isPrivate) { if (isPrivate) {
return apiPullPrivateMessages({ minId, size }, signal) return apiPullPrivateMessageList({ minId, size }, signal)
} }
if (isChannel) { if (isChannel) {
return apiPullChannelMessages({ minId, size }, signal) return apiPullChannelMessageList({ minId, size }, signal)
} }
return apiPullGroupMessages({ minId, size }, signal) return apiPullGroupMessageList({ minId, size }, signal)
}, },
applyPage: async (list, nextMinId) => { applyPage: async (list, nextMinId) => {
const pulledMessages: PulledMessage[] = [] const pulledMessages: PulledMessage[] = []