Quickstart: Go

package main

import (
	"context"
	"fmt"
	"log"
	"os"
	"os/signal"
	"time"

	workflows "github.com/ezgamehost/workflows-sdk-go"
)

type Input struct {
	Name string `json:"name"`
}

type Output struct {
	Greeting string    `json:"greeting"`
	At       time.Time `json:"at"`
}

var hello = workflows.New("hello", func(ctx workflows.Context, in Input) (Output, error) {
	greeting, err := workflows.Run(ctx, "greet", func(sc workflows.StepContext) (string, error) {
		return "Hello, " + in.Name + "!", nil
	})
	if err != nil {
		return Output{}, err
	}
	if err := workflows.Sleep(ctx, "pause", 5*time.Second); err != nil {
		return Output{}, err
	}
	at, err := workflows.Now(ctx, "finished-at")
	if err != nil {
		return Output{}, err
	}
	return Output{Greeting: greeting, At: at}, nil
})

func main() {
	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
	defer stop()
	if len(os.Args) > 1 && os.Args[1] == "start" {
		start(ctx)
		return
	}
	w, err := workflows.NewWorker(workflows.WorkerOptions{
		APIKey:         os.Getenv("EZGH_API_KEY"),
		OrganizationID: os.Getenv("EZGH_ORG_ID"),
		ProjectID:      os.Getenv("EZGH_PROJECT_ID"),
		App:            os.Getenv("EZGH_APP_ID"),
		Workflows:      []workflows.Workflow{hello},
	})
	if err != nil {
		log.Fatal(err)
	}
	log.Print("Worker polling. Press Ctrl+C to stop.")
	if err := w.Run(ctx); err != nil {
		log.Fatal(err)
	}
}

func start(ctx context.Context) {
	c, err := workflows.NewClient(workflows.ClientOptions{
		APIKey:         os.Getenv("EZGH_API_KEY"),
		OrganizationID: os.Getenv("EZGH_ORG_ID"),
		ProjectID:      os.Getenv("EZGH_PROJECT_ID"),
	})
	if err != nil {
		log.Fatal(err)
	}
	run, err := c.Start(ctx, os.Getenv("EZGH_APP_ID"), "hello", Input{Name: "Ada"}, workflows.StartOptions{})
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("Started run", run.ID)
	for !run.Terminal() {
		time.Sleep(time.Second)
		if run, err = c.Get(ctx, run.ID); err != nil {
			log.Fatal(err)
		}
	}
	var out Output
	if run.Status == workflows.RunStatusCompleted {
		if err := c.Output(ctx, run.ID, &out); err != nil {
			log.Fatal(err)
		}
	}
	fmt.Println(run.Status, out.Greeting, out.At)
}