forked from oskanberg/slack-tube-service
-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
6 changed files
with
237 additions
and
225 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,138 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "github.com/pkg/errors" | ||
| "github.com/thoeni/go-tfl" | ||
| "sort" | ||
| "strings" | ||
| ) | ||
|
|
||
| func statusCommand(slackCommandArgs []string, slackRequest slackRequest) (*slackResponse, error) { | ||
|
|
||
| var r slackResponse = NewEphemeral() | ||
|
|
||
| tubeLine := strings.Join(slackCommandArgs, " ") | ||
| teamDomain := strings.Replace(slackRequest.TeamDomain, " ", "", -1) | ||
|
|
||
| go func() { | ||
| tubeLineLabel := "all" | ||
| if tubeLine != "" { | ||
| tubeLineLabel = tubeLine | ||
| } | ||
| slackRequestsTotal.WithLabelValues(teamDomain, tubeLineLabel).Inc() | ||
| }() | ||
|
|
||
| r.Text = fmt.Sprintf("Slack Tube Service") | ||
|
|
||
| var lines []string | ||
| if tubeLine != "" { | ||
| lines = []string{tubeLine} | ||
| } | ||
|
|
||
| reportsMap, err := tubeService.GetStatusFor(lines) | ||
|
|
||
| if err != nil { | ||
| r.Text = "Error while retrieving information from TFL" | ||
| return &r, errors.Wrap(err, "TFLError") | ||
| } else if len(reportsMap) == 0 { | ||
| r.Text = "Not a recognised line." | ||
| return &r, errors.New("LineNotRecognised") | ||
| } | ||
|
|
||
| r.Attachments = reportMapToSortedAttachmentsArray(reportsMap) | ||
| return &r, nil | ||
| } | ||
|
|
||
| // Returns the status for lines a specific user subscribed to | ||
| func forCommand(slackCommandArgs []string, slackRequest slackRequest) (*slackResponse, error) { | ||
|
|
||
| var r slackResponse = NewEphemeral() | ||
|
|
||
| user := slackCommandArgs[0] | ||
| id := fmt.Sprintf("%s-%s", slackRequest.TeamID, user[1:]) | ||
|
|
||
| lines, err := getLinesFor(id) | ||
| if err != nil { | ||
| if err.Error() == "UserNotFound" { | ||
| r.Text = fmt.Sprintf("Couldn't find lines for user: %s", user) | ||
| } else { | ||
| r.Text = fmt.Sprintf("Error while retrieving lines for user: %s", user) | ||
| } | ||
| return &r, errors.Wrap(err, "GetUserError") | ||
| } | ||
|
|
||
| reportsMap, err := tubeService.GetStatusFor(lines) | ||
|
|
||
| if err != nil { | ||
| r.Text = "Error while retrieving information from TFL" | ||
| return &r, errors.Wrap(err, "TFLError") | ||
| } else if len(reportsMap) == 0 { | ||
| r.Text = "Not a recognised line." | ||
| return &r, errors.New("LineNotRecognised") | ||
| } | ||
|
|
||
| r.Attachments = reportMapToSortedAttachmentsArray(reportsMap) | ||
| return &r, nil | ||
| } | ||
|
|
||
| func subscribeCommand(slackCommandArgs []string, slackRequest slackRequest) (*slackResponse, error) { | ||
|
|
||
| var r slackResponse = NewEphemeral() | ||
|
|
||
| if len(slackCommandArgs) == 0 { | ||
| r.Text = fmt.Sprintf("A line to subscribe to must be specified :thinking_face:. For example `/tube subscribe bakerloo`") | ||
| return &r, errors.New("SubscriptionNotAvailable") | ||
| } | ||
|
|
||
| id := fmt.Sprintf("%s-%s", slackRequest.TeamID, slackRequest.Username) | ||
| username := slackRequest.Username | ||
| subscribedLines := []string{strings.Join(slackCommandArgs, " ")} | ||
|
|
||
| if _, err := statusCommand(slackCommandArgs, slackRequest); err != nil { | ||
| if strings.Contains(err.Error(), "LineNotRecognised") { | ||
| r.Text = fmt.Sprintf("Line %s is not a recognised line, therefore subscription is not available", subscribedLines[0]) | ||
| return &r, errors.Wrap(err, "SubscriptionNotAvailable") | ||
| } | ||
| } | ||
|
|
||
| if err := putNewSlackUser(id, username, subscribedLines); err != nil { | ||
| if strings.Contains(err.Error(), "UserAlreadyExists") { | ||
| if err := updateExistingSlackUser(id, username, subscribedLines); err != nil { | ||
| r.Text = fmt.Sprintf("Error while updating subscriptions for user %s", username) | ||
| return &r, nil | ||
| } | ||
| r.Text = fmt.Sprintf("Line %s added to subscriptions for existing user %s", subscribedLines[0], username) | ||
| return &r, nil | ||
| } else { | ||
| r.Text = fmt.Sprintf("Error while creating subscriptions for user %s", username) | ||
| return &r, nil | ||
| } | ||
| } | ||
| r.Text = fmt.Sprintf("Line %s added to subscriptions for new user %s", subscribedLines[0], username) | ||
| return &r, nil | ||
| } | ||
|
|
||
| func reportMapToSortedAttachmentsArray(inputMap map[string]tfl.Report) []attachment { | ||
| keys := make([]string, len(inputMap)) | ||
| attachments := make([]attachment, len(inputMap)) | ||
| i := 0 | ||
|
|
||
| for k := range inputMap { | ||
| keys[i] = k | ||
| i++ | ||
| } | ||
| sort.Strings(keys) | ||
|
|
||
| for j, k := range keys { | ||
| attachments[j] = mapTflLineToSlackAttachment(inputMap[k]) | ||
| } | ||
|
|
||
| return attachments | ||
| } | ||
|
|
||
| func versionCommand(slackCommandArgs []string, slackRequest slackRequest) (*slackResponse, error) { | ||
| var r slackResponse = NewEphemeral() | ||
| r.Text = fmt.Sprintf("Slack Tube Service - %s [%s]", AppVersion, Sha) | ||
| return &r, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.