8cd72b46a3
* INFRA-2887 : Upsert users cron refactor * INFRA-2887 : Review changes * INFRA-2887 : added UT's * INFRA-2887 : Second round review changes * INFRA-2887 : Add default ack * INFRA-2887 : Add default ack * INFRA-2887 : make flow async
142 lines
4.1 KiB
Go
142 lines
4.1 KiB
Go
package socketModeClient
|
|
|
|
import (
|
|
"github.com/slack-go/slack"
|
|
"github.com/slack-go/slack/socketmode"
|
|
)
|
|
|
|
type SocketModeClientWrapper struct {
|
|
SocketModeClient *socketmode.Client
|
|
}
|
|
|
|
func NewSocketModeClientWrapper(socketModeClient *socketmode.Client) *SocketModeClientWrapper {
|
|
return &SocketModeClientWrapper{socketModeClient}
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) PostMessage(
|
|
channelID string,
|
|
options ...slack.MsgOption,
|
|
) (string, string, error) {
|
|
return wrapper.SocketModeClient.PostMessage(channelID, options...)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) UpdateMessage(
|
|
channelID string,
|
|
timestamp string,
|
|
options ...slack.MsgOption,
|
|
) (string, string, string, error) {
|
|
return wrapper.SocketModeClient.UpdateMessage(channelID, timestamp, options...)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) UploadFile(
|
|
params slack.FileUploadParameters,
|
|
) (file *slack.File, err error) {
|
|
return wrapper.SocketModeClient.UploadFile(params)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) AddBookmark(
|
|
channelID string,
|
|
params slack.AddBookmarkParameters,
|
|
) (slack.Bookmark, error) {
|
|
return wrapper.SocketModeClient.AddBookmark(channelID, params)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) PostEphemeral(
|
|
channelID string,
|
|
userID string,
|
|
options ...slack.MsgOption,
|
|
) (string, error) {
|
|
return wrapper.SocketModeClient.PostEphemeral(channelID, userID, options...)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) GetUsersInfo(
|
|
users ...string,
|
|
) (*[]slack.User, error) {
|
|
return wrapper.SocketModeClient.GetUsersInfo(users...)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) GetUserByEmail(
|
|
email string,
|
|
) (*slack.User, error) {
|
|
return wrapper.SocketModeClient.GetUserByEmail(email)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) CreateConversation(
|
|
params slack.CreateConversationParams,
|
|
) (*slack.Channel, error) {
|
|
return wrapper.SocketModeClient.CreateConversation(params)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) JoinConversation(
|
|
channelID string,
|
|
) (*slack.Channel, string, []string, error) {
|
|
return wrapper.SocketModeClient.JoinConversation(channelID)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) GetConversationInfo(
|
|
input *slack.GetConversationInfoInput,
|
|
) (*slack.Channel, error) {
|
|
return wrapper.SocketModeClient.GetConversationInfo(input)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) GetConversationHistory(
|
|
params *slack.GetConversationHistoryParameters,
|
|
) (*slack.GetConversationHistoryResponse, error) {
|
|
return wrapper.SocketModeClient.GetConversationHistory(params)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) GetConversationReplies(
|
|
params *slack.GetConversationRepliesParameters,
|
|
) (msgs []slack.Message, hasMore bool, nextCursor string, err error) {
|
|
return wrapper.SocketModeClient.GetConversationReplies(params)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) SetTopicOfConversation(
|
|
channelID string,
|
|
topic string,
|
|
) (*slack.Channel, error) {
|
|
return wrapper.SocketModeClient.SetTopicOfConversation(channelID, topic)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) GetUsersInConversation(
|
|
params *slack.GetUsersInConversationParameters,
|
|
) ([]string, string, error) {
|
|
return wrapper.SocketModeClient.GetUsersInConversation(params)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) InviteUsersToConversation(
|
|
channelID string,
|
|
users ...string,
|
|
) (*slack.Channel, error) {
|
|
return wrapper.SocketModeClient.InviteUsersToConversation(channelID, users...)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) OpenView(
|
|
triggerID string,
|
|
view slack.ModalViewRequest,
|
|
) (*slack.ViewResponse, error) {
|
|
return wrapper.SocketModeClient.OpenView(triggerID, view)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) AckRequest(
|
|
request socketmode.Request, payload ...interface{},
|
|
) {
|
|
wrapper.SocketModeClient.Ack(request, payload...)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) GetClient() *socketmode.Client {
|
|
return wrapper.SocketModeClient
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) ArchiveConversation(
|
|
channelID string,
|
|
) error {
|
|
return wrapper.SocketModeClient.ArchiveConversation(channelID)
|
|
}
|
|
|
|
func (wrapper *SocketModeClientWrapper) GetUsers(
|
|
userOptions slack.GetUsersOption,
|
|
) ([]slack.User, error) {
|
|
return wrapper.SocketModeClient.GetUsers(userOptions)
|
|
}
|