Function TestFlowWithoutTriggerNotRegistered

flow/registry_test.go:49–65

A flow without a trigger is not a running listener and isn't registered.

(t *testing.T)

// A flow without a trigger is not a running listener and isn't registered.
func TestFlowWithoutTriggerNotRegistered(t *testing.T) {
	reg := registry.NewMemoryRegistry()
	br := broker.NewMemoryBroker()
	_ = br.Connect()

	f := New("oneshot", Steps(appendStep("a")))
	if err := f.Register(reg, br, client.DefaultClient); err != nil {
		t.Fatalf("Register: %v", err)
	}
	if svcs, _ := reg.GetService("oneshot"); len(svcs) != 0 {
		t.Errorf("triggerless flow should not register, got %d", len(svcs))
	}
	// It still runs on demand.
	if err := f.Execute(context.Background(), ""); err != nil {
		t.Fatalf("Execute: %v", err)
	}
}