Skip to content

Commit bc8fac0

Browse files
committed
Use Temporal polyfill in depth tests
Mirror the existing PostgreSQL and MySQL test pattern so Redis, AMQP, and SQLite depth tests can construct Temporal durations when running under Node versions without a native Temporal global. Assisted-by: Codex:gpt-5.5
1 parent 5b4c2ba commit bc8fac0

3 files changed

Lines changed: 9 additions & 0 deletions

File tree

‎packages/amqp/src/mq.test.ts‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,15 @@
11
import { suite } from "@alinea/suite";
22
import { AmqpMessageQueue } from "@fedify/amqp/mq";
33
import { getRandomKey, testMessageQueue, waitFor } from "@fedify/testing";
4+
import * as temporal from "@js-temporal/polyfill";
45
import { assert, assertEquals, assertFalse, assertGreater } from "@std/assert";
56
import { delay } from "@std/async/delay";
67
// @deno-types="npm:@types/amqplib"
78
import { type ChannelModel, connect } from "amqplib";
89
import process from "node:process";
910

11+
const Temporal = globalThis.Temporal ?? temporal.Temporal;
12+
1013
const AMQP_URL = process.env.AMQP_URL;
1114
const test = AMQP_URL ? suite(import.meta) : suite(import.meta).skip;
1215

‎packages/redis/src/mq.test.ts‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,14 @@
11
import { test } from "@fedify/fixture";
22
import { RedisMessageQueue } from "@fedify/redis/mq";
33
import { getRandomKey, testMessageQueue } from "@fedify/testing";
4+
import * as temporal from "@js-temporal/polyfill";
45
import assert from "node:assert/strict";
56
import process from "node:process";
67

78
import { Redis } from "ioredis";
89

10+
const Temporal = globalThis.Temporal ?? temporal.Temporal;
11+
912
const dbUrl = process.env.REDIS_URL;
1013

1114
async function disposeMessageQueue(mq: object): Promise<void> {

‎packages/sqlite/src/mq.test.ts‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,14 @@ import { PlatformDatabase } from "#sqlite";
22
import { test } from "@fedify/fixture";
33
import { SqliteMessageQueue } from "@fedify/sqlite/mq";
44
import { getRandomKey, testMessageQueue } from "@fedify/testing";
5+
import * as temporal from "@js-temporal/polyfill";
56
import assert from "node:assert/strict";
67
import { mkdtemp } from "node:fs/promises";
78
import { tmpdir } from "node:os";
89
import { join } from "node:path";
910

11+
const Temporal = globalThis.Temporal ?? temporal.Temporal;
12+
1013
const dbDir = await mkdtemp(join(tmpdir(), "fedify-sqlite-"));
1114
const dbPath = join(dbDir, `${getRandomKey("sqlite")}.db`);
1215
const db = new PlatformDatabase(dbPath);

0 commit comments

Comments
 (0)