Function application_refresh_watch_locked

src/daemon/application.c:455–536

Caller holds application->mutex. */

/* Caller holds application->mutex. */
static void application_refresh_watch_locked(cbm_daemon_application_session_t *session) {
    cbm_daemon_application_t *application = session->application;
    if (!application->watcher || !session->context_set ||
        session->tool_profile != CBM_MCP_TOOL_PROFILE_ALL || session->hook_event ||
        session->hook_dialect || session->auto_index_subscribed) {
        return;
    }
    const char *project = cbm_mcp_server_session_project(session->mcp);
    const char *root = cbm_mcp_server_session_root(session->mcp);
    if (!project || !project[0] || !root || !root[0]) {
        return;
    }
    if (!application_session_workspace_allowed(session, "watch")) {
        application_release_session_watch_locked(session);
        return;
    }
    bool enabled = !application->config ||
                   cbm_config_get_bool(application->config, CBM_CONFIG_AUTO_WATCH, true);
    bool db_exists = application_regular_db_exists(project);

    /* Disconnect cancellation is the logical ownership boundary. An
     * in-flight request may reach this refresh after cancel returned but
     * before runtime can join it and call session_close; it must never
     * recreate that session's watch. */
    if (application->stopping || application_request_cancelled_locked(session)) {
        return;
    }
    cbm_daemon_application_watch_t *watch = application_find_watch_locked(application, project);
    if (!enabled || !db_exists) {
        /* A delete/config transition is global for this project. Remove the
         * physical watch and clear every logical subscriber in one step. */
        if (watch) {
            application_remove_watch_locked(application, watch);
        }
        return;
    }
    if (session->watch) {
        return;
    }
    if (watch) {
        if (strcmp(watch->root, root) == 0) {
            if (!application_watch_job_subscribe_late_session_locked(session, watch)) {
                cbm_log_warn("daemon.watch.late_owner_allocation_failed", "project", project,
                             "action", "retry");
                return;
            }
            watch->subscribers++;
            session->watch = watch;
        } else {
            cbm_log_warn("daemon.watch.project_collision", "project", project, "existing_root",
                         watch->root, "requested_root", root);
        }
        return;
    }

    watch = calloc(1, sizeof(*watch));
    if (watch) {
        watch->project = strdup(project);