package main import ( "fmt" "net/http" "sync" "github.com/mattermost/focalboard/server/server" "github.com/mattermost/focalboard/server/services/config" "github.com/mattermost/focalboard/server/services/mlog" "github.com/mattermost/mattermost-server/v5/model" "github.com/mattermost/mattermost-server/v5/plugin" ) // Plugin implements the interface expected by the Mattermost server to communicate between the server and plugin processes. type Plugin struct { plugin.MattermostPlugin // configurationLock synchronizes access to the configuration. configurationLock sync.RWMutex // configuration is the active plugin configuration. Consult getConfiguration and // setConfiguration for usage. configuration *configuration server *server.Server wsHub *WSHub } type WSHub struct { API plugin.API handleWSMessage func(data []byte) } func (h *WSHub) SendWSMessage(data []byte) { h.API.PublishPluginClusterEvent(model.PluginClusterEvent{ Id: "websocket_event", Data: data, }, model.PluginClusterEventSendOptions{ SendType: model.PluginClusterEventSendTypeReliable, }) } func (h *WSHub) SetReceiveWSMessage(handler func(data []byte)) { h.handleWSMessage = handler } func (p *Plugin) OnActivate() error { mmconfig := p.API.GetUnsanitizedConfig() filesS3Config := config.AmazonS3Config{} if mmconfig.FileSettings.AmazonS3AccessKeyId != nil { filesS3Config.AccessKeyId = *mmconfig.FileSettings.AmazonS3AccessKeyId } if mmconfig.FileSettings.AmazonS3SecretAccessKey != nil { filesS3Config.SecretAccessKey = *mmconfig.FileSettings.AmazonS3SecretAccessKey } if mmconfig.FileSettings.AmazonS3Bucket != nil { filesS3Config.Bucket = *mmconfig.FileSettings.AmazonS3Bucket } if mmconfig.FileSettings.AmazonS3PathPrefix != nil { filesS3Config.PathPrefix = *mmconfig.FileSettings.AmazonS3PathPrefix } if mmconfig.FileSettings.AmazonS3Region != nil { filesS3Config.Region = *mmconfig.FileSettings.AmazonS3Region } if mmconfig.FileSettings.AmazonS3Endpoint != nil { filesS3Config.Endpoint = *mmconfig.FileSettings.AmazonS3Endpoint } if mmconfig.FileSettings.AmazonS3SSL != nil { filesS3Config.SSL = *mmconfig.FileSettings.AmazonS3SSL } if mmconfig.FileSettings.AmazonS3SignV2 != nil { filesS3Config.SignV2 = *mmconfig.FileSettings.AmazonS3SignV2 } if mmconfig.FileSettings.AmazonS3SSE != nil { filesS3Config.SSE = *mmconfig.FileSettings.AmazonS3SSE } if mmconfig.FileSettings.AmazonS3Trace != nil { filesS3Config.Trace = *mmconfig.FileSettings.AmazonS3Trace } logger := mlog.NewLogger() server, err := server.New(&config.Configuration{ ServerRoot: *mmconfig.ServiceSettings.SiteURL + "/plugins/focalboard", Port: -1, DBType: *mmconfig.SqlSettings.DriverName, DBConfigString: *mmconfig.SqlSettings.DataSource, DBTablePrefix: "focalboard_", UseSSL: false, SecureCookie: true, WebPath: *mmconfig.PluginSettings.Directory + "/focalboard/pack", FilesDriver: *mmconfig.FileSettings.DriverName, FilesPath: *mmconfig.FileSettings.Directory, FilesS3Config: filesS3Config, Telemetry: true, WebhookUpdate: []string{}, SessionExpireTime: 2592000, SessionRefreshTime: 18000, LocalOnly: false, EnableLocalMode: false, LocalModeSocketLocation: "", AuthMode: "mattermost", }, "", logger) if err != nil { fmt.Println("ERROR INITIALIZING THE SERVER", err) return err } p.wsHub = &WSHub{API: p.API} server.SetWSHub(p.wsHub) p.server = server return server.Start() } func (p *Plugin) OnPluginClusterEvent(c *plugin.Context, ev model.PluginClusterEvent) { if ev.Id == "websocket_event" { p.wsHub.handleWSMessage(ev.Data) } } func (p *Plugin) OnDeactivate() error { return p.server.Shutdown() } // ServeHTTP demonstrates a plugin that handles HTTP requests by greeting the world. func (p *Plugin) ServeHTTP(c *plugin.Context, w http.ResponseWriter, r *http.Request) { router := p.server.GetRootRouter() router.ServeHTTP(w, r) } // See https://developers.mattermost.com/extend/plugins/server/reference/