diff options
author | Harshil Sharma <harshil.sharma@joshtechnologygroup.com> | 2018-09-26 20:49:22 +0000 |
---|---|---|
committer | Jesse Hallam <jesse.hallam@gmail.com> | 2018-09-26 16:49:22 -0400 |
commit | af275fe9242303581192258ef4f6457fa45a58e4 (patch) | |
tree | df05afdb0894d577574cbee5d056ffddeec3a93e /store/sqlstore/service_terms_store.go | |
parent | 4e59a27293394b6d5529efd13ad711daebbc0eb3 (diff) | |
download | chat-af275fe9242303581192258ef4f6457fa45a58e4.tar.gz chat-af275fe9242303581192258ef4f6457fa45a58e4.tar.bz2 chat-af275fe9242303581192258ef4f6457fa45a58e4.zip |
#MM-12130 changes for custom service terms (#9450)
* #MM-12130 changes for custom service terms
* Fixed styling
* Added getServiceTerms API
* removed unnecessary panic
* removed custom service terms text from flat config
* reverted user sql store as those changes are no longer needed
* added tests
* Updated a config key to be more standard
* Added copyright info
* Loading service terms only if the feature is enabled
* Loading service terms only if the feature is enabled
* removed unused index
* added createservice termns API
* made a param to bool instead of string
* added createservice termns API
* review fixes
* fixed styling
* Minor refactoring
* removed saveConfig and loadConfig magic
* added empty service terms text check to createServiceTerms API
* refactoed some urls to be terms_of_service instead of service_terms
* removed check for support settings
* changed URLs in tests
* removed unused code
* fixed a bug
* added service termd id in conif
* fixed a test
* review fixes
* minor fixes
* Fixed TestCreateServiceTerms
Diffstat (limited to 'store/sqlstore/service_terms_store.go')
-rw-r--r-- | store/sqlstore/service_terms_store.go | 143 |
1 files changed, 143 insertions, 0 deletions
diff --git a/store/sqlstore/service_terms_store.go b/store/sqlstore/service_terms_store.go new file mode 100644 index 000000000..43a1189f6 --- /dev/null +++ b/store/sqlstore/service_terms_store.go @@ -0,0 +1,143 @@ +// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved. +// See License.txt for license information. + +package sqlstore + +import ( + "database/sql" + "github.com/mattermost/mattermost-server/einterfaces" + "github.com/mattermost/mattermost-server/model" + "github.com/mattermost/mattermost-server/store" + "github.com/mattermost/mattermost-server/utils" + "net/http" +) + +type SqlServiceTermsStore struct { + SqlStore + metrics einterfaces.MetricsInterface +} + +var serviceTermsCache = utils.NewLru(model.SERVICE_TERMS_CACHE_SIZE) + +const serviceTermsCacheName = "ServiceTerms" + +func NewSqlTermStore(sqlStore SqlStore, metrics einterfaces.MetricsInterface) store.ServiceTermsStore { + s := SqlServiceTermsStore{sqlStore, metrics} + + for _, db := range sqlStore.GetAllConns() { + table := db.AddTableWithName(model.ServiceTerms{}, "ServiceTerms").SetKeys(false, "Id") + table.ColMap("Id").SetMaxSize(26) + table.ColMap("UserId").SetMaxSize(26) + table.ColMap("Text").SetMaxSize(model.POST_MESSAGE_MAX_BYTES_V2) + } + + return s +} + +func (s SqlServiceTermsStore) CreateIndexesIfNotExists() { +} + +func (s SqlServiceTermsStore) Save(serviceTerms *model.ServiceTerms) store.StoreChannel { + return store.Do(func(result *store.StoreResult) { + if len(serviceTerms.Id) > 0 { + result.Err = model.NewAppError( + "SqlServiceTermsStore.Save", + "store.sql_service_terms_store.save.existing.app_error", + nil, + "id="+serviceTerms.Id, http.StatusBadRequest, + ) + return + } + + serviceTerms.PreSave() + + if result.Err = serviceTerms.IsValid(); result.Err != nil { + return + } + + if err := s.GetMaster().Insert(serviceTerms); err != nil { + result.Err = model.NewAppError( + "SqlServiceTermsStore.Save", + "store.sql_service_terms.save.app_error", + nil, + "service_term_id="+serviceTerms.Id+",err="+err.Error(), + http.StatusInternalServerError, + ) + } + + result.Data = serviceTerms + + serviceTermsCache.AddWithDefaultExpires(serviceTerms.Id, serviceTerms) + }) +} + +func (s SqlServiceTermsStore) GetLatest(allowFromCache bool) store.StoreChannel { + return store.Do(func(result *store.StoreResult) { + if allowFromCache { + if serviceTermsCache.Len() == 0 { + if s.metrics != nil { + s.metrics.IncrementMemCacheMissCounter(serviceTermsCacheName) + } + } else { + if cacheItem, ok := serviceTermsCache.Get(serviceTermsCache.Keys()[0]); ok { + if s.metrics != nil { + s.metrics.IncrementMemCacheHitCounter(serviceTermsCacheName) + } + + result.Data = cacheItem.(*model.ServiceTerms) + return + } else if s.metrics != nil { + s.metrics.IncrementMemCacheMissCounter(serviceTermsCacheName) + } + } + } + + var serviceTerms *model.ServiceTerms + + err := s.GetReplica().SelectOne(&serviceTerms, "SELECT * FROM ServiceTerms ORDER BY CreateAt DESC LIMIT 1") + if err != nil { + if err == sql.ErrNoRows { + result.Err = model.NewAppError("SqlServiceTermsStore.GetLatest", "store.sql_service_terms_store.get.no_rows.app_error", nil, "err="+err.Error(), http.StatusNotFound) + } else { + result.Err = model.NewAppError("SqlServiceTermsStore.GetLatest", "store.sql_service_terms_store.get.app_error", nil, "err="+err.Error(), http.StatusInternalServerError) + } + } else { + result.Data = serviceTerms + + if allowFromCache { + serviceTermsCache.AddWithDefaultExpires(serviceTerms.Id, serviceTerms) + } + } + }) +} + +func (s SqlServiceTermsStore) Get(id string, allowFromCache bool) store.StoreChannel { + return store.Do(func(result *store.StoreResult) { + if allowFromCache { + if serviceTermsCache.Len() == 0 { + if s.metrics != nil { + s.metrics.IncrementMemCacheMissCounter(serviceTermsCacheName) + } + } else { + if cacheItem, ok := serviceTermsCache.Get(id); ok { + if s.metrics != nil { + s.metrics.IncrementMemCacheHitCounter(serviceTermsCacheName) + } + + result.Data = cacheItem.(*model.ServiceTerms) + return + } else if s.metrics != nil { + s.metrics.IncrementMemCacheMissCounter(serviceTermsCacheName) + } + } + } + + if obj, err := s.GetReplica().Get(model.ServiceTerms{}, id); err != nil { + result.Err = model.NewAppError("SqlServiceTermsStore.Get", "store.sql_service_terms_store.get.app_error", nil, "err="+err.Error(), http.StatusInternalServerError) + } else if obj == nil { + result.Err = model.NewAppError("SqlServiceTermsStore.GetLatest", "store.sql_service_terms_store.get.no_rows.app_error", nil, "", http.StatusNotFound) + } else { + result.Data = obj.(*model.ServiceTerms) + } + }) +} |