Update examples and emulation

Author: tshemsedinov

emulation/storage.js

@@ -41,8 +41,9 @@ class Record extends Emitter {
 
   async #load() {
     if (this.#data !== null) return this;
-    this.#data = await this.#storage.get(this.#id);
-    if (this.#data) {
+    const rawData = await this.#storage.get(this.#id);
+    if (rawData) {
+      this.#data = JSON.parse(JSON.stringify(rawData));
       this.#convertToReferences(this.#data);
       this.#defineProperties();
     }
@@ -123,11 +124,6 @@ class Record extends Emitter {
     this.#data = null;
     this.#changes = {};
   }
-
-  async ensureLoaded() {
-    if (this.#data !== null) return this;
-    return await this.#load();
-  }
 }
 
 class SyncManager {
@@ -160,15 +156,53 @@ class SyncManager {
   }
 }
 
+class Collection {
+  #storage;
+  #name;
+
+  constructor(storage, name) {
+    this.#storage = storage;
+    this.#name = name;
+  }
+
+  get name() {
+    return this.#name;
+  }
+
+  async insert(data) {
+    const id = generateUUID();
+    const record = { ...data, $type: this.#name };
+    await this.#storage.saveData(id, record);
+    return this.#storage.record(id);
+  }
+
+  async get(id) {
+    return this.#storage.get(id);
+  }
+
+  async delete(id) {
+    return this.#storage.delete(id);
+  }
+
+  async update(id, delta) {
+    return this.#storage.update(id, delta);
+  }
+
+  async record(id) {
+    return this.#storage.record(id);
+  }
+}
+
 class Storage {
   #data = new Map();
   #records = new Map();
   #sync = null;
   #cache = new Map();
   #updates = [];
+  #schema = null;
 
-  // eslint-disable-next-line no-unused-vars
   constructor(options = {}) {
+    if (options.schema) this.#schema = options.schema;
     this.#sync = new SyncManager();
     return this.#init();
   }
@@ -180,9 +214,22 @@ class Storage {
       this.#data.set(id, item);
       this.#cache.set(id, item);
     }
+    this.#initCollections();
     return this;
   }
 
+  #initCollections() {
+    const entities = this.#schema?.entities;
+    if (!entities) return;
+    for (const [name] of entities.entries?.() ?? Object.entries(entities)) {
+      this[name] = new Collection(this, name);
+    }
+  }
+
+  get schema() {
+    return this.#schema;
+  }
+
   #emitUpdate(id, data, delta) {
     const emitter = this.#records.get(id);
     if (emitter) {
@@ -207,7 +254,7 @@ class Storage {
     return this.#data.has(id);
   }
 
-  async get(id) {
+  async loadData(id) {
     if (this.#cache.has(id)) {
       return this.#cache.get(id);
     }
@@ -220,6 +267,10 @@ class Storage {
     return null;
   }
 
+  async get(id) {
+    return this.loadData(id);
+  }
+
   getCachedData(id) {
     return this.#cache.has(id) ? this.#cache.get(id) : null;
   }
@@ -281,14 +332,10 @@ class Storage {
 
   async record(id) {
     if (!this.#records.has(id)) {
-      const recordPromise = new Record(id, this);
-      const record = await recordPromise;
+      const record = await new Record(id, this);
       this.#records.set(id, record);
-      return record;
     }
-    const record = this.#records.get(id);
-    await record.ensureLoaded();
-    return record;
+    return this.#records.get(id);
   }
 
   // eslint-disable-next-line no-unused-vars
@@ -307,4 +354,4 @@ class Storage {
 
 const open = async (options = {}) => new Storage(options);
 
-module.exports = { Storage, open, SyncManager };
+module.exports = { Storage, Collection, Record, open, SyncManager };

example.js

@@ -1,9 +1,12 @@
 'use strict';
 
 const globalStorage = require('./gs.js');
+const xxii = require('xxii-schema');
 
 const main = async () => {
-  const storage = await globalStorage.open();
+  const xxiiSchema = await xxii.load();
+  console.log(xxiiSchema);
+  const storage = await globalStorage.open({ schema: xxiiSchema });
 
   await storage.sync
     .addNode({
@@ -36,20 +39,19 @@ const main = async () => {
   const nodes = storage.sync.listNodes();
   console.log('List nodes', nodes);
 
-  // Domain logic
+  // Implicit API - Record with dynamic getters/setters
 
   const authorData = { name: 'Timur', email: 'timur@example.com' };
   const authorId = await storage.insert(authorData);
+  const authorRecord = await storage.record(authorId);
+  authorRecord.email = 'timur.shemsedinov@gmail.com';
+  await authorRecord.save();
 
   const post = { title: 'Example', content: 'Text', author: authorId };
-  const id = await storage.insert(post);
-
-  // Implicit API - Record with dynamic getters/setters
-
-  const postRecord = await storage.record(id);
+  const postRecord = await storage.Post.insert(post);
 
   postRecord.on('update', (data, delta) => {
-    console.log('Record updated:', { id, data, delta });
+    console.log('Record updated:', { id: postRecord.id, data, delta });
   });
 
   console.log('Title:', postRecord.title);
@@ -64,19 +66,15 @@ const main = async () => {
 
   await postRecord.save();
 
-  const authorRecord = await postRecord.author.record();
-  console.log('Author name:', authorRecord.name);
-
-  // Delete record
-  // await postRecord.delete();
+  console.log('Author name:', postRecord.author.name);
 
   // Explicit API (still available)
 
-  const exists = await storage.has(id);
+  const exists = await storage.has(postRecord.id);
   if (exists) {
-    const data = await storage.get(id);
+    const data = await storage.get(postRecord.id);
     data.content += ' more changes';
-    await storage.set(id, data);
+    await storage.set(postRecord.id, data);
   }
 
   await storage.sync.start();