service

Documentation

Index

• type MessageOpenlineFields
• type SlackService
  • func NewSlackService(cfg *config.Config, log logger.Logger, repositories *repository.Repositories) SlackService
• type SyncFromSourceService
  • func NewSlackRawService(cfg *config.Config, log logger.Logger, repositories *repository.Repositories, ...) SyncFromSourceService
• type UserOpenlineFields

Types

type MessageOpenlineFields

type MessageOpenlineFields struct {
	ChannelUserIds   []string          `json:"channel_user_ids"`
	ChannelUserNames map[string]string `json:"channel_user_names"`
	ChannelId        string            `json:"channel_id"`
	ChannelName      string            `json:"channel_name"`
	OrganizationId   string            `json:"organization_id"`
	Permalink        string            `json:"permalink"`
}

type SlackService

type SlackService interface {
	FetchChannelInfo(ctx context.Context, token, channelId string) (*slack.Channel, error)
	AuthTest(ctx context.Context, token string) (*slack.AuthTestResponse, error)
	FetchUserIdsFromSlackChannel(ctx context.Context, token, channelId string) ([]string, error)
	FetchUserInfo(ctx context.Context, token, userId string) (*slack.User, error)
	FetchNewMessagesFromSlackChannel(ctx context.Context, tenant, token, channelId string, from, to time.Time) ([]slack.Message, error)
	FetchMessagesFromSlackChannelWithReplies(ctx context.Context, tenant, token, channelId string, to time.Time, lookbackWindow int) ([]slack.Message, error)
	FetchNewThreadMessages(ctx context.Context, token, channelId, parentTs string, from, to time.Time) ([]slack.Message, error)
	GetMessagePermalink(ctx context.Context, token, channelId, messageTs string) (string, error)
}

func NewSlackService

func NewSlackService(cfg *config.Config, log logger.Logger, repositories *repository.Repositories) SlackService

type SyncFromSourceService

type SyncFromSourceService interface {
	SyncSlackRawData()
}

func NewSlackRawService

func NewSlackRawService(cfg *config.Config, log logger.Logger, repositories *repository.Repositories, rawDataStoreDb *config.RawDataStoreDB) SyncFromSourceService

type UserOpenlineFields

type UserOpenlineFields struct {
	OrganizationId string `json:"organization_id"`
	TenantDomain   string `json:"tenant_domain"`
	TenantTeamId   string `json:"tenant_team_id"`
}