@@ -4,6 +4,7 @@ import { resolvePreferredOpenClawTmpDir } from "openclaw/plugin-sdk/temp-path";
|
4 | 4 | import { beforeEach, describe, expect, it, vi } from "vitest"; |
5 | 5 | |
6 | 6 | const loadOutboundMediaFromUrlMock = vi.fn(); |
| 7 | +const ZALO_OUTBOUND_MEDIA_DIR_NAME = "openclaw-zalo-outbound-media"; |
7 | 8 | |
8 | 9 | vi.mock("openclaw/plugin-sdk/outbound-media", () => ({ |
9 | 10 | loadOutboundMediaFromUrl: (...args: unknown[]) => loadOutboundMediaFromUrlMock(...args), |
@@ -16,6 +17,11 @@ import {
|
16 | 17 | tryHandleHostedZaloMediaRequest, |
17 | 18 | } from "./outbound-media.js"; |
18 | 19 | |
| 20 | +function resolveHostedZaloMediaDirName(): string { |
| 21 | +const workerId = process.env.VITEST_WORKER_ID ?? process.env.VITEST_POOL_ID; |
| 22 | +return workerId ? `${ZALO_OUTBOUND_MEDIA_DIR_NAME}-${workerId}` : ZALO_OUTBOUND_MEDIA_DIR_NAME; |
| 23 | +} |
| 24 | + |
19 | 25 | function createMockResponse() { |
20 | 26 | const headers = new Map<string, string>(); |
21 | 27 | return { |
@@ -90,7 +96,7 @@ describe("zalo outbound hosted media", () => {
|
90 | 96 | expect(id).toHaveLength(24); |
91 | 97 | expect(/^[0-9a-f]+$/.test(id)).toBe(true); |
92 | 98 | |
93 | | -const storageDir = join(resolvePreferredOpenClawTmpDir(), "openclaw-zalo-outbound-media"); |
| 99 | +const storageDir = join(resolvePreferredOpenClawTmpDir(), resolveHostedZaloMediaDirName()); |
94 | 100 | const [dirStats, metadataStats, bufferStats] = await Promise.all([ |
95 | 101 | stat(storageDir), |
96 | 102 | stat(join(storageDir, `${id}.json`)), |
|
