[demo] Server: Add accuracy tracking

.gitignore

@@ -1,4 +1,3 @@
 .idea/
 .vscode/
-
 .venv/

demo/server.js

@@ -3,8 +3,7 @@ const fs = require('fs');
 const initSqlJs = require('sql.js');
 const app = express();
 const port = process.env.PORT || 5387;
-const bodyParser = require('body-parser');
-const jsonParser = bodyParser.json();
+const jsonParser = express.json();
 
 const dbPath = 'db.sqlite';
 
@@ -19,7 +18,8 @@ initSqlJs().then(SQL => {
     db = new SQL.Database();
     sqlstr = "CREATE TABLE model (id INTEGER PRIMARY KEY, name TEXT, address TEXT, description TEXT, model_type TEXT, encoder TEXT, accuracy NUMBER);"
       + "CREATE TABLE data (transaction_hash TEXT PRIMARY KEY, text TEXT);"
-      + "CREATE INDEX index_address ON model(address);";
+      + "CREATE INDEX index_address ON model(address);"
+      + "CREATE TABLE accuracy (transaction_hash TEXT, block_number INTEGER, model_id INTEGER, accuracy NUMBER, timestamp DATETIME DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (model_id) REFERENCES model (id));";
     db.run(sqlstr);
   }
 
@@ -150,4 +150,52 @@ initSqlJs().then(SQL => {
   });
 
   app.listen(port, () => console.log(`Listening on port ${port}`));
+
+   // ACCURACY RECORD MANAGEMENT
+   function presistAccuracyRecord(accuracy) {
+    db.run('INSERT INTO accuracy VALUES (?, ?, ?, ?, CURRENT_TIMESTAMP);', [
+      accuracy.transactionHash,
+      accuracy.blockNumber,
+      accuracy.modelId,
+      accuracy.accuracy,
+    ]);
+    fs.writeFile(dbPath, Buffer.from(db.export()), () => {});
+  }
+
+ // Add a new accuracy record for a model
+  app.post('/api/accuracy', jsonParser, (req, res) => {
+    const body = req.body
+    presistAccuracyRecord(body);
+    return res.sendStatus(200);
+  });
+
+  // Get the accuracy history 
+  app.get('/api/accuracy/model', (req, res) => {
+    const { modelId  } = req.query;
+    if (modelId != null) {
+      const getStmt = db.prepare('SELECT * FROM accuracy where model_id == $modelId ORDER BY timestamp;',
+      {
+        $modelId: modelId
+      })
+      const accuracyHistory = [];
+      while (getStmt.step()) {
+        const accuracy = getStmt.get();
+        accuracyHistory.push({
+          transactionHash: accuracy[0],
+          blockNumber: accuracy[1],
+          modelId: accuracy[2],
+          accuracy: accuracy[3],
+          timestamp: accuracy[4],
+        });
+      }
+      getStmt.free();
+      if (accuracyHistory.length) {
+        res.send({ accuracyHistory });
+      } else {
+        res.send({ message: "Not Valid modelId" });
+      }
+    } else {
+      return res.status(400).send({ message: "Null" });
+    }
+  });
 });