babashka-pod-docker/main.go

package main

import (
	"babashka-pod-docker/babashka"
	"babashka-pod-docker/docker"

	"github.com/atomist-skills/go-skill"
	"github.com/sirupsen/logrus"
)

func main() {
	skill.Log.SetLevel(logrus.ErrorLevel)
	for {
		message, err := babashka.ReadMessage()
		if err != nil {
			babashka.WriteErrorResponse(message, err)
			continue
		}

		res, err := docker.ProcessMessage(message)
		if err != nil {
			babashka.WriteErrorResponse(message, err)
			continue
		}

		describeres, ok := res.(*babashka.DescribeResponse)
		if ok {
			babashka.WriteDescribeResponse(describeres)
			continue
		}

		if res != "running" {
			babashka.WriteInvokeResponse(message, res)
		}
	}
}