bull-arena - npm Package Compare versions

Comparing version 4.2.0 to 4.3.0

package.json

@@ -43,2 +43,4 @@ {
     "cm": "git cz",
+    "dc:up": "docker-compose -f docker-compose.yml up -d",
+    "dc:down": "docker-compose -f docker-compose.yml down",
     "dry:run": "npm publish --dry-run",
@@ -70,3 +72,3 @@ "lint": "prettier -c .",
   "repository": "https://github.com/bee-queue/arena.git",
-  "version": "4.2.0"
+  "version": "4.3.0"
 }

public/dashboard.js

@@ -317,2 +317,34 @@ $(document).ready(() => {
 
+  $('.js-update-job-data').on('click', function (e) {
+    e.preventDefault();
+    const jobId = $(this).data('job-id');
+    const queueName = $(this).data('queue-name');
+    const queueHost = $(this).data('queue-host');
+    const stringifiedData = JSON.stringify(window.jsonEditor.get());
+    const r = window.confirm(
+      `Update job #${jobId} data in queue "${queueHost}/${queueName}"?`
+    );
+
+    if (r) {
+      $.ajax({
+        url: `${basePath}/api/queue/${encodeURIComponent(
+          queueHost
+        )}/${encodeURIComponent(queueName)}/job/${encodeURIComponent(
+          jobId
+        )}/data`,
+        type: 'PUT',
+        data: stringifiedData,
+        contentType: 'application/json',
+      })
+        .done(() => {
+          alert('Job data successfully updated!');
+          window.location.reload();
+        })
+        .fail((jqXHR) => {
+          window.alert('Failed to update job data, check console for error.');
+          console.error(jqXHR.responseText);
+        });
+    }
+  });
+
   $('.js-add-flow').on('click', function () {
@@ -319,0 +351,0 @@ const data = window.jsonEditor.get();

src/server/views/api/index.js

@@ -9,2 +9,3 @@ const router = require('express').Router();
 const jobRemove = require('./jobRemove');
+const jobDataUpdate = require('./jobDataUpdate');
 const repeatableJobRemove = require('./repeatableJobRemove');
@@ -28,2 +29,3 @@ const bulkJobsPromote = require('./bulkJobsPromote');
 );
+router.put('/queue/:queueHost/:queueName/job/:id/data', jobDataUpdate);
 router.patch('/queue/:queueHost/:queueName/job/:id', jobRetry);
@@ -30,0 +32,0 @@ router.put('/queue/:queueHost/:queueName/pause', queuePause);

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

Improved metrics

Total package byte prevSize

2144120

increased by0.15%

Number of package files

64

increased by1.59%

Lines of code

6010

increased by0.87%

No dependency changes