From ff280997b1904c8ae3ad94c82b693465e82ab519 Mon Sep 17 00:00:00 2001
From: Bel LaPointe <153096461+breel-render@users.noreply.github.com>
Date: Mon, 15 Apr 2024 16:23:41 -0600
Subject: [PATCH] main can run many pipelines

---
 main.go | 24 +++++++++++++++---------
 1 file changed, 15 insertions(+), 9 deletions(-)

diff --git a/main.go b/main.go
index 5cacef1..baff566 100644
--- a/main.go
+++ b/main.go
@@ -36,22 +36,28 @@ func run(ctx context.Context, cfg Config) error {
 	select {
 	case <-ctx.Done():
 		return ctx.Err()
-	case err := <-processSlackToMessagePipeline(ctx, cfg):
+	case err := <-processPipelines(ctx, cfg.slackToMessagePipeline):
 		return err
 	case err := <-listenAndServe(ctx, cfg):
 		return err
 	}
 }
 
-func processSlackToMessagePipeline(ctx context.Context, cfg Config) chan error {
+func processPipelines(ctx context.Context, first Pipeline, pipelines ...Pipeline) chan error {
+	ctx, can := context.WithCancel(ctx)
+	defer can()
+
+	pipelines = append(pipelines, first)
 	errs := make(chan error)
-	go func() {
-		defer close(errs)
-		select {
-		case errs <- cfg.slackToMessagePipeline.Process(ctx):
-		case <-ctx.Done():
-		}
-	}()
+	for i := range pipelines {
+		go func(i int) {
+			defer close(errs)
+			select {
+			case errs <- pipelines[i].Process(ctx):
+			case <-ctx.Done():
+			}
+		}(i)
+	}
 	return errs
 }