compiler

type Compiler interface {
	// Parse parses source into an intermediate representation.
	Parse(source []byte) (IR, error)

	// ParseString is a convenience wrapper for string input.
	ParseString(source string) (IR, error)

	// Compile compiles an already-parsed IR into a Query.
	Compile(ir IR) (*Query, error)
}

type IR interface {
	IRKind() string
}

type Query struct {
	// Circuit is the DBSP circuit implementing the query.
	Circuit *circuit.Circuit

	// InputMap maps external input names/topics to circuit input node IDs.
	InputMap map[string]string

	// InputLogicalMap maps external input names/topics to internal logical names
	// used by the compiler inside expressions. If a name is missing, it is
	// treated as identity (external == logical).
	InputLogicalMap map[string]string

	// OutputMap maps external output names/topics to circuit output node IDs.
	OutputMap map[string]string

	// OutputLogicalMap maps external output names/topics to internal logical
	// output names. If a name is missing, it is treated as identity.
	OutputLogicalMap map[string]string
}