flowtest

type Assert struct {
	Path  string `json:"path"`
	Op    string `json:"op"`
	Value string `json:"value,omitempty"`
}

type Emit func(event string, payload any)

type Expect struct {
	Status  int      `json:"status"`
	Asserts []Assert `json:"asserts,omitempty"`
}

type Flow struct {
	Name        string `json:"name"`
	Description string `json:"description,omitempty"`
	// Role, when set, pre-mints a tenant JWT for that RBAC role into {{token}}
	// before step 1 (the convenience path). A flow that wants to exercise the
	// REAL login instead makes step 1 a POST /auth/login and captures
	// {{token}} from the response — a capture overwrites the pre-minted var.
	Role  string `json:"role,omitempty"`
	Steps []Step `json:"steps"`
}

type FlowResult struct {
	Name       string       `json:"name"`
	Pass       bool         `json:"pass"`
	Steps      []StepResult `json:"steps"`
	StepsTotal int          `json:"steps_total"`
	StepsFail  int          `json:"steps_failed"`
	DurationMS int64        `json:"duration_ms"`
}

type Run struct {
	ID            int64           `json:"id"`
	TenantID      string          `json:"tenant_id"`
	SchemaVersion int             `json:"schema_version"`
	Scope         string          `json:"scope"` // "suite" or the flow name
	Pass          bool            `json:"pass"`
	FlowsTotal    int             `json:"flows_total"`
	FlowsFailed   int             `json:"flows_failed"`
	StepsTotal    int             `json:"steps_total"`
	StepsFailed   int             `json:"steps_failed"`
	Results       json.RawMessage `json:"results,omitempty"` // []FlowResult
	CreatedAt     time.Time       `json:"created_at"`
}

type Runner struct {
	// Handler is the live data-plane router (App.currentRouter).
	Handler http.Handler
	// JWTSecret mints the flow-level Role token — the SAME tenant-JWT contract
	// the engine validates (never a super-admin credential).
	JWTSecret string
	// HostSuffix builds the request Host (<tenant><HostSuffix>) the tenant
	// middleware resolves. Default ".flows.internal".
	HostSuffix string
}

type Step struct {
	Name    string            `json:"name"`
	Method  string            `json:"method"`
	Path    string            `json:"path"` // e.g. /api/citas or /auth/login
	Body    string            `json:"body,omitempty"`
	Headers map[string]string `json:"headers,omitempty"`
	// Upload, when set, sends a multipart file (POST /api/files) instead of Body.
	Upload *Upload `json:"upload,omitempty"`
	Expect Expect  `json:"expect"`
	// Capture maps {{variable}} names to dot-paths into the response JSON
	// (e.g. "cita_id": "id", "token": "token", "first": "data.0.id").
	Capture map[string]string `json:"capture,omitempty"`
}

type StepResult struct {
	Index      int               `json:"index"`
	Name       string            `json:"name"`
	Method     string            `json:"method"`
	Path       string            `json:"path"` // after variable substitution
	Skipped    bool              `json:"skipped,omitempty"`
	Pass       bool              `json:"pass"`
	Status     int               `json:"status"`
	Expected   int               `json:"expected"`
	Failures   []string          `json:"failures,omitempty"`
	BodySample string            `json:"body_sample,omitempty"` // the response body (capped ~2 KB) — every step, pass or fail
	Captured   map[string]string `json:"captured,omitempty"`
	DurationMS int64             `json:"duration_ms"`
}

type StoredFlow struct {
	ID        string    `json:"id"`
	TenantID  string    `json:"tenant_id"`
	Name      string    `json:"name"`
	Steps     int       `json:"steps"`
	Flow      *Flow     `json:"flow,omitempty"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type Upload struct {
	Field    string `json:"field,omitempty"` // form field; default "file"
	Filename string `json:"filename"`
	Content  string `json:"content"` // inline text content (e.g. "%PDF-1.4 ...")
}