store

type NoteListOptions struct {
	Type     string
	FlowIDs  []string
	Contains string
	AfterID  string
	Limit    int
}

type NoteMeta struct {
	NoteID    string    `msgpack:"nid"`
	Type      string    `msgpack:"t"`
	FlowIDs   []string  `msgpack:"fids"`
	Content   string    `msgpack:"c"`
	CreatedAt time.Time `msgpack:"ca"`
	UpdatedAt time.Time `msgpack:"ua"`
}

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

type Provider func(name string) (Storage, error)

type ReplayHistoryEntry struct {
	FlowID    string
	CreatedAt time.Time // When replay was executed

	// Request data (for display and export)
	RawRequest      []byte // pre-rule request (base for replay)
	ModifiedRequest []byte // post-rule request (what was sent); nil if no rules applied
	Method          string
	Host            string
	Path            string
	Scheme          string // "http" or "https"
	Port            int    // original port (0 = infer from scheme)
	Protocol        string // "http/1.1" or "h2"

	// Response data
	RespHeaders []byte
	RespBody    []byte
	RespStatus  int
	Duration    time.Duration

	// Lineage
	SourceFlowID string // Original flow_id that was replayed (empty for request_send)
}

type ReplayHistoryMeta struct {
	FlowID       string        `msgpack:"fid"`
	Method       string        `msgpack:"m"`
	Host         string        `msgpack:"h"`
	Path         string        `msgpack:"p"`
	Scheme       string        `msgpack:"sc,omitempty"` // "http" or "https"
	Port         int           `msgpack:"po,omitempty"` // original port (0 = infer from scheme)
	Protocol     string        `msgpack:"pr"`
	SourceFlowID string        `msgpack:"sf"`
	CreatedAt    time.Time     `msgpack:"ca"`
	RespStatus   int           `msgpack:"rs"`
	RespLen      int           `msgpack:"rl"`
	Duration     time.Duration `msgpack:"d"`
}

type ReplayHistoryPayload struct {
	RawRequest      []byte `msgpack:"rq"`
	ModifiedRequest []byte `msgpack:"mq,omitempty"` // post-rule request; nil if no rules applied
	RespHeaders     []byte `msgpack:"rh"`
	RespBody        []byte `msgpack:"rb"`
}

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

type SpillStoreConfig struct {
	Dir                 string  // optional, auto-created if empty
	FilePrefix          string  // optional prefix for data file name (e.g. "hist" -> "hist.spill.bin")
	MaxHotBytes         int64   // max value bytes in hot cache
	EvictTargetRatio    float64 // evict to this ratio, higher values evict less
	CompactionThreshold int64   // rewrite file when dead bytes exceed this
	ZSTDLevel           int     // compression level (1-21)
}

type Storage interface {
	Set(key string, blob []byte) error
	Get(key string) ([]byte, bool, error)
	KeySet() []string
	Size() int
	Delete(key string) error
	DeleteAll() error
	Close() error
}