hard delete

Author: bennyschmidt

.dss/data/json/.gitkeep

@@ -0,0 +1 @@
+20.17

.nvmrc

@@ -9,12 +9,15 @@ const dss = require('./lib')(DATA_URI);
 module.exports = http({
   GET: {},
   POST: {
-    read: async ({ collectionName, query, page }) => (
-      dss.read(collectionName, query, page)
+    read: async ({ collectionName, query, page, limit }) => (
+      dss.read(collectionName, query, page, limit)
     ),
     write: async ({ collectionName, query, payload }) => (
       dss.write(collectionName, query, payload)
     ),
+    delete: async ({ collectionName, query }) => (
+      dss.delete(collectionName, query)
+    ),
     backup: async ({ collectionName }) => (
       dss.backup(collectionName)
     ),

index.js

@@ -7,14 +7,18 @@ const { generateUUID } = require('cryptography-utilities');
 const FILE_SIZE_LIMIT = 500000;
 
 const MEDIA_TYPES = {
-  base64: 'b64',
-  json: 'json'
+  base64: 'b64'
 };
 
 const defaultMediaType = Object.keys(MEDIA_TYPES)[0];
 
 const Database = dataURI => {
-  let getCollection, updateCollection, backupCollection, storeMedia;
+  let getCollection;
+  let updateCollection;
+  let deleteCollection;
+  let backupCollection;
+  let storeMedia;
+  let searchMedia;
 
   backupCollection = async (collectionName, page = 1) => {
     const files = await fs.readdir(dataURI);
@@ -46,24 +50,27 @@ const Database = dataURI => {
     return {
       read: getCollection,
       write: updateCollection,
+      delete: deleteCollection,
       backup: backupCollection,
       store: storeMedia,
       search: searchMedia
     };
   };
 
-  getCollection = async (collectionName, query, page = 1, limit = 1000) => {
+  getCollection = async (collectionName, query, page, limit = 1000) => {
     const files = await fs.readdir(dataURI);
 
-    const documents = files
-      .filter(file => (
-        file
-          .split('.')[0]
-          .split('-')[0] === collectionName
-      ))
-      .map(file => (
-        file.replace('.json', '')
-      ));
+    const documents = page
+      ? [files[page]]
+      : files
+        .filter(file => (
+          file
+            .split('.')[0]
+            .split('-')[0] === collectionName
+        ))
+        .map(file => (
+          file.replace('.json', '')
+        ));
 
     let concatResult = [];
 
@@ -104,6 +111,60 @@ const Database = dataURI => {
       data: concatResult.slice(-limit),
       read: getCollection,
       write: updateCollection,
+      delete: deleteCollection,
+      backup: backupCollection,
+      store: storeMedia,
+      search: searchMedia
+    };
+  };
+
+  deleteCollection = async (collectionName, query) => {
+    const files = await fs.readdir(dataURI);
+
+    const documents = files
+      .filter(file => (
+        file
+          .split('.')[0]
+          .split('-')[0] === collectionName
+      ))
+      .map(file => (
+        file.replace('.json', '')
+      ));
+
+    const fileName = documents.length > 1
+      ? documents.sort().pop()
+      : collectionName;
+
+    const fileSrc = `${dataURI}/${fileName}.json`;
+
+    const data = await fs.readFile(fileSrc, 'utf8');
+
+    const collection = JSON.parse(data);
+
+    if (query) {
+      Object.values(collection).forEach(record => {
+        Object.keys(record).forEach(key => {
+          // eslint-disable-next-line no-magic-numbers
+          if (key === Object.keys(query)[0] && record[key] === query[key]) {
+            delete record[key];
+          }
+        });
+      });
+
+      await fs.writeFile(
+        fileSrc,
+        JSON.stringify(collection),
+        'utf8'
+      );
+    } else {
+      await fs.unlink(fileSrc);
+    }
+
+    return {
+      data: { deletedAt: Date.now() },
+      read: getCollection,
+      write: updateCollection,
+      delete: deleteCollection,
       backup: backupCollection,
       store: storeMedia,
       search: searchMedia
@@ -189,7 +250,10 @@ const Database = dataURI => {
       data: result,
       read: getCollection,
       write: updateCollection,
-      backup: backupCollection
+      delete: deleteCollection,
+      backup: backupCollection,
+      store: storeMedia,
+      search: searchMedia
     };
   };
 
@@ -199,7 +263,7 @@ const Database = dataURI => {
 
     await fs.writeFile(`${dataURI}/${extension}/${fileId}.${extension}`, media, 'utf8');
 
-    return `data:${mediaType === 'json' ? 'json' : 'image'}/${fileId}`;
+    return `data:image/${fileId}`;
   };
 
   searchMedia = async (mediaAddress, mediaType = defaultMediaType) => {
@@ -211,6 +275,7 @@ const Database = dataURI => {
   return {
     read: getCollection,
     write: updateCollection,
+    delete: deleteCollection,
     backup: backupCollection,
     store: storeMedia,
     search: searchMedia