The data model for apps and agents

1
import * as Schema from 'effect/Schema';
2
import { DXN, Filter, Obj, Query, Type } from '@dxos/echo';
3

4
class Task extends Type.makeObject<Task>(
5
  DXN.make('com.example.type.task', '0.1.0'),
6
)(Schema.Struct({ title: Schema.String, done: Schema.Boolean })) {}
7

8
const open = db.query(Query.select(Filter.type(Task, { done: false })));
9
open.subscribe(() => console.log(open.results.length));
10

11
// The subscriber has already run when `add` returns.
12
const task = db.add(Obj.make(Task, { title: 'Ship the docs', done: false }));
13

14
// A CRDT change: it merges with any peer's edit to this task.
15
Obj.update(task, (task) => {
16
  task.done = true;
17
});