@tallyui/storage-sqlite

--- package.json (entry) ---
{
  "name": "@tallyui/storage-sqlite",
  "version": "0.2.0",
  "type": "module",
  "description": "RxDB storage adapter for SQLite via expo-sqlite",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
  "source": "./src/index.ts",
  "exports": {
    ".": {
      "types": "./dist/index.d.ts",
      "import": "./dist/index.js",
      "source": "./src/index.ts"
    }
  },
  "files": [
    "dist",
    "src"
  ],
  "license": "MIT",
  "dependencies": {
    "rxdb": "16.21.1",
    "rxjs": "7.8.2"
  },
  "peerDependencies": {
    "expo-sqlite": ">=15.0.0"
  },
  "scripts": {
    "build": "tsup",
    "typecheck": "tsc --noEmit",
    "test": "vitest run"
  }
}

--- index.js (entry) ---
// src/rx-storage-sqlite.ts
import { ensureRxStorageInstanceParamsAreCorrect } from "rxdb";
import { RXDB_VERSION } from "rxdb/plugins/utils";

// src/storage-instance.ts
import { categorizeBulkWriteRows, getQueryMatcher, getSortComparator } from "rxdb";
import { now, ensureNotFalsy } from "rxdb/plugins/utils";
import { Subject } from "rxjs";

// src/mango-to-sql.ts
function mangoQueryToSQL(query) {
  const params = [];
  const conditions = [];
  conditions.push(`json_extract(data, '$._deleted') = 0`);
  if (query.selector && Object.keys(query.selector).length > 0) {
    const selectorSql = selectorToSQL(query.selector, params);
    if (selectorSql) {
      conditions.push(selectorSql);
    }
  }
  const where = conditions.length > 0 ? `WHERE ${conditions.join(" AND ")}` : "";
  let orderBy = "";
  if (query.sort && query.sort.length > 0) {
    const orderParts = query.sort.map((sortPart) => {
      const entries = Object.entries(sortPart);
      if (entries.length === 0) return "";
      const [field, direction] = entries[0];
      const jsonPath = fieldToJsonExtract(field);
      return `${jsonPath} ${direction === "desc" ? "DESC" : "ASC"}`;
    }).filter(Boolean);
    if (orderP

--- bundled output (OSV-MAL flagged — LLM scope expansion) ---

--- dist/index.d.ts (bundled) ---
import { RxStorage } from 'rxdb';

interface SQLiteDatabase {
    execSync(source: string): void;
    getAllSync<T>(source: string, params?: any[]): T[];
    runSync(source: string, params?: any[]): {
        changes: number;
        lastInsertRowId: number;
    };
}
interface SQLiteStorageSettings {
    database: SQLiteDatabase;
}

interface SQLiteStorageInternals {
    database: SQLiteDatabase;
    tableName: string;
}

type RxStorageSQLite = RxStorage<SQLiteStorageInternals, SQLiteStorageSettings>;
declare function getRxStorageSQLite(database: SQLiteDatabase): RxStorageSQLite;

export { type SQLiteDatabase, type SQLiteStorageSettings, getRxStorageSQLite };


--- dist/index.js (bundled) ---
// src/rx-storage-sqlite.ts
import { ensureRxStorageInstanceParamsAreCorrect } from "rxdb";
import { RXDB_VERSION } from "rxdb/plugins/utils";

// src/storage-instance.ts
import { categorizeBulkWriteRows, getQueryMatcher, getSortComparator } from "rxdb";
import { now, ensureNotFalsy } from "rxdb/plugins/utils";
import { Subject } from "rxjs";

// src/mango-to-sql.ts
function mangoQueryToSQL(query) {
  const params = [];
  const conditions = [];
  conditions.push(`json_extract(data, '$._deleted') = 0`);
  if (query.selector && Object.keys(query.selector).length > 0) {
    const selectorSql = selectorToSQL(query.selector, params);
    if (selectorSql) {
      conditions.push(selectorSql);
    }
  }
  const where = conditions.length > 0 ? `WHERE ${conditions.join(" AND ")}` : "";
  let orderBy = "";
  if (query.sort && query.sort.length > 0) {
    const orderParts = query.sort.map((sortPart) => {
      const entries = Object.entries(sortPart);
      if (entries.length === 0) return "";
      const [field, direction] = entries[0];
      const jsonPath = fieldToJsonExtract(field);
      return `${jsonPath} ${direction === "desc" ? "DESC" : "ASC"}`;
    }).filter(Boolean);
    if (orderParts.length > 0) {
      orderBy = `ORDER BY ${orderParts.join(", ")}`;
    }
  }
  const limitParams = [];
  let limit = "";
  if (query.limit !== void 0 && query.limit !== null) {
    limit = "LIMIT ?";
    limitParams.push(query.limit);
  }
  if (query.skip && query.skip > 0) {
    if (!limit) {
      limit = "LIMIT -1";
    }
    limit += " OFFSET ?";
    limitParams.push(query.skip);
  }
  return { where, params, orderBy, limit, limitParams };
}
function buildQuerySQL(tableName, query) {
  const result = mangoQueryToSQL(query);
  const allParams = [...result.params, ...result.limitParams];
  const parts = [
    `SELECT data FROM "${tableName}"`,
    result.where,
    result.orderBy,
    result.limit
  ].filter(Boolean);
  return { sql: parts.join(" "), params: allParams };
}
function