laravolt / camunda
High level model, something like Eloquent, to interact with Camunda resources via REST API
Installs: 10 459
Dependents: 1
Suggesters: 0
Security: 0
Stars: 16
Watchers: 6
Forks: 11
Open Issues: 5
Requires
- php: >=8.0
- ext-simplexml: *
- guzzlehttp/guzzle: ^7.2
- spatie/data-transfer-object: ^3.6.1
Requires (Dev)
- brianium/paratest: ^6.2
- friendsofphp/php-cs-fixer: v3.0.0-rc.1
- orchestra/testbench: ^6.11
- sempro/phpunit-pretty-print: ^1.4
README
Convenience Laravel HTTP client wrapper to interact with Camunda REST API.
Installation
composer require laravolt/camunda
Configuration
Prepare your .env
:
CAMUNDA_URL=http://localhost:8080/engine-rest #optional CAMUNDA_TENANT_ID= CAMUNDA_USER= CAMUNDA_PASSWORD=
Add following entries to config/services.php
:
'camunda' => [ 'url' => env('CAMUNDA_URL', 'https://localhost:8080/engine-rest'), 'user' => env('CAMUNDA_USER', 'demo'), 'password' => env('CAMUNDA_PASSWORD', 'demo'), 'tenant_id' => env('CAMUNDA_TENANT_ID', ''), ],
Usage
Process Definition
use Laravolt\Camunda\Http\ProcessDefinitionClient; $variables = ['title' => ['value' => 'Sample Title', 'type' => 'string']]; // Start new process instance $instance = ProcessDefinitionClient::start(key: 'process_1', variables: $variables); // Start new process instance with some business key $instance = ProcessDefinitionClient::start(key: 'process_1', variables: $variables, businessKey: 'somekey'); // Get BPMN definition in XML format ProcessDefinitionClient::xml(key: 'process_1'); ProcessDefinitionClient::xml(id: 'process_1:xxxx'); // Get all definition ProcessDefinitionClient::get(); // Get definitions based on some parameters $params = ['latestVersion' => true]; ProcessDefinitionClient::get($params);
Camunda API reference: https://docs.camunda.org/manual/latest/reference/rest/process-definition/
Process Instance
use Laravolt\Camunda\Http\ProcessInstanceClient; // Find by ID $processInstance = ProcessInstanceClient::find(id: 'some-id'); // Get all instances ProcessInstanceClient::get(); // Get instances based on some parameters $params = ['businessKeyLike' => 'somekey']; ProcessInstanceClient::get($params); ProcessInstanceClient::variables(id: 'some-id'); ProcessInstanceClient::delete(id: 'some-id');
Camunda API reference: https://docs.camunda.org/manual/latest/reference/rest/process-instance/
Message Event
use Laravolt\Camunda\Http\MessageEventClient; // Start processinstance with message event // Required // messageName : message event name // businessKey : Busniess key for process instance // Rerturn Process insntance from message event MessageEventClient::start(messageName: "testing", businessKey: "businessKey")
Task
use Laravolt\Camunda\Http\TaskClient; $task = TaskClient::find(id: 'task-id'); $tasks = TaskClient::getByProcessInstanceId(id: 'process-instance-id'); $tasks = TaskClient::getByProcessInstanceIds(ids: 'arrayof-process-instance-ids'); TaskClient::submit(id: 'task-id', variables: ['name' => ['value' => 'Foo', 'type' => 'String']]); // will return true or false $variables = TaskClient::submitAndReturnVariables(id: 'task-id', variables: ['name' => ['value' => 'Foo', 'type' => 'String']]) // will return array of variable // Claim a Task $tasks = TaskClient::claim($task_id, $user_id); // Unclaim a Task $tasks = TaskClient::unclaim($task_id); // Assign a Task $tasks = TaskClient::assign($task_id, $user_id);
Camunda API reference: https://docs.camunda.org/manual/latest/reference/rest/task/
External Task
use Laravolt\Camunda\Http\ExternalTaskClient; $topics = [ ['topicName' => 'pdf', 'lockDuration' => 600_000] ]; $externalTasks = ExternalTaskClient::fetchAndLock('worker1', $topics); foreach ($externalTasks as $externalTask) { // do something with $externalTask // Mark as complete after finished ExternalTaskClient::complete($externalTasks->id); } // Unlock some task ExternalTaskClient::unlock($task->id) // Get task locked $externalTaskLocked = ExternalTaskClient::getTaskLocked();
Camunda API reference: https://docs.camunda.org/manual/latest/reference/rest/external-task/
Consume External Task
Create a new job to consume external task via php artisan make:job <JobName>
and modify the skeleton:
use Laravolt\Camunda\Dto\ExternalTask; use Laravolt\Camunda\Http\ExternalTaskClient; public function __construct( public string $workerId, public ExternalTask $task ) { } public function handle() { // Do something with $this->task, e.g: get the variables and generate PDF $variables = \Laravolt\Camunda\Http\ProcessInstanceClient::variables($this->task->processDefinitionId); // PdfService::generate() // Complete the task $status = ExternalTaskClient::complete($this->task->id, $this->workerId); }
Subscribe to some topic:
// AppServiceProvider.php use Laravolt\Camunda\Http\ExternalTaskClient; public function boot() { ExternalTaskClient::subscribe('pdf', GeneratePdf::class); }
Register the scheduler:
// app/Console/Kernel.php protected function schedule(Schedule $schedule) { $schedule->command('camunda:consume-external-task --workerId=worker1')->everyMinute(); }
If you need shorter pooling time (sub-minute frequency), please check Laravel Short Schedule.
Reference:
- https://laravel.com/docs/master/scheduling
- https://laravel.com/docs/master/queues
- https://github.com/spatie/laravel-short-schedule
Task History (Completed Task)
use Laravolt\Camunda\Http\TaskHistoryClient; $completedTask = TaskHistoryClient::find(id: 'task-id'); $completedTasks = TaskHistoryClient::getByProcessInstanceId(id: 'process-instance-id');
Camunda API reference: https://docs.camunda.org/manual/latest/reference/rest/history/task/
Deployment
use Laravolt\Camunda\Http\DeploymentClient; // Deploy bpmn file(s) DeploymentClient::create('test-deploy', '/path/to/file.bpmn'); DeploymentClient::create('test-deploy', ['/path/to/file1.bpmn', '/path/to/file2.bpmn']); // Get deployment list DeploymentClient::get(); // Find detailed info about some deployment DeploymentClient::find($id); // Truncate (delete all) deployments $cascade = true; DeploymentClient::truncate($cascade); // Delete single deployment DeploymentClient::delete(id: 'test-deploy', cascade: $cascade);
Raw Endpoint
You can utilize Laravolt\Camunda\CamundaClient
to call any Camunda REST endpoint.
use Laravolt\Camunda\CamundaClient; $response = CamundaClient::make()->get('version'); echo $response->status(); // 200 echo $response->object(); // sdtClass echo $response->json(); // array, something like ["version" => "7.14.0"]
CamundaClient::make()
is a wrapper for Laravel HTTP Client with base URL already set based on your Camunda services configuration. Take a look at the documentation for more information.