flowresult

type EventPublisher interface {
	PublishHTTPResponse(response mhttp.HTTPResponse, workspaceID idwrap.IDWrap)
	PublishHTTPResponseHeader(header mhttp.HTTPResponseHeader, workspaceID idwrap.IDWrap)
	PublishHTTPResponseAssert(assert mhttp.HTTPResponseAssert, workspaceID idwrap.IDWrap)

	PublishGraphQLResponse(response mgraphql.GraphQLResponse, workspaceID idwrap.IDWrap)
	PublishGraphQLResponseHeader(header mgraphql.GraphQLResponseHeader, workspaceID idwrap.IDWrap)
	PublishGraphQLResponseAssert(assert mgraphql.GraphQLResponseAssert, workspaceID idwrap.IDWrap)

	PublishExecution(eventType string, execution mflow.NodeExecution, flowID idwrap.IDWrap)
	PublishNodeState(flowID, originalNodeID idwrap.IDWrap, state mflow.NodeState, info string)
	PublishEdgeState(edge mflow.Edge)
	PublishLog(flowID idwrap.IDWrap, status runner.FlowNodeStatus)
}

type ExecutionStateTracker struct {
	// contains filtered or unexported fields
}

type ExecutionStateTrackerOpts struct {
	FlowID  idwrap.IDWrap
	BufSize int

	NodeKindMap      map[idwrap.IDWrap]mflow.NodeKind
	EdgesBySource    map[idwrap.IDWrap][]mflow.Edge
	InverseNodeIDMap map[string]idwrap.IDWrap

	Drain *ResponseDrain

	NodeExecutionService *sflow.NodeExecutionService
	NodeService          *sflow.NodeService
	EdgeService          *sflow.EdgeService

	Publisher EventPublisher
	Logger    *slog.Logger
}

type NoopResultProcessor struct {
	// contains filtered or unexported fields
}

type ResponseDrain struct {
	// contains filtered or unexported fields
}

type ResponseDrainOpts struct {
	WorkspaceID idwrap.IDWrap
	BufSize     int

	HTTPResponseService    shttp.HttpResponseService
	GraphQLResponseService sgraphql.GraphQLResponseService

	Publisher EventPublisher
	Logger    *slog.Logger
}

type ResultProcessor interface {
	// HTTPResponseChan returns the channel for HTTP response side-effects.
	// Pass this to the node builder so request nodes can send responses.
	HTTPResponseChan() chan nrequest.NodeRequestSideResp

	// GraphQLResponseChan returns the channel for GraphQL response side-effects.
	// Pass this to the node builder so GraphQL nodes can send responses.
	GraphQLResponseChan() chan ngraphql.NodeGraphQLSideResp

	// NodeStateChan returns the channel for node execution status events.
	// Pass this to the FlowRunner via FlowEventChannels.NodeStates.
	NodeStateChan() chan runner.FlowNodeStatus

	// Start begins the drain goroutines that process responses and status events.
	// Must be called before the flow runner starts.
	Start()

	// Wait blocks until all processing is complete.
	// The runner must have finished (closing NodeStateChan) before Wait returns.
	// Wait also closes the response channels and waits for their drains.
	Wait()
}

type ServerResultProcessor struct {
	// contains filtered or unexported fields
}

type ServerResultProcessorOpts struct {
	FlowID      idwrap.IDWrap
	WorkspaceID idwrap.IDWrap

	// Flow data — maps are built internally from these
	Nodes         []mflow.Node
	Edges         []mflow.Edge
	NodeIDMapping map[string]idwrap.IDWrap // original → versioned node ID mapping

	// Services for persistence
	HTTPResponseService    shttp.HttpResponseService
	GraphQLResponseService sgraphql.GraphQLResponseService
	NodeExecutionService   *sflow.NodeExecutionService
	NodeService            *sflow.NodeService
	EdgeService            *sflow.EdgeService

	// Event publishing
	Publisher EventPublisher
	Logger    *slog.Logger
}