inbox

type Attachment struct {
	Type    string // "file", "skill", "raw"
	Ref     string // e.g. "@/tmp/targets.txt", "@scan"
	Content string
	Error   string
}

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

type Expander struct {
	ReadFile    func(path string) (string, error)
	LookupSkill func(name string) (string, bool)
	MaxFileSize int
}

type Inbox interface {
	Push(msg Message) error
	Drain() []Message
	Close()
	Closed() bool
	Len() int
	Wait(ctx context.Context) bool
	RegisterProducer(name string) *ProducerHandle
	ActiveProducers() int
}

type Message struct {
	Message     *aop.Message
	Origin      Origin
	Priority    Priority
	Attachments []Attachment
	Meta        map[string]any
	CreatedAt   time.Time
}

type Origin string

type Priority int

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