Get Details about a specific connector (#24)

* Remove .DS_Store files
* Get Details about a specific connector

Author: Swarnendu Gupta

.gitignore

@@ -11,4 +11,6 @@ dist/
 __debug_bin*
 
 # Go
-vendor
+vendor
+
+**/.DS_Store

client/connectors.go

@@ -57,3 +57,31 @@ func (c *ConnectorService) ListConnectorCatalogue(ctx context.Context, scope dto
 
 	return result, nil
 }
+
+// GetConnector retrieves a connector by its identifier
+// https://apidocs.harness.io/tag/Connectors#operation/getConnector
+func (c *ConnectorService) GetConnector(ctx context.Context, scope dto.Scope, connectorIdentifier string) (*pkgDTO.ConnectorDetail, error) {
+	path := fmt.Sprintf("/ng/api/connectors/%s", connectorIdentifier)
+	params := make(map[string]string)
+	// Ensure accountIdentifier is always set
+	if scope.AccountID == "" {
+		return nil, fmt.Errorf("accountIdentifier cannot be null")
+	}
+	addScope(scope, params)
+
+	// Define a struct to match the actual API response structure
+	type connectorResponse struct {
+		Status        string                   `json:"status"`
+		Data          pkgDTO.ConnectorDetail   `json:"data"`
+		MetaData      interface{}              `json:"metaData"`
+		CorrelationID string                   `json:"correlationId"`
+	}
+
+	var response connectorResponse
+	err := c.Client.Get(ctx, path, params, nil, &response)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get connector: %w", err)
+	}
+
+	return &response.Data, nil
+}

pkg/harness/dto/connectors.go

@@ -29,3 +29,66 @@ type ConnectorCatalogueItem struct {
 	SSCAType                       string   `json:"sscaType,omitempty"`
 	SSCASupported                  bool     `json:"sscaSupported,omitempty"`
 }
+
+// ConnectorDetail represents the detailed information of a connector.
+// Based on https://apidocs.harness.io/tag/Connectors#operation/getConnector
+type ConnectorDetail struct {
+	Connector             Connector             `json:"connector"`
+	CreatedAt             int64                 `json:"createdAt"`
+	LastModifiedAt        int64                 `json:"lastModifiedAt"`
+	Status                ConnectorStatus       `json:"status"`
+	ActivityDetails       ActivityDetails       `json:"activityDetails"`
+	HarnessManaged        bool                  `json:"harnessManaged"`
+	GitDetails            GitDetails            `json:"gitDetails"`
+	EntityValidityDetails EntityValidityDetails `json:"entityValidityDetails"`
+	GovernanceMetadata    interface{}           `json:"governanceMetadata,omitempty"`
+	IsFavorite            bool                  `json:"isFavorite"`
+}
+
+// Connector represents the core connector information.
+type Connector struct {
+	Name              string                 `json:"name"`
+	Identifier        string                 `json:"identifier"`
+	Description       string                 `json:"description"`
+	AccountIdentifier string                 `json:"accountIdentifier"`
+	OrgIdentifier     string                 `json:"orgIdentifier"`
+	ProjectIdentifier string                 `json:"projectIdentifier"`
+	Tags              map[string]string      `json:"tags"`
+	Type              string                 `json:"type"`
+	Spec              map[string]interface{} `json:"spec"`
+}
+
+// ConnectorStatus represents the status information of a connector.
+type ConnectorStatus struct {
+	Status            string                    `json:"status"`
+	ErrorSummary      string                    `json:"errorSummary"`
+	Errors            []ConnectorError          `json:"errors"`
+	TestedAt          int64                     `json:"testedAt"`
+	LastTestedAt      int64                     `json:"lastTestedAt"`
+	LastConnectedAt   int64                     `json:"lastConnectedAt"`
+	LastAlertSent     int64                     `json:"lastAlertSent"`
+}
+
+// ConnectorError represents an error in connector status.
+type ConnectorError struct {
+	Reason  string `json:"reason"`
+	Message string `json:"message"`
+	Code    int    `json:"code"`
+}
+
+// ActivityDetails represents the activity information of a connector.
+type ActivityDetails struct {
+	LastActivityTime int64 `json:"lastActivityTime"`
+}
+
+// GitDetails represents git-related information of a connector.
+type GitDetails struct {
+	Valid       bool   `json:"valid"`
+	InvalidYaml string `json:"invalidYaml"`
+}
+
+// EntityValidityDetails represents the validity information of a connector.
+type EntityValidityDetails struct {
+	Valid       bool   `json:"valid"`
+	InvalidYaml string `json:"invalidYaml"`
+}

pkg/harness/tools.go

@@ -74,6 +74,43 @@ func ListConnectorCatalogueTool(harnessConfig *config.Config, c *client.Client)
 		}
 }
 
+// GetConnectorDetailsTool creates a tool for getting details of a specific connector
+// https://apidocs.harness.io/tag/Connectors#operation/getConnector
+func GetConnectorDetailsTool(config *config.Config, c *client.Client) (mcp.Tool, server.ToolHandlerFunc) {
+	return mcp.NewTool("get_connector_details",
+			mcp.WithDescription("Get detailed information about a specific connector."),
+			mcp.WithString("connector_identifier",
+				mcp.Required(),
+				mcp.Description("The identifier of the connector"),
+			),
+			WithScope(config, false),
+		),
+		func(ctx context.Context, request mcp.CallToolRequest) (*mcp.CallToolResult, error) {
+			connectorIdentifier, err := requiredParam[string](request, "connector_identifier")
+			if err != nil {
+				return mcp.NewToolResultError(err.Error()), nil
+			}
+
+			scope, err := fetchScope(config, request, false)
+			if err != nil {
+				return mcp.NewToolResultError(err.Error()), nil
+			}
+
+			connectorService := client.ConnectorService{Client: c}
+			data, err := connectorService.GetConnector(ctx, scope, connectorIdentifier)
+			if err != nil {
+				return nil, fmt.Errorf("failed to get connector: %w", err)
+			}
+
+			r, err := json.Marshal(data)
+			if err != nil {
+				return nil, fmt.Errorf("failed to marshal connector: %w", err)
+			}
+
+			return mcp.NewToolResultText(string(r)), nil
+		}
+}
+
 // InitToolsets initializes and returns the toolset groups
 func InitToolsets(config *config.Config) (*toolsets.ToolsetGroup, error) {
 	// Create a toolset group
@@ -355,6 +392,7 @@ func registerConnectors(config *config.Config, tsg *toolsets.ToolsetGroup) error
 	connectors := toolsets.NewToolset("connectors", "Harness Connector related tools").
 		AddReadTools(
 			toolsets.NewServerTool(ListConnectorCatalogueTool(config, c)),
+			toolsets.NewServerTool(GetConnectorDetailsTool(config, c)),
 		)
 
 	tsg.AddToolset(connectors)