messaging

type HookFactory func(params map[string]string, stateManager flow.StateManager, msgService Service, timer models.Timer) (ResponseAction, error)

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

type ResponseAction func(ctx context.Context, from, responseText string, timestamp int64) (handled bool, err error)

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

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

type Service interface {
	// ValidateAndCanonicalizeRecipient validates and canonicalizes a recipient identifier.
	// Returns the canonicalized recipient and an error if validation fails.
	// This allows each service to implement its own recipient validation rules.
	ValidateAndCanonicalizeRecipient(recipient string) (string, error)

	// SendMessage sends a message to a recipient.
	SendMessage(ctx context.Context, to string, body string) error

	// SendTypingIndicator updates the recipient's chat presence to show or hide a typing indicator.
	// Implementations should treat this as best-effort and not fail hard if the provider doesn't support it.
	SendTypingIndicator(ctx context.Context, to string, typing bool) error

	// Start begins any background processing (e.g., polling for events).
	Start(ctx context.Context) error

	// Stop stops background processing and cleans up resources.
	Stop() error

	// Receipts returns a channel of receipt events (sent, delivered, read).
	Receipts() <-chan models.Receipt

	// Responses returns a channel of incoming participant responses.
	Responses() <-chan models.Response
}

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