Implement schema validation add creation

Author: tshemsedinov

Pragmatic/static/application.js

@@ -20,16 +20,18 @@ class Logger {
 
 const logger = new Logger('output');
 const schemas = {
-  user: { keyPath: 'id', autoIncrement: true },
+  user: {
+    id: { type: 'int', primary: true },
+    name: { type: 'str', index: true },
+    age: { type: 'int' },
+  },
 };
 const db = await new Database('Example', { version: 1, schemas });
 
 const actions = {
   add: async () => {
     const name = prompt('Enter user name:');
-    if (!name) return;
     const age = parseInt(prompt('Enter age:'), 10);
-    if (!Number.isInteger(age)) return;
     const user = { name, age };
     await db.insert({ store: 'user', record: user });
     logger.log('Added:', user);

Pragmatic/static/storage.js

@@ -33,10 +33,12 @@ class Database {
   #upgrade(db) {
     for (const [name, schema] of Object.entries(this.#schemas)) {
       if (!db.objectStoreNames.contains(name)) {
-        const store = db.createObjectStore(name, schema);
-        const indexes = schema.indexes ?? [];
-        for (const { name: idxName, keyPath, options } of indexes) {
-          store.createIndex(idxName, keyPath, options);
+        const options = { keyPath: 'id', autoIncrement: true };
+        const store = db.createObjectStore(name, options);
+        for (const [field, def] of Object.entries(schema)) {
+          if (name !== 'id' && def.index) {
+            store.createIndex(field, field, { unique: false });
+          }
         }
       }
     }
@@ -59,11 +61,30 @@ class Database {
     });
   }
 
+  validate({ store, record }) {
+    const schema = this.#schemas[store];
+    if (!schema) throw new Error(`Schema for ${store} is not defined`);
+    for (const [key, val] of Object.entries(record)) {
+      const field = schema[key];
+      const name = `Field ${store}.${key}`;
+      if (!field) throw new Error(`${name} is not defined`);
+      if (field.type === 'int') {
+        if (Number.isInteger(val)) continue;
+        throw new Error(`${name} expected to be integer`);
+      } else if (field.type === 'str') {
+        if (typeof val === 'string') continue;
+        throw new Error(`${name} expected to be string`);
+      }
+    }
+  }
+
   insert({ store, record }) {
+    this.validate({ store, record });
     return this.#exec(store, (objectStore) => objectStore.add(record));
   }
 
   update({ store, record }) {
+    this.validate({ store, record });
     return this.#exec(store, (objectStore) => objectStore.put(record));
   }
 

Pragmatic/test/database.js

@@ -3,13 +3,16 @@ import assert from 'node:assert/strict';
 import 'fake-indexeddb/auto';
 import { Database } from '../static/storage.js';
 
+const schemas = {
+  user: {
+    id: { type: 'int', primary: true },
+    name: { type: 'str', index: true },
+    age: { type: 'int' },
+  },
+};
+
 test('Pragmatic: Database CRUD + DSL', async () => {
-  const db = await new Database('PragmaticDB', {
-    version: 1,
-    schemas: {
-      user: { keyPath: 'id', autoIncrement: true },
-    },
-  });
+  const db = await new Database('PragmaticDB', { version: 1, schemas });
 
   // Insert
   await db.insert({ store: 'user', record: { name: 'Marcus', age: 20 } });
@@ -74,12 +77,7 @@ test('Pragmatic: Database CRUD + DSL', async () => {
 });
 
 test('Pragmatic: Complex DSL', async () => {
-  const db = await new Database('ComplexDB', {
-    version: 1,
-    schemas: {
-      user: { keyPath: 'id', autoIncrement: true },
-    },
-  });
+  const db = await new Database('ComplexDB', { version: 1, schemas });
 
   await db.insert({ store: 'user', record: { name: 'Marcus', age: 20 } });
   await db.insert({ store: 'user', record: { name: 'Lucius', age: 20 } });