graph

type DependencyProvider map[string]Node

type Edge interface {
	ID() string
	From() string
	To() string
	Connect(from, to Node) error
}

type IO struct {
	Observable rxgo.Observable
	Cleanup    func()
}

type IOFunc func(ctx context.Context, input IO) (IO, error)

type Info struct {
	Method *grpc.MethodDescriptor
}

type Listener interface {
	GetNode() Node
	Transform(ctx context.Context, input *IO) (*IO, error)
}

type Node interface {
	ID() string
	Name() string
	NormalizedName() string
	// TODO breadchris type should probably just return a message descriptor
	Type() (*Info, error)

	Provide() ([]*gen.Node, error)

	// Provider returns the node that this node depends on. (eg. a grpc method node will return the service node)
	Provider() (Node, error)
	SetProvider(n Node) error

	// Dependents returns the nodes that depend on this node.
	Dependents() []Node
	AddDependent(n Node)

	// Wire up the node to an input stream of data and return an output stream of data
	Wire(ctx context.Context, input IO) (IO, error)

	// Subscribers returns the nodes that subscribe to this node.
	Subscribers() []Listener
	AddSubscriber(n Listener)

	// Publishers returns the nodes that this node subscribes to.
	Publishers() []Listener
	AddPublishers(n Listener)
}

type ProtoEdge interface {
	protoreflect.ProtoMessage
	GetId() string
	GetFrom() string
	GetTo() string
}

type ProtoGraph[T ProtoNode, U ProtoEdge] interface {
	SetNodes([]T)
	SetEdges([]U)
	GetNodes() []T
	GetEdges() []U
}

type ProtoNode interface {
	protoreflect.ProtoMessage
	GetId() string
}

type ProtoProject[T ProtoNode, U ProtoEdge] interface {
	GetId() string
	GetGraph() ProtoGraph[T, U]
}