Function cbm_daemon_watch_subscribe

src/daemon/daemon.c:570–627

}

cbm_daemon_subscription_result_t cbm_daemon_watch_subscribe(
    cbm_daemon_coordinator_t *coordinator, cbm_daemon_client_id_t client_id,
    const char *project_key, cbm_daemon_subscription_id_t *subscription_id) {
    if (subscription_id) {
        *subscription_id = CBM_DAEMON_SUBSCRIPTION_ID_INVALID;
    }
    if (!coordinator || !subscription_id || !project_key || project_key[0] == '\0' ||
        client_id == CBM_DAEMON_CLIENT_ID_INVALID) {
        return CBM_DAEMON_SUBSCRIPTION_REJECTED;
    }

    cbm_mutex_lock(&coordinator->mutex);
    if (coordinator->state != CBM_DAEMON_COORDINATOR_RUNNING ||
        !find_client_locked(coordinator, client_id)) {
        cbm_mutex_unlock(&coordinator->mutex);
        return CBM_DAEMON_SUBSCRIPTION_REJECTED;
    }
    cbm_daemon_watch_t *watch = find_watch_locked(coordinator, project_key);
    bool started = watch == NULL;
    cbm_daemon_watch_t *new_watch = NULL;
    char *key_copy = NULL;
    cbm_daemon_subscription_t *subscription = malloc(sizeof(*subscription));
    if (started) {
        new_watch = calloc(1, sizeof(*new_watch));
        key_copy = daemon_string_dup(project_key);
    }
    if (!subscription || (started && (!new_watch || !key_copy))) {
        free(subscription);
        free(new_watch);
        free(key_copy);
        cbm_mutex_unlock(&coordinator->mutex);
        return CBM_DAEMON_SUBSCRIPTION_REJECTED;
    }

    cbm_daemon_subscription_id_t id = issue_subscription_id_locked(coordinator);
    if (id == CBM_DAEMON_SUBSCRIPTION_ID_INVALID) {
        free(subscription);
        free(new_watch);
        free(key_copy);
        cbm_mutex_unlock(&coordinator->mutex);
        return CBM_DAEMON_SUBSCRIPTION_REJECTED;
    }
    if (started) {
        new_watch->project_key = key_copy;
        new_watch->next = coordinator->watches;
        coordinator->watches = new_watch;
        coordinator->watch_count++;
        watch = new_watch;
    }
    subscription->id = id;
    subscription->client_id = client_id;
    subscription->next = watch->subscriptions;
    watch->subscriptions = subscription;
    watch->subscription_count++;
    *subscription_id = id;
    cbm_mutex_unlock(&coordinator->mutex);
    return started ? CBM_DAEMON_SUBSCRIPTION_STARTED : CBM_DAEMON_SUBSCRIPTION_JOINED;
}