Add status change confirmation

server/api/api.go

@@ -31,4 +31,5 @@ func Init(h *httputils.Handler, env mscalendar.Env, notificationProcessor mscale
 	postActionRouter.HandleFunc(config.PathDecline, api.postActionDecline).Methods("POST")
 	postActionRouter.HandleFunc(config.PathTentative, api.postActionTentative).Methods("POST")
 	postActionRouter.HandleFunc(config.PathRespond, api.postActionRespond).Methods("POST")
+	postActionRouter.HandleFunc(config.PathConfirmStatusChange, api.postActionConfirmStatusChange).Methods("POST")
 }

server/api/post_action.go

@@ -4,14 +4,18 @@
 package api
 
 import (
+	"encoding/json"
+	"errors"
 	"fmt"
 	"net/http"
 	"strings"
+	"time"
 
 	"github.com/mattermost/mattermost-server/v5/model"
 
 	"github.com/mattermost/mattermost-plugin-mscalendar/server/config"
 	"github.com/mattermost/mattermost-plugin-mscalendar/server/mscalendar"
+	"github.com/mattermost/mattermost-plugin-mscalendar/server/mscalendar/views"
 	"github.com/mattermost/mattermost-plugin-mscalendar/server/utils"
 )
 
@@ -134,3 +138,94 @@ func prettyOption(option string) string {
 		return ""
 	}
 }
+
+func (api *api) postActionConfirmStatusChange(w http.ResponseWriter, req *http.Request) {
+	mattermostUserID := req.Header.Get("Mattermost-User-ID")
+	if mattermostUserID == "" {
+		utils.SlackAttachmentError(w, "Not authorized.")
+		return
+	}
+
+	response := model.PostActionIntegrationResponse{}
+	post := &model.Post{}
+
+	request := model.PostActionIntegrationRequestFromJson(req.Body)
+	if request == nil {
+		utils.SlackAttachmentError(w, "Invalid request.")
+		return
+	}
+
+	value, ok := request.Context["value"].(bool)
+	if !ok {
+		utils.SlackAttachmentError(w, `No recognizable value for property "value".`)
+		return
+	}
+
+	returnText := "The status has not been changed."
+	if value {
+		changeTo, ok := request.Context["change_to"]
+		if !ok {
+			utils.SlackAttachmentError(w, "No state to change to.")
+			return
+		}
+		stringChangeTo := changeTo.(string)
+		prettyChangeTo, ok := request.Context["pretty_change_to"]
+		if !ok {
+			prettyChangeTo = changeTo
+		}
+		stringPrettyChangeTo := prettyChangeTo.(string)
+
+		api.PluginAPI.UpdateMattermostUserStatus(mattermostUserID, stringChangeTo)
+		returnText = fmt.Sprintf("The status has been changed to %s.", stringPrettyChangeTo)
+	}
+
+	eventInfo, err := getEventInfo(request.Context)
+	if err != nil {
+		utils.SlackAttachmentError(w, err.Error())
+		return
+	}
+
+	if eventInfo != "" {
+		returnText = eventInfo + "\n" + returnText
+	}
+
+	sa := &model.SlackAttachment{
+		Title: "Status Change",
+		Text:  returnText,
+	}
+
+	model.ParseSlackAttachment(post, []*model.SlackAttachment{sa})
+
+	response.Update = post
+	w.Header().Set("Content-Type", "application/json")
+	w.Write(response.ToJson())
+}
+
+func getEventInfo(ctx map[string]interface{}) (string, error) {
+	hasEvent, ok := ctx["hasEvent"].(bool)
+	if !ok {
+		return "", errors.New("Cannot check whether there is an event attached.")
+	}
+	if !hasEvent {
+		return "", nil
+	}
+
+	subject, ok := ctx["subject"].(string)
+	if !ok {
+		return "", errors.New("Cannot find the event subject.")
+	}
+
+	weblink, ok := ctx["weblink"].(string)
+	if !ok {
+		return "", errors.New("Cannot find the event weblink.")
+	}
+
+	marshalledStartTime, ok := ctx["startTime"].(string)
+	if !ok {
+		return "", errors.New("Cannot find the event start time.")
+	}
+	var startTime time.Time
+	json.Unmarshal([]byte(marshalledStartTime), &startTime)
+
+	return views.RenderEventWillStartLine(subject, weblink, startTime), nil
+}

server/command/availability.go

@@ -4,16 +4,24 @@
 package command
 
 func (c *Command) availability(parameters ...string) (string, bool, error) {
+	authorized, err := c.MSCalendar.IsAuthorizedAdmin(c.Args.UserId)
+	if err != nil {
+		return "", false, err
+	}
+	if !authorized {
+		return "Not authorized", false, nil
+	}
+
 	switch {
 	case len(parameters) == 0:
-		resString, err := c.MSCalendar.SyncStatus(c.Args.UserId)
+		resString, err := c.MSCalendar.Sync(c.Args.UserId)
 		if err != nil {
 			return "", false, err
 		}
 
 		return resString, false, nil
 	case len(parameters) == 1 && parameters[0] == "all":
-		resString, err := c.MSCalendar.SyncStatusAll()
+		resString, err := c.MSCalendar.SyncAll()
 		if err != nil {
 			return "", false, err
 		}

server/command/connect_test.go

@@ -52,7 +52,6 @@ func TestConnect(t *testing.T) {
 
 			conf := &config.Config{
 				PluginURL: "http://localhost",
-				BotUserID: "bot_user_id",
 			}
 
 			mscal := mock_mscalendar.NewMockMSCalendar(ctrl)

server/command/disconnect_test.go

@@ -51,7 +51,6 @@ func TestDisconnect(t *testing.T) {
 
 			conf := &config.Config{
 				PluginURL: "http://localhost",
-				BotUserID: "bot_user_id",
 			}
 
 			mscal := mock_mscalendar.NewMockMSCalendar(ctrl)

server/config/config.go

@@ -20,7 +20,6 @@ type StoredConfig struct {
 type Config struct {
 	StoredConfig
 
-	BotUserID              string
 	BuildDate              string
 	BuildHash              string
 	BuildHashShort         string

server/config/const.go

@@ -12,16 +12,17 @@ const (
 	Repository      = "mattermost-plugin-mscalendar"
 	CommandTrigger  = "mscalendar"
 
-	PathOAuth2       = "/oauth2"
-	PathComplete     = "/complete"
-	PathAPI          = "/api/v1"
-	PathPostAction   = "/action"
-	PathRespond      = "/respond"
-	PathAccept       = "/accept"
-	PathDecline      = "/decline"
-	PathTentative    = "/tentative"
-	PathNotification = "/notification/v1"
-	PathEvent        = "/event"
+	PathOAuth2              = "/oauth2"
+	PathComplete            = "/complete"
+	PathAPI                 = "/api/v1"
+	PathPostAction          = "/action"
+	PathRespond             = "/respond"
+	PathAccept              = "/accept"
+	PathDecline             = "/decline"
+	PathTentative           = "/tentative"
+	PathConfirmStatusChange = "/confirm"
+	PathNotification        = "/notification/v1"
+	PathEvent               = "/event"
 
 	FullPathEventNotification = PathNotification + PathEvent
 	FullPathOAuth2Redirect    = PathOAuth2 + PathComplete

server/jobs/job_manager_test.go

@@ -12,7 +12,6 @@ import (
 	"github.com/stretchr/testify/require"
 
 	"github.com/mattermost/mattermost-plugin-api/cluster"
-	"github.com/mattermost/mattermost-plugin-mscalendar/server/config"
 	"github.com/mattermost/mattermost-plugin-mscalendar/server/jobs/mock_cluster"
 	"github.com/mattermost/mattermost-plugin-mscalendar/server/mscalendar"
 	"github.com/mattermost/mattermost-plugin-mscalendar/server/mscalendar/mock_plugin_api"
@@ -29,9 +28,7 @@ func newTestEnv(ctrl *gomock.Controller) mscalendar.Env {
 	mockPluginAPI := mock_plugin_api.NewMockPluginAPI(ctrl)
 
 	logger := &bot.NilLogger{}
-	conf := &config.Config{BotUserID: "bot_mm_id"}
 	return mscalendar.Env{
-		Config: conf,
 		Dependencies: &mscalendar.Dependencies{
 			Store:     s,
 			Logger:    logger,

server/jobs/status_sync_job.go

@@ -15,16 +15,16 @@ func NewStatusSyncJob() RegisteredJob {
 	return RegisteredJob{
 		id:                statusSyncJobID,
 		interval:          mscalendar.StatusSyncJobInterval,
-		work:              runStatusSyncJob,
+		work:              runSyncJob,
 		isEnabledByConfig: isStatusSyncJobEnabled,
 	}
 }
 
-// runStatusSyncJob synchronizes all users' statuses between mscalendar and Mattermost.
-func runStatusSyncJob(env mscalendar.Env) {
+// runSyncJob synchronizes all users' statuses between mscalendar and Mattermost.
+func runSyncJob(env mscalendar.Env) {
 	env.Logger.Debugf("User status sync job beginning")
 
-	_, err := mscalendar.New(env, "").SyncStatusAll()
+	_, err := mscalendar.New(env, "").SyncAll()
 	if err != nil {
 		env.Logger.Errorf("Error during user status sync job: %v", err)
 	}