Function runtime_worker_handle_unsubscribe

src/daemon/runtime.c:1259–1268

}

static bool runtime_worker_handle_unsubscribe(cbm_daemon_runtime_worker_t *worker,
                                              const uint8_t *payload, uint32_t length) {
    if (!runtime_worker_service_running(worker) || !payload || length != UNSUBSCRIBE_REQUEST_SIZE) {
        return false;
    }
    cbm_daemon_subscription_id_t subscription_id = runtime_get_u64(payload);
    bool removed = cbm_daemon_job_unsubscribe(worker->service->coordinator, worker->client_id,
                                              subscription_id);
    return runtime_worker_send_status(worker, CBM_DAEMON_RUNTIME_OP_JOB_UNSUBSCRIBE, removed);
}

static void *runtime_application_worker(void *opaque) {
    cbm_daemon_runtime_worker_t *worker = opaque;