feat: add support for backup-plan changes

Author: sgtoj

fixtures/samples.json

@@ -386,5 +386,59 @@
       "creationDate": "2020-06-22T18:50:46.407Z",
       "state": "CREATED"
     }
+  },
+  {
+    "version": "0",
+    "id": "2895aefb-dd4a-0a23-6071-2652abd92c3f",
+    "detail-type": "Backup Plan State Change",
+    "source": "aws.backup",
+    "account": "1112233445566",
+    "time": "2020-06-24T23:18:25Z",
+    "region": "us-west-2",
+    "resources": [
+      "arn:aws:backup:us-west-2:1112233445566:backup-plan:83fcb8ee-2d93-42ac-b06f-591563f3f8de"
+    ],
+    "detail": {
+      "backupPlanId": "83fcb8ee-2d93-42ac-b06f-591563f3f8de",
+      "versionId": "NjIwNDFjMDEtNmZlNC00M2JmLTkzZDgtNzNkZjQyNzkxNDk0",
+      "modifiedAt": "2020-06-24T23:18:19.168Z",
+      "state": "MODIFIED"
+    }
+  },
+  {
+    "version": "0",
+    "id": "33fc5c1d-6db2-b3d9-1e70-1c9a2c23645c",
+    "detail-type": "Backup Plan State Change",
+    "source": "aws.backup",
+    "account": "1112233445566",
+    "time": "2020-06-24T23:18:25Z",
+    "region": "us-west-2",
+    "resources": [
+      "arn:aws:backup:us-west-2:1112233445566:backup-plan:83fcb8ee-2d93-42ac-b06f-591563f3f8de"
+    ],
+    "detail": {
+      "backupPlanId": "83fcb8ee-2d93-42ac-b06f-591563f3f8de",
+      "versionId": "NjIwNDFjMDEtNmZlNC00M2JmLTkzZDgtNzNkZjQyNzkxNDk0",
+      "deletionDate": "2020-06-24T23:18:19.411Z",
+      "state": "DELETED"
+    }
+  },
+  {
+    "version": "0",
+    "id": "b64fb2d0-ae16-ff9a-faf6-0bdd0d4bfdef",
+    "detail-type": "Backup Plan State Change",
+    "source": "aws.backup",
+    "account": "1112233445566",
+    "time": "2020-06-24T23:18:19Z",
+    "region": "us-west-2",
+    "resources": [
+      "arn:aws:backup:us-west-2:1112233445566:backup-plan:2c103c5f-6d6e-4cac-9147-d3afa4c84f59"
+    ],
+    "detail": {
+      "backupPlanId": "2c103c5f-6d6e-4cac-9147-d3afa4c84f59",
+      "versionId": "N2Q4OTczMzEtZmY1My00N2UwLWE3ODUtMjViYWYyOTUzZWY4",
+      "creationDate": "2020-06-24T23:18:15.318Z",
+      "state": "CREATED"
+    }
   }
 ]

internal/app/app.go

@@ -27,6 +27,8 @@ func (a *App) ParseEvent(e awsEvent.CloudWatchEvent) (events.StateChangeEvent, e
 	switch e.DetailType {
 	case "Backup Job State Change":
 		return events.NewBackupJobStateChange(e.Detail)
+	case "Backup Plan State Change":
+		return events.NewBackupPlanStateChange(e.Detail)
 	case "Copy Job State Change":
 		return events.NewCopyJobStateChange(e.Detail)
 	case "Restore Job State Change":

internal/events/backup-plan.go

@@ -0,0 +1,50 @@
+package events
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/slack-go/slack"
+)
+
+type BackupPlanStateChange struct {
+	StateChangeEvent
+	BackupPlanId  string `json:"backupPlanId"`
+	VersionId     string `json:"versionId"`
+	State         string `json:"state"`
+	StatusMessage string `json:"statusMessage"`
+	Raw           string `json:"-"`
+}
+
+func (sce *BackupPlanStateChange) SlackMessage() (slack.MsgOption, slack.MsgOption) {
+	var blocks []slack.Block
+
+	header := slack.NewHeaderBlock(slack.NewTextBlockObject("plain_text", "Backup Plan Change", false, false))
+	blocks = append(blocks, header)
+
+	var details []*slack.TextBlockObject
+	details = append(details, slack.NewTextBlockObject("mrkdwn", fmt.Sprintf("*State*\n%s", sce.State), false, false))
+	blocks = append(blocks, slack.NewSectionBlock(nil, details, nil))
+
+	if sce.StatusMessage != "" {
+		desc := slack.NewSectionBlock(
+			slack.NewTextBlockObject("mrkdwn", fmt.Sprintf("```\n%s\n```", sce.StatusMessage), false, false),
+			nil, nil,
+		)
+		blocks = append(blocks, desc)
+	}
+	return slack.MsgOptionText(sce.StatusMessage, false), slack.MsgOptionBlocks(blocks...)
+}
+
+func (sce *BackupPlanStateChange) IsAlertable() bool {
+	return true
+}
+
+func NewBackupPlanStateChange(raw json.RawMessage) (*BackupPlanStateChange, error) {
+	var sce BackupPlanStateChange
+	if err := json.Unmarshal(raw, &sce); err != nil {
+		return &BackupPlanStateChange{}, err
+	}
+	sce.StatusMessage = "Backup plan for AWS Backup service was changed. Please confirm it was intended."
+	return &sce, nil
+}

internal/events/copy-job.go

@@ -12,7 +12,7 @@ import (
 
 type CopyJobStateChange struct {
 	StateChangeEvent
-	CopyJobId     string `json:"backupJobId"`
+	CopyJobId     string `json:"copyJobId"`
 	ResourceArn   string `json:"resourceArn"`
 	ResourceType  string `json:"resourceType"`
 	State         string `json:"state"`