Function createSyncExecutor

apps/desktop/main/worker/query/messages.ts:44–55

(sessionId: string)

// ==================== Executor adapter ====================

function createSyncExecutor(sessionId: string): AsyncSqlExecutor | null {
  const db = openDatabase(sessionId)
  if (!db) return null
  return {
    all<T>(sql: string, params: unknown[] = []): Promise<T[]> {
      return Promise.resolve(db.prepare(sql).all(...params) as T[])
    },
    get<T>(sql: string, params: unknown[] = []): Promise<T | undefined> {
      return Promise.resolve(db.prepare(sql).get(...params) as T | undefined)
    },
  }
}

// ==================== Query functions ====================