import { config } from "../../../config";
import {
  ScrapeRequestInput,
  Document,
  ExtractRequestInput,
  ExtractResponse,
  CrawlRequestInput,
  CrawlResponse,
  CrawlStatusResponse,
  OngoingCrawlsResponse,
  ErrorResponse,
  CrawlErrorsResponse,
  MapRequestInput,
  BatchScrapeRequestInput,
  SearchRequestInput,
  SearchFeedbackRequestInput,
  ParseRequestInput,
} from "../../../controllers/v2/types";
import request from "supertest";
import {
  TEST_API_URL,
  scrapeTimeout,
  indexCooldown,
  Identity,
  idmux,
} from "../lib";
import { SearchV2Response } from "../../../lib/entities";

// Re-export shared utilities for backwards compatibility
export { scrapeTimeout, indexCooldown, Identity, idmux, TEST_API_URL };
export default request;

const pollSleep = async () => new Promise(r => setTimeout(r, 50));

// =========================================
// Scrape API
// =========================================

export async function scrapeRaw(body: ScrapeRequestInput, identity: Identity) {
  return await request(TEST_API_URL)
    .post("/v2/scrape")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

function expectScrapeToSucceed(
  response: Awaited<ReturnType<typeof scrapeRaw>>,
) {
  if (response.statusCode !== 200) {
    console.warn(
      "Scrape did not succeed",
      JSON.stringify(response.body, null, 2),
    );
  }

  expect(response.statusCode).toBe(200);
  expect(response.body.success).toBe(true);
  expect(typeof response.body.data).toBe("object");
}

function expectScrapeToFail(response: Awaited<ReturnType<typeof scrapeRaw>>) {
  expect(response.statusCode).not.toBe(200);
  expect(response.body.success).toBe(false);
  expect(typeof response.body.error).toBe("string");
}

export async function scrape(
  body: ScrapeRequestInput,
  identity: Identity,
): Promise<Document> {
  const raw = await scrapeRaw(body, identity);
  expectScrapeToSucceed(raw);
  return raw.body.data;
}

export async function scrapeWithFailure(
  body: ScrapeRequestInput,
  identity: Identity,
): Promise<{
  success: false;
  error: string;
}> {
  const raw = await scrapeRaw(body, identity);
  expectScrapeToFail(raw);
  return raw.body;
}

// =========================================
// Monitor API
// =========================================

export type MonitorCreateInput = {
  name: string;
  schedule: { cron: string; timezone?: string };
  webhook?: { url: string; headers?: Record<string, string> };
  notification?: {
    email?: {
      enabled?: boolean;
      recipients?: string[];
      includeDiffs?: boolean;
    };
  };
  targets: Array<
    | {
        type: "scrape";
        urls: string[];
        scrapeOptions?: Record<string, unknown>;
      }
    | {
        type: "crawl";
        url: string;
        crawlOptions?: Record<string, unknown>;
        scrapeOptions?: Record<string, unknown>;
      }
  >;
  retentionDays?: number;
  goal?: string;
  judgeEnabled?: boolean;
  origin?: string;
};

export async function monitorCreateRaw(
  body: MonitorCreateInput,
  identity: Identity,
) {
  return await request(TEST_API_URL)
    .post("/v2/monitor")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

export async function monitorListRaw(identity: Identity) {
  return await request(TEST_API_URL)
    .get("/v2/monitor")
    .set("Authorization", `Bearer ${identity.apiKey}`);
}

export async function monitorGetRaw(id: string, identity: Identity) {
  return await request(TEST_API_URL)
    .get(`/v2/monitor/${id}`)
    .set("Authorization", `Bearer ${identity.apiKey}`);
}

export async function monitorPatchRaw(
  id: string,
  body: Partial<MonitorCreateInput> & { status?: "active" | "paused" },
  identity: Identity,
) {
  return await request(TEST_API_URL)
    .patch(`/v2/monitor/${id}`)
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

export async function monitorDeleteRaw(id: string, identity: Identity) {
  return await request(TEST_API_URL)
    .delete(`/v2/monitor/${id}`)
    .set("Authorization", `Bearer ${identity.apiKey}`);
}

export async function monitorRunRaw(id: string, identity: Identity) {
  return await request(TEST_API_URL)
    .post(`/v2/monitor/${id}/run`)
    .set("Authorization", `Bearer ${identity.apiKey}`);
}

export async function monitorCheckRaw(
  monitorId: string,
  checkId: string,
  identity: Identity,
  query?: Record<string, string | number>,
) {
  const req = request(TEST_API_URL)
    .get(`/v2/monitor/${monitorId}/checks/${checkId}`)
    .set("Authorization", `Bearer ${identity.apiKey}`);
  return query ? req.query(query) : req;
}

export async function monitorEmailConfirmRaw(token: string) {
  return await request(TEST_API_URL)
    .post(`/v2/monitor/email/confirm`)
    .set("Content-Type", "application/json")
    .send({ token });
}

export async function monitorEmailUnsubscribeRaw(token: string) {
  return await request(TEST_API_URL)
    .post(`/v2/monitor/email/unsubscribe`)
    .set("Content-Type", "application/json")
    .send({ token });
}

export async function monitorEmailConfirmRawViaQuery(token: string) {
  return await request(TEST_API_URL)
    .post(`/v2/monitor/email/confirm`)
    .query({ token });
}

export async function parseRaw(
  body: {
    options?: Omit<ParseRequestInput, "file">;
    file: {
      content: Buffer | string;
      filename: string;
      contentType?: string;
    };
  },
  identity: Identity,
) {
  const fileContent =
    typeof body.file.content === "string"
      ? Buffer.from(body.file.content)
      : body.file.content;

  const req = request(TEST_API_URL)
    .post("/v2/parse")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .attach("file", fileContent, {
      filename: body.file.filename,
      contentType: body.file.contentType,
    });

  if (body.options !== undefined) {
    req.field("options", JSON.stringify(body.options));
  }

  return await req;
}

export async function parse(
  body: {
    options?: Omit<ParseRequestInput, "file">;
    file: {
      content: Buffer | string;
      filename: string;
      contentType?: string;
    };
  },
  identity: Identity,
): Promise<Document> {
  const raw = await parseRaw(body, identity);
  expectScrapeToSucceed(raw);
  return raw.body.data;
}

export async function parseWithFailure(
  body: {
    options?: Omit<ParseRequestInput, "file">;
    file?: {
      content: Buffer | string;
      filename: string;
      contentType?: string;
    };
    rawOptions?: string;
  },
  identity: Identity,
): Promise<{
  success: false;
  error: string;
  code?: string;
}> {
  const req = request(TEST_API_URL)
    .post("/v2/parse")
    .set("Authorization", `Bearer ${identity.apiKey}`);

  if (body.file) {
    const fileContent =
      typeof body.file.content === "string"
        ? Buffer.from(body.file.content)
        : body.file.content;

    req.attach("file", fileContent, {
      filename: body.file.filename,
      contentType: body.file.contentType,
    });
  }

  if (body.rawOptions !== undefined) {
    req.field("options", body.rawOptions);
  } else if (body.options !== undefined) {
    req.field("options", JSON.stringify(body.options));
  }

  const raw = await req;
  expect(raw.statusCode).not.toBe(200);
  expect(raw.body.success).toBe(false);
  expect(typeof raw.body.error).toBe("string");
  return raw.body;
}

export async function scrapeStatusRaw(jobId: string, identity: Identity) {
  return await request(TEST_API_URL)
    .get("/v2/scrape/" + encodeURIComponent(jobId))
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .send();
}

export async function scrapeStatus(
  jobId: string,
  identity: Identity,
): Promise<Document> {
  const raw = await scrapeStatusRaw(jobId, identity);
  expect(raw.statusCode).toBe(200);
  expect(raw.body.success).toBe(true);
  expect(typeof raw.body.data).toBe("object");
  expect(raw.body.data).not.toBeNull();
  expect(raw.body.data).toBeDefined();
  return raw.body.data;
}

export async function scrapeInteractRaw(
  jobId: string,
  body: {
    code: string;
    language?: "python" | "node" | "bash";
    timeout?: number;
    origin?: string;
  },
  identity: Identity,
) {
  return await request(TEST_API_URL)
    .post("/v2/scrape/" + encodeURIComponent(jobId) + "/interact")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

export async function scrapeStopInteractiveBrowserRaw(
  jobId: string,
  identity: Identity,
) {
  return await request(TEST_API_URL)
    .delete("/v2/scrape/" + encodeURIComponent(jobId) + "/interact")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .send();
}

// =========================================
// Crawl API
// =========================================

export async function crawlStart(body: CrawlRequestInput, identity: Identity) {
  return await request(TEST_API_URL)
    .post("/v2/crawl")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

async function crawlStatus(id: string, identity: Identity) {
  return await request(TEST_API_URL)
    .get("/v2/crawl/" + encodeURIComponent(id))
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .send();
}

async function crawlOngoingRaw(identity: Identity) {
  return await request(TEST_API_URL)
    .get("/v2/crawl/ongoing")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .send();
}

export async function crawlOngoing(
  identity: Identity,
): Promise<Exclude<OngoingCrawlsResponse, ErrorResponse>> {
  const res = await crawlOngoingRaw(identity);
  expect(res.statusCode).toBe(200);
  expect(res.body.success).toBe(true);
  return res.body;
}

function expectCrawlStartToSucceed(
  response: Awaited<ReturnType<typeof crawlStart>>,
) {
  if (response.statusCode !== 200) {
    console.warn(
      "Crawl start did not succeed",
      JSON.stringify(response.body, null, 2),
    );
  }

  expect(response.statusCode).toBe(200);
  expect(response.body.success).toBe(true);
  expect(typeof response.body.id).toBe("string");
}

function expectCrawlToSucceed(
  response: Awaited<ReturnType<typeof crawlStatus>>,
) {
  if (
    response.statusCode !== 200 ||
    response.body.success !== true ||
    response.body.status !== "completed"
  ) {
    console.warn(
      "Crawl did not succeed",
      JSON.stringify(response.body, null, 2),
    );
  }

  expect(response.statusCode).toBe(200);
  expect(response.body.success).toBe(true);
  expect(typeof response.body.status).toBe("string");
  expect(response.body.status).toBe("completed");
  expect(response.body).toHaveProperty("data");
  expect(Array.isArray(response.body.data)).toBe(true);
  expect(response.body.data.length).toBeGreaterThan(0);
}

export async function asyncCrawl(
  body: CrawlRequestInput,
  identity: Identity,
): Promise<Exclude<CrawlResponse, ErrorResponse>> {
  const cs = await crawlStart(body, identity);
  expectCrawlStartToSucceed(cs);
  return cs.body;
}

export async function asyncCrawlWaitForFinish(
  id: string,
  identity: Identity,
): Promise<Exclude<CrawlStatusResponse, ErrorResponse>> {
  let x: Awaited<ReturnType<typeof crawlStatus>> | undefined;

  do {
    if (x) await pollSleep();
    x = await crawlStatus(id, identity);
    expect(x.statusCode).toBe(200);
    expect(typeof x.body.status).toBe("string");
  } while (x.body.status === "scraping");

  expectCrawlToSucceed(x);
  return x.body;
}

async function crawlErrors(
  id: string,
  identity: Identity,
): Promise<Exclude<CrawlErrorsResponse, ErrorResponse>> {
  const res = await request(TEST_API_URL)
    .get("/v2/crawl/" + id + "/errors")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .send();

  expect(res.statusCode).toBe(200);
  expect(res.body.success).not.toBe(false);

  return res.body;
}

export async function crawl(
  body: CrawlRequestInput,
  identity: Identity,
  shouldSucceed: boolean = true,
): Promise<Exclude<CrawlStatusResponse & { id: string }, ErrorResponse>> {
  const cs = await crawlStart(body, identity);
  expectCrawlStartToSucceed(cs);

  let x: Awaited<ReturnType<typeof crawlStatus>> | undefined;

  do {
    if (x) await pollSleep();
    x = await crawlStatus(cs.body.id, identity);
    expect(x.statusCode).toBe(200);
    expect(typeof x.body.status).toBe("string");
  } while (x.body.status === "scraping");

  const errors = await crawlErrors(cs.body.id, identity);
  if (errors.errors.length > 0) {
    console.warn("Crawl ", cs.body.id, " had errors:", errors.errors);
  }

  if (shouldSucceed) {
    expectCrawlToSucceed(x);
  }

  return {
    ...x.body,
    id: cs.body.id,
  };
}

// =========================================
// Batch Scrape API
// =========================================

async function batchScrapeStart(
  body: BatchScrapeRequestInput,
  identity: Identity,
) {
  return await request(TEST_API_URL)
    .post("/v2/batch/scrape")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

async function batchScrapeStatus(id: string, identity: Identity) {
  return await request(TEST_API_URL)
    .get("/v2/batch/scrape/" + encodeURIComponent(id))
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .send();
}

function expectBatchScrapeStartToSucceed(
  response: Awaited<ReturnType<typeof batchScrapeStart>>,
) {
  if (response.statusCode !== 200) {
    console.warn(
      "Batch scrape start did not succeed",
      JSON.stringify(response.body, null, 2),
    );
  }
  expect(response.statusCode).toBe(200);
  expect(response.body.success).toBe(true);
  expect(typeof response.body.id).toBe("string");
}

function expectBatchScrapeToSucceed(
  response: Awaited<ReturnType<typeof batchScrapeStatus>>,
) {
  if (
    response.statusCode !== 200 ||
    response.body.success !== true ||
    response.body.status !== "completed"
  ) {
    console.warn(
      "Batch scrape did not succeed",
      JSON.stringify(response.body, null, 2),
    );
  }
  expect(response.statusCode).toBe(200);
  expect(response.body.success).toBe(true);
  expect(typeof response.body.status).toBe("string");
  expect(response.body.status).toBe("completed");
  expect(response.body).toHaveProperty("data");
  expect(Array.isArray(response.body.data)).toBe(true);
  expect(response.body.data.length).toBeGreaterThan(0);
}

export async function batchScrape(
  body: BatchScrapeRequestInput,
  identity: Identity,
): Promise<Exclude<CrawlStatusResponse, ErrorResponse> & { id: string }> {
  const bss = await batchScrapeStart(body, identity);
  expectBatchScrapeStartToSucceed(bss);

  let x: Awaited<ReturnType<typeof batchScrapeStatus>> | undefined;

  do {
    if (x) await pollSleep();
    x = await batchScrapeStatus(bss.body.id, identity);
    expect(x.statusCode).toBe(200);
    expect(typeof x.body.status).toBe("string");
  } while (x.body.status === "scraping");

  expectBatchScrapeToSucceed(x);
  return {
    ...x.body,
    id: bss.body.id,
  };
}

// =========================================
// Map API
// =========================================

export async function map(body: MapRequestInput, identity: Identity) {
  return await request(TEST_API_URL)
    .post("/v2/map")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

export function expectMapToSucceed(response: Awaited<ReturnType<typeof map>>) {
  if (response.statusCode !== 200) {
    console.warn("Map did not succeed", JSON.stringify(response.body, null, 2));
  }

  expect(response.statusCode).toBe(200);
  expect(response.body.success).toBe(true);
  expect(Array.isArray(response.body.links)).toBe(true);
  expect(response.body.links.length).toBeGreaterThan(0);
}

// =========================================
// Search API
// =========================================

export async function searchRaw(body: SearchRequestInput, identity: Identity) {
  return await request(TEST_API_URL)
    .post("/v2/search")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

function expectSearchToSucceed(
  response: Awaited<ReturnType<typeof searchRaw>>,
) {
  expect(response.statusCode).toBe(200);
  expect(response.body.success).toBe(true);
  expect(typeof response.body.data).toBe("object");
}

function expectSearchToFail(response: Awaited<ReturnType<typeof searchRaw>>) {
  expect(response.statusCode).not.toBe(200);
  expect(response.body.success).toBe(false);
  expect(typeof response.body.error).toBe("string");
}

export async function search(
  body: SearchRequestInput,
  identity: Identity,
): Promise<SearchV2Response> {
  const raw = await searchRaw(body, identity);
  expectSearchToSucceed(raw);
  return raw.body.data;
}

export async function searchWithFailure(
  body: SearchRequestInput,
  identity: Identity,
): Promise<{
  success: false;
  error: string;
  details?: unknown;
}> {
  const raw = await searchRaw(body, identity);
  expectSearchToFail(raw);
  return raw.body;
}

export async function searchRawFull(
  body: SearchRequestInput,
  identity: Identity,
) {
  return await request(TEST_API_URL)
    .post("/v2/search")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

export async function searchFeedbackRaw(
  searchId: string,
  body: SearchFeedbackRequestInput,
  identity: Identity,
) {
  return await request(TEST_API_URL)
    .post("/v2/search/" + encodeURIComponent(searchId) + "/feedback")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

export async function searchFeedback(
  searchId: string,
  body: SearchFeedbackRequestInput,
  identity: Identity,
): Promise<{
  success: true;
  feedbackId: string;
  creditsRefunded: number;
  creditsRefundedToday?: number;
  dailyRefundCap?: number;
  dailyCapReached?: boolean;
  alreadySubmitted?: boolean;
  warning?: string;
}> {
  const raw = await searchFeedbackRaw(searchId, body, identity);
  if (raw.statusCode !== 200) {
    console.warn(
      "Search feedback did not succeed",
      JSON.stringify(raw.body, null, 2),
    );
  }
  expect(raw.statusCode).toBe(200);
  expect(raw.body.success).toBe(true);
  expect(typeof raw.body.feedbackId).toBe("string");
  expect(typeof raw.body.creditsRefunded).toBe("number");
  return raw.body;
}

export async function searchFeedbackWithFailure(
  searchId: string,
  body: SearchFeedbackRequestInput,
  identity: Identity,
): Promise<{
  success: false;
  error: string;
  details?: unknown;
}> {
  const raw = await searchFeedbackRaw(searchId, body, identity);
  expect(raw.statusCode).not.toBe(200);
  expect(raw.body.success).toBe(false);
  expect(typeof raw.body.error).toBe("string");
  return raw.body;
}

// =========================================
// Billing API
// =========================================

export async function creditUsage(
  identity: Identity,
): Promise<{ remainingCredits: number }> {
  const req = await request(TEST_API_URL)
    .get("/v2/team/credit-usage")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json");

  if (req.status !== 200) {
    throw req.body;
  }

  return req.body.data;
}

export async function creditUsageHistorical(identity: Identity): Promise<{
  success: boolean;
  periods: {
    startDate: string | null;
    endDate: string | null;
    creditsUsed: number;
  }[];
}> {
  const req = await request(TEST_API_URL)
    .get("/v2/team/credit-usage/historical")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json");

  if (req.status !== 200) {
    throw req.body;
  }

  return req.body;
}

export async function tokenUsageHistorical(identity: Identity): Promise<{
  success: boolean;
  periods: {
    startDate: string | null;
    endDate: string | null;
    tokensUsed: number;
  }[];
}> {
  const req = await request(TEST_API_URL)
    .get("/v2/team/token-usage/historical")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json");

  if (req.status !== 200) {
    throw req.body;
  }

  return req.body;
}

// =========================================
// Concurrency API
// =========================================

async function concurrencyCheck(
  identity: Identity,
): Promise<{ concurrency: number; maxConcurrency: number }> {
  const x = await request(TEST_API_URL)
    .get("/v2/team/queue-status")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json");

  expect(x.statusCode).toBe(200);
  expect(x.body.success).toBe(true);
  return {
    concurrency: x.body.activeJobsInQueue,
    maxConcurrency: x.body.maxConcurrency,
  };
}

export async function crawlWithConcurrencyTracking(
  body: CrawlRequestInput,
  identity: Identity,
): Promise<{
  crawl: Exclude<CrawlStatusResponse, ErrorResponse>;
  concurrencies: number[];
}> {
  const cs = await crawlStart(body, identity);
  expectCrawlStartToSucceed(cs);

  let x,
    concurrencies: number[] = [];

  do {
    if (x) await pollSleep();
    x = await crawlStatus(cs.body.id, identity);
    expect(x.statusCode).toBe(200);
    expect(typeof x.body.status).toBe("string");
    concurrencies.push((await concurrencyCheck(identity)).concurrency);
  } while (x.body.status === "scraping");

  expectCrawlToSucceed(x);
  return {
    crawl: x.body,
    concurrencies,
  };
}

export async function batchScrapeWithConcurrencyTracking(
  body: BatchScrapeRequestInput,
  identity: Identity,
): Promise<{
  batchScrape: Exclude<CrawlStatusResponse, ErrorResponse>;
  concurrencies: number[];
}> {
  const cs = await batchScrapeStart(body, identity);
  expectBatchScrapeStartToSucceed(cs);

  let x,
    concurrencies: number[] = [];

  do {
    if (x) await pollSleep();
    x = await batchScrapeStatus(cs.body.id, identity);
    expect(x.statusCode).toBe(200);
    expect(typeof x.body.status).toBe("string");
    concurrencies.push((await concurrencyCheck(identity)).concurrency);
  } while (x.body.status === "scraping");

  expectBatchScrapeToSucceed(x);
  return {
    batchScrape: x.body,
    concurrencies,
  };
}

// =========================================
// Extract API
// =========================================

async function extractStart(body: ExtractRequestInput, identity: Identity) {
  return await request(TEST_API_URL)
    .post("/v2/extract")
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .set("Content-Type", "application/json")
    .send(body);
}

async function extractStatus(id: string, identity: Identity) {
  return await request(TEST_API_URL)
    .get("/v2/extract/" + encodeURIComponent(id))
    .set("Authorization", `Bearer ${identity.apiKey}`)
    .send();
}

function expectExtractStartToSucceed(
  response: Awaited<ReturnType<typeof extractStart>>,
) {
  expect(response.statusCode).toBe(200);
  expect(response.body.success).toBe(true);
  expect(typeof response.body.id).toBe("string");
}

function expectExtractToSucceed(
  response: Awaited<ReturnType<typeof extractStatus>>,
) {
  expect(response.statusCode).toBe(200);
  expect(response.body.success).toBe(true);
  expect(typeof response.body.status).toBe("string");
  expect(response.body.status).toBe("completed");
  expect(response.body).toHaveProperty("data");
}

export async function extract(
  body: ExtractRequestInput,
  identity: Identity,
): Promise<ExtractResponse> {
  const es = await extractStart(body, identity);
  expectExtractStartToSucceed(es);

  let x: Awaited<ReturnType<typeof extractStatus>> | undefined;

  do {
    if (x) await pollSleep();
    x = await extractStatus(es.body.id, identity);
    expect(x.statusCode).toBe(200);
    expect(typeof x.body.status).toBe("string");
  } while (x.body.status === "processing");

  expectExtractToSucceed(x);
  return x.body;
}

export async function extractRaw(
  body: ExtractRequestInput,
  identity: Identity,
) {
  return await extractStart(body, identity);
}

// =========================================
// ZDR API
// =========================================

export async function zdrcleaner(teamId: string) {
  const res = await request(TEST_API_URL)
    .get(`/admin/${config.BULL_AUTH_KEY}/zdrcleaner`)
    .query({ teamId });

  expect(res.statusCode).toBe(200);
  expect(res.body.ok).toBe(true);
}