Changeset 79a0317 for imaps-frontend/node_modules/fastq

Timestamp:

01/21/25 03:08:24 (3 days ago)

Author:

stefan toskovski <stefantoska84@…>

Branches:

main

Parents:

0c6b92a

Message:

F4 Finalna Verzija

Location:

imaps-frontend/node_modules/fastq

Files:

• SECURITY.md (added)
• package.json (modified) (3 diffs)
• queue.js (modified) (1 diff)
• test/promise.js (modified) (1 diff)

imaps-frontend/node_modules/fastq/package.json

@@ -1 +1 @@
 {
-  "name": "fastq",
-  "version": "1.17.1",
-  "description": "Fast, in memory work queue",
-  "main": "queue.js",
-  "scripts": {
-    "lint": "standard --verbose | snazzy",
-    "unit": "nyc --lines 100 --branches 100 --functions 100 --check-coverage --reporter=text tape test/test.js test/promise.js",
-    "coverage": "nyc --reporter=html --reporter=cobertura --reporter=text tape test/test.js test/promise.js",
-    "test:report": "npm run lint && npm run unit:report",
-    "test": "npm run lint && npm run unit",
-    "typescript": "tsc --project ./test/tsconfig.json",
-    "legacy": "tape test/test.js"
+  "_from": "fastq@^1.6.0",
+  "_id": "fastq@1.18.0",
+  "_inBundle": false,
+  "_integrity": "sha512-QKHXPW0hD8g4UET03SdOdunzSouc9N4AuHdsX8XNcTsuz+yYFILVNIX4l9yHABMhiEI9Db0JTTIpu0wB+Y1QQw==",
+  "_location": "/fastq",
+  "_phantomChildren": {},
+  "_requested": {
+    "type": "range",
+    "registry": true,
+    "raw": "fastq@^1.6.0",
+    "name": "fastq",
+    "escapedName": "fastq",
+    "rawSpec": "^1.6.0",
+    "saveSpec": null,
+    "fetchSpec": "^1.6.0"
   },
-  "pre-commit": [
-    "test",
-    "typescript"
+  "_requiredBy": [
+    "/@nodelib/fs.walk"
   ],
-  "repository": {
-    "type": "git",
-    "url": "git+https://github.com/mcollina/fastq.git"
+  "_resolved": "https://registry.npmjs.org/fastq/-/fastq-1.18.0.tgz",
+  "_shasum": "d631d7e25faffea81887fe5ea8c9010e1b36fee0",
+  "_spec": "fastq@^1.6.0",
+  "_where": "/home/stevetosak/Proekt/IMaps/imaps-frontend/node_modules/@nodelib/fs.walk",
+  "author": {
+    "name": "Matteo Collina",
+    "email": "hello@matteocollina.com"
   },
-  "keywords": [
-    "fast",
-    "queue",
-    "async",
-    "worker"
-  ],
-  "author": "Matteo Collina <hello@matteocollina.com>",
-  "license": "ISC",
   "bugs": {
     "url": "https://github.com/mcollina/fastq/issues"
   },
-  "homepage": "https://github.com/mcollina/fastq#readme",
+  "bundleDependencies": false,
+  "dependencies": {
+    "reusify": "^1.0.4"
+  },
+  "deprecated": false,
+  "description": "Fast, in memory work queue",
   "devDependencies": {
     "async": "^3.1.0",
@@ -43 +46 @@
     "typescript": "^5.0.4"
   },
-  "dependencies": {
-    "reusify": "^1.0.4"
+  "homepage": "https://github.com/mcollina/fastq#readme",
+  "keywords": [
+    "fast",
+    "queue",
+    "async",
+    "worker"
+  ],
+  "license": "ISC",
+  "main": "queue.js",
+  "name": "fastq",
+  "pre-commit": [
+    "test",
+    "typescript"
+  ],
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/mcollina/fastq.git"
+  },
+  "scripts": {
+    "coverage": "nyc --reporter=html --reporter=cobertura --reporter=text tape test/test.js test/promise.js",
+    "legacy": "tape test/test.js",
+    "lint": "standard --verbose | snazzy",
+    "test": "npm run lint && npm run unit",
+    "test:report": "npm run lint && npm run unit:report",
+    "typescript": "tsc --project ./test/tsconfig.json",
+    "unit": "nyc --lines 100 --branches 100 --functions 100 --check-coverage --reporter=text tape test/test.js test/promise.js"
   },
   "standard": {
@@ -50 +77 @@
       "example.mjs"
     ]
-  }
+  },
+  "version": "1.18.0"
 }

imaps-frontend/node_modules/fastq/queue.js

@@ -289 +289 @@
 
   function drained () {
-    if (queue.idle()) {
-      return new Promise(function (resolve) {
-        resolve()
+    var p = new Promise(function (resolve) {
+      process.nextTick(function () {
+        if (queue.idle()) {
+          resolve()
+        } else {
+          var previousDrain = queue.drain
+          queue.drain = function () {
+            if (typeof previousDrain === 'function') previousDrain()
+            resolve()
+            queue.drain = previousDrain
+          }
+        }
       })
-    }
-
-    var previousDrain = queue.drain
-
-    var p = new Promise(function (resolve) {
-      queue.drain = function () {
-        previousDrain()
-        resolve()
-      }
     })
 

imaps-frontend/node_modules/fastq/test/promise.js

@@ -247 +247 @@
   process.removeListener('unhandledRejection', handleRejection)
 })
+
+test('drained should resolve after async tasks complete', async function (t) {
+  const logs = []
+
+  async function processTask () {
+    await new Promise(resolve => setTimeout(resolve, 0))
+    logs.push('processed')
+  }
+
+  const queue = buildQueue(processTask, 1)
+  queue.drain = () => logs.push('called drain')
+
+  queue.drained().then(() => logs.push('drained promise resolved'))
+
+  await Promise.all([
+    queue.push(),
+    queue.push(),
+    queue.push()
+  ])
+
+  t.deepEqual(logs, [
+    'processed',
+    'processed',
+    'processed',
+    'called drain',
+    'drained promise resolved'
+  ], 'events happened in correct order')
+})
+
+test('drained should handle undefined drain function', async function (t) {
+  const queue = buildQueue(worker, 1)
+
+  async function worker (arg) {
+    await sleep(10)
+    return arg
+  }
+
+  queue.drain = undefined
+  queue.push(1)
+  await queue.drained()
+
+  t.pass('drained resolved successfully with undefined drain')
+})