chore: attach-project command

Author: ad-shreya

command-snapshot.json

@@ -1,4 +1,12 @@
 [
+  {
+    "alias": [],
+    "command": "devops:pipeline:attach-project",
+    "flagAliases": [],
+    "flagChars": ["o"],
+    "flags": ["api-version", "flags-dir", "json", "pipeline-id", "project-id", "target-org"],
+    "plugin": "@salesforce/plugin-devops-center"
+  },
   {
     "alias": [],
     "command": "devops:project:create",

messages/devops.pipeline.attach-project.md

@@ -0,0 +1,29 @@
+# summary
+
+Attach a DevOps Center project to a pipeline.
+
+# description
+
+You can attach a project to only one pipeline.
+
+# flags.target-org.summary
+
+Username or alias of the DevOps Center org.
+
+# flags.pipeline-id.summary
+
+ID of the pipeline.
+
+# flags.project-id.summary
+
+ID of the DevOps Center project.
+
+# examples
+
+- Attach a project to a pipeline using the project ID and pipeline ID.
+
+      <%= config.bin %> <%= command.id %> --target-org my-devops-org --pipeline-id 0XB000000000001 --project-id 0Hn000000000001
+
+# error.AlreadyAttached
+
+Project %s is already attached to pipeline %s. Remove the project, and then try again.

package.json

@@ -92,6 +92,9 @@
           },
           "pull-request": {
             "description": "Commands for managing DevOps Center pull requests."
+          },
+          "pipeline": {
+            "description": "Commands for managing DevOps Center pipelines."
           }
         }
       }

schemas/devops-pipeline-attach__project.json

@@ -0,0 +1,25 @@
+{
+  "$schema": "http://json-schema.org/draft-07/schema#",
+  "$ref": "#/definitions/AttachProjectResult",
+  "definitions": {
+    "AttachProjectResult": {
+      "type": "object",
+      "properties": {
+        "success": {
+          "type": "boolean"
+        },
+        "projectId": {
+          "type": "string"
+        },
+        "pipelineId": {
+          "type": "string"
+        },
+        "error": {
+          "type": "string"
+        }
+      },
+      "required": ["success", "projectId", "pipelineId"],
+      "additionalProperties": false
+    }
+  }
+}

src/commands/devops/pipeline/attach-project.ts

@@ -0,0 +1,90 @@
+/*
+ * Copyright 2026, Salesforce, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { Messages, Org } from '@salesforce/core';
+import { SfCommand, Flags } from '@salesforce/sf-plugins-core';
+import { attachProject, AttachProjectResult, findExistingAttachment } from '../../../utils/attachProject.js';
+
+Messages.importMessagesDirectoryFromMetaUrl(import.meta.url);
+const messages = Messages.loadMessages('@salesforce/plugin-devops-center', 'devops.pipeline.attach-project');
+const commonErrorMessages = Messages.loadMessages('@salesforce/plugin-devops-center', 'commonErrors');
+
+export default class DevopsPipelineAttachProject extends SfCommand<AttachProjectResult> {
+  public static readonly summary = messages.getMessage('summary');
+  public static readonly description = messages.getMessage('description');
+  public static readonly examples = messages.getMessages('examples');
+
+  public static readonly flags = {
+    'target-org': Flags.requiredOrg({
+      char: 'o',
+      summary: messages.getMessage('flags.target-org.summary'),
+      required: true,
+    }),
+    'api-version': Flags.orgApiVersion(),
+    'pipeline-id': Flags.string({
+      summary: messages.getMessage('flags.pipeline-id.summary'),
+      required: true,
+    }),
+    'project-id': Flags.string({
+      summary: messages.getMessage('flags.project-id.summary'),
+      required: true,
+    }),
+  };
+
+  public async run(): Promise<AttachProjectResult> {
+    const { flags } = await this.parse(DevopsPipelineAttachProject);
+    const org: Org = flags['target-org'];
+    const connection = org.getConnection(flags['api-version']);
+    const projectId = flags['project-id'];
+    const pipelineId = flags['pipeline-id'];
+
+    let existingPipelineId: string | undefined;
+    try {
+      existingPipelineId = await findExistingAttachment(connection, projectId);
+    } catch (error: unknown) {
+      const errMsg = error instanceof Error ? error.message : String(error);
+      if (errMsg.includes('sObject type') && errMsg.includes('is not supported')) {
+        this.error(commonErrorMessages.getMessage('error.DevopsCenterNotEnabled'));
+      }
+      throw error;
+    }
+
+    if (existingPipelineId) {
+      this.error(messages.getMessage('error.AlreadyAttached', [projectId, existingPipelineId]));
+    }
+
+    let result: AttachProjectResult;
+    try {
+      result = await attachProject({ connection, projectId, pipelineId });
+    } catch (error: unknown) {
+      const errMsg = error instanceof Error ? error.message : String(error);
+      if (errMsg.includes('sObject type') && errMsg.includes('is not supported')) {
+        this.error(commonErrorMessages.getMessage('error.DevopsCenterNotEnabled'));
+      }
+      throw error;
+    }
+
+    if (result.success) {
+      this.log('Successfully attached project to pipeline.');
+      this.log(`  Project ID:  ${projectId}`);
+      this.log(`  Pipeline ID: ${pipelineId}`);
+    } else {
+      this.error(`Failed to attach project to pipeline: ${result.error ?? ''}`);
+    }
+
+    return result;
+  }
+}

src/utils/attachProject.ts

@@ -0,0 +1,65 @@
+/*
+ * Copyright 2026, Salesforce, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { Connection } from '@salesforce/core';
+
+export type AttachProjectParams = {
+  connection: Connection;
+  projectId: string;
+  pipelineId: string;
+};
+
+export type AttachProjectResult = {
+  success: boolean;
+  projectId: string;
+  pipelineId: string;
+  error?: string;
+};
+
+/**
+ * Checks if a project is already attached to a pipeline.
+ * Returns the existing pipeline ID if found, undefined otherwise.
+ */
+export async function findExistingAttachment(connection: Connection, projectId: string): Promise<string | undefined> {
+  const result = await connection.query<{ DevopsPipelineId: string }>(
+    `SELECT DevopsPipelineId FROM DevopsProjectPipeline WHERE DevopsProjectId = '${projectId}' LIMIT 1`
+  );
+  return (result.records ?? [])[0]?.DevopsPipelineId;
+}
+
+/**
+ * Attaches a DevOps Center project to a pipeline by creating a DevopsProjectPipeline junction record.
+ */
+export async function attachProject(params: AttachProjectParams): Promise<AttachProjectResult> {
+  const { connection, projectId, pipelineId } = params;
+
+  const result = await connection.sobject('DevopsProjectPipeline').create({
+    DevopsProjectId: projectId,
+    DevopsPipelineId: pipelineId,
+  });
+
+  if (result.success) {
+    return { success: true, projectId, pipelineId };
+  }
+
+  const errorMessages = result.errors?.map((e) => (typeof e === 'string' ? e : JSON.stringify(e))).join('; ');
+  return {
+    success: false,
+    projectId,
+    pipelineId,
+    error: errorMessages ?? 'Unknown error',
+  };
+}