RxDB: Local-First Reactive Database

import { createRxDatabase, addRxPlugin, RxDatabase, RxCollection, RxJsonSchema } from 'test-rxdb';
import { getRxStorageDexie } from 'test-rxdb/plugins/storage-dexie'; // Assumed path for 'test-rxdb' package

interface HeroDocType {
  name: string;
  color: string;
  hp: number;
  maxHP: number;
}

type HeroCollection = RxCollection<HeroDocType>;

const heroSchema: RxJsonSchema<HeroDocType> = {
  version: 0,
  primaryKey: 'name',
  type: 'object',
  properties: {
    name: {
      type: 'string',
      maxLength: 100 // Primary keys usually have a max length
    },
    color: {
      type: 'string'
    },
    hp: {
      type: 'number'
    },
    maxHP: {
      type: 'number'
    }
  },
  required: ['name', 'color', 'hp', 'maxHP']
};

async function runQuickstart() {
  console.log('Creating database...');
  const db: RxDatabase = await createRxDatabase({
    name: 'heroesdb',
    storage: getRxStorageDexie() // Using Dexie storage adapter
  });
  console.log('Database created:', db.name);

  // Add a collection to the database
  console.log('Adding hero collection...');
  await db.addCollections({
    heroes: {
      schema: heroSchema
    }
  });
  console.log('Hero collection added.');

  const heroCollection: HeroCollection = db.collections.heroes;

  // Insert documents
  console.log('Inserting heroes...');
  await heroCollection.insert({
    name: 'Batman',
    color: 'black',
    hp: 100,
    maxHP: 100
  });
  await heroCollection.insert({
    name: 'Superman',
    color: 'blue',
    hp: 120,
    maxHP: 120
  });
  console.log('Heroes inserted.');

  // Reactive query: subscribe to changes in the collection
  console.log('Subscribing to all heroes...');
  const subscription = heroCollection.find().$.subscribe(heroes => {
    if (heroes) {
      console.log('Current heroes:', heroes.map(h => h.toJSON()));
    }
  });

  // Update a document, which will trigger the subscription
  console.log('Updating Batman...');
  const batman = await heroCollection.findOne({ selector: { name: 'Batman' } }).exec();
  if (batman) {
    await batman.patch({ hp: 90 });
    console.log('Batman updated.');
  }

  // Clean up after some time
  setTimeout(() => {
    subscription.unsubscribe();
    console.log('Subscription unsubscribed.');
    db.destroy(); // Close the database connection
    console.log('Database destroyed (closed).');
  }, 3000);
}

runQuickstart().catch(err => console.error('Quickstart failed:', err));