mirror of
https://github.com/mattermost/focalboard.git
synced 2024-12-21 13:38:56 +02:00
11bd3720f1
* remove unneeded store interfaces * - reduce dependencies for notifications service - notifications service no longer concerned with web socket notifications gnored, and an empty message aborts the commit. * use app to add member to board * remove unneeded API * remove dependency on app package * fix webapp jest Co-authored-by: Mattermod <mattermod@users.noreply.github.com>
190 lines
6.0 KiB
Go
190 lines
6.0 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/mattermost/focalboard/server/model"
|
|
"github.com/mattermost/focalboard/server/services/config"
|
|
"github.com/mattermost/focalboard/server/services/notify/notifymentions"
|
|
"github.com/mattermost/focalboard/server/services/notify/notifysubscriptions"
|
|
"github.com/mattermost/focalboard/server/services/notify/plugindelivery"
|
|
"github.com/mattermost/focalboard/server/services/permissions"
|
|
"github.com/mattermost/focalboard/server/services/store"
|
|
|
|
pluginapi "github.com/mattermost/mattermost-plugin-api"
|
|
|
|
mm_model "github.com/mattermost/mattermost-server/v6/model"
|
|
|
|
"github.com/mattermost/mattermost-server/v6/shared/mlog"
|
|
)
|
|
|
|
const (
|
|
botUsername = "boards"
|
|
botDisplayname = "Boards"
|
|
botDescription = "Created by Boards plugin."
|
|
)
|
|
|
|
type notifyBackendParams struct {
|
|
cfg *config.Configuration
|
|
client *pluginapi.Client
|
|
permissions permissions.PermissionsService
|
|
appAPI *appAPI
|
|
serverRoot string
|
|
logger *mlog.Logger
|
|
}
|
|
|
|
func createMentionsNotifyBackend(params notifyBackendParams) (*notifymentions.Backend, error) {
|
|
delivery, err := createDelivery(params.client, params.serverRoot)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
backendParams := notifymentions.BackendParams{
|
|
AppAPI: params.appAPI,
|
|
Permissions: params.permissions,
|
|
Delivery: delivery,
|
|
Logger: params.logger,
|
|
}
|
|
|
|
backend := notifymentions.New(backendParams)
|
|
|
|
return backend, nil
|
|
}
|
|
|
|
func createSubscriptionsNotifyBackend(params notifyBackendParams) (*notifysubscriptions.Backend, error) {
|
|
delivery, err := createDelivery(params.client, params.serverRoot)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
backendParams := notifysubscriptions.BackendParams{
|
|
ServerRoot: params.serverRoot,
|
|
AppAPI: params.appAPI,
|
|
Permissions: params.permissions,
|
|
Delivery: delivery,
|
|
Logger: params.logger,
|
|
NotifyFreqCardSeconds: params.cfg.NotifyFreqCardSeconds,
|
|
NotifyFreqBoardSeconds: params.cfg.NotifyFreqBoardSeconds,
|
|
}
|
|
backend := notifysubscriptions.New(backendParams)
|
|
|
|
return backend, nil
|
|
}
|
|
|
|
func createDelivery(client *pluginapi.Client, serverRoot string) (*plugindelivery.PluginDelivery, error) {
|
|
bot := &mm_model.Bot{
|
|
Username: botUsername,
|
|
DisplayName: botDisplayname,
|
|
Description: botDescription,
|
|
}
|
|
botID, err := client.Bot.EnsureBot(bot)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to ensure %s bot: %w", botDisplayname, err)
|
|
}
|
|
|
|
pluginAPI := &pluginAPIAdapter{client: client}
|
|
|
|
return plugindelivery.New(botID, serverRoot, pluginAPI), nil
|
|
}
|
|
|
|
// pluginAPIAdapter provides a simple wrapper around the component based Plugin API
|
|
// which flattens the API to satisfy an interface.
|
|
type pluginAPIAdapter struct {
|
|
client *pluginapi.Client
|
|
}
|
|
|
|
func (da *pluginAPIAdapter) GetDirectChannel(userID1, userID2 string) (*mm_model.Channel, error) {
|
|
return da.client.Channel.GetDirect(userID1, userID2)
|
|
}
|
|
|
|
func (da *pluginAPIAdapter) CreatePost(post *mm_model.Post) error {
|
|
return da.client.Post.CreatePost(post)
|
|
}
|
|
|
|
func (da *pluginAPIAdapter) GetUserByID(userID string) (*mm_model.User, error) {
|
|
return da.client.User.Get(userID)
|
|
}
|
|
|
|
func (da *pluginAPIAdapter) GetUserByUsername(name string) (*mm_model.User, error) {
|
|
return da.client.User.GetByUsername(name)
|
|
}
|
|
|
|
func (da *pluginAPIAdapter) GetTeamMember(teamID string, userID string) (*mm_model.TeamMember, error) {
|
|
return da.client.Team.GetMember(teamID, userID)
|
|
}
|
|
|
|
func (da *pluginAPIAdapter) GetChannelByID(channelID string) (*mm_model.Channel, error) {
|
|
return da.client.Channel.Get(channelID)
|
|
}
|
|
|
|
func (da *pluginAPIAdapter) GetChannelMember(channelID string, userID string) (*mm_model.ChannelMember, error) {
|
|
return da.client.Channel.GetMember(channelID, userID)
|
|
}
|
|
|
|
func (da *pluginAPIAdapter) CreateMember(teamID string, userID string) (*mm_model.TeamMember, error) {
|
|
return da.client.Team.CreateMember(teamID, userID)
|
|
}
|
|
|
|
type appIface interface {
|
|
CreateSubscription(sub *model.Subscription) (*model.Subscription, error)
|
|
AddMemberToBoard(member *model.BoardMember) (*model.BoardMember, error)
|
|
}
|
|
|
|
// appAPI provides app and store APIs for notification services. Where appropriate calls are made to the
|
|
// app layer to leverage the additional websocket notification logic present there, and other times the
|
|
// store APIs are called directly.
|
|
type appAPI struct {
|
|
store store.Store
|
|
app appIface
|
|
}
|
|
|
|
func (a *appAPI) init(store store.Store, app appIface) {
|
|
a.store = store
|
|
a.app = app
|
|
}
|
|
|
|
func (a *appAPI) GetBlockHistory(blockID string, opts model.QueryBlockHistoryOptions) ([]model.Block, error) {
|
|
return a.store.GetBlockHistory(blockID, opts)
|
|
}
|
|
|
|
func (a *appAPI) GetSubTree2(boardID, blockID string, opts model.QuerySubtreeOptions) ([]model.Block, error) {
|
|
return a.store.GetSubTree2(boardID, blockID, opts)
|
|
}
|
|
|
|
func (a *appAPI) GetBoardAndCardByID(blockID string) (board *model.Board, card *model.Block, err error) {
|
|
return a.store.GetBoardAndCardByID(blockID)
|
|
}
|
|
|
|
func (a *appAPI) GetUserByID(userID string) (*model.User, error) {
|
|
return a.store.GetUserByID(userID)
|
|
}
|
|
|
|
func (a *appAPI) CreateSubscription(sub *model.Subscription) (*model.Subscription, error) {
|
|
return a.app.CreateSubscription(sub)
|
|
}
|
|
|
|
func (a *appAPI) GetSubscribersForBlock(blockID string) ([]*model.Subscriber, error) {
|
|
return a.store.GetSubscribersForBlock(blockID)
|
|
}
|
|
|
|
func (a *appAPI) UpdateSubscribersNotifiedAt(blockID string, notifyAt int64) error {
|
|
return a.store.UpdateSubscribersNotifiedAt(blockID, notifyAt)
|
|
}
|
|
|
|
func (a *appAPI) UpsertNotificationHint(hint *model.NotificationHint, notificationFreq time.Duration) (*model.NotificationHint, error) {
|
|
return a.store.UpsertNotificationHint(hint, notificationFreq)
|
|
}
|
|
|
|
func (a *appAPI) GetNextNotificationHint(remove bool) (*model.NotificationHint, error) {
|
|
return a.store.GetNextNotificationHint(remove)
|
|
}
|
|
|
|
func (a *appAPI) GetMemberForBoard(boardID, userID string) (*model.BoardMember, error) {
|
|
return a.store.GetMemberForBoard(boardID, userID)
|
|
}
|
|
|
|
func (a *appAPI) AddMemberToBoard(member *model.BoardMember) (*model.BoardMember, error) {
|
|
return a.app.AddMemberToBoard(member)
|
|
}
|