@dr-js/core@0.3.0-dev.7

notable change:
- dev-fix: double `asyncTask[ PLAN ]` call in `runAsyncTask`
- dev-fix: verbose result of `getStatus` from `extendLaneValueMap`
- fix: ci: patch `libgbm1` for `puppeteer@3`, check: puppeteer/puppeteer#5674
- script sort
- package update

.github/workflows/ci-test.yml

@@ -26,6 +26,9 @@ jobs:
           echo "node: $(node -v)"
           echo "npm: $(npm -v)"
 
+      - name: Patch `libgbm1` for `puppeteer@3` # https://github.com/puppeteer/puppeteer/issues/5674
+        run: sudo apt-get install -y libgbm1
+
       - run: npm ci
 
       - run: npm test

package.json

@@ -1,7 +1,7 @@
 {
   "private": true,
   "name": "@dr-js/core",
-  "version": "0.3.0-dev.6",
+  "version": "0.3.0-dev.7",
   "description": "A collection of strange functions",
   "author": "dr-js",
   "license": "MIT",
@@ -17,19 +17,19 @@
     "script-pack-test": "node -r @babel/register ./script verbose pack test",
     "script-publish": "node -r @babel/register ./script pack publish",
     "script-publish-dev": "node -r @babel/register ./script pack publish-dev",
-    "script-generate-spec": "cross-env BABEL_ENV=use-source node -r @babel/register ./script/generateSpec ./tempFileDelete.config.json",
-    "script-delete-temp-build-file": "cross-env BABEL_ENV=use-source node -r @babel/register ./source-bin -c ./tempFileDelete.config.json",
+    "script-generate-spec": "dr-dev --EE BABEL_ENV=use-source -E -- node -r @babel/register ./script/generateSpec ./tempFileDelete.config.json",
+    "script-delete-temp-build-file": "dr-dev --EE BABEL_ENV=use-source -E -- node -r @babel/register ./source-bin -c ./tempFileDelete.config.json",
     "// build =======================": "",
     "build-bin": "babel ./source-bin --out-dir ./output-gitignore/bin --copy-files",
-    "build-bin-dev": "cross-env BABEL_ENV=dev babel ./source-bin --out-dir ./output-gitignore/bin --copy-files --watch",
+    "build-bin-dev": "dr-dev --EE BABEL_ENV=dev -E -- babel ./source-bin --out-dir ./output-gitignore/bin --copy-files --watch",
     "build-library-babel": "babel ./source --out-dir ./output-gitignore/library --ignore source/browser/",
-    "build-library-babel-dev": "cross-env BABEL_ENV=dev npm run build-library-babel -- --watch",
+    "build-library-babel-dev": "dr-dev --EE BABEL_ENV=dev -E -- npm run build-library-babel -- --watch",
     "build-library-webpack": "node -r @babel/register ./script/webpack production profile",
     "build-library-webpack-dev": "node -r @babel/register ./script/webpack development watch",
-    "build-module": "cross-env BABEL_ENV=module babel ./source --out-dir ./output-gitignore/module",
+    "build-module": "dr-dev --EE BABEL_ENV=module -E -- babel ./source --out-dir ./output-gitignore/module",
     "// test ========================": "",
-    "test-dev": "cross-env BABEL_ENV=dev dr-dev --TR @babel/register -T source/node/system/ResolveCommand.test.js",
-    "test-sanity": "cross-env BABEL_ENV=dev dr-dev --TR @babel/register -T source/common/.sanity.test/promise.test.js",
+    "test-dev": "dr-dev --EE BABEL_ENV=dev -E -- dr-dev --TR @babel/register -T source/common/module/AsyncTask.test.js",
+    "test-sanity": "dr-dev --EE BABEL_ENV=dev -E -- dr-dev --TR @babel/register -T source/common/.sanity.test/promise.test.js",
     "test-source": "dr-dev --TR @babel/register -T source/env/ source/common/ source/node/ --TFS .test.js",
     "test-output-library": "dr-dev -T output-gitignore/library/env/ output-gitignore/library/common/ output-gitignore/library/node/ --TFS .test.js",
     "test-output-module": "dr-dev --TR @babel/register -T output-gitignore/module/env/ output-gitignore/module/common/ output-gitignore/module/node/ --TFS .test.js",
@@ -47,8 +47,8 @@
     "npm": ">=6.12"
   },
   "devDependencies": {
-    "@dr-js/dev": "0.3.0-dev.4",
-    "@dr-js/dev-web-puppeteer": "0.3.0-dev.4"
+    "@dr-js/dev": "0.3.0-dev.6",
+    "@dr-js/dev-web-puppeteer": "0.3.0-dev.6"
   },
   "sideEffects": false
 }

source/common/module/AsyncLane.js

@@ -125,7 +125,7 @@ const extendLaneValueMap = (asyncLane) => {
 
   const getStatus = (isVerbose) => {
     const status = asyncLane.getStatus()
-    isVerbose && status.forEach((laneStatus) => { laneStatus.valueList = [ ...laneList[ laneStatus.index ].valueMap ] })
+    isVerbose && status.forEach((laneStatus) => { laneStatus.valueList = [ ...laneList[ laneStatus.index ].valueMap.values() ] })
     return status
   }
 

source/common/module/AsyncTask.js

@@ -93,13 +93,19 @@ const getAsyncTaskPhase = (asyncTask) => asyncTask[ OUTPUT ] ? DONE
 
 const runAsyncTask = (asyncTask) => { // re-run will overwrite existing `promise/query`
   if (__DEV__ && getAsyncTaskPhase(asyncTask) !== IDLE) throw new Error('should reset asyncTask to idle')
+
   const planResult = asyncTask[ PLAN ](asyncTask)
-  if (__DEV__ && !basicObject(planResult)) throw new Error('expect asyncTask[ PLAN ] return object')
-  Object.assign(asyncTask, asyncTask[ PLAN ](asyncTask)) // merge back and re-use same task object
+
+  if (__DEV__ && !basicObject(planResult)) throw new Error('expect asyncTask[ PLAN ] to return object')
+
+  if (planResult !== asyncTask) Object.assign(asyncTask, planResult) // merge back and re-use same task object
+
   __DEV__ && promiseAlike(asyncTask[ PLAN_PROMISE ])
   __DEV__ && basicFunction(asyncTask[ QUERY ])
-  asyncTask[ PROMISE ] = catchPromise(asyncTask[ PLAN_PROMISE ]) // record output, should never reject
-    .then((output) => (asyncTask[ OUTPUT ] = output))
+
+  asyncTask[ PROMISE ] = catchPromise(asyncTask[ PLAN_PROMISE ]) // should not reject
+    .then((output) => (asyncTask[ OUTPUT ] = output)) // record output as { result, error }
+
   return asyncTask[ PROMISE ]
 }
 

source/common/module/AsyncTask.test.js

@@ -75,6 +75,17 @@ describe('source/common/module/AsyncTask', () => {
     stringifyEqual(output, { result: undefined, error: outputError })
   })
 
+  it('direct error', async () => {
+    const promise = runAsyncTask({
+      [ PLAN ]: () => ({
+        [ PLAN_PROMISE ]: Promise.reject(outputError),
+        [ QUERY ]: async (type) => {}
+      })
+    })
+    const output = await promise
+    stringifyEqual(output, { result: undefined, error: outputError })
+  })
+
   it('resetAsyncTask', async () => {
     const asyncTask = getAsyncTask()
     await runAsyncTask(asyncTask)

source/node/.sanity.test/function.test.js

@@ -9,7 +9,7 @@ const PATH_TEMP = `${__dirname}/temp-gitignore`
 const runFuncWithExposeGC = async (...funcList) => withTempDirectory(
   PATH_TEMP,
   async () => run({
-    command: process.argv0,
+    command: process.argv[ 0 ],
     argList: [
       '--expose-gc', // allow `global.gc()` call
       '--max-old-space-size=32', // limit max memory usage for faster OOM

source/node/system/ResolveCommand.test.js

@@ -19,6 +19,8 @@ describe('Node.Module.ResolveCommand', () => {
   ]
 
   it('resolveCommandName()', () => {
+    // strictEqual(resolveCommandName(process.argv0), process.argv[ 0 ], 'should return same node path')
+
     for (const [ commandName, isExpectResult ] of COMMAND_NAME_LIST) {
       const result = resolveCommandName(commandName)
       info(`${JSON.stringify(commandName)} => ${JSON.stringify(result)}`)