import type { EncryptedMessage } from '../types'

export interface MessageRepository {
  getAvailableMessageCount(connectionId: string): number | Promise<number>
  takeFromQueue(
    connectionId: string,
    limit?: number,
    keepMessages?: boolean
  ): EncryptedMessage[] | Promise<EncryptedMessage[]>
  add(connectionId: string, payload: EncryptedMessage): void | Promise<void>
}