🐛 Add missing arg to start consume process

.github/workflows/ci.yml

@@ -16,4 +16,4 @@ jobs:
       - name: Install dependencies
         run: go get .
       - name: Test with Go
-        run: go test
+        run: go test ./...

internal/event/grouped-listeners.json → internal/event/console.sh

@@ -1,3 +1,5 @@
+#!/bin/bash
+json=$(cat << EOF
 {
     "event1": [
         {
@@ -11,4 +13,8 @@
             "type": "async"
         }
     ]
-}
+}
+EOF
+)
+
+echo $json

internal/event/event.go

@@ -48,9 +48,9 @@ func (listenerReader *ListenerReader) GetAll() []Listener {
 	return ungroupedListeners
 }
 
-func NewListenerReader(command string) ListenerReaderInterface {
+func NewListenerReader(pathToConsoleApp string) ListenerReaderInterface {
 	return &ListenerReader{
-		command: command,
+		command: fmt.Sprintf("%s event:listener:get async", pathToConsoleApp),
 	}
 }
 
@@ -60,14 +60,14 @@ type ListenerConverterInterface interface {
 }
 
 type ListenerConverter struct {
-	command string
+	pathToConsoleApp string
 }
 
 func (listenerConverter *ListenerConverter) ConvertToProcess(listener Listener) process.ProcessInterface {
 	return process.NewProcess(
 		fmt.Sprintf(
-			"%s %s %s",
-			listenerConverter.command,
+			"%s event:queue:consume %s %s",
+			listenerConverter.pathToConsoleApp,
 			listener.EventName,
 			listener.Identifier,
 		),
@@ -84,8 +84,8 @@ func (listenerConverter *ListenerConverter) ConvertMultipleToProcesses(listeners
 	return processes
 }
 
-func NewListenerConverter(command string) ListenerConverterInterface {
+func NewListenerConverter(pathToConsoleApp string) ListenerConverterInterface {
 	return &ListenerConverter{
-		command: command,
+		pathToConsoleApp: pathToConsoleApp,
 	}
 }

internal/event/event_test.go

@@ -6,7 +6,7 @@ import (
 )
 
 func TestGetAll(t *testing.T) {
-	listenerReader := NewListenerReader("cat ./grouped-listeners.json")
+	listenerReader := NewListenerReader("./console.sh")
 	listeners := listenerReader.GetAll()
 
 	if len(listeners) != 2 {

main.go

@@ -21,11 +21,11 @@ func main() {
 		jellyfishApplicationDir = os.Args[1]
 	}
 
-	consoleCommand := fmt.Sprintf("%s/vendor/bin/console", strings.TrimRight(jellyfishApplicationDir, "/"))
+	pathToConsoleApp := fmt.Sprintf("%s/vendor/bin/console", strings.TrimRight(jellyfishApplicationDir, "/"))
 
-	listenerReader := event.NewListenerReader(consoleCommand)
+	listenerReader := event.NewListenerReader(pathToConsoleApp)
 	listeners := listenerReader.GetAll()
-	listenerConverter := event.NewListenerConverter(consoleCommand)
+	listenerConverter := event.NewListenerConverter(pathToConsoleApp)
 	processes := listenerConverter.ConvertMultipleToProcesses(listeners)
 	eventQueueWorker := worker.NewEventQueueWorker(processes)