New and Improved

Author: jwulf

.vscode/settings.json

@@ -1,5 +1,20 @@
 {
 	"editor.codeActionsOnSave": {
 		"source.organizeImports": true
-	}
+	},
+	"workbench.colorCustomizations": {
+		"activityBar.background": "#8a2ca2",
+		"activityBar.foreground": "#e7e7e7",
+		"activityBar.inactiveForeground": "#e7e7e799",
+		"activityBarBadge.background": "#af9530",
+		"activityBarBadge.foreground": "#15202b",
+		"titleBar.activeBackground": "#68217a",
+		"titleBar.inactiveBackground": "#68217a99",
+		"titleBar.activeForeground": "#e7e7e7",
+		"titleBar.inactiveForeground": "#e7e7e799",
+		"statusBar.background": "#68217a",
+		"statusBarItem.hoverBackground": "#8a2ca2",
+		"statusBar.foreground": "#e7e7e7"
+	},
+	"peacock.color": "#68217A"
 }

README.md

@@ -280,20 +280,17 @@ This will produce output similar to:
 // Autogenerated constants for msg-start.bpmn
 
 export enum TaskType = {
-
     CONSOLE_LOG = "console-log"
-
 };
 
 export enum MessageName = {
-
     MSG_EMIT_FRAME = "MSG-EMIT_FRAME",
     MSG_START_JOB = "MSG-START_JOB"
-
 };
-
 ```
 
+## Scaffolding code from a BPM file
+
 ## Logging
 
 Control the log output for the client library by setting the ZBClient log level. Valid log levels are `NONE` (supress all logging), `ERROR` (log only exceptions), `INFO` (general logging), or `DEBUG` (verbose logging). You can set this in the client constructor:

bin/zeebe-node-cli

@@ -0,0 +1,7 @@
+#!/usr/bin/env node
+const ZB = require("../")
+
+const workfile = args[1]
+(async () => {
+  console.log(await ZB.BpmnParser.scaffold(workflowFile));
+})();

package.json

@@ -22,6 +22,7 @@
 		"url": "https://github.com/creditsenseau/zeebe-client-node-js"
 	},
 	"main": "dist/index.js",
+	"bin": "bin/zeebe-node-cli",
 	"scripts": {
 		"build": "tsc",
 		"watch": "tsc -w",

src/__tests__/integration/Client-BrokenBpmn.spec.ts

@@ -1,12 +1,13 @@
 import { ZBClient } from '../..'
 
 process.env.ZB_NODE_LOG_LEVEL = process.env.ZB_NODE_LOG_LEVEL || 'NONE'
+const gatewayAddress = process.env.ZEEBE_GATEWAY_ADDRESS || '0.0.0.0:26500'
 
 describe('ZBClient', () => {
 	let zbc: ZBClient
 
 	beforeEach(async () => {
-		zbc = new ZBClient('0.0.0.0:26500')
+		zbc = new ZBClient(gatewayAddress)
 	})
 
 	afterEach(async () => {

src/__tests__/integration/Client-DeployWorkflow.spec.ts

@@ -1,8 +1,9 @@
 import { ZBClient } from '../../index'
+const gatewayAddress = process.env.ZEEBE_GATEWAY_ADDRESS || '0.0.0.0:26500'
 
 describe('ZBClient', () => {
 	it('deploys a workflow', async () => {
-		const zbc = new ZBClient('localhost')
+		const zbc = new ZBClient(gatewayAddress)
 		const result = await zbc.deployWorkflow(
 			`./src/__tests__/testdata/Client-DeployWorkflow.bpmn`
 		)

src/__tests__/integration/Client-MessageStart.spec.ts

@@ -2,12 +2,13 @@ import { v4 as uuid } from 'uuid'
 import { ZBClient } from '../..'
 
 process.env.ZB_NODE_LOG_LEVEL = process.env.ZB_NODE_LOG_LEVEL || 'NONE'
+const gatewayAddress = process.env.ZEEBE_GATEWAY_ADDRESS || '0.0.0.0:26500'
 
 describe('ZBClient', () => {
 	let zbc: ZBClient
 
 	beforeEach(async () => {
-		zbc = new ZBClient('0.0.0.0:26500')
+		zbc = new ZBClient(gatewayAddress)
 	})
 
 	afterEach(async () => {

src/__tests__/integration/Worker-Failure.spec.ts

@@ -1,13 +1,14 @@
 import { ZBClient } from '../..'
 
 process.env.ZB_NODE_LOG_LEVEL = process.env.ZB_NODE_LOG_LEVEL || 'NONE'
+const gatewayAddress = process.env.ZEEBE_GATEWAY_ADDRESS || '0.0.0.0:26500'
 
 describe('ZBWorker', () => {
 	let zbc: ZBClient
 	let wf
 
 	beforeEach(() => {
-		zbc = new ZBClient('0.0.0.0:26500')
+		zbc = new ZBClient(gatewayAddress)
 	})
 
 	afterEach(async () => {

src/__tests__/integration/Worker-LongPoll.spec.ts

@@ -1,20 +1,21 @@
 import { ZBClient } from '../..'
 
 process.env.ZB_NODE_LOG_LEVEL = process.env.ZB_NODE_LOG_LEVEL || 'NONE'
+const gatewayAddress = process.env.ZEEBE_GATEWAY_ADDRESS || '0.0.0.0:26500'
 
 describe('ZBWorker', () => {
 	let wf1
 	let wf2
 
 	afterAll(async () => {
-		const zbc = new ZBClient('0.0.0.0:26500')
+		const zbc = new ZBClient(gatewayAddress)
 		await zbc.cancelWorkflowInstance(wf1.workflowInstanceKey)
 		await zbc.cancelWorkflowInstance(wf2.workflowInstanceKey)
 		await zbc.close()
 	})
 
 	it("Doesn't long poll by default", async done => {
-		const zbc = new ZBClient('0.0.0.0:26500')
+		const zbc = new ZBClient(gatewayAddress)
 		const res = await zbc.deployWorkflow(
 			'./src/__tests__/testdata/Worker-LongPoll.bpmn'
 		)
@@ -40,7 +41,7 @@ describe('ZBWorker', () => {
 
 	it('Can long poll', async done => {
 		jest.setTimeout(30000)
-		const zbcLongPoll = new ZBClient('0.0.0.0:26500', {
+		const zbcLongPoll = new ZBClient(gatewayAddress, {
 			longPoll: 600000,
 		})
 		const res = await zbcLongPoll.deployWorkflow(

src/__tests__/integration/Worker-RaiseIncident.spec.ts

@@ -1,11 +1,12 @@
 import { ZBClient } from '../..'
+const gatewayAddress = process.env.ZEEBE_GATEWAY_ADDRESS || '0.0.0.0:26500'
 
 /**
  * Note: This test leaves its workflow instance active so the incident can be manually verified
  */
 describe('ZBWorker', () => {
 	let wfi
-	const zbc = new ZBClient('0.0.0.0:26500')
+	const zbc = new ZBClient(gatewayAddress)
 
 	afterAll(() => {
 		zbc.cancelWorkflowInstance(wfi)