use-dcp-worker - npm Package Compare versions

Comparing version 1.0.2 to 1.0.3

lib/useDCPWorker.js

@@ -46,6 +46,6 @@ "use strict";
     }
-    else if (action.type === 'SUBMIT_TRUE') {
+    else if (action.type === 'SUBMITTING_TRUE') {
         updatedState.submitting = true;
     }
-    else if (action.type === 'SUBMIT_FALSE') {
+    else if (action.type === 'SUBMITTING_FALSE') {
         updatedState.fetching = false;
@@ -362,5 +362,3 @@ }
                 dcpWorker.on('sandbox', (sandbox) => {
-                    let lastStarted = NaN;
-                    const onStart = () => {
-                        lastStarted = Date.now();
+                    sandbox.on('slice', () => {
                         dispatchWorkerState({
@@ -370,36 +368,27 @@ type: 'SET_WORKING_SANDBOXES',
                         });
-                    };
-                    const onFinish = () => {
-                        const timeSpent = Date.now() - lastStarted;
-                        lastStarted = NaN;
-                        if (isFinite(timeSpent))
-                            dispatchWorkerStats({
-                                type: 'INCREMENT_COMPUTE_TIME',
-                                data: timeSpent,
-                            });
-                        dispatchWorkerState({
-                            type: 'SET_WORKING_SANDBOXES',
-                            data: dcpWorker.workingSandboxes.length,
+                    });
+                    sandbox.on('metrics', (_, measurements) => {
+                        dispatchWorkerStats({
+                            type: 'INCREMENT_COMPUTE_TIME',
+                            data: measurements.elapsed, // seconds
                         });
-                    };
-                    sandbox.on('start', onStart);
-                    sandbox.on('sliceFinish', onFinish);
-                    sandbox.on('terminate', () => {
-                        sandbox.off('start', onStart);
-                        sandbox.off('sliceFinish', onFinish);
                     });
                 });
-                dcpWorker.on('submit', () => {
+                dcpWorker.on('payment', (payment) => {
                     dispatchWorkerStats({ type: 'INCREMENT_SLICES' });
-                });
-                dcpWorker.on('payment', (receipt) => {
                     dispatchWorkerStats({
                         type: 'INCREMENT_CREDITS',
-                        data: receipt.payment,
+                        data: payment,
                     });
+                    dispatchWorkerState({
+                        type: 'SET_WORKING_SANDBOXES',
+                        data: dcpWorker.workingSandboxes.length,
+                    });
                 });
-                dcpWorker.on('fetchStart', () => {
+                dcpWorker.on('beforeFetch', () => {
                     dispatchWorkerState({ type: 'FETCHING_TRUE' });
                 });
-                dcpWorker.on('fetchEnd', () => {
+                dcpWorker.on('fetch', (payload) => {
+                    if (payload instanceof Error)
+                        return dispatchWorkerState({ type: 'ERROR', data: payload });
                     // extra delay for cleaner UI visual updates between quick fetching states
@@ -410,14 +399,10 @@ setTimeout(() => {
                 });
-                dcpWorker.on('fetchError', (error) => {
-                    dispatchWorkerState({ type: 'ERROR', data: error });
+                dcpWorker.on('beforeReturn', () => {
+                    dispatchWorkerState({ type: 'SUBMITTING_TRUE' });
                 });
-                dcpWorker.on('submitStart', () => {
-                    dispatchWorkerState({ type: 'SUBMIT_TRUE' });
+                dcpWorker.on('result', (payload) => {
+                    if (payload instanceof Error)
+                        return dispatchWorkerState({ type: 'ERROR', data: payload });
+                    dispatchWorkerState({ type: 'SUBMITTING_FALSE' });
                 });
-                dcpWorker.on('submitEnd', () => {
-                    dispatchWorkerState({ type: 'SUBMIT_FALSE' });
-                });
-                dcpWorker.on('submitError', (error) => {
-                    dispatchWorkerState({ type: 'ERROR', data: error });
-                });
                 dcpWorker.on('start', () => {
@@ -424,0 +409,0 @@ dispatchWorkerState({ type: 'WORKING_TRUE' });

package.json

 {
   "name": "use-dcp-worker",
-  "version": "1.0.2",
+  "version": "1.0.3",
   "description": "Embed the DCP Worker in a React app",
@@ -5,0 +5,0 @@ "main": "lib/useDCPWorker.js",

README.md

@@ -93,3 +93,3 @@ # use-dcp-worker
   - `credits: BigNumber`: Total credits earned.
-  - `computeTime: number`: Total time computed (ms).
+  - `computeTime: number`: Total time computed in seconds.
 - `workerOptionsState: object`: Refer to `workerOptions` in Parameters. This is to be treated as a read-only object, mutating it will not update worker options.
@@ -96,0 +96,0 @@ - `sandboxes: object`: List of Sandbox objects of sandboxes currently working. Sandbox objects consist of the properties: `id`, `isWorking`, `public`, `sliceStartTime`, and `progress`.

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

64574

decreased by-2.58%

Number of package files

7

decreased by-12.5%

Lines of code

1188

decreased by-2.46%

No dependency changes