enbox

import {
  createConnectionStore,
  defineApplicationManifest,
  defineProtocol,
  recordCodecs,
} from '@enbox/api';

// Define a typed protocol
const NotesDefinition = {
  protocol:  'https://example.com/notes',
  published: true,
  types: {
    note: {
      schema:      'https://example.com/note',
      dataFormats: ['application/json'],
    },
  },
  structure: { note: {} },
} as const;

const Notes = defineProtocol(NotesDefinition, {
  note: recordCodecs.json<{ title: string; body: string }>(),
});

// Connect and use the protocol
const application = defineApplicationManifest({ protocols: [Notes] } as const);
const store = createConnectionStore({ application });
let snapshot = await store.initialize();
if (snapshot.phase === 'disconnected') {
  snapshot = await store.connectVault({ createIdentity: true });
}
if (snapshot.phase !== 'connected') {
  throw snapshot.error ?? new Error('Connection was not established.');
}
const notes = snapshot.enbox.using(Notes);

// Create
const record = await notes.records.create('note', {
  data: { title: 'First note', body: 'Hello from Enbox!' },
});

// Read
const data = await record.value();

// Update
await record.update({
  data: { title: 'Updated note', body: 'Changed.' },
});

// Query
const { records } = await notes.records.query('note');

// Delete
await record.delete();

// Sign out and release app-lifetime resources
await store.disconnect();
await store.dispose();