feat: encode data for storage

Chia-Network · Jan 3, 2022 · bc4a1a1 · bc4a1a1
1 parent d575a01
commit bc4a1a1
Show file tree

Hide file tree

Showing 3 changed files with 28 additions and 9 deletions.
diff --git a/package.json b/package.json
@@ -8,7 +8,7 @@
   },
   "scripts": {
     "requirements-check": "node --experimental-json-modules check_node_version.js",
-    "start": "node --experimental-specifier-resolution=node ./src/server.js",
+    "start": "node --experimental-specifier-resolution=node --no-warnings ./src/server.js",
     "test": "mocha tests/**/*.spec.js --reporter spec --exit",
     "release": "./node_modules/.bin/standard-version && git push --tags",
     "postinstall": "npm run requirements-check",

diff --git a/src/fullnode/fullnode.js b/src/fullnode/fullnode.js
@@ -1,23 +1,27 @@
 import * as simulator from './simulator';
 
 export const updateProjectRecord = async (uuid, record, stagingRecordId) => {
-  await simulator.updateProjectRecord(uuid, record, stagingRecordId);
+  const encoded = btoa(JSON.stringify(record));
+  await simulator.updateProjectRecord(uuid, encoded, stagingRecordId);
 };
 
 export const createProjectRecord = async (uuid, record, stagingRecordId) => {
-  await simulator.createProjectRecord(uuid, record, stagingRecordId);
+  const encoded = btoa(JSON.stringify(record));
+  await simulator.createProjectRecord(uuid, encoded, stagingRecordId);
 };
 
 export const deleteProjectRecord = async (uuid, stagingRecordId) => {
   await simulator.deleteProjectRecord(uuid, stagingRecordId);
 };
 
 export const updateUnitRecord = async (uuid, record, stagingRecordId) => {
-  await simulator.updateUnitRecord(uuid, record, stagingRecordId);
+  const encoded = btoa(JSON.stringify(record));
+  await simulator.updateUnitRecord(uuid, encoded, stagingRecordId);
 };
 
 export const createUnitRecord = async (uuid, record, stagingRecordId) => {
-  await simulator.createUnitRecord(uuid, record, stagingRecordId);
+  const encoded = btoa(JSON.stringify(record));
+  await simulator.createUnitRecord(uuid, encoded, stagingRecordId);
 };
 
 export const deleteUnitRecord = async (uuid, stagingRecordId) => {

diff --git a/src/fullnode/simulator.js b/src/fullnode/simulator.js
@@ -3,7 +3,12 @@ const THIRTY_SEC = 30000;
 
 // Simulate 30 seconds passing before commited to node
 
-export const updateProjectRecord = async (uuid, record, stagingRecordId) => {
+export const updateProjectRecord = async (
+  uuid,
+  encodedRecord,
+  stagingRecordId,
+) => {
+  const record = JSON.parse(encodedRecord.toString('utf8'));
   return new Promise((resolve) => {
     setTimeout(async () => {
       if (stagingRecordId) {
@@ -26,7 +31,10 @@ export const updateProjectRecord = async (uuid, record, stagingRecordId) => {
   });
 };
 
-export const createProjectRecord = (uuid, record, stagingRecordId) => {
+export const createProjectRecord = (uuid, encodedRecord, stagingRecordId) => {
+  const record = JSON.parse(atob(encodedRecord));
+
+  console.log(record);
   return new Promise((resolve) => {
     setTimeout(async () => {
       await Project.create({
@@ -69,7 +77,13 @@ export const deleteProjectRecord = (uuid, stagingRecordId) => {
   });
 };
 
-export const updateUnitRecord = async (uuid, record, stagingRecordId) => {
+export const updateUnitRecord = async (
+  uuid,
+  encodedRecord,
+  stagingRecordId,
+) => {
+  const record = JSON.parse(encodedRecord.toString('utf8'));
+
   await deleteUnitRecord(uuid);
   await createUnitRecord(uuid, record);
 
@@ -82,7 +96,8 @@ export const updateUnitRecord = async (uuid, record, stagingRecordId) => {
   }
 };
 
-export const createUnitRecord = (uuid, record, stagingRecordId) => {
+export const createUnitRecord = (uuid, encodedRecord, stagingRecordId) => {
+  const record = JSON.parse(encodedRecord.toString('utf8'));
   return new Promise((resolve) => {
     setTimeout(async () => {
       await Unit.create({