model for a randomness-beacon.

Author: sbazerque

examples/randomness-beacon/model/Beacon.ts

@@ -0,0 +1,76 @@
+import { Hashing, HashedObject, MutableObject, MutationOp } from 'data/model';
+
+import { BeaconValueOp } from './BeaconValueOp';
+
+class Beacon extends MutableObject {
+
+    static className = 'hhs/v0/examples/Beacon';
+    static opClasses = [BeaconValueOp.className];
+
+    steps?: number;
+
+    _lastOp?: BeaconValueOp;
+    _values: string[];
+
+    constructor(seed?: string, steps?: number) {
+        super(Beacon.opClasses);
+
+        if (seed !== undefined && steps !== undefined) {
+            this.setId(seed);
+            this.steps = steps;
+        }
+        
+        this._values = [];
+    }
+
+
+    async mutate(op: MutationOp, isNew: boolean): Promise<void> {
+       
+        if (op instanceof BeaconValueOp) {
+
+            if (!isNew && this._lastOp !== undefined &&
+                !this._lastOp.equals(op)) {
+
+                if (op.prevOps?.size() === 0) {
+                    if (this._lastOp !== undefined) {
+                        throw new Error('Initial BeaconValueOp received, but there are already other ops in this beacon.');
+                    }
+    
+                    
+                } else {
+                    if (this._lastOp === undefined) {
+                        throw new Error('Non-initial BeaconValueOp received, but there are no values in this beacon.');
+                    }
+    
+                    if (!this._lastOp.equals(op.prevOps?.values().next().value)) {
+                        throw new Error('Received BeaconValueOp does not point to last known beacon value.');
+                    }
+                }
+
+                this._lastOp = op;
+                this._values.push(Hashing.toHex(op.hash()));
+            
+            }
+
+            
+        } 
+
+    }
+
+    getClassName(): string {
+        throw new Error('Method not implemented.');
+    }
+
+    init(): void {
+        
+    }
+
+    validate(references: Map<string, HashedObject>): boolean {
+       references;
+
+       return this.steps !== undefined && this.getId() !== undefined;
+    }
+
+}
+
+export { Beacon };

examples/randomness-beacon/model/BeaconValueOp.ts

@@ -0,0 +1,107 @@
+
+import { Hashing, Hash, HashedObject, MutationOp } from 'data/model';
+
+import { Beacon } from './Beacon';
+
+const createVdf = require('@subspace/vdf');
+
+
+class BeaconValueOp extends MutationOp {
+
+    static className = 'hhs/v0/examples/BeaconValueOp';
+
+    static vdfInit = async () => {
+        BeaconValueOp.vdfVerifier = await createVdf();
+    };
+    static vdfVerifier: any;
+
+
+    seq?: number;
+    vdfResult?: string;
+
+    constructor(target?: Beacon, seq?: number, vdfResult?: string) {
+        super(target);
+
+        if (seq !== undefined && vdfResult !== undefined) {
+            this.seq = seq;
+            this.vdfResult = vdfResult;
+        }
+    }
+
+    getClassName(): string {
+        return BeaconValueOp.className;
+    }
+
+    init(): void {
+        
+    }
+
+    validate(references: Map<Hash, HashedObject>): boolean {
+
+        if (this.seq === undefined || this.vdfResult === undefined) {
+            return false;
+        }
+
+        if (this.seq < 0) {
+            return false;
+        }
+
+        if (!super.validate(references)) {
+            return false;
+        }
+
+        if (! (this.getTarget() instanceof Beacon)) {
+            return false;
+        }
+
+        if (this.getAuthor() !== undefined) {
+            return false;
+        }
+
+        if (this.prevOps === undefined) {
+            return false;
+        }
+
+        let challenge: string;
+
+        if (this.prevOps.size() === 0) {
+            if (this.seq !== 0) {
+                return false;
+            }
+
+            challenge = this.getTarget().getId() as string;
+        } else {
+            if (this.prevOps.size() !== 1) {
+                return false;
+            }
+
+            let prev = this.prevOps.values().next().value;
+
+            if (!(prev instanceof BeaconValueOp)) {
+                return false;
+            }
+
+            if (prev.getTarget().equals(this.getTarget())) {
+                return false;
+            }
+
+            if ((prev.seq as number) + 1 !== this.seq) {
+                return false;
+            }
+
+            challenge = Hashing.toHex(prev.hash());
+        }
+
+        const steps = (this.getTarget() as Beacon).steps as number;
+
+        if (!BeaconValueOp.vdfVerifier.verify(steps, challenge, this.vdfResult, 2048, true)) {
+            return false;
+        }
+
+        return true;
+
+    }
+
+}
+
+export { BeaconValueOp };

package.json

@@ -23,6 +23,7 @@
   },
   "devDependencies": {
     "@hyper-hyper-space/node-env": "^0.8.0",
+    "@subspace/vdf": "^0.1.0",
     "@types/jest": "^26.0.0",
     "@types/ws": "^7.2.6",
     "dts-generator": "^3.0.0",

src/data/containers/MutableSet.ts

@@ -199,7 +199,7 @@ MutableSetDeleteOp.registerClass(MutableSetDeleteOp.className, MutableSetDeleteO
 
 class MutableSet<T extends HashedObject> extends MutableObject {
 
-    static className = 'hss/MutableSet';
+    static className = 'hss/v0/MutableSet';
     static opClasses = [MutableSetAddOp.className, MutableSetDeleteOp.className];
     static logger    = new Logger(MutableSet.className, LogLevel.INFO);
 

yarn.lock

@@ -2103,6 +2103,13 @@
   dependencies:
     "@sinonjs/commons" "^1.7.0"
 
+"@subspace/vdf@^0.1.0":
+  version "0.1.0"
+  resolved "https://registry.yarnpkg.com/@subspace/vdf/-/vdf-0.1.0.tgz#f341dc742e84df7eac9bf9653a08ddfea2b615c1"
+  integrity sha512-iKYdYOcAtALmxxgreWqnHphT7m8HIyBsAYLrPSRvOJM9hTY+Rfg+EsLiqXLgHoIXyy980dQhoE4yIwu8xXDmvg==
+  dependencies:
+    "@types/node" "^11.13.4"
+
 "@svgr/babel-plugin-add-jsx-attribute@^5.4.0":
   version "5.4.0"
   resolved "https://registry.yarnpkg.com/@svgr/babel-plugin-add-jsx-attribute/-/babel-plugin-add-jsx-attribute-5.4.0.tgz#81ef61947bb268eb9d50523446f9c638fb355906"
@@ -2301,6 +2308,11 @@
   resolved "https://registry.yarnpkg.com/@types/node/-/node-14.0.13.tgz#ee1128e881b874c371374c1f72201893616417c9"
   integrity sha512-rouEWBImiRaSJsVA+ITTFM6ZxibuAlTuNOCyxVbwreu6k6+ujs7DfnU9o+PShFhET78pMBl3eH+AGSI5eOTkPA==
 
+"@types/node@^11.13.4":
+  version "11.15.35"
+  resolved "https://registry.yarnpkg.com/@types/node/-/node-11.15.35.tgz#282b97494e4967649d776c3cc91da5f861a03c40"
+  integrity sha512-kmxE30w+R//Vh/+dlVS5DPPyzPtWtrMrJ9+io7jvkPtWv3X43ERA4HTcFEn/R7dtHO3HCMU1y3WKf3NDLYhQEQ==
+
 "@types/normalize-package-data@^2.4.0":
   version "2.4.0"
   resolved "https://registry.yarnpkg.com/@types/normalize-package-data/-/normalize-package-data-2.4.0.tgz#e486d0d97396d79beedd0a6e33f4534ff6b4973e"