Push Experimental Blog and Database Classes to Public

Author: Ray Arayilakath

index.js

@@ -1,26 +1,28 @@
 import fs from 'fs';
 import path from 'path';
+import _ from 'lodash';
 import stringify from 'json-stable-stringify-without-jsonify';
 import replapi from './src/source.js';
 
 const defaultInitVariables = {
-  username: undefined,
+  username: '',
   captcha: {
-    token: undefined,
+    token: '',
   },
   endpoints: {
-    gql: undefined,
-    restful: undefined,
-    login: undefined,
+    gql: '',
+    restful: '',
+    login: '',
   },
   markdown: {
-    length: undefined,
-    removeMarkdown: undefined,
+    length: '',
+    removeMarkdown: '',
   },
   previewCount: {
-    comments: undefined,
+    comments: '',
   },
-  experimentalFeatures: undefined,
+  experimentalFeatures: '',
+  createDatabaseFlag: '',
 };
 
 function sortByKey(a, b) {
@@ -29,28 +31,15 @@ function sortByKey(a, b) {
 
 export default function ReplAPI(initVariables) {
   if (initVariables) {
-    for (const [key, value] of Object.entries(initVariables)) {
-      if (typeof value === 'object') {
-        for (const [nestedKey, nestedValue] of Object.entries(value)) {
-          if (typeof nestedValue !== 'string' && typeof nestedValue !== 'number') {
-            throw new Error(`Invalid type for value of ${nestedKey}.`);
-          } else if (defaultInitVariables[key][nestedKey] === undefined) {
-            defaultInitVariables[key][nestedKey] = nestedValue;
-          }
-        }
-      } else if (typeof value !== 'string' && typeof value !== 'number' && typeof value !== 'boolean') {
-        throw new Error(`Invalid type for value of ${key}.`);
-      } else if (defaultInitVariables[key] === undefined) {
-        defaultInitVariables[key] = value;
-      }
-    }
+    _.assign(defaultInitVariables, initVariables)
     fs.writeFileSync(path.join(process.cwd(), '.replapirc.json'), `${stringify(defaultInitVariables, { cmp: sortByKey, space: 4 })}\n`, { encoding: 'utf8' });
   } else {
     fs.writeFileSync(path.join(process.cwd(), '.replapirc.json'), `${stringify(defaultInitVariables, { cmp: sortByKey, space: 4 })}\n`, { encoding: 'utf8' });
   }
 
   return {
     defaults: defaultInitVariables,
+    Blog: replapi.Blog,
     Board: replapi.Board,
     Comment: replapi.Comment,
     CustomDataQuery: replapi.CustomDataQuery,

package-lock.json

@@ -28,10 +28,13 @@
   "dependencies": {
     "atob": "^2.1.2",
     "json-stable-stringify-without-jsonify": "^1.0.1",
+    "lodash": "^4.17.21",
     "node-fetch": "^2.6.1",
-    "node-html-parser": "^3.1.3"
+    "node-html-parser": "^3.1.3",
+    "rss-parser": "^3.12.0"
   },
   "devDependencies": {
+    "@replit/database": "^2.0.1",
     "eslint": "^7.24.0",
     "eslint-config-airbnb-base": "^14.2.1",
     "eslint-plugin-import": "^2.22.1"

package.json

@@ -0,0 +1,37 @@
+import Parser from 'rss-parser';
+import fs from 'fs';
+import path from 'path';
+
+const parser = new Parser();
+
+let exportable;
+let isExperimentalFeaturesEnabled;
+if (fs.existsSync(path.join(process.cwd(), '.replapirc.json'))) {
+  isExperimentalFeaturesEnabled = JSON.parse(fs.readFileSync(path.join(process.cwd(), '.replapirc.json'))).experimentalFeatures;
+}
+
+if (isExperimentalFeaturesEnabled) {
+  exportable = class Blog {
+    async blogData() {
+    	const feed = await parser.parseURL('https://blog.replit.com/feed.xml');
+    	delete feed.items;
+
+    	return feed;
+    }
+
+    async blogItems(order = 'newest', count = 10) {
+    	const feed = await parser.parseURL('https://blog.replit.com/feed.xml');
+
+    	if (order === 'oldest') feed.items.reverse();
+    	const posts = feed.items.slice(0, count);
+
+    	return posts;
+    }
+  };
+} else {
+  exportable = function noExperimentalFeatures() {
+    console.log('Experimental Features are not enabled. To learn more about experimental features please visit the documentation.');
+  };
+}
+
+export default exportable;

src/classes/Blog.js

@@ -1,9 +1,8 @@
 import fetch from 'node-fetch';
+import _ from 'lodash';
 import fs from 'fs';
 import path from 'path';
-
-import headers from '../utils/headers.js';
-import constants from '../utils/constants.js';
+import crypto from 'crypto';
 
 function hash(value, salt) {
   const hashItem = crypto.createHmac('sha512', salt);
@@ -31,36 +30,106 @@ if (fs.existsSync(path.join(process.cwd(), '.replapirc.json'))) {
 
 if (isExperimentalFeaturesEnabled) {
   exportable = class Database {
-    constructor(replitdbtoken, salt, options) {
-      this.replitdbtoken = replitdbtoken || process.env.REPLIT_DB_URL.split('/')[4];
+    constructor(dbToken, salt = '', options = {}) {
+      if (!process.env.REPLIT_DB_URL) throw new Error('Please run the Database Class on a Replit Project only.');
+
+      this.dbToken = dbToken || process.env.REPLIT_DB_URL;
       this.salt = salt;
-      this.options = options;
+      this.options = {
+        id: String(dbToken).split('/')[4] || process.env.REPLIT_DB_URL.split('/')[4],
+        owner: process.env.REPL_OWNER,
+        collaborators: { ...options.collaborators },
+        password: { ...hash(String(options.password), String(salt)) },
+        type: options.type,
+        encrypted: options.encrypted || [false],
+        'max-items': options['max-items'] || 10,
+      };
+    }
+
+    async init() {
+      const isDatabaseSetup = await fetch(`${this.dbToken}/${encodeURIComponent('replapi_database_config')}`, {
+        method: 'GET',
+      }).then((res) => res.text());
+
+      if (!isDatabaseSetup) {
+        if (this.options.type === 'plus') {
+          let createDatabaseFlag;
+          if (fs.existsSync(path.join(process.cwd(), '.replapirc.json'))) {
+            createDatabaseFlag = JSON.parse(fs.readFileSync(path.join(process.cwd(), '.replapirc.json'))).createDatabaseFlag;
+          }
+
+          if (createDatabaseFlag) {
+            const info = await fetch(`${this.dbToken}`, {
+              method: 'POST',
+              headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
+              body: `${encodeURIComponent('replapi_database_config')}=${encodeURIComponent(JSON.stringify({ ...this.options }))}`,
+            });
+          } else {
+            throw new Error('Are you sure you want to use these options to configure a Database? You will not be able to change these options in the future. If you are, then in your .replapirc.json file set a "createDatabaseFlag" key to "true". For more information, read the documentation.');
+          }
+        } else if (this.options.type === 'repldb') {
+          const info = await fetch(`${this.dbToken}`, {
+            method: 'POST',
+            headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
+            body: `${encodeURIComponent('replapi_database_config')}=${encodeURIComponent(JSON.stringify({ ...this.options }))}`,
+          });
+        } else {
+          throw new Error('Invalid Database Type. For a normal database, use the "repldb" option.');
+        }
+      }
     }
 
-    async set(key, value) {
-      const info = await fetch(`https://kv.replit.com/v0/${this.replitdbtoken}`, {
+    async createCollection(collectionName) {
+      const info = await fetch(`${this.dbToken}`, {
         method: 'POST',
-        headers,
-        body: `${encodeURIComponent(key)}=${encodeURIComponent(JSON.stringify(value))}`,
+        headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
+        body: `${encodeURIComponent(collectionName)}=${encodeURIComponent(JSON.stringify({}))}`,
+      });
+    }
+
+    async createDoc(collectionName, docName, docItems) {
+      const collection = await this.getCollection(collectionName);
+      collection[docName] = { ...docItems };
+
+      const info = await fetch(`${this.dbToken}`, {
+        method: 'POST',
+        headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
+        body: `${encodeURIComponent(collectionName)}=${encodeURIComponent(JSON.stringify(collection))}`,
+      });
+    }
+
+    async getCollection(collectionName) {
+      const info = await fetch(`${this.dbToken}/${collectionName}`, {
+        method: 'GET',
       }).then((res) => res.json());
+
+      return info;
     }
 
-    async get(key) {
-      const info = await fetch(`https://kv.replit.com/v0/${this.replitdbtoken}/${key}`, {
+    async getDoc(collectionName, docName) {
+      const info = await fetch(`${this.dbToken}/${collectionName}`, {
         method: 'GET',
-        headers,
-      }).then((res) => {
-  			  res.json();
+      }).then((res) => res.json());
+
+      return info[docName];
+    }
+
+    async updateDoc(collectionName, docName, docItems) {
+      const collection = await this.getCollection(collectionName);
+			_.assignIn(collection[docName], docItems);
+
+      const info = await fetch(`${this.dbToken}`, {
+        method: 'POST',
+        headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
+        body: `${encodeURIComponent(collectionName)}=${encodeURIComponent(JSON.stringify(collection))}`,
       });
     }
 
     async delete(key) {
       const info = await fetch(`https://kv.replit.com/v0/${this.replitdbtoken}/${key}`, {
         method: 'GET',
         headers,
-      }).then((res) => {
-  			  res.json();
-      });
+      }).then((res) => res.json() );
     }
   };
 } else {

src/classes/Database.js

@@ -1,3 +1,4 @@
+import Blog from './classes/Blog.js';
 import Board from './classes/Board.js';
 import Comment from './classes/Comment.js';
 import { CustomDataQuery, CustomRecursiveQuery } from './classes/Custom.js';
@@ -11,6 +12,7 @@ import Repl from './classes/Repl.js';
 import User from './classes/User.js';
 
 export default {
+  Blog,
   Board,
   Comment,
   CustomDataQuery,