andreashuber69/lightning-node-operator

// https://github.com/andreashuber69/lightning-node-operator/develop/README.md
import assert from "node:assert";
import { describe, it } from "node:test";
import type { AuthenticatedLightningArgs, PaginationArgs } from "lightning";

import { getMilliseconds } from "../../info/getMilliseconds.js";
import type { TimeBoundElement } from "../../TimeBoundElement.js";
import { connectLnd } from "../connectLnd.js";

export const testPaginatedArrayResultFunction = async <
    Element extends TimeBoundElement,
    After extends string,
    Before extends string,
>(
    func: (args: AuthenticatedLightningArgs<PaginationArgs>) => AsyncGenerator<Element, void>,
    after: After,
    before: Before,
) => {
    await describe(func.name, async () => {
        await it("should yield a number of elements not higher than defined by the limit", async () => {
            const limit = 3;
            let length = 0;

            for await (const _ of func({ limit, ...await connectLnd() })) {
                ++length;
            }

            assert(length <= limit);
            assert(length >= 0);
        });

        await it("should return results of 1 day", async () => {
            const oneDay = getMilliseconds(1);
            const now = Date.now();
            const oneDayAgo = now - oneDay;

            const results = func({
                [after]: new Date(oneDayAgo).toISOString(),
                [before]: new Date(now).toISOString(),
                ...await connectLnd(),
            });

            for await (const result of results) {
                assert(now - Date.parse(result.created_at) < oneDay);
            }
        });
    });
};