atmt

Documentation

Index

• Variables
• func BadRequest(resp *Message)
• func Error(resp *Message, code StatusCode)
• func InternalServerError(resp *Message)
• func Push(url string, msg Message) (err error)
• func PushCtx(ctx context.Context, url string, msg Message) (err error)
• func StartSrv(srv *Server)
• func StopSrv(srv *Server)
• type Content
  • func FormatContent(v ...any) (content Content)
  • func (c *Content) Plaintext() string
  • func (c Content) String() string
• type DataPush
• type DataRequest
• type DataRequestBuilder
• type DataResponse
• type DataResponseBuilder
• type Handler
  • func MultiHandler(handlers []Handler) Handler
• type HandlerFunc
  • func (h HandlerFunc) ServeMessage(resp *Message, post Message)
• type Matcher
• type Message
  • func SendMessage(url string, msg Message) (resp Message, err error)
  • func SendMessageCtx(ctx context.Context, url string, msg Message) (resp Message, err error)
• type MessageBuilder
  • func (b *MessageBuilder[Data]) Message() (msg Message, err error)
  • func (b *MessageBuilder[Data]) Write(w *Message) (err error)
• type MessageID
• type MessageType
  • func (typ MessageType) String() (str string)
• type Paragraph
  • func Image(name, ref string) Paragraph
  • func Record(name, ref string) Paragraph
  • func Text(txt string) Paragraph
  • func Video(name, ref string) Paragraph
• type ParagraphType
• type PostError
• type ServeMux
  • func NewServeMux() *ServeMux
  • func (mux *ServeMux) Handle(m Matcher, h Handler)
  • func (mux *ServeMux) Handler(msg Message) (m Matcher, h Handler)
  • func (mux *ServeMux) Matcher() Matcher
  • func (mux *ServeMux) ServeMessage(resp *Message, post Message)
• type Server
  • func (srv *Server) ListenAndServe() (err error)
  • func (srv *Server) Shutdown(ctx context.Context) (err error)
• type StatusCode
  • func (c StatusCode) String() string
  • func (c StatusCode) Text() string

Variables

var DefaultServeMux = NewServeMux()

Functions

func BadRequest

func BadRequest(resp *Message)

func Error

func Error(resp *Message, code StatusCode)

func InternalServerError

func InternalServerError(resp *Message)

func Push

func Push(url string, msg Message) (err error)

func PushCtx

func PushCtx(ctx context.Context, url string, msg Message) (err error)

func StartSrv

func StartSrv(srv *Server)

func StopSrv

func StopSrv(srv *Server)

Types

type Content

type Content []Paragraph

func FormatContent

func FormatContent(v ...any) (content Content)

func (*Content) Plaintext

func (c *Content) Plaintext() string

func (Content) String

func (c Content) String() string

type DataPush

type DataPush struct {
	MessageID MessageID `json:"message_id"`
	Sender    string    `json:"sender"`
}

type DataRequest

type DataRequest[Action ~uint8] struct {
	Action Action          `json:"action"`
	Args   json.RawMessage `json:"args"`
}

type DataRequestBuilder

type DataRequestBuilder[Action ~uint8, Args any] struct {
	Action Action `json:"action"`
	Args   Args   `json:"args"`
}

type DataResponse

type DataResponse struct {
	StatusCode StatusCode      `json:"status_code"`
	Values     json.RawMessage `json:"values"`
}

type DataResponseBuilder

type DataResponseBuilder[Values any] struct {
	StatusCode StatusCode `json:"status_code"`
	Values     Values     `json:"values"`
}

type Handler

type Handler interface {
	ServeMessage(resp *Message, post Message)
}

func MultiHandler

func MultiHandler(handlers []Handler) Handler

type HandlerFunc

type HandlerFunc func(*Message, Message)

func (HandlerFunc) ServeMessage

func (h HandlerFunc) ServeMessage(resp *Message, post Message)

type Matcher

type Matcher struct {
	Match     func(msg Message) bool
	Priority  int
	Temporary bool
}

type Message

type Message struct {
	Type    MessageType     `json:"type"`
	Data    json.RawMessage `json:"data"`
	Content Content         `json:"content"`
}

func SendMessage

func SendMessage(url string, msg Message) (resp Message, err error)

func SendMessageCtx

func SendMessageCtx(ctx context.Context, url string, msg Message) (resp Message, err error)

type MessageBuilder

type MessageBuilder[Data any] struct {
	Type    MessageType `json:"type"`
	Data    Data        `json:"data"`
	Content []Paragraph `json:"content"`
}

func (*MessageBuilder[Data]) Message

func (b *MessageBuilder[Data]) Message() (msg Message, err error)

func (*MessageBuilder[Data]) Write

func (b *MessageBuilder[Data]) Write(w *Message) (err error)

type MessageID

type MessageID = primitive.ObjectID

type MessageType

type MessageType uint8

const (
	MessagePush MessageType = iota + 1
	MessageRequest
	MessageResponse
)

func (MessageType) String

func (typ MessageType) String() (str string)

type Paragraph

type Paragraph struct {
	Type ParagraphType `json:"type" bson:"type,omitempty"`
	Text string        `json:"text" bson:"text,omitempty"`
	Name string        `json:"name" bson:"name,omitempty"`
	Ref  string        `json:"ref" bson:"ref,omitempty"`
}

func Image

func Image(name, ref string) Paragraph

func Record

func Record(name, ref string) Paragraph

func Text

func Text(txt string) Paragraph

func Video

func Video(name, ref string) Paragraph

type ParagraphType

type ParagraphType uint8

const (
	ParagraphText ParagraphType = iota + 1
	ParagraphImage
	ParagraphRecord
	ParagraphVideo
)

type PostError

type PostError interface {
	error
	StatusCode() StatusCode
}

type ServeMux

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

func NewServeMux

func NewServeMux() *ServeMux

func (*ServeMux) Handle

func (mux *ServeMux) Handle(m Matcher, h Handler)

func (*ServeMux) Handler

func (mux *ServeMux) Handler(msg Message) (m Matcher, h Handler)

func (*ServeMux) Matcher

func (mux *ServeMux) Matcher() Matcher

func (*ServeMux) ServeMessage

func (mux *ServeMux) ServeMessage(resp *Message, post Message)

type Server

type Server struct {
	Addr    string
	Handler Handler
	// contains filtered or unexported fields
}

func (*Server) ListenAndServe

func (srv *Server) ListenAndServe() (err error)

func (*Server) Shutdown

func (srv *Server) Shutdown(ctx context.Context) (err error)

type StatusCode

type StatusCode uint8

const (
	StatusOK StatusCode = iota + 1
	StatusBadRequest
	StatusUnauthorized
	StatusInternalServerError
)

func (StatusCode) String

func (c StatusCode) String() string

func (StatusCode) Text

func (c StatusCode) Text() string