flow

type ClaudeExtractor struct {
	Timeout time.Duration
}

type Contact struct {
	Company string `json:"company,omitempty" jsonschema:"Company or organization"`
	Email   string `json:"email" jsonschema:"Email address"`
	Name    string `json:"name" jsonschema:"Full name"`
	Notes   string `json:"notes,omitempty" jsonschema:"Notes for the follow-up"`
}

type ContactInput struct {
	MessageID int64
	Prompt    string
	ThreadID  int64
}

type Deps struct {
	DBOS    dbos.DBOSContext
	Extract Extractor
	Log     *slog.Logger
	Publish func(threadID int64)
	Store   db.ThreadStore
	Tasks   db.TaskStore
}

type Extractor interface {
	Extract(ctx context.Context, message string) (Contact, error)
}

type ExtractorFunc func(ctx context.Context, message string) (Contact, error)

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