[MI-2339][server]: Added support to show pipeline build link preview.

server/constants/constants.go

@@ -41,6 +41,9 @@ const (
 	// Regex to verify pull request link
 	PullRequestLinkRegex = `http(s)?:\/\/dev.azure.com\/[a-zA-Z0-9!@#$%^&*()_+\-=\[\]{};':"\\|,.<>\/?]*\/[a-zA-Z0-9!@#$%^&*()_+\-=\[\]{};':"\\|,.<>\/?]*\/_git\/[a-zA-Z0-9!@#$%^&*()_+\-=\[\]{};':"\\|,.<>\/?]*\/pullrequest\/[1-9]+`
 
+	// Regex to verify pipeline build details link
+	BuildDetailsLinkRegex = `http(s)?:\/\/dev.azure.com\/[a-zA-Z0-9!@#$%^&*()_+\-=\[\]{};':"\\|,.<>\/?]*\/[a-zA-Z0-9!@#$%^&*()_+\-=\[\]{};':"\\|,.<>\/?]*\/_build\/results\?buildId=[a-zA-Z0-9!@#$%^&*()_+\-=\[\]{};':"\\|,.<>\/?]+`
+
 	// Azure API Versions
 	CreateTaskAPIVersion = "7.1-preview.3"
 	TasksIDAPIVersion    = "5.1"
@@ -117,18 +120,16 @@ const (
 	WSEventSubscriptionDeleted = "subscription_deleted"
 
 	// Colors
-	ReposIconColor  = "#d74f27"
-	BoardsIconColor = "#53bba1"
+	IconColorRepos     = "#d74f27"
+	IconColorBoards    = "#53bba1"
+	IconColorPipelines = "#4275E4"
 
 	SubscriptionEventTypeDummy = "dummy"
 	FileNameGitBranchIcon      = "git-branch-icon.svg"
 	FileNameProjectIcon        = "project-icon.svg"
 	FileNameReposIcon          = "repos-icon.svg"
 	FileNameBoardsIcon         = "boards-icon.svg"
 	FileNamePipelinesIcon      = "pipelines-icon.svg"
-	IconColorBoards            = "#53bba1"
-	IconColorRepos             = "#d74f27"
-	IconColorPipelines         = "#4b68ad"
 
 	SlackAttachmentAuthorNameRepos     = "Azure Repos"
 	SlackAttachmentAuthorNameBoards    = "Azure Boards"

server/constants/messages.go

@@ -13,6 +13,7 @@ const (
 	CreatedTask           = "[%s #%d](%s) (%s) was successfully created by %s."
 	TaskTitle             = "[%s #%d: %s](%s)"
 	PullRequestTitle      = "[#%d: %s](%s)"
+	BuildDetailsTitle     = "[#%s](%s): %s"
 	AlreadyLinkedProject  = "This project is already linked."
 	NoProjectLinked       = "No project is linked, please link a project."
 

server/constants/routes.go

@@ -24,6 +24,7 @@ const (
 	CreateTask                          = "/%s/%s/_apis/wit/workitems/$%s?api-version=7.1-preview.3"
 	GetTask                             = "%s/%s/_apis/wit/workitems/%s?api-version=7.1-preview.3"
 	GetPullRequest                      = "%s/%s/_apis/git/pullrequests/%s?api-version=6.0"
+	GetBuildDetails                     = "%s/%s/_apis/build/builds/%s?api-version=6.0"
 	GetGitRepositories                  = "%s/%s/_apis/git/repositories?api-version=6.0"
 	GetGitRepositoryBranches            = "%s/%s/_apis/git/repositories/%s/refs?filter=heads"
 	GetSubscriptionFilterPossibleValues = "%s/_apis/hooks/inputValuesQuery?api-version=6.0"

server/plugin/client.go

@@ -27,6 +27,7 @@ type Client interface {
 	CheckIfUserIsProjectAdmin(organizationName, projectID, pluginURL, mattermostUserID string) (int, error)
 	GetGitRepositories(organization, projectName, mattermostUserID string) (*serializers.GitRepositoriesResponse, int, error)
 	GetGitRepositoryBranches(organization, projectName, repository, mattermostUserID string) (*serializers.GitBranchesResponse, int, error)
+	GetBuildDetails(organization, projectName, buildID, mattermostUserID string) (*serializers.BuildDetails, int, error)
 	GetSubscriptionFilterPossibleValues(request *serializers.GetSubscriptionFilterPossibleValuesRequestPayload, mattermostUserID string) (*serializers.SubscriptionFilterPossibleValuesResponseFromClient, int, error)
 }
 
@@ -118,6 +119,19 @@ func (c *client) GetPullRequest(organization, pullRequestID, projectName, matter
 	return pullRequest, statusCode, nil
 }
 
+// Function to get the pipeline build details.
+func (c *client) GetBuildDetails(organization, projectName, buildID, mattermostUserID string) (*serializers.BuildDetails, int, error) {
+	buildDetailsURL := fmt.Sprintf(constants.GetBuildDetails, organization, projectName, buildID)
+
+	var buildDetails *serializers.BuildDetails
+	_, statusCode, err := c.CallJSON(c.plugin.getConfiguration().AzureDevopsAPIBaseURL, buildDetailsURL, http.MethodGet, mattermostUserID, nil, &buildDetails, nil)
+	if err != nil {
+		return nil, statusCode, errors.Wrap(err, "failed to get the pipeline build details")
+	}
+
+	return buildDetails, statusCode, nil
+}
+
 // Function to link a project and an organization.
 func (c *client) Link(body *serializers.LinkRequestPayload, mattermostUserID string) (*serializers.Project, int, error) {
 	projectURL := fmt.Sprintf(constants.GetProject, body.Organization, body.Project)

server/plugin/plugin.go

@@ -124,5 +124,11 @@ func (p *Plugin) MessageWillBePosted(c *plugin.Context, post *model.Post) (*mode
 		return newPost, msg
 	}
 
+	// Check if a message contains a pipeline build link.
+	if buildDetailsData, link, isValid := IsLinkPresent(post.Message, constants.BuildDetailsLinkRegex); isValid {
+		newPost, msg := p.PostBuildDetailsPreview(buildDetailsData, link, post.UserId, post.ChannelId)
+		return newPost, msg
+	}
+
 	return nil, ""
 }

server/plugin/taskLinkPreview.go

@@ -14,6 +14,7 @@ import (
 func (p *Plugin) PostTaskPreview(linkData []string, userID, channelID string) (*model.Post, string) {
 	task, _, err := p.Client.GetTask(linkData[3], linkData[7], linkData[4], userID)
 	if err != nil {
+		p.API.LogDebug("Error in getting task details from Azure", "Error", err.Error())
 		return nil, ""
 	}
 
@@ -35,7 +36,7 @@ func (p *Plugin) PostTaskPreview(linkData []string, userID, channelID string) (*
 		AuthorName: "Azure Boards",
 		AuthorIcon: fmt.Sprintf("%s/plugins/%s/static/%s", p.GetSiteURL(), constants.PluginID, constants.FileNameBoardsIcon),
 		Title:      fmt.Sprintf(constants.TaskTitle, task.Fields.Type, task.ID, task.Fields.Title, task.Link.HTML.Href),
-		Color:      constants.BoardsIconColor,
+		Color:      constants.IconColorBoards,
 		Fields: []*model.SlackAttachmentField{
 			{
 				Title: "State",
@@ -62,6 +63,7 @@ func (p *Plugin) PostTaskPreview(linkData []string, userID, channelID string) (*
 func (p *Plugin) PostPullRequestPreview(linkData []string, link, userID, channelID string) (*model.Post, string) {
 	pullRequest, _, err := p.Client.GetPullRequest(linkData[3], linkData[8], linkData[6], userID)
 	if err != nil {
+		p.API.LogDebug("Error in getting pull request details from Azure", "Error", err.Error())
 		return nil, ""
 	}
 
@@ -83,7 +85,7 @@ func (p *Plugin) PostPullRequestPreview(linkData []string, link, userID, channel
 		AuthorName: "Azure Repos",
 		AuthorIcon: fmt.Sprintf("%s/plugins/%s/static/%s", p.GetSiteURL(), constants.PluginID, constants.FileNameReposIcon),
 		Title:      fmt.Sprintf(constants.PullRequestTitle, pullRequest.PullRequestID, pullRequest.Title, link),
-		Color:      constants.ReposIconColor,
+		Color:      constants.IconColorRepos,
 		Fields: []*model.SlackAttachmentField{
 			{
 				Title: "Target Branch",
@@ -107,3 +109,53 @@ func (p *Plugin) PostPullRequestPreview(linkData []string, link, userID, channel
 
 	return post, ""
 }
+
+func (p *Plugin) PostBuildDetailsPreview(linkData []string, link, userID, channelID string) (*model.Post, string) {
+	organization := linkData[3]
+	project := linkData[4]
+	buildID := strings.Split(linkData[6], "&")[0][16:]
+	buildDetails, _, err := p.Client.GetBuildDetails(organization, project, buildID, userID)
+	if err != nil {
+		p.API.LogDebug("Error in getting build details from Azure", "Error", err.Error())
+		return nil, ""
+	}
+
+	post := &model.Post{
+		UserId:    userID,
+		ChannelId: channelID,
+	}
+
+	attachment := &model.SlackAttachment{
+		AuthorName: "Azure Pipelines",
+		AuthorIcon: fmt.Sprintf("%s/plugins/%s/static/%s", p.GetSiteURL(), constants.PluginID, constants.FileNamePipelinesIcon), // TODO: update icon file
+		Title:      fmt.Sprintf(constants.BuildDetailsTitle, buildDetails.BuildNumber, buildDetails.Link.Web.Href, buildDetails.Definition.Name),
+		Color:      constants.IconColorPipelines,
+		Fields: []*model.SlackAttachmentField{
+			{
+				Title: "Repository",
+				Value: buildDetails.Repository.Name,
+				Short: true,
+			},
+			{
+				Title: "Source Branch",
+				Value: buildDetails.SourceBranch,
+				Short: true,
+			},
+			{
+				Title: "Requested By",
+				Value: buildDetails.RequestedBy.DisplayName,
+				Short: true,
+			},
+			{
+				Title: "Status",
+				Value: buildDetails.Status,
+				Short: true,
+			},
+		},
+		Footer:     project,
+		FooterIcon: fmt.Sprintf("%s/plugins/%s/static/%s", p.GetSiteURL(), constants.PluginID, constants.FileNameProjectIcon),
+	}
+
+	model.ParseSlackAttachment(post, []*model.SlackAttachment{attachment})
+	return post, ""
+}

server/serializers/subscriptions.go

@@ -269,6 +269,21 @@ func GetSubscriptionFilterPossibleValuesRequestPayloadFromJSON(data io.Reader) (
 	return body, nil
 }
 
+type BuildDetails struct {
+	BuildNumber  string      `json:"buildNumber"`
+	SourceBranch string      `json:"sourceBranch"`
+	Repository   Repository  `json:"repository"`
+	Status       string      `json:"status"`
+	RequestedBy  RequestedBy `json:"requestedBy"`
+	Project      Project     `json:"project"`
+	Link         Link        `json:"_links"`
+	Definition   Definition  `json:"definition"`
+}
+
+type RequestedBy struct {
+	DisplayName string `json:"displayName"`
+}
+
 func CreateSubscriptionRequestPayloadFromJSON(data io.Reader) (*CreateSubscriptionRequestPayload, error) {
 	var body *CreateSubscriptionRequestPayload
 	if err := json.NewDecoder(data).Decode(&body); err != nil {

server/serializers/task.go

@@ -45,6 +45,7 @@ type TaskFieldValue struct {
 
 type Link struct {
 	HTML Href `json:"html"`
+	Web  Href `json:"web"`
 }
 
 type Href struct {