diff options
author | Wim <wim@42.be> | 2020-03-01 20:59:19 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-03-01 20:59:19 +0100 |
commit | 250b3bb5795240d5ebdab5416ab99dbc41be734b (patch) | |
tree | 11e44ec2e7e37cd7eb0deaf0a7843fe6bf3c0e40 /vendor/github.com/nlopes/slack/websocket.go | |
parent | e9edbfc051afc643d91fc04bc7fb3fe70039c213 (diff) | |
download | matterbridge-msglm-250b3bb5795240d5ebdab5416ab99dbc41be734b.tar.gz matterbridge-msglm-250b3bb5795240d5ebdab5416ab99dbc41be734b.tar.bz2 matterbridge-msglm-250b3bb5795240d5ebdab5416ab99dbc41be734b.zip |
Use upstream slack-go/slack again (#1018)
Diffstat (limited to 'vendor/github.com/nlopes/slack/websocket.go')
-rw-r--r-- | vendor/github.com/nlopes/slack/websocket.go | 103 |
1 files changed, 0 insertions, 103 deletions
diff --git a/vendor/github.com/nlopes/slack/websocket.go b/vendor/github.com/nlopes/slack/websocket.go deleted file mode 100644 index d6895f2a..00000000 --- a/vendor/github.com/nlopes/slack/websocket.go +++ /dev/null @@ -1,103 +0,0 @@ -package slack - -import ( - "net/url" - "sync" - "time" - - "github.com/gorilla/websocket" -) - -const ( - // MaxMessageTextLength is the current maximum message length in number of characters as defined here - // https://api.slack.com/rtm#limits - MaxMessageTextLength = 4000 -) - -// RTM represents a managed websocket connection. It also supports -// all the methods of the `Client` type. -// -// Create this element with Client's NewRTM() or NewRTMWithOptions(*RTMOptions) -type RTM struct { - // Client is the main API, embedded - Client - - idGen IDGenerator - pingInterval time.Duration - pingDeadman *time.Timer - - // Connection life-cycle - conn *websocket.Conn - IncomingEvents chan RTMEvent - outgoingMessages chan OutgoingMessage - killChannel chan bool - disconnected chan struct{} - disconnectedm *sync.Once - forcePing chan bool - - // UserDetails upon connection - info *Info - - // useRTMStart should be set to true if you want to use - // rtm.start to connect to Slack, otherwise it will use - // rtm.connect - useRTMStart bool - - // dialer is a gorilla/websocket Dialer. If nil, use the default - // Dialer. - dialer *websocket.Dialer - - // mu is mutex used to prevent RTM connection race conditions - mu *sync.Mutex - - // connParams is a map of flags for connection parameters. - connParams url.Values -} - -// signal that we are disconnected by closing the channel. -// protect it with a mutex to ensure it only happens once. -func (rtm *RTM) disconnect() { - rtm.disconnectedm.Do(func() { - close(rtm.disconnected) - }) -} - -// Disconnect and wait, blocking until a successful disconnection. -func (rtm *RTM) Disconnect() error { - // always push into the kill channel when invoked, - // this lets the ManagedConnection() function properly clean up. - // if the buffer is full then just continue on. - select { - case rtm.killChannel <- true: - return nil - case <-rtm.disconnected: - return ErrAlreadyDisconnected - } -} - -// GetInfo returns the info structure received when calling -// "startrtm", holding metadata needed to implement a full -// chat client. It will be non-nil after a call to StartRTM(). -func (rtm *RTM) GetInfo() *Info { - return rtm.info -} - -// SendMessage submits a simple message through the websocket. For -// more complicated messages, use `rtm.PostMessage` with a complete -// struct describing your attachments and all. -func (rtm *RTM) SendMessage(msg *OutgoingMessage) { - if msg == nil { - rtm.Debugln("Error: Attempted to SendMessage(nil)") - return - } - - rtm.outgoingMessages <- *msg -} - -func (rtm *RTM) resetDeadman() { - rtm.pingDeadman.Reset(deadmanDuration(rtm.pingInterval)) -} - -func deadmanDuration(d time.Duration) time.Duration { - return d * 4 -} |