chore: setup REST client early

Author: jarekdanielak

demo/server.mjs

@@ -5,59 +5,41 @@ import dotenv from 'dotenv';
 const __filename = fileURLToPath(import.meta.url);
 const __dirname = path.dirname(__filename);
 
-dotenv.config({ path: path.join(__dirname, '.env') });
-
 import express from 'express';
 
 import { Camunda8 } from '@camunda8/sdk';
 
-const app = express();
-
-app.use(express.json());
-
-app.use(express.static(path.join(__dirname, 'public')));
 
 /** @type {import('@camunda8/sdk').CamundaRestClient} */
 let camundaRestClient;
 
-const PORT = process.env.PORT || 3000;
+try {
 
-app.listen(PORT, () => {
-  console.log(`\n🚀 Camunda 8 API starting on port ${PORT}\n`);
+  const config = dotenv.config({ path: path.join(__dirname, '.env') }).parsed;
 
+  if (!Object.keys(config)?.length) {
+    throw new Error('No configuration found in .env file');
+  }
 
-  const config = {
-    ...process.env,
-    CAMUNDA_TOKEN_DISK_CACHE_DISABLE: true
-  };
+  const c8 = new Camunda8(config);
+  camundaRestClient = c8.getCamundaRestClient();
 
-  try {
-    const c8 = new Camunda8(config);
-    camundaRestClient = c8.getCamundaRestClient();
-  } catch (error) {
-    console.error('Failed to create Camunda 8 REST client:', error);
-    console.warn('API requests will return { success: false }');
-    return;
-  }
+  createJobWorker();
+} catch (error) {
+  console.error('Failed to create Camunda 8 REST client:', error);
+  console.warn('API requests will return { success: false }');
+}
 
-  camundaRestClient.createJobWorker({
-    type: 'foo',
-    jobHandler: async (job) => {
-      console.log('🚀 Processing job worker...');
+const app = express();
 
-      // Simulate some work with a delay
-      await new Promise((resolve) => setTimeout(resolve, 2000));
+app.use(express.json());
 
-      console.log('🚀 Job completed');
+app.use(express.static(path.join(__dirname, 'public')));
 
-      job.complete({
-        foo: 'jobWorkerWasHere'
-      });
-    },
-    pollInterval: 1000,
-    timeout: 5000,
-    maxJobsToActivate: 5
-  });
+const PORT = process.env.PORT || 3000;
+
+app.listen(PORT, () => {
+  console.log(`\n🚀 Camunda 8 API starting on port ${PORT}\n`);
 });
 
 app.post('/api/deploy', async (req, res) => {
@@ -193,4 +175,30 @@ app.get('/api/getProcessInstanceIncident/:processInstanceKey', async (req, res)
   } catch (err) {
     res.status(500).json({ success: false, error: err.message });
   }
-});
+});
+
+function createJobWorker() {
+  if (!camundaRestClient) {
+    console.warn('Camunda environment not configured, job worker not started');
+    return;
+  }
+
+  camundaRestClient.createJobWorker({
+    type: 'foo',
+    jobHandler: async (job) => {
+      console.log('🚀 Processing job worker...');
+
+      // Simulate some work with a delay
+      await new Promise((resolve) => setTimeout(resolve, 2000));
+
+      console.log('🚀 Job completed');
+
+      job.complete({
+        foo: 'jobWorkerWasHere'
+      });
+    },
+    pollInterval: 1000,
+    timeout: 5000,
+    maxJobsToActivate: 5
+  });
+}