Adding log as destination for alerting

cmd/pessimism/main.go

@@ -53,7 +53,7 @@ func initializeServer(ctx context.Context, cfg *config.Config,
 // initializeAlerting ... Performs dependency injection to build alerting struct
 func initializeAlerting(ctx context.Context, cfg *config.Config) alert.Manager {
 	sc := client.NewSlackClient(cfg.SlackURL)
-	return alert.NewManager(ctx, sc)
+	return alert.NewSlackManager(ctx, sc)
 }
 
 // initalizeETL ... Performs dependency injection to build etl struct

internal/alert/interpolator.go

@@ -37,7 +37,7 @@ func NewInterpolator() Interpolator {
 	return &interpolator{}
 }
 
-// InterpolateSlackMessage ... Interpolates a slack message with the given invariant session UUID and message
+// InterpolateSlackMessage ... Interpolates a Slack message with the given invariant session UUID and message
 func (*interpolator) InterpolateSlackMessage(sUUID core.SUUID, message string) string {
 	return fmt.Sprintf(SlackMsgFmt,
 		sUUID.PID.InvType().String(),

internal/alert/manager.go

@@ -33,7 +33,7 @@ type alertManager struct {
 }
 
 // NewManager ... Instantiates a new alert manager
-func NewManager(ctx context.Context, sc client.SlackClient) Manager {
+func NewSlackManager(ctx context.Context, sc client.SlackClient) Manager {
 	// NOTE - Consider constructing dependencies in higher level
 	// abstraction and passing them in
 
@@ -52,6 +52,21 @@ func NewManager(ctx context.Context, sc client.SlackClient) Manager {
 	return am
 }
 
+func NewLogManager(ctx context.Context) Manager {
+	ctx, cancel := context.WithCancel(ctx)
+
+	am := &alertManager{
+		ctx:    ctx,
+		cancel: cancel,
+
+		sc:           client.NewSlackClient(""), // will change when deps are constructed at higher level
+		interpolator: NewInterpolator(),
+		store:        NewStore(),
+		alertTransit: make(chan core.Alert),
+	}
+	return am
+}
+
 // AddInvariantSession ... Adds an invariant session to the alert manager store
 func (am *alertManager) AddInvariantSession(sUUID core.SUUID, alertDestination core.AlertDestination) error {
 	return am.store.AddAlertDestination(sUUID, alertDestination)
@@ -62,7 +77,7 @@ func (am *alertManager) Transit() chan core.Alert {
 	return am.alertTransit
 }
 
-// handleSlackPost ... Handles posting an alert to slack channel
+// handleSlackPost ... Handles posting an alert to Slack channel
 func (am *alertManager) handleSlackPost(alert core.Alert) error {
 	slackMsg := am.interpolator.InterpolateSlackMessage(alert.SUUID, alert.Content)
 
@@ -78,6 +93,17 @@ func (am *alertManager) handleSlackPost(alert core.Alert) error {
 	return nil
 }
 
+// handleSlackPost ... Handles posting an alert to console log
+func (am *alertManager) handleLogPost(alert core.Alert) {
+	logger := logging.WithContext(am.ctx)
+
+	logger.Error("Pessimism Alert",
+		zap.String("Invariant Condition", alert.SUUID.PID.InvType().String()),
+		zap.String("Network", alert.SUUID.PID.Network().String()),
+		zap.String("Session UUID", alert.SUUID.String()),
+		zap.String("Assessment Content", alert.Content))
+}
+
 // EventLoop ... Event loop for alert manager subsystem
 func (am *alertManager) EventLoop() error {
 	logger := logging.WithContext(am.ctx)
@@ -106,6 +132,11 @@ func (am *alertManager) EventLoop() error {
 					logger.Error("Could not post alert to slack", zap.Error(err))
 				}
 
+			case core.Log:
+				logger.Debug("Attempting to log alert to console")
+				am.handleLogPost(alert)
+				logger.Debug("Logging alert to console completed")
+
 			case core.ThirdParty:
 				logger.Error("Attempting to post alert to third_party which is not yet supported")
 

internal/core/constants.go

@@ -98,15 +98,18 @@ func StringToInvariantType(stringType string) InvariantType {
 type AlertDestination uint8
 
 const (
-	Slack      AlertDestination = iota + 1
-	ThirdParty                  // 2
+	Slack AlertDestination = iota + 1
+	Log
+	ThirdParty // 2
 )
 
 // String ... Converts an alerting destination type to a string
 func (ad AlertDestination) String() string {
 	switch ad {
 	case Slack:
 		return "slack"
+	case Log:
+		return "log"
 	case ThirdParty:
 		return "third_party"
 	default:
@@ -119,7 +122,8 @@ func StringToAlertingDestType(stringType string) AlertDestination {
 	switch stringType {
 	case "slack":
 		return Slack
-
+	case "log":
+		return Log
 	case "third_party":
 		return ThirdParty
 	}