import * as Cause from "effect/Cause";import * as DateTime from "effect/DateTime";import * as Exit from "effect/Exit";import * as Option from "effect/Option";import * as Result from "effect/Result";import * as Schema from "effect/Schema";import { PositiveInt, TrimmedNonEmptyString } from "@t3tools/contracts";import { decodeJsonResult, formatSchemaError } from "@t3tools/shared/schemaJson"; export interface NormalizedAzureDevOpsPullRequestRecord {  readonly number: number;  readonly title: string;  readonly url: string;  readonly baseRefName: string;  readonly headRefName: string;  readonly state: "open" | "closed" | "merged";  readonly updatedAt: Option.Option<DateTime.Utc>;} const AzureDevOpsPullRequestSchema = Schema.Struct({  pullRequestId: PositiveInt,  title: TrimmedNonEmptyString,  url: Schema.optional(Schema.String),  repository: Schema.optional(    Schema.Struct({      name: Schema.optional(Schema.String),      webUrl: Schema.optional(Schema.String),      project: Schema.optional(        Schema.Struct({          name: Schema.optional(Schema.String),        }),      ),    }),  ),  sourceRefName: TrimmedNonEmptyString,  targetRefName: TrimmedNonEmptyString,  status: Schema.String,  creationDate: Schema.optional(Schema.OptionFromNullOr(Schema.DateTimeUtcFromString)),  closedDate: Schema.optional(Schema.OptionFromNullOr(Schema.DateTimeUtcFromString)),  _links: Schema.optional(    Schema.Struct({      web: Schema.optional(        Schema.Struct({          href: Schema.String,        }),      ),    }),  ),}); function trimOptionalString(value: string | null | undefined): string | null {  const trimmed = value?.trim() ?? "";  return trimmed.length > 0 ? trimmed : null;} function normalizeRefName(refName: string): string {  return refName.trim().replace(/^refs\/heads\//, "");} function normalizeAzureDevOpsPullRequestState(status: string): "open" | "closed" | "merged" {  switch (status.trim().toLowerCase()) {    case "completed":      return "merged";    case "abandoned":      return "closed";    default:      return "open";  }} function encodeAzureDevOpsPathSegment(segment: string): string {  return encodeURIComponent(segment);} function azureDevOpsOrganizationBaseFromRestApiUrl(  value: string | null | undefined,): string | null {  const rawUrl = trimOptionalString(value);  if (!rawUrl) {    return null;  }   try {    const url = new URL(rawUrl);    const hostname = url.hostname.toLowerCase();    const pathSegments = url.pathname.split("/").filter((segment) => segment.length > 0);    const isAzureRestUrl = pathSegments.some((segment) => segment.toLowerCase() === "_apis");    if (!isAzureRestUrl) {      return null;    }     if (hostname === "dev.azure.com") {      const organization = pathSegments[0];      return organization ? `${url.origin}/${organization}` : null;    }     if (hostname.endsWith(".visualstudio.com")) {      return url.origin;    }     return null;  } catch {    return null;  }} function normalizeAzureDevOpsPullRequestUrl(  raw: Schema.Schema.Type<typeof AzureDevOpsPullRequestSchema>,): string {  const webLink = trimOptionalString(raw._links?.web?.href);  if (webLink) {    return webLink;  }   const repositoryWebUrl = trimOptionalString(raw.repository?.webUrl);  if (repositoryWebUrl) {    return `${repositoryWebUrl.replace(/\/+$/, "")}/pullrequest/${raw.pullRequestId}`;  }   const organizationBase = azureDevOpsOrganizationBaseFromRestApiUrl(raw.url);  const projectName = trimOptionalString(raw.repository?.project?.name);  const repositoryName = trimOptionalString(raw.repository?.name);  if (organizationBase && projectName && repositoryName) {    const encodedProjectName = encodeAzureDevOpsPathSegment(projectName);    const encodedRepositoryName = encodeAzureDevOpsPathSegment(repositoryName);    return `${organizationBase}/${encodedProjectName}/_git/${encodedRepositoryName}/pullrequest/${raw.pullRequestId}`;  }   return trimOptionalString(raw.url) ?? "";} function normalizeAzureDevOpsPullRequestRecord(  raw: Schema.Schema.Type<typeof AzureDevOpsPullRequestSchema>,): NormalizedAzureDevOpsPullRequestRecord {  return {    number: raw.pullRequestId,    title: raw.title,    url: normalizeAzureDevOpsPullRequestUrl(raw),    baseRefName: normalizeRefName(raw.targetRefName),    headRefName: normalizeRefName(raw.sourceRefName),    state: normalizeAzureDevOpsPullRequestState(raw.status),    updatedAt: (raw.closedDate ?? Option.none()).pipe(      Option.orElse(() => raw.creationDate ?? Option.none()),    ),  };} const decodeAzureDevOpsPullRequestList = decodeJsonResult(Schema.Array(Schema.Unknown));const decodeAzureDevOpsPullRequest = decodeJsonResult(AzureDevOpsPullRequestSchema);const decodeAzureDevOpsPullRequestEntry = Schema.decodeUnknownExit(AzureDevOpsPullRequestSchema); export const formatAzureDevOpsJsonDecodeError = formatSchemaError; export function decodeAzureDevOpsPullRequestListJson(  raw: string,): Result.Result<  ReadonlyArray<NormalizedAzureDevOpsPullRequestRecord>,  Cause.Cause<Schema.SchemaError>> {  const result = decodeAzureDevOpsPullRequestList(raw);  if (Result.isSuccess(result)) {    const pullRequests: NormalizedAzureDevOpsPullRequestRecord[] = [];    for (const entry of result.success) {      const decodedEntry = decodeAzureDevOpsPullRequestEntry(entry);      if (Exit.isFailure(decodedEntry)) {        continue;      }      pullRequests.push(normalizeAzureDevOpsPullRequestRecord(decodedEntry.value));    }    return Result.succeed(pullRequests);  }  return Result.fail(result.failure);} export function decodeAzureDevOpsPullRequestJson(  raw: string,): Result.Result<NormalizedAzureDevOpsPullRequestRecord, Cause.Cause<Schema.SchemaError>> {  const result = decodeAzureDevOpsPullRequest(raw);  if (Result.isSuccess(result)) {    return Result.succeed(normalizeAzureDevOpsPullRequestRecord(result.success));  }  return Result.fail(result.failure);}