import { z } from "zod";
import { AdoClient } from "../../ado-client.js";
import * as BuildInterfaces from "azure-devops-node-api/interfaces/BuildInterfaces";
export const runPipelineSchema = z.object({
project: z.string().optional().describe("Project name, defaults to ADO_PROJECT env var"),
pipelineId: z.number().describe("Pipeline ID"),
branch: z.string().optional().describe("Branch to run on"),
variables: z.record(z.string()).optional().describe("Runtime variables to set"),
parameters: z.record(z.string()).optional().describe("Pipeline parameters"),
stagesToSkip: z.array(z.string()).optional().describe("Stages to skip"),
});
export const runPipelineTool = {
name: "run_pipeline",
description: "Trigger a new pipeline run",
inputSchema: {
type: "object" as const,
properties: {
project: {
type: "string",
description: "Project name, defaults to ADO_PROJECT env var",
},
pipelineId: {
type: "number",
description: "Pipeline ID",
},
branch: {
type: "string",
description: "Branch to run on",
},
variables: {
type: "object",
additionalProperties: { type: "string" },
description: "Runtime variables to set",
},
parameters: {
type: "object",
additionalProperties: { type: "string" },
description: "Pipeline parameters",
},
stagesToSkip: {
type: "array",
items: { type: "string" },
description: "Stages to skip",
},
},
required: ["pipelineId"],
},
};
export interface RunPipelineResult {
id: number;
buildNumber: string;
status: string;
sourceBranch: string;
url: string;
message: string;
}
export async function runPipeline(
client: AdoClient,
params: z.infer<typeof runPipelineSchema>
): Promise<RunPipelineResult> {
const validatedParams = runPipelineSchema.parse(params);
const project = client.resolveProject(validatedParams.project);
const buildApi = await client.getBuildApi();
// Build the queue request
const build: BuildInterfaces.Build = {
definition: {
id: validatedParams.pipelineId,
},
};
if (validatedParams.branch) {
build.sourceBranch = `refs/heads/${validatedParams.branch}`;
}
// Add variables if specified
if (validatedParams.variables) {
build.parameters = JSON.stringify(validatedParams.variables);
}
// Add template parameters if specified
if (validatedParams.parameters) {
build.templateParameters = validatedParams.parameters;
}
// Add stages to skip if specified (cast to any as not in type defs)
if (validatedParams.stagesToSkip && validatedParams.stagesToSkip.length > 0) {
(build as any).stagesToSkip = validatedParams.stagesToSkip;
}
const queuedBuild = await buildApi.queueBuild(build, project);
if (!queuedBuild) {
throw new Error("Failed to queue pipeline run");
}
return {
id: queuedBuild.id || 0,
buildNumber: queuedBuild.buildNumber || "",
status: "notStarted",
sourceBranch: queuedBuild.sourceBranch?.replace("refs/heads/", "") || "",
url: queuedBuild.url || "",
message: `Successfully queued pipeline run ${queuedBuild.buildNumber}`,
};
}
