ws

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

type HandlerStore interface {
	GetUserByAPIKey(ctx context.Context, apiKey string) (*identity.User, error)
	GetAgentByEmail(ctx context.Context, email string) (*identity.AgentIdentity, error)
	GetMessagesByAgent(ctx context.Context, agentID, status string, limit int, afterTime time.Time, afterID string) ([]identity.Message, error)
}

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

type Notification struct {
	MessageID      string    `json:"message_id"`
	ConversationID string    `json:"conversation_id,omitempty"`
	From           string    `json:"from"`
	To             string    `json:"to"`
	Subject        string    `json:"subject"`
	ReceivedAt     time.Time `json:"received_at"`
}