Add application message (#6)

* add expired message to application
govau · Mar 6, 2019 · ea751da · ea751da
1 parent 54ad1ac
commit ea751da
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 5 deletions.
diff --git a/.vscode/launch.json b/.vscode/launch.json
@@ -9,15 +9,17 @@
             "type": "coreclr",
             "request": "launch",
             "preLaunchTask": "build",
-            "program": "${workspaceFolder}/subscribers/slack/bin/Debug/netcoreapp2.2/slack.dll",
+            "program": "${workspaceFolder}/subscribers/slack/worker/bin/Debug/netcoreapp2.2/slack.worker.dll",
             "args": [],
-            "cwd": "${workspaceFolder}/subscribers/slack",
+            "cwd": "${workspaceFolder}/subscribers/slack/worker",
             "console": "internalConsole",
             "stopAtEntry": false,
             "internalConsoleOptions": "openOnSessionStart",
             "env": {
                 "AWS_SQS_QUEUE_URL": "http://localhost:4576/queue/dta-marketplace-local-slack",
-                "AWS_SQS_SERVICE_URL": "http://localhost:4576"
+                "AWS_SQS_SERVICE_URL": "http://localhost:4576",
+                "WORK_INTERVAL_IN_SECONDS": "5",
+                "AWS_SQS_LONG_POLL_TIME_IN_SECONDS": "1"
             }
         },
         {

diff --git a/.vscode/tasks.json b/.vscode/tasks.json
@@ -7,9 +7,9 @@
             "type": "process",
             "args": [
                 "build",
-                "${workspaceFolder}/subscribers/slack/slack.csproj"
+                "${workspaceFolder}/subscribers/slack/worker/worker.csproj"
             ],
             "problemMatcher": "$msCompile"
         }
     ]
-}
+}
diff --git a/subscribers/slack/worker/Processors/ApplicationMessageProcessor.cs b/subscribers/slack/worker/Processors/ApplicationMessageProcessor.cs
@@ -21,6 +21,7 @@ public async override Task<bool> Process(AwsSnsMessage awsSnsMessage) {
                     var definition = new {
                         name = "",
                         email_address = "",
+                        from_expired = default(bool?),
                         application = new {
                             id = -1,
                             name = "",
@@ -35,6 +36,9 @@ public async override Task<bool> Process(AwsSnsMessage awsSnsMessage) {
                         subject = "An existing seller has started a new application";
                     } else if (message.application.type == "new") {
                         subject = "A new seller has started an application";
+                        if (message.from_expired.GetValueOrDefault(false)) {
+                            subject += " (from expired)";
+                        }
                     }
                     if (string.IsNullOrEmpty(subject) == false) {
                         var slackMessage =