[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"
@@ -115,14 +118,16 @@ const (
 	WSEventSubscriptionDeleted = "subscription_deleted"
 
 	// Colors
-	ReposIconColor  = "#d74f27"
-	BoardsIconColor = "#53bba1"
+	ReposIconColor    = "#d74f27"
+	BoardsIconColor   = "#53bba1"
+	PipelineIconColor = "#4275E4"
 
 	SubscriptionEventTypeDummy = "dummy"
 	FileNameGitBranchIcon      = "git-branch-icon.svg"
 	FileNameProjectIcon        = "project-icon.svg"
 	FileNameReposIcon          = "repos-icon.svg"
 	FileNameBoardsIcon         = "boards-icon.svg"
+	FileNamePipeline           = "pipeline-icon.svg"
 	IconColorBoards            = "#53bba1"
 	IconColorRepos             = "#d74f27"
 

server/constants/messages.go

@@ -12,6 +12,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

@@ -23,6 +23,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"
 	GetProject               = "/%s/_apis/projects/%s?api-version=7.1-preview.4"

server/plugin/client.go

@@ -26,6 +26,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)
 }
 
 type client struct {
@@ -116,6 +117,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

@@ -106,3 +106,51 @@ 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 {
+		return nil, ""
+	}
+
+	post := &model.Post{
+		UserId:    userID,
+		ChannelId: channelID,
+	}
+	attachment := &model.SlackAttachment{
+		AuthorName: "Azure Pipeline",
+		AuthorIcon: fmt.Sprintf("%s/plugins/%s/static/%s", p.GetSiteURL(), constants.PluginID, constants.FileNamePipeline), // TODO: update icon file
+		Title:      fmt.Sprintf(constants.BuildDetailsTitle, buildDetails.BuildNumber, buildDetails.Link.Web.Href, buildDetails.Definition.Name),
+		Color:      constants.PipelineIconColor,
+		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

@@ -157,6 +157,25 @@ type DeleteSubscriptionRequestPayload struct {
 	Repository   string `json:"repository"`
 }
 
+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"`
+}
+
+type Definition struct {
+	Name string `json:"name"`
+}
+
 func CreateSubscriptionRequestPayloadFromJSON(data io.Reader) (*CreateSubscriptionRequestPayload, error) {
 	var body *CreateSubscriptionRequestPayload
 	if err := json.NewDecoder(data).Decode(&body); err != nil {

server/serializers/task.go

@@ -45,12 +45,17 @@ type TaskFieldValue struct {
 
 type Link struct {
 	HTML Href `json:"html"`
+	Web  Web  `json:"web"`
 }
 
 type Href struct {
 	Href string `json:"href"`
 }
 
+type Web struct {
+	Href string `json:"href"`
+}
+
 type TaskUserDetails struct {
 	ID          string `json:"id"`
 	DisplayName string `json:"displayName"`