bucket_definitions:
  global:
    data:
      - SELECT * FROM todos
      - SELECT * FROM lists WHERE archived = false

import { column, Schema, Table } from '@powersync/react-native';

const todos = new Table(
  {
    list_id: column.text,
    created_at: column.text,
    completed_at: column.text,
    description: column.text,
    created_by: column.text,
    completed_by: column.text,
    completed: column.integer
  },
  { indexes: { list: ['list_id'] } }
);

export const AppSchema = new Schema({
  todos
});

import { PowerSyncDatabase } from '@powersync/react-native';
import { AppSchema } from './Schema';

export const db = new PowerSyncDatabase({
  schema: AppSchema,
  database: {
    dbFilename: 'powersync.db'
  }
});

import { AbstractPowerSyncDatabase, PowerSyncBackendConnector, PowerSyncCredentials } from '@powersync/react-native';
import { db } from './Database';

class Connector implements PowerSyncBackendConnector {
  async fetchCredentials(): Promise<PowerSyncCredentials> {
    // for development: use development token
    return {
      endpoint: 'https://your-instance.powersync.com',
      token: 'your-development-token-here'
    };
  }

  async uploadData(database: AbstractPowerSyncDatabase) {
    const transaction = await database.getNextCrudTransaction();
    if (!transaction) return;

    for (const op of transaction.crud) {
      const record = { ...op.opData, id: op.id };
      // upload to your backend API
    }

    await transaction.complete();
  }
}

// connect the database to PowerSync Service
const connector = new Connector();
await db.connect(connector);

// Get all todos
const todos = await db.getAll('SELECT * FROM todos');

// Get a single todo
const todo = await db.get('SELECT * FROM todos WHERE id = ?', [todoId]);

// Watch for changes (reactive query)
const stream = db.watch('SELECT * FROM todos WHERE list_id = ?', [listId]);
for await (const todos of stream) {
  // Update UI when data changes
  console.log(todos);
}

// Note: The above example requires async iterator support in React Native. 
// If you encounter issues, use one of these callback-based APIs instead:

// Option 1: Using onResult callback
// const abortController = new AbortController();
// db.watch(
//   'SELECT * FROM todos WHERE list_id = ?',
//   [listId],
//   {
//     onResult: (todos) => {
//       // Update UI when data changes
//       console.log(todos);
//     }
//   },
//   { signal: abortController.signal }
// );

// Option 2: Using the query builder API
// const query = db
//   .query({
//     sql: 'SELECT * FROM todos WHERE list_id = ?',
//     parameters: [listId]
//   })
//   .watch();
// query.registerListener({
//   onData: (todos) => {
//     // Update UI when data changes
//     console.log(todos);
//   }
// });

// Insert a new todo
await db.execute(
  'INSERT INTO todos (id, created_at, list_id, description) VALUES (uuid(), date(), ?, ?)',
  [listId, 'Buy groceries']
);

// Update a todo
await db.execute(
  'UPDATE todos SET completed = 1, completed_at = date() WHERE id = ?',
  [todoId]
);

// Delete a todo
await db.execute('DELETE FROM todos WHERE id = ?', [todoId]);