Function application_background_index

src/daemon/application.c:3335–3442

}

static int application_background_index(cbm_daemon_application_t *application,
                                        const char *project_name, const char *root_path,
                                        bool require_live_watch) {
    if (!application || !project_name || !root_path) {
        return -1;
    }
    char canonical_root[APPLICATION_PATH_CAP];
    struct stat root_status;
    if (!cbm_canonical_path(root_path, canonical_root, sizeof(canonical_root)) ||
        stat(canonical_root, &root_status) != 0 || !S_ISDIR(root_status.st_mode)) {
        return -1;
    }
    yyjson_mut_doc *document = yyjson_mut_doc_new(NULL);
    yyjson_mut_val *root = document ? yyjson_mut_obj(document) : NULL;
    if (!document || !root) {
        yyjson_mut_doc_free(document);
        return -1;
    }
    yyjson_mut_doc_set_root(document, root);
    bool encoded = yyjson_mut_obj_add_strcpy(document, root, "repo_path", canonical_root);
    char *default_project = cbm_project_name_from_path(canonical_root);
    bool custom_project =
        project_name[0] && (!default_project || strcmp(default_project, project_name) != 0);
    if (encoded && custom_project) {
        encoded = yyjson_mut_obj_add_strcpy(document, root, "name", project_name);
    }
    free(default_project);
    char *args = encoded ? yyjson_mut_write(document, 0, NULL) : NULL;
    yyjson_mut_doc_free(document);
    if (!args) {
        return -1;
    }
    char *project_key = application_index_project_key(canonical_root, args);
    if (!project_key) {
        free(args);
        return -1;
    }

    application_job_subscribe_status_t subscribe_status = APPLICATION_JOB_SUBSCRIBE_UNAVAILABLE;
    application_jobs_reap_completed(application);
    cbm_mutex_lock(&application->mutex);
    cbm_daemon_application_watch_t *watch =
        require_live_watch ? application_find_watch_locked(application, project_name) : NULL;
    bool watch_live = !require_live_watch ||
                      (watch && watch->subscribers > 0 && strcmp(watch->root, canonical_root) == 0);
    size_t watch_owner_count = 0;
    bool watch_subscriptions_ok = true;
    cbm_daemon_application_job_t *job =
        watch_live ? application_job_subscribe_locked(application, project_key, canonical_root,
                                                      args, &subscribe_status)
                   : NULL;
    if (job && require_live_watch) {
        watch_subscriptions_ok = application_watch_job_subscribe_sessions_locked(
            application, watch, job, &watch_owner_count);
        if (watch_subscriptions_ok && watch_owner_count > 0) {
            job->watcher_waiters++;
        } else if (!watch_subscriptions_ok) {
            subscribe_status = APPLICATION_JOB_SUBSCRIBE_ALLOCATION_FAILED;