Function cbm_daemon_watch_unsubscribe

src/daemon/daemon.c:658–694

}

bool cbm_daemon_watch_unsubscribe(cbm_daemon_coordinator_t *coordinator,
                                  cbm_daemon_client_id_t client_id,
                                  cbm_daemon_subscription_id_t subscription_id) {
    if (!coordinator || client_id == CBM_DAEMON_CLIENT_ID_INVALID ||
        subscription_id == CBM_DAEMON_SUBSCRIPTION_ID_INVALID) {
        return false;
    }

    cbm_daemon_callback_batch_t batch;
    cbm_mutex_lock(&coordinator->mutex);
    callback_batch_init_locked(coordinator, &batch);
    if (!find_client_locked(coordinator, client_id)) {
        cbm_mutex_unlock(&coordinator->mutex);
        return false;
    }
    bool removed = false;
    cbm_daemon_watch_t **cursor = &coordinator->watches;
    while (*cursor) {
        cbm_daemon_watch_t *watch = *cursor;
        removed = remove_subscription_locked(&watch->subscriptions, &watch->subscription_count,
                                             client_id, subscription_id);
        if (!removed) {
            cursor = &watch->next;
            continue;
        }
        if (watch->subscription_count == 0) {
            *cursor = watch->next;
            watch->next = NULL;
            coordinator->watch_count--;
            queue_watch_release_locked(coordinator, watch, &batch);
        }
        break;
    }
    cbm_mutex_unlock(&coordinator->mutex);
    callback_batch_run(coordinator, &batch);
    return removed;
}

size_t cbm_daemon_job_subscribers(cbm_daemon_coordinator_t *coordinator, const char *project_key) {
    if (!coordinator || !project_key) {