oh-my-opencode/src/shared/zip-entry-listing/tar-zip-entry-listing.test.ts

import { afterEach, describe, expect, it, mock, spyOn } from "bun:test"

import * as logger from "../logger"

type TarZipEntryListingModule = typeof import("./tar-zip-entry-listing")

async function importFreshTarZipEntryListingModule(): Promise<TarZipEntryListingModule> {
  return await import(`./tar-zip-entry-listing?test=${Date.now()}-${Math.random()}`)
}

function createTarFileLine(fileName: string): string {
	return `-rw-r--r-- 1 user group 123 Jan 01 12:34 ${fileName}`
}

function getWarnedUnparsedLines(logSpy: ReturnType<typeof spyOn>): string[] {
	return logSpy.mock.calls.flatMap(([message, data]) => {
		if (
			message !== "warning: unparsed tar listing line" ||
			typeof data !== "object" ||
			data === null ||
			!("line" in data) ||
			typeof data.line !== "string"
		) {
			return []
		}

		return [data.line]
	})
}

function captureThrownError(run: () => void): Error {
	try {
		run()
	} catch (error) {
		if (error instanceof Error) {
			return error
		}
	}

	throw new Error("Expected parser to throw")
}

describe("parseTarListingOutput", () => {
	afterEach(() => {
		mock.restore()
	})

		describe("#given tar output with any unparsed lines", () => {
		it("#when parsing the output #then throws immediately (fail-closed)", async () => {
			// given
			const logSpy = spyOn(logger, "log").mockImplementation(() => {})
			const { parseTarListingOutput } = await importFreshTarZipEntryListingModule()
			const listedOutput = [
				createTarFileLine("file-1.txt"),
				createTarFileLine("file-2.txt"),
				"unparsed listing line",
			].join("\n")

			// when
			const thrownError = captureThrownError(() => parseTarListingOutput(listedOutput))

			// then
			expect(thrownError.message).toMatch(/could not be parsed/i)
			expect(getWarnedUnparsedLines(logSpy)).toContain("unparsed listing line")
		})
	})

		describe("#given tar output with multiple unparsed lines", () => {
		it("#when parsing the output #then throws with count details", async () => {
			// given
			const logSpy = spyOn(logger, "log").mockImplementation(() => {})
			const { parseTarListingOutput } = await importFreshTarZipEntryListingModule()
			const listedOutput = [
				createTarFileLine("file-1.txt"),
				createTarFileLine("file-2.txt"),
				createTarFileLine("file-3.txt"),
				createTarFileLine("file-4.txt"),
				createTarFileLine("file-5.txt"),
				createTarFileLine("file-6.txt"),
				createTarFileLine("file-7.txt"),
				createTarFileLine("file-8.txt"),
				"unparsed listing line 1",
				"unparsed listing line 2",
			].join("\n")

			// when
			const thrownError = captureThrownError(() => parseTarListingOutput(listedOutput))

			// then
			expect(thrownError.message).toMatch(/could not be parsed/i)
			expect(getWarnedUnparsedLines(logSpy)).toEqual(
				expect.arrayContaining([
					"unparsed listing line 1",
					"unparsed listing line 2",
				])
			)
		})
	})

		describe("#given tar output where every non-empty line is unparsed", () => {
		it("#when parsing the output #then rejects the listing", async () => {
			// given
			const logSpy = spyOn(logger, "log").mockImplementation(() => {})
			const { parseTarListingOutput } = await importFreshTarZipEntryListingModule()

			// when
			const thrownError = captureThrownError(() =>
				parseTarListingOutput(["unknown format 1", "unknown format 2"].join("\n"))
			)

			// then
			expect(thrownError.message).toMatch(/could not be parsed/i)
			expect(getWarnedUnparsedLines(logSpy)).toEqual(
				expect.arrayContaining(["unknown format 1", "unknown format 2"])
			)
		})
	})
})