summaryrefslogtreecommitdiffstats
path: root/jobs/server.go
diff options
context:
space:
mode:
authorJonathan Fritz <jonathan.fritz@mattermost.com>2018-02-13 08:39:56 -0500
committerJonathan Fritz <jonathan.fritz@mattermost.com>2018-02-13 08:39:56 -0500
commit18fa32567b56584c6e24da2ae68814d5bf8ece6f (patch)
tree311ab6a3918ba64ac665286f15950b32dc1b1dba /jobs/server.go
parent7b2861de3a09cf00d00b0872cc537d54302c4bfa (diff)
parent8b79f5d49cb8d4877e136a76e515edef41ef6f28 (diff)
downloadchat-18fa32567b56584c6e24da2ae68814d5bf8ece6f.tar.gz
chat-18fa32567b56584c6e24da2ae68814d5bf8ece6f.tar.bz2
chat-18fa32567b56584c6e24da2ae68814d5bf8ece6f.zip
Merge branch 'release-4.7' into XYZ-110
Diffstat (limited to 'jobs/server.go')
-rw-r--r--jobs/server.go33
1 files changed, 33 insertions, 0 deletions
diff --git a/jobs/server.go b/jobs/server.go
index 01cf821dc..4015d581e 100644
--- a/jobs/server.go
+++ b/jobs/server.go
@@ -4,9 +4,12 @@
package jobs
import (
+ l4g "github.com/alecthomas/log4go"
+
ejobs "github.com/mattermost/mattermost-server/einterfaces/jobs"
"github.com/mattermost/mattermost-server/model"
"github.com/mattermost/mattermost-server/store"
+ "github.com/mattermost/mattermost-server/utils"
)
type ConfigService interface {
@@ -47,6 +50,36 @@ func (srv *JobServer) Config() *model.Config {
return srv.ConfigService.Config()
}
+func (srv *JobServer) LoadLicense() {
+ licenseId := ""
+ if result := <-srv.Store.System().Get(); result.Err == nil {
+ props := result.Data.(model.StringMap)
+ licenseId = props[model.SYSTEM_ACTIVE_LICENSE_ID]
+ }
+
+ var licenseBytes []byte
+
+ if len(licenseId) != 26 {
+ // Lets attempt to load the file from disk since it was missing from the DB
+ _, licenseBytes = utils.GetAndValidateLicenseFileFromDisk(*srv.ConfigService.Config().ServiceSettings.LicenseFileLocation)
+ } else {
+ if result := <-srv.Store.License().Get(licenseId); result.Err == nil {
+ record := result.Data.(*model.LicenseRecord)
+ licenseBytes = []byte(record.Bytes)
+ l4g.Info("License key valid unlocking enterprise features.")
+ } else {
+ l4g.Info(utils.T("mattermost.load_license.find.warn"))
+ }
+ }
+
+ if licenseBytes != nil {
+ utils.LoadLicense(licenseBytes)
+ l4g.Info("License key valid unlocking enterprise features.")
+ } else {
+ l4g.Info(utils.T("mattermost.load_license.find.warn"))
+ }
+}
+
func (srv *JobServer) StartWorkers() {
srv.Workers = srv.InitWorkers().Start()
}