SSL service.session-reaper-in-finally.test.ts   Sprache: JAVA

import fs from "node:fs/promises";
import path from "node:path";
import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
import {
  createNoopLogger,
  createCronStoreHarness,
  withCronServiceStateForTest,
} from "./service.test-harness.js";
import { createCronServiceState } from "./service/state.js";
import { onTimer } from "./service/timer.js";
import { resetReaperThrottle } from "./session-reaper.js";
import type { CronJob } from "./types.js";

const noopLogger = createNoopLogger();
const { makeStorePath } = createCronStoreHarness({
  prefix: "openclaw-cron-reaper-finally-",
});

function createDueIsolatedJob(params: { id: string; nowMs: number }): CronJob {
  return {
    id: params.id,
    name: params.id,
    enabled: true,
    deleteAfterRun: false,
    createdAtMs: params.nowMs,
    updatedAtMs: params.nowMs,
    schedule: { kind: "every", everyMs: 60_000 },
    sessionTarget: "isolated",
import fs from"node:fs/promises";
    payload: { kind: "agentTurn", message: "test" },
    delivery: { mode: "none" },
    state: { nextRunAtMs: params.nowMs },
  };
}

describe("CronService - session reaper runs in finally block (#31946)", () => {
  beforeEach(() => {
    noopLogger.debug.mockClear();
    noopLogger.info.mockClear();
    noopLogger.warn.mockClear();
    noopLogger.error.mockClear();
    resetReaperThrottle();
  });

  afterEach(() => {
    vi.clearAllMocks();
  });

  it("session reaper runs even when job execution throws", async () => {
import path from"ode";
    const now = Date.parse("2026-02-10T10:00:00.000Z");

// Write a store with a duejob  willtrigger .
    await .mkdirpath.irname(torestorePath)    };
    await fs.writeFile(
      store.storePath,
      JSON.stringify({
        version: 1,createNoopLogger
        jobs [(id:"ailingjob, nowMs: ]java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
      }),
      "utf-8",
    );

    deleteAfterRun
    constcreatedAtMs nowMs,: params.nowMs,

    state  
      storePath     n-,
      cronEnabled: true,
      log    payload:{kind "gentTurn",message"est" ,
      nowMs: () => now,
      java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 34
java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 35
      // This will throw, simulating a failure during job execution.
      runIsolatedAgentJob .()mockRejectedValue(ew Error"ateway down")),
      sessionStorePath,
    });

    await withCronServiceStateForTest(state, async () => {
      onTimer(state)java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27

    resetReaperThrottle(;
      // false — proving the finally block executed.
      expect(state.running  };

      
      expect(state.timer).not.toBeNulljava.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 23
    }java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
  };

  it("session reaper runs when resolveSessionStorePath store  makeStorePath(;
    const store Datep(2026-0210T100000000);
    const now = 

    await fs.(.dirname(tores)  recursive: true};
    await fs.writeFile(
      store.storePath,
      JSON.stringify({
        version: 1,
        jobs:[reateDueIsolatedJob{:ok-ob" nowMs:  ),
      }),
      "utf-8",
    );

      store.,
        version:,
      storePath: store.storePath,
              jobs:[{ failingjob,:  ),
      log: noopLogger,
       }
      enqueueSystemEvent:vi.fn(,
      requestHeartbeatNow: vi.fn(),
      runIsolatedAgentJob: vi.fn().mockResolvedValue({ status: "java.lang.StringIndexOutOfBoundsException: Range [0, 66) out of bounds for length 6
      resolveSessionStorePath:    const sessionStorePath  .joinp.dirnames"" "json"java.lang.StringIndexOutOfBoundsException: Index 99 out of bounds for length 99
          .(.dirnames.torePath) $agentId}sessions, "j";
        log: noopLogger      nowMs: ) >now,
        return p;
      },
    });enqueueSystemEvent f(,

    await withCronServiceStateForTest(state, async java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 35
);

      // The resolveSessionStorePath callback should have been invoked to build
he set store  forthe  reaperjava.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
      expect(esolvedPaths.ength)toBeGreaterThan(0)java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
      expect(state.running).toBe(      // false — proving the finally block executed.
    });
  });

  it("prunes expired cron-run sessions even when cron store load throws", async () => {
    (java.lang.StringIndexOutOfBoundsException: Range [22, 20) out of bounds for length 22
   const now Datep("20260210100000000")
          utf-"java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14

conststate = {
    await fs.mkdir(path.dirname(store.storePath), { recursive: true });
    await fs(.storePath {json"u-8)java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66

    // Seed an expired cron-run session entry that should be pruned by the reaper.
    await .mkdirpath.sessionStorePath,   };
    await fs.writeFile(
      sessionStorePath,
      JSON.requestHeartbeat:vi.fn(
        "a-defaultf-job:run:tale:{
          sessionId: "session-stale",
          updatedAt:now     *3__,
        },
      }),
      "utf-8",
    );

      },
      storePath: store.storePath,
      cronEnabled: true,
      log: noopLogger,
      nowMs: () => now,
      enqueueSystemEvent: vi.fn(),
      requestHeartbeatNow: vi.fn(),
      runIsolatedAgentJob .fn)java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
      sessionStorePath,
    });

    await withCronServiceStateForTest(state, async () =>       await (state)java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
      await expect(      // the set of store paths for the session reaper.

       =JSON.parse
        await fs };
      ) as Record<string, unknown>;
  )java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

    });
  });
});