beacon - WIP

Author: sbazerque

examples/randomness-beacon/model/Beacon.ts

@@ -66,19 +66,11 @@ class Beacon extends MutableObject implements SpaceEntryPoint {
             Beacon.log.debug(() => 'Racing for challenge (' + this.steps + ' steps): "' + this.currentChallenge() + '".');
 
             this._computation = new Worker('./dist-examples/examples/randomness-beacon/model/worker.js');
-            console.log('is death immediate?')
-            this._computation.on('online', () => {console.log('worker is online')});
             this._computation.on('error', (err: Error) => { console.log('ERR');console.log(err)});
-            this._computation.on('exit', (exitCode: number) => {
-                console.log('worker exited with ' + exitCode);
-            })
-            console.log('created worker')
             this._computation.on('message', async (msg: {challenge: string, result: string}) => {
 
                 Beacon.log.debug(() => 'Solved challenge "' + msg.challenge + '" with: "' + msg.result + '".');
 
-                
-
                 if (msg.challenge === this.currentChallenge()) {
                     let op = new BeaconValueOp(this, this.currentSeq(), msg.result);
 
@@ -92,25 +84,23 @@ class Beacon extends MutableObject implements SpaceEntryPoint {
                     await this.getStore().save(this);
 
                 } else {
-                    console.log('mismatched challenge');
+                    Beacon.log.debug('Mismatched challenge - could be normal.');
                 }
             });
             this._computation.postMessage({steps: this.steps, challenge: this.currentChallenge()});
-            console.log('posted message to worker')
 
         } else {
-            console.log('race was called but a computation is running');
+            Beacon.log.debug('Race was called but a computation is running.');
         }
     }
 
     stopRace() {
-        console.log('stopRace()');
+        Beacon.log.debug('Going to stop current VDF computation.');
         if (this._computation !== undefined) {
             if (this._computationTermination === undefined) {
-                console.log('need to stop')
                 this._computationTermination = this._computation.terminate().then(
                     (ret: number) => {
-                        console.log('stopped');
+                        Beacon.log.trace('Stopped VDF computation');
                         this._computation = undefined;
                         this._computationTermination = undefined;
                         return ret;
@@ -174,15 +164,14 @@ class Beacon extends MutableObject implements SpaceEntryPoint {
 
                 if (this._autoCompute) {
                     if (this._computation === undefined) {
-                        console.log('computation was finished');
                         this.race();
                     } else {
-                        console.log('chaining');
                         this.stopRace();
-                        this._computationTermination?.then(() => { console.log('finished now!');this.race(); });
+                        this._computationTermination?.then(() => { this.race(); });
                     }
-                    
                 }
+
+                Beacon.log.debug('Challenge now is "' + this.currentChallenge() + '".');
 
             }
 

examples/randomness-beacon/model/BeaconValueOp.ts

@@ -114,7 +114,7 @@ class BeaconValueOp extends MutationOp {
         const challengeBuffer = Buffer.from(challenge, 'hex');
         const resultBuffer = Buffer.from(this.vdfResult, 'hex');
 
-        if (!BeaconValueOp.vdfVerifier.verify(steps, challengeBuffer, resultBuffer, 2048, true)) {
+        if (!BeaconValueOp.vdfVerifier.verify(steps, challengeBuffer, resultBuffer, 2048, false)) {
             BeaconValueOp.log.trace('VDF verification failed.');
             return false;
         }

examples/randomness-beacon/model/VDF.ts

@@ -1,23 +1,28 @@
+import { Logger, LogLevel } from "util/logging";
+
 const createVdf = require('@subspace/vdf').default;
 (global as any).document = { }; // yikes!
 
 class VDF {
+
+    static log = new Logger(VDF.name, LogLevel.TRACE)
+
     static async compute(challenge: string, steps: number): Promise<string> {
 
-        console.log('computing...')
+        VDF.log.debug('Computing VDF...');
 
         const vdfInstance = await createVdf();
-        const result = vdfInstance.generate(steps, Buffer.from(challenge, 'hex'), 2048, true);
+        const result = vdfInstance.generate(steps, Buffer.from(challenge, 'hex'), 2048, false);
 
-        console.log('done!')
+        VDF.log.debug('Done computing VDF.')
 
         const t = Date.now();
 
-        console.log('verification: ' + vdfInstance.verify(steps, Buffer.from(challenge, 'hex'), result, 2048, true));
+        VDF.log.debug('VDF sekf verification: ' + vdfInstance.verify(steps, Buffer.from(challenge, 'hex'), result, 2048, true));
 
         const elapsed = Date.now() - t;
 
-        console.log('verification took ' + elapsed + ' millis');
+        VDF.log.debug('verification took ' + elapsed + ' millis');
 
         return Buffer.from(result).toString('hex');
     }

examples/randomness-beacon/model/worker.ts

@@ -5,13 +5,9 @@ class VDFWorker {
     static start() {
 
             parentPort?.on('message', async (q: {challenge: string, steps: number}) => {
-    
-    
-                console.log('worker woke up')
+
 
                 let result = await VDF.compute(q.challenge, q.steps);
-    
-                console.log('worker has worked')
 
                 if (parentPort !== undefined && parentPort !== null) {
                     parentPort.postMessage(
@@ -22,7 +18,6 @@ class VDFWorker {
                         }
                     );
 
-                    console.log('worker has answered')
                 }