renovate/lib/modules/datasource/azure-pipelines-tasks/index.ts

import type { TypeOf, ZodType } from 'zod/v4';
import { GlobalConfig } from '../../../config/global.ts';
import { withCache } from '../../../util/cache/package/with-cache.ts';
import * as hostRules from '../../../util/host-rules.ts';
import type { HttpOptions } from '../../../util/http/types.ts';
import { id as versioning } from '../../versioning/loose/index.ts';
import { Datasource } from '../datasource.ts';
import type { GetReleasesConfig, Release, ReleaseResult } from '../types.ts';
import {
  AzurePipelinesFallbackTasks,
  AzurePipelinesJSON,
  AzurePipelinesTaskVersion,
} from './schema.ts';

const TASKS_URL_BASE =
  'https://raw.githubusercontent.com/renovatebot/azure-devops-marketplace/main';
const BUILT_IN_TASKS_URL = `${TASKS_URL_BASE}/azure-pipelines-builtin-tasks.json`;
const MARKETPLACE_TASKS_URL = `${TASKS_URL_BASE}/azure-pipelines-marketplace-tasks.json`;
const BUILT_IN_TASKS_CHANGELOG_URL =
  'https://github.com/microsoft/azure-pipelines-tasks/releases';

export class AzurePipelinesTasksDatasource extends Datasource {
  static readonly id = 'azure-pipelines-tasks';

  constructor() {
    super(AzurePipelinesTasksDatasource.id);
  }

  override readonly customRegistrySupport = false;

  override readonly defaultVersioning = versioning;

  async getReleases({
    packageName,
  }: GetReleasesConfig): Promise<ReleaseResult | null> {
    const platform = GlobalConfig.get('platform');
    const endpoint = GlobalConfig.get('endpoint');
    const { token } = hostRules.find({
      hostType: AzurePipelinesTasksDatasource.id,
      url: endpoint,
    });

    if (platform === 'azure' && endpoint && token) {
      const auth = Buffer.from(`renovate:${token}`).toString('base64');
      const opts: HttpOptions = {
        headers: { authorization: `Basic ${auth}` },
      };
      const results = await this.getTasks(
        `${endpoint}/_apis/distributedtask/tasks/`,
        opts,
        AzurePipelinesJSON,
      );

      const result: ReleaseResult = { releases: [] };

      results.value
        .filter((task) => {
          const matchers = [
            task.id === packageName,
            task.name === packageName,
            task.contributionIdentifier !== null &&
              `${task.contributionIdentifier}.${task.id}` === packageName,
            task.contributionIdentifier !== null &&
              `${task.contributionIdentifier}.${task.name}` === packageName,
          ];
          return matchers.some((match) => match);
        })
        .sort(AzurePipelinesTasksDatasource.compareSemanticVersions('version'))
        .forEach((task) => {
          const release: Release = {
            version: `${task.version!.major}.${task.version!.minor}.${task.version!.patch}`,
            changelogContent: task.releaseNotes,
            isDeprecated: task.deprecated,
          };

          if (task.serverOwned) {
            release.changelogUrl = BUILT_IN_TASKS_CHANGELOG_URL;
          }

          result.releases.push(release);
        });

      return result;
    }
    const versions =
      (
        await this.getTasks(BUILT_IN_TASKS_URL, {}, AzurePipelinesFallbackTasks)
      )[packageName.toLowerCase()] ??
      (
        await this.getTasks(
          MARKETPLACE_TASKS_URL,
          {},
          AzurePipelinesFallbackTasks,
        )
      )[packageName.toLowerCase()];

    if (versions) {
      const releases = versions.map((version) => ({ version }));
      return { releases };
    }

    return null;
  }

  private async _getTasks<Schema extends ZodType>(
    url: string,
    opts: HttpOptions,
    schema: Schema,
  ): Promise<TypeOf<Schema>> {
    const { body } = await this.http.getJson(url, opts, schema);
    return body;
  }

  getTasks<Schema extends ZodType>(
    url: string,
    opts: HttpOptions,
    schema: Schema,
  ): Promise<TypeOf<Schema>> {
    return withCache(
      {
        namespace: `datasource-${AzurePipelinesTasksDatasource.id}`,
        key: url,
        ttlMinutes: 24 * 60,
      },
      () => this._getTasks(url, opts, schema),
    );
  }

  static compareSemanticVersions = (key: string) => (a: any, b: any) => {
    const a1Version = AzurePipelinesTaskVersion.safeParse(a[key]).data;
    const b1Version = AzurePipelinesTaskVersion.safeParse(b[key]).data;

    const a1 =
      a1Version === undefined
        ? ''
        : `${a1Version.major}.${a1Version.minor}.${a1Version.patch}`;
    const b1 =
      b1Version === undefined
        ? ''
        : `${b1Version.major}.${b1Version.minor}.${b1Version.patch}`;

    const len = Math.min(a1.length, b1.length);

    for (let i = 0; i < len; i++) {
      const a2 = +a1[i] || 0;
      const b2 = +b1[i] || 0;

      if (a2 !== b2) {
        return a2 > b2 ? 1 : -1;
      }
    }

    return b1.length - a1.length;
  };
}