Add support for OpenID connect!!

app/classes/oidc/CoreIDAdapter.js

@@ -0,0 +1,89 @@
+const Connection = require('flitter-orm/src/services/Connection')
+const { ObjectId } = require('mongodb')
+
+let DB
+
+/**
+ * An OpenID Connect provider adapter with some CoreID specific tweaks.
+ */
+class CoreIDAdapter {
+    constructor(name) {
+        this.name = 'openid_' + name
+    }
+
+    async upsert(_id, payload, expiresIn) {
+        let expiresAt
+
+        if (expiresIn) {
+            expiresAt = new Date(Date.now() + (expiresIn * 1000))
+        }
+
+        await this.coll().updateOne(
+            { _id },
+            { $set: { payload, ...(expiresAt ? { expiresAt } : undefined) } },
+            { upsert: true },
+        )
+    }
+
+    async find(_id) {
+        if ( this.name === 'openid_Client' ) _id = ObjectId(_id)
+
+        const result = await this.coll().find(
+            { _id },
+            { payload: 1 },
+        ).limit(1).next()
+
+        if (!result) return undefined
+        return result.payload
+    }
+
+    async findByUserCode(userCode) {
+        const result = await this.coll().find(
+            { 'payload.userCode': userCode },
+            { payload: 1 },
+        ).limit(1).next()
+
+        if (!result) return undefined
+        return result.payload
+    }
+
+    async findByUid(uid) {
+        const result = await this.coll().find(
+            { 'payload.uid': uid },
+            { payload: 1 },
+        ).limit(1).next()
+
+        if (!result) return undefined
+        return result.payload
+    }
+
+    async destroy(_id) {
+        await this.coll().deleteOne({ _id })
+    }
+
+    async revokeByGrantId(grantId) {
+        await this.coll().deleteMany({ 'payload.grantId': grantId })
+    }
+
+    async consume(_id) {
+        await this.coll().findOneAndUpdate(
+            { _id },
+            { $set: { 'payload.consumed': Math.floor(Date.now() / 1000) } },
+        )
+    }
+
+    coll(name) {
+        return this.constructor.coll(name || this.name)
+    }
+
+    static coll(name) {
+        return DB.collection(name)
+    }
+
+    static connect(app) {
+        DB = app.di().get(Connection.name)
+    }
+}
+
+module.exports = CoreIDAdapter
+