diff options
Diffstat (limited to 'vendor/github.com/matterbridge/slack/channels.go')
-rw-r--r-- | vendor/github.com/matterbridge/slack/channels.go | 350 |
1 files changed, 0 insertions, 350 deletions
diff --git a/vendor/github.com/matterbridge/slack/channels.go b/vendor/github.com/matterbridge/slack/channels.go deleted file mode 100644 index 4a67b2fb..00000000 --- a/vendor/github.com/matterbridge/slack/channels.go +++ /dev/null @@ -1,350 +0,0 @@ -package slack - -import ( - "context" - "errors" - "net/url" - "strconv" -) - -type channelResponseFull struct { - Channel Channel `json:"channel"` - Channels []Channel `json:"channels"` - Purpose string `json:"purpose"` - Topic string `json:"topic"` - NotInChannel bool `json:"not_in_channel"` - History - SlackResponse -} - -// Channel contains information about the channel -type Channel struct { - groupConversation - IsChannel bool `json:"is_channel"` - IsGeneral bool `json:"is_general"` - IsMember bool `json:"is_member"` -} - -func channelRequest(ctx context.Context, path string, values url.Values, debug bool) (*channelResponseFull, error) { - response := &channelResponseFull{} - err := post(ctx, path, values, response, debug) - if err != nil { - return nil, err - } - if !response.Ok { - return nil, errors.New(response.Error) - } - return response, nil -} - -// ArchiveChannel archives the given channel -func (api *Client) ArchiveChannel(channel string) error { - return api.ArchiveChannelContext(context.Background(), channel) -} - -// ArchiveChannelContext archives the given channel with a custom context -func (api *Client) ArchiveChannelContext(ctx context.Context, channel string) error { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - } - _, err := channelRequest(ctx, "channels.archive", values, api.debug) - if err != nil { - return err - } - return nil -} - -// UnarchiveChannel unarchives the given channel -func (api *Client) UnarchiveChannel(channel string) error { - return api.UnarchiveChannelContext(context.Background(), channel) -} - -// UnarchiveChannelContext unarchives the given channel with a custom context -func (api *Client) UnarchiveChannelContext(ctx context.Context, channel string) error { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - } - _, err := channelRequest(ctx, "channels.unarchive", values, api.debug) - if err != nil { - return err - } - return nil -} - -// CreateChannel creates a channel with the given name and returns a *Channel -func (api *Client) CreateChannel(channel string) (*Channel, error) { - return api.CreateChannelContext(context.Background(), channel) -} - -// CreateChannelContext creates a channel with the given name and returns a *Channel with a custom context -func (api *Client) CreateChannelContext(ctx context.Context, channel string) (*Channel, error) { - values := url.Values{ - "token": {api.config.token}, - "name": {channel}, - } - response, err := channelRequest(ctx, "channels.create", values, api.debug) - if err != nil { - return nil, err - } - return &response.Channel, nil -} - -// GetChannelHistory retrieves the channel history -func (api *Client) GetChannelHistory(channel string, params HistoryParameters) (*History, error) { - return api.GetChannelHistoryContext(context.Background(), channel, params) -} - -// GetChannelHistoryContext retrieves the channel history with a custom context -func (api *Client) GetChannelHistoryContext(ctx context.Context, channel string, params HistoryParameters) (*History, error) { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - } - if params.Latest != DEFAULT_HISTORY_LATEST { - values.Add("latest", params.Latest) - } - if params.Oldest != DEFAULT_HISTORY_OLDEST { - values.Add("oldest", params.Oldest) - } - if params.Count != DEFAULT_HISTORY_COUNT { - values.Add("count", strconv.Itoa(params.Count)) - } - if params.Inclusive != DEFAULT_HISTORY_INCLUSIVE { - if params.Inclusive { - values.Add("inclusive", "1") - } else { - values.Add("inclusive", "0") - } - } - if params.Unreads != DEFAULT_HISTORY_UNREADS { - if params.Unreads { - values.Add("unreads", "1") - } else { - values.Add("unreads", "0") - } - } - response, err := channelRequest(ctx, "channels.history", values, api.debug) - if err != nil { - return nil, err - } - return &response.History, nil -} - -// GetChannelInfo retrieves the given channel -func (api *Client) GetChannelInfo(channel string) (*Channel, error) { - return api.GetChannelInfoContext(context.Background(), channel) -} - -// GetChannelInfoContext retrieves the given channel with a custom context -func (api *Client) GetChannelInfoContext(ctx context.Context, channel string) (*Channel, error) { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - } - response, err := channelRequest(ctx, "channels.info", values, api.debug) - if err != nil { - return nil, err - } - return &response.Channel, nil -} - -// InviteUserToChannel invites a user to a given channel and returns a *Channel -func (api *Client) InviteUserToChannel(channel, user string) (*Channel, error) { - return api.InviteUserToChannelContext(context.Background(), channel, user) -} - -// InviteUserToChannelCustom invites a user to a given channel and returns a *Channel with a custom context -func (api *Client) InviteUserToChannelContext(ctx context.Context, channel, user string) (*Channel, error) { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - "user": {user}, - } - response, err := channelRequest(ctx, "channels.invite", values, api.debug) - if err != nil { - return nil, err - } - return &response.Channel, nil -} - -// JoinChannel joins the currently authenticated user to a channel -func (api *Client) JoinChannel(channel string) (*Channel, error) { - return api.JoinChannelContext(context.Background(), channel) -} - -// JoinChannelContext joins the currently authenticated user to a channel with a custom context -func (api *Client) JoinChannelContext(ctx context.Context, channel string) (*Channel, error) { - values := url.Values{ - "token": {api.config.token}, - "name": {channel}, - } - response, err := channelRequest(ctx, "channels.join", values, api.debug) - if err != nil { - return nil, err - } - return &response.Channel, nil -} - -// LeaveChannel makes the authenticated user leave the given channel -func (api *Client) LeaveChannel(channel string) (bool, error) { - return api.LeaveChannelContext(context.Background(), channel) -} - -// LeaveChannelContext makes the authenticated user leave the given channel with a custom context -func (api *Client) LeaveChannelContext(ctx context.Context, channel string) (bool, error) { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - } - response, err := channelRequest(ctx, "channels.leave", values, api.debug) - if err != nil { - return false, err - } - if response.NotInChannel { - return response.NotInChannel, nil - } - return false, nil -} - -// KickUserFromChannel kicks a user from a given channel -func (api *Client) KickUserFromChannel(channel, user string) error { - return api.KickUserFromChannelContext(context.Background(), channel, user) -} - -// KickUserFromChannelContext kicks a user from a given channel with a custom context -func (api *Client) KickUserFromChannelContext(ctx context.Context, channel, user string) error { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - "user": {user}, - } - _, err := channelRequest(ctx, "channels.kick", values, api.debug) - if err != nil { - return err - } - return nil -} - -// GetChannels retrieves all the channels -func (api *Client) GetChannels(excludeArchived bool) ([]Channel, error) { - return api.GetChannelsContext(context.Background(), excludeArchived) -} - -// GetChannelsContext retrieves all the channels with a custom context -func (api *Client) GetChannelsContext(ctx context.Context, excludeArchived bool) ([]Channel, error) { - values := url.Values{ - "token": {api.config.token}, - } - if excludeArchived { - values.Add("exclude_archived", "1") - } - response, err := channelRequest(ctx, "channels.list", values, api.debug) - if err != nil { - return nil, err - } - return response.Channels, nil -} - -// SetChannelReadMark sets the read mark of a given channel to a specific point -// Clients should try to avoid making this call too often. When needing to mark a read position, a client should set a -// timer before making the call. In this way, any further updates needed during the timeout will not generate extra calls -// (just one per channel). This is useful for when reading scroll-back history, or following a busy live channel. A -// timeout of 5 seconds is a good starting point. Be sure to flush these calls on shutdown/logout. -func (api *Client) SetChannelReadMark(channel, ts string) error { - return api.SetChannelReadMarkContext(context.Background(), channel, ts) -} - -// SetChannelReadMarkContext sets the read mark of a given channel to a specific point with a custom context -// For more details see SetChannelReadMark documentation -func (api *Client) SetChannelReadMarkContext(ctx context.Context, channel, ts string) error { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - "ts": {ts}, - } - _, err := channelRequest(ctx, "channels.mark", values, api.debug) - if err != nil { - return err - } - return nil -} - -// RenameChannel renames a given channel -func (api *Client) RenameChannel(channel, name string) (*Channel, error) { - return api.RenameChannelContext(context.Background(), channel, name) -} - -// RenameChannelContext renames a given channel with a custom context -func (api *Client) RenameChannelContext(ctx context.Context, channel, name string) (*Channel, error) { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - "name": {name}, - } - // XXX: the created entry in this call returns a string instead of a number - // so I may have to do some workaround to solve it. - response, err := channelRequest(ctx, "channels.rename", values, api.debug) - if err != nil { - return nil, err - } - return &response.Channel, nil -} - -// SetChannelPurpose sets the channel purpose and returns the purpose that was successfully set -func (api *Client) SetChannelPurpose(channel, purpose string) (string, error) { - return api.SetChannelPurposeContext(context.Background(), channel, purpose) -} - -// SetChannelPurposeContext sets the channel purpose and returns the purpose that was successfully set with a custom context -func (api *Client) SetChannelPurposeContext(ctx context.Context, channel, purpose string) (string, error) { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - "purpose": {purpose}, - } - response, err := channelRequest(ctx, "channels.setPurpose", values, api.debug) - if err != nil { - return "", err - } - return response.Purpose, nil -} - -// SetChannelTopic sets the channel topic and returns the topic that was successfully set -func (api *Client) SetChannelTopic(channel, topic string) (string, error) { - return api.SetChannelTopicContext(context.Background(), channel, topic) -} - -// SetChannelTopicContext sets the channel topic and returns the topic that was successfully set with a custom context -func (api *Client) SetChannelTopicContext(ctx context.Context, channel, topic string) (string, error) { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - "topic": {topic}, - } - response, err := channelRequest(ctx, "channels.setTopic", values, api.debug) - if err != nil { - return "", err - } - return response.Topic, nil -} - -// GetChannelReplies gets an entire thread (a message plus all the messages in reply to it). -func (api *Client) GetChannelReplies(channel, thread_ts string) ([]Message, error) { - return api.GetChannelRepliesContext(context.Background(), channel, thread_ts) -} - -// GetChannelRepliesContext gets an entire thread (a message plus all the messages in reply to it) with a custom context -func (api *Client) GetChannelRepliesContext(ctx context.Context, channel, thread_ts string) ([]Message, error) { - values := url.Values{ - "token": {api.config.token}, - "channel": {channel}, - "thread_ts": {thread_ts}, - } - response, err := channelRequest(ctx, "channels.replies", values, api.debug) - if err != nil { - return nil, err - } - return response.History.Messages, nil -} |