Function searchMessagesLike

packages/core/src/query/message-queries.ts:142–197

(
  db: DatabaseAdapter,
  keyword: string,
  options?: { limit?: number; offset?: number }
)

 * 不依赖 FTS 索引，适用于 CLI/MCP 场景
 */
export function searchMessagesLike(
  db: DatabaseAdapter,
  keyword: string,
  options?: { limit?: number; offset?: number }
): PaginatedMessages {
  const limit = options?.limit ?? 50
  const offset = options?.offset ?? 0

  const countRow = db
    .prepare(
      `SELECT COUNT(*) as total
       FROM message msg
       JOIN member m ON msg.sender_id = m.id
       WHERE msg.content LIKE ? AND COALESCE(m.account_name, '') != '系统消息'`
    )
    .get(`%${keyword}%`) as { total: number }

  const rows = db
    .prepare(
      `SELECT
        msg.id as id,
        m.id as senderId,
        COALESCE(m.group_nickname, m.account_name, m.platform_id) as senderName,
        m.platform_id as senderPlatformId,
        msg.content as content,
        msg.ts as timestamp,
        msg.type as type
      FROM message msg
      JOIN member m ON msg.sender_id = m.id
      WHERE msg.content LIKE ? AND COALESCE(m.account_name, '') != '系统消息'
      ORDER BY msg.ts DESC
      LIMIT ? OFFSET ?`
    )
    .all(`%${keyword}%`, limit + 1, offset) as Array<{
    id: number
    senderId: number
    senderName: string
    senderPlatformId: string
    content: string
    timestamp: number
    type: number
  }>

  const hasMore = rows.length > limit
  const messages = rows.slice(0, limit).map((row) => ({
    id: Number(row.id),
    senderId: Number(row.senderId),
    senderName: String(row.senderName || ''),
    senderPlatformId: String(row.senderPlatformId || ''),
    content: row.content != null ? String(row.content) : '',
    timestamp: Number(row.timestamp),
    type: Number(row.type),
  }))

  return { messages, hasMore, total: countRow.total }
}

/**