Initial commit

Author: ThinhVu

.gitignore

@@ -0,0 +1,2 @@
+/.idea/
+/node_modules/

package-lock.json

@@ -0,0 +1,25 @@
+{
+  "name": "hmmjs",
+  "version": "1.0.0",
+  "description": "client side mongoose like database query interface",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/ThinhVu/hmmjs.git"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "bugs": {
+    "url": "https://github.com/ThinhVu/hmmjs/issues"
+  },
+  "homepage": "https://github.com/ThinhVu/hmmjs#readme",
+  "dependencies": {
+    "jest": "^29.3.1",
+    "mongodb": "^4.11.0",
+    "mongoose": "^6.7.2"
+  }
+}

package.json

@@ -0,0 +1,21 @@
+const chain = hmm => new Proxy({}, {
+  get(target, p) {
+    switch (p) {
+      case '$':
+        return hmm.send(hmm.payload);
+      case 'toString':
+        return () => JSON.stringify(hmm.payload)
+      default:
+        return function (...args) {
+          hmm.payload.fns.push({n: p, args})
+          return chain(hmm)
+        }
+    }
+  }
+})
+
+module.exports = send => new Proxy({}, {
+  get(target, p) {
+    return chain({send, payload: {model: p, fns: []}})
+  }
+})

src/builder.js

@@ -0,0 +1,29 @@
+const hmmFactory = require('./builder')
+
+describe('hmm-builder', function () {
+  it('should build correct post payload', () => {
+    const hmm = hmmFactory(() => {})
+    const hmm2Str = hmm.user.find({_id: 1}, {username: 1, password: 1}).sort({createdDate: -1}).limit(10).toString()
+    const output = {
+      model: 'user',
+      fns: [
+        { n: 'find', args: [{_id: 1}, {username: 1, password: 1}]},
+        { n: 'sort', args: [{createdDate: -1}]},
+        { n: 'limit', args: [10] }
+      ]
+    }
+    expect(hmm2Str).toEqual(JSON.stringify(output))
+  })
+
+  it('should post a payload', async () => {
+    const post = payload => fetch({ method: 'POST', url: 'http://localhost:3000/api/', body: payload })
+    const mockPost = jest.fn(payload => "RESPONSE:" +  JSON.stringify(payload))
+    const hmm = hmmFactory(mockPost)
+    const qry = hmm.user.find({_id: 1}, { username: 1, password: 1 }).sort({createdDate: -1}).limit(10)
+    const hmm2Str = qry.toString()
+    const rs = await qry.$
+    expect(mockPost.mock.calls.length).toBe(1)
+    expect(JSON.stringify(mockPost.mock.calls[0][0])).toBe(hmm2Str)
+    expect(rs).toEqual("RESPONSE:" + hmm2Str)
+  })
+})

src/builder.test.js

@@ -0,0 +1,9 @@
+module.exports = (dbi, convertArgs) => {
+  return async payload => {
+    const {model, fns} = payload
+    let imme = dbi[model]
+    for (const fn of fns)
+      imme = imme[fn.n](...(convertArgs ? convertArgs(fn.args): fn.args))
+    return imme
+  }
+}

src/executor.js

@@ -0,0 +1,55 @@
+const executorFac = require('./executor')
+const {ObjectID} = require('mongodb')
+const {default: db, model, Schema} = require('mongoose')
+const UserModel = model('User', new Schema({u: String, p: String, age: Number}))
+
+let hmmExec;
+
+describe('executor', () => {
+  beforeAll(async () => {
+    await db.connect('mongodb://localhost:27017/hmm')
+    const dbi = { user: UserModel }
+    const convertArgs = args => args.map(arg => typeof (arg) !== 'object'
+        ? arg
+        : Object.keys(arg).reduce((prev, k) => {
+          prev[k] = k === '_id'
+              ? new ObjectID(arg[k])
+              : arg[k];
+          return prev
+        }, {}))
+    hmmExec = executorFac(dbi, convertArgs)
+    // init user
+    await UserModel.deleteMany()
+    for (let i = 0; i < 100; ++i)
+      await UserModel.create({ u: `u${i}`, p: `p${i}`, age: i })
+  })
+
+  it('should execute 1', async () => {
+    const payload = {
+      model: 'user',
+      fns: [
+        { n: 'find', args: [{u: 'u10'}, {u: 1, p: 1}]},
+        { n: 'limit', args: [1] }
+      ]
+    }
+    const rs = await hmmExec(payload)
+    expect(rs.length).toEqual(1)
+    expect(rs[0].p).toEqual('p10')
+    expect(rs[0].age).toEqual(undefined)
+  })
+
+  it('should execute 2', async () => {
+    const payload = {
+      model: 'user',
+      fns: [
+        { n: 'find', args: [{age: {$gt: 10}}, {u: 1, p: 1}]},
+        { n: 'sort', args: [{age: 1}] },
+        { n: 'limit', args: [10] }
+      ]
+    }
+    const rs = await hmmExec(payload)
+    expect(rs.length).toEqual(10)
+    expect(rs[0].p).toEqual('p11')
+    expect(rs[rs.length - 1].p).toEqual('p20')
+  })
+})