feat(Main): publish slack notifications if slack configuration is ava…

…ilable

README.md

@@ -52,6 +52,20 @@ $ curl "http:https://localhost:8181/run?definition=main&secret=secret-token"
 
 while the browser will show only a `success` message, the server will give you more feedback
 
+## Slack integration
+
+To receive slack notifications, create a new [Incoming Webhook](https://slack.com/apps/A0F7XDUAZ-incoming-webhooks) in your Slack account. Then, run orchy with the following environment variables:
+
+* `SLACK_HOOK_URL` - webhook url, e.g. `https://hooks.slack.com/services/ABC/DEF/GHI`
+* `SLACK_CHANNEL` - channel to post notifications to, e.g. `deployment-logs`
+
+```shell
+$ SLACK_HOOK_URL=<url> SLACK_CHANNEL=<channel> orchy
+
+Orchy server is running at http:https://localhost:8181
+```
+
+
 ## Feedback from the server
 
 When `configuration.json` file is missing:

src/Main.purs

@@ -1,29 +1,19 @@
 module Main where
 
-import Prelude
-
 import Data.Either (Either(..))
-import Data.Maybe (Maybe(..))
 import Effect (Effect)
 import HTTP.Server as HTTPServer
 import HTTP.Utils as HTTPUtils
 import Logger as Logger
-import Node.Process (lookupEnv)
 import Orchestrator.FS (readFile)
 import Orchestrator.JSON (fromJSON)
 import Orchestrator.Main (makeId, makeSecret, runDefinitionWithIdAndSecret)
-import Simple.JSON (readJSON_)
-
-getPort :: Effect Int
-getPort = do
- maybePort <- lookupEnv "PORT"
- case (maybePort >>= readJSON_) of
- Nothing -> pure 8181
- (Just port) -> pure port
+import Prelude
+import System.Environment (readEnvInt)
 
 main :: Effect Unit
 main = do
- port <- getPort
+ port <- readEnvInt "PORT" 8181
  configuration <- readFile "configuration.json"
  case configuration of
  (Left _) -> Logger.error "Failure reading configuration.json"

src/Orchestrator/Main.purs

@@ -19,6 +19,7 @@ import Effect (Effect)
 import Effect.Aff (Aff, Error, launchAff_, message)
 import Effect.Class (liftEffect)
 import Logger as Logger
+import Notifications.Slack as Slack
 import Prelude ((&&), (*>))
 import System.Commands (asyncExec)
 
@@ -124,16 +125,24 @@ runDefinition (Definition { dir, commands }) = launchAff_ do
  (Right _) -> logSuccess
  where
  logFailure :: Aff Unit
- logFailure = liftEffect $ Logger.error "Execution FAILED"
+ logFailure = do
+ liftEffect $ Logger.error "Execution FAILED"
+ Slack.notify "Execution FAILED"
 
  logSuccess :: Aff Unit
- logSuccess = liftEffect $ Logger.info "Execution SUCCEEDED"
+ logSuccess = do
+ liftEffect $ Logger.info "Execution SUCCEEDED"
+ Slack.notify "Execution SUCCEEDED"
 
  logOutput :: Error -> Aff Unit
- logOutput = liftEffect <<< Logger.quote <<< message
+ logOutput error = do
+ liftEffect <<< Logger.quote $ message error
+ Slack.notify $ message error
 
  executeCommand :: Dir -> Command -> Aff Unit
  executeCommand (Dir cwd) (Command program args) = do
  liftEffect $ Logger.info $ "Executing " <> (joinWith " " (program : args))
+ Slack.notify $ "Executing " <> (joinWith " " (program : args))
  output <- asyncExec program args { cwd }
  liftEffect $ Logger.quote output
+ Slack.notify output