diff --git a/src/api/repository/message.repository.ts b/src/api/repository/message.repository.ts index d719de01..64ac9982 100644 --- a/src/api/repository/message.repository.ts +++ b/src/api/repository/message.repository.ts @@ -12,6 +12,7 @@ export class MessageQuery { where: MessageRaw; limit?: number; sort?: { [key: string]: SortOrder }; + skip?: number; } export class MessageRepository extends Repository { @@ -126,6 +127,7 @@ export class MessageRepository extends Repository { .find({ ...query.where }) .select(query.select || {}) .sort(query?.sort ?? { messageTimestamp: -1 }) + .skip(query?.skip ?? 0) .limit(query?.limit ?? 0); } diff --git a/src/api/services/channel.service.ts b/src/api/services/channel.service.ts index ea3a57c1..966c8897 100644 --- a/src/api/services/channel.service.ts +++ b/src/api/services/channel.service.ts @@ -1256,6 +1256,7 @@ export class ChannelStartupService { owner: this.instance.name, }, limit: query?.limit, + skip: query?.skip, }; } return await this.repository.message.find(query);