summaryrefslogtreecommitdiffstats
path: root/store/sql_tokens_store.go
diff options
context:
space:
mode:
authorChris <ccbrown112@gmail.com>2017-09-25 09:11:25 -0500
committerJoram Wilander <jwawilander@gmail.com>2017-09-25 10:11:25 -0400
commit49fe5fbf3db56fc466b8997b182ee135d7a4365d (patch)
tree1252fea09aa3ce899e2e8edb1fb7b42900f50bca /store/sql_tokens_store.go
parentb2c5b97601b61f5748b46e4e386134203111ebb0 (diff)
downloadchat-49fe5fbf3db56fc466b8997b182ee135d7a4365d.tar.gz
chat-49fe5fbf3db56fc466b8997b182ee135d7a4365d.tar.bz2
chat-49fe5fbf3db56fc466b8997b182ee135d7a4365d.zip
Move sql store code into store/sqlstore package (#7502)
* move sql store code into store/sqlstore package * move non-sql constants back up to store * fix api test * derp
Diffstat (limited to 'store/sql_tokens_store.go')
-rw-r--r--store/sql_tokens_store.go109
1 files changed, 0 insertions, 109 deletions
diff --git a/store/sql_tokens_store.go b/store/sql_tokens_store.go
deleted file mode 100644
index 85f266bfa..000000000
--- a/store/sql_tokens_store.go
+++ /dev/null
@@ -1,109 +0,0 @@
-// Copyright (c) 2017 Mattermost, Inc. All Rights Reserved.
-// See License.txt for license information.
-
-package store
-
-import (
- "database/sql"
- "net/http"
-
- l4g "github.com/alecthomas/log4go"
-
- "github.com/mattermost/mattermost-server/model"
-)
-
-type SqlTokenStore struct {
- SqlStore
-}
-
-func NewSqlTokenStore(sqlStore SqlStore) TokenStore {
- s := &SqlTokenStore{sqlStore}
-
- for _, db := range sqlStore.GetAllConns() {
- table := db.AddTableWithName(model.Token{}, "Tokens").SetKeys(false, "Token")
- table.ColMap("Token").SetMaxSize(64)
- table.ColMap("Type").SetMaxSize(64)
- table.ColMap("Extra").SetMaxSize(128)
- }
-
- return s
-}
-
-func (s SqlTokenStore) CreateIndexesIfNotExists() {
-}
-
-func (s SqlTokenStore) Save(token *model.Token) StoreChannel {
-
- storeChannel := make(StoreChannel, 1)
-
- go func() {
- result := StoreResult{}
-
- if result.Err = token.IsValid(); result.Err != nil {
- storeChannel <- result
- close(storeChannel)
- return
- }
-
- if err := s.GetMaster().Insert(token); err != nil {
- result.Err = model.NewAppError("SqlTokenStore.Save", "store.sql_recover.save.app_error", nil, "", http.StatusInternalServerError)
- }
-
- storeChannel <- result
- close(storeChannel)
- }()
-
- return storeChannel
-}
-
-func (s SqlTokenStore) Delete(token string) StoreChannel {
-
- storeChannel := make(StoreChannel, 1)
-
- go func() {
- result := StoreResult{}
-
- if _, err := s.GetMaster().Exec("DELETE FROM Tokens WHERE Token = :Token", map[string]interface{}{"Token": token}); err != nil {
- result.Err = model.NewAppError("SqlTokenStore.Delete", "store.sql_recover.delete.app_error", nil, "", http.StatusInternalServerError)
- }
-
- storeChannel <- result
- close(storeChannel)
- }()
-
- return storeChannel
-}
-
-func (s SqlTokenStore) GetByToken(tokenString string) StoreChannel {
-
- storeChannel := make(StoreChannel, 1)
-
- go func() {
- result := StoreResult{}
-
- token := model.Token{}
-
- if err := s.GetReplica().SelectOne(&token, "SELECT * FROM Tokens WHERE Token = :Token", map[string]interface{}{"Token": tokenString}); err != nil {
- if err == sql.ErrNoRows {
- result.Err = model.NewAppError("SqlTokenStore.GetByToken", "store.sql_recover.get_by_code.app_error", nil, err.Error(), http.StatusBadRequest)
- } else {
- result.Err = model.NewAppError("SqlTokenStore.GetByToken", "store.sql_recover.get_by_code.app_error", nil, err.Error(), http.StatusInternalServerError)
- }
- }
-
- result.Data = &token
-
- storeChannel <- result
- close(storeChannel)
- }()
-
- return storeChannel
-}
-
-func (s SqlTokenStore) Cleanup() {
- l4g.Debug("Cleaning up token store.")
- deltime := model.GetMillis() - model.MAX_TOKEN_EXIPRY_TIME
- if _, err := s.GetMaster().Exec("DELETE FROM Tokens WHERE CreateAt < :DelTime", map[string]interface{}{"DelTime": deltime}); err != nil {
- l4g.Error("Unable to cleanup token store.")
- }
-}