OutboundConnectorWebhook.java

// Part of the runtime that provides webhook endpoints
@PostMapping("/inbound/{context}")
public ResponseEntity<ProcessInstanceEvent> inbound(
    @PathVariable String context,
    @RequestBody Map<String, Object> body,
    @RequestHeader Map<String, String> headers) {

  if (!registry.containsContextPath(context)) {
    throw new ResponseStatusException(HttpStatus.NOT_FOUND, "No webhook found for context: " + context);
  }
  WebhookConnectorProperties connectorProperties = registry.getWebhookConnectorByContextPath(context);
  boolean valid = validateSecret(connectorProperties, webhookContext);
  if (!valid) {
    return ResponseEntity.status(400).build();
  }
  Map<String, Object> variables = extractVariables(connectorProperties, webhookContext);
  ProcessInstanceEvent processInstanceEvent = zeebeClient
    .newCreateInstanceCommand()
    .bpmnProcessId(connectorProperties.bpmnProcessId())
    .version(connectorProperties.version())
    .variables(variables)
    .send()
    .join(); // TODO: Switch to rective HTTP client
  return ResponseEntity.status(HttpStatus.CREATED).body(processInstanceEvent);
}