hookbot

Nov 16, 2020

Changes in this version

+ var TopicRE *regexp.Regexp = regexp.MustCompile("^(?:/unsafe)?/(?:pub|sub)/(.*)$")

+ var UnsafeURI = regexp.MustCompile("^/unsafe/(pub|sub)/.*")

+ func ConfigureRouters(c *cli.Context, h *Hookbot)

+ func IsConnectionClose(err error) bool

+ func IsUnsafeRequest(r *http.Request) bool

+ func RegisterRouter(router Router)

+ func RequireUnsafeHeader(wrapped http.Handler) http.HandlerFunc

+ func SecureEqual(x, y string) bool

+ func Sha1HMAC(key, payload string) string

+ func Topic(r *http.Request) string

+ type Hookbot struct

+ func New(key string) *Hookbot

+ func (h *Hookbot) Add(topic string) Listener

+ func (h *Hookbot) AddRouter(r Router)

+ func (h *Hookbot) BothPubSub(pub, sub http.Handler) http.Handler

+ func (h *Hookbot) Del(l Listener)

+ func (h *Hookbot) IsKeyOK(w http.ResponseWriter, r *http.Request) bool

+ func (h *Hookbot) KeyChecker(wrapped http.Handler) http.HandlerFunc

+ func (h *Hookbot) Loop()

+ func (h *Hookbot) Publish(m Message) bool

+ func (h *Hookbot) ServePublish(w http.ResponseWriter, r *http.Request)

+ func (h *Hookbot) ServeSubscribe(conn *websocket.Conn, r *http.Request)

+ func (h *Hookbot) ShowStatus(period time.Duration)

+ func (h *Hookbot) Shutdown()

+ func (h *Hookbot) TimeoutSendWorker(r chan MessageListener)

+ type Listener struct

+ Topic string

+ type Message struct

+ Body []byte

+ Sent chan bool

+ Topic string

+ type MessageListener struct

+ type MessageListeners struct

+ type Router interface

+ Name func() string

+ Route func(in Message, publish func(Message) bool)

+ Topics func() []string

+ type WebsocketHandlerFunc func(*websocket.Conn, *http.Request)

+ func (wrapped WebsocketHandlerFunc) ServeHTTP(w http.ResponseWriter, r *http.Request)