diff options
Diffstat (limited to 'store/sql_supplier.go')
-rw-r--r-- | store/sql_supplier.go | 47 |
1 files changed, 27 insertions, 20 deletions
diff --git a/store/sql_supplier.go b/store/sql_supplier.go index df934f2cb..a5f4f71b6 100644 --- a/store/sql_supplier.go +++ b/store/sql_supplier.go @@ -58,26 +58,27 @@ const ( ) type SqlSupplierOldStores struct { - team TeamStore - channel ChannelStore - post PostStore - user UserStore - audit AuditStore - cluster ClusterDiscoveryStore - compliance ComplianceStore - session SessionStore - oauth OAuthStore - system SystemStore - webhook WebhookStore - command CommandStore - preference PreferenceStore - license LicenseStore - token TokenStore - emoji EmojiStore - status StatusStore - fileInfo FileInfoStore - reaction ReactionStore - job JobStore + team TeamStore + channel ChannelStore + post PostStore + user UserStore + audit AuditStore + cluster ClusterDiscoveryStore + compliance ComplianceStore + session SessionStore + oauth OAuthStore + system SystemStore + webhook WebhookStore + command CommandStore + preference PreferenceStore + license LicenseStore + token TokenStore + emoji EmojiStore + status StatusStore + fileInfo FileInfoStore + reaction ReactionStore + job JobStore + userAccessToken UserAccessTokenStore } type SqlSupplier struct { @@ -117,6 +118,7 @@ func NewSqlSupplier() *SqlSupplier { supplier.oldStores.status = NewSqlStatusStore(supplier) supplier.oldStores.fileInfo = NewSqlFileInfoStore(supplier) supplier.oldStores.job = NewSqlJobStore(supplier) + supplier.oldStores.userAccessToken = NewSqlUserAccessTokenStore(supplier) initSqlSupplierReactions(supplier) @@ -147,6 +149,7 @@ func NewSqlSupplier() *SqlSupplier { supplier.oldStores.status.(*SqlStatusStore).CreateIndexesIfNotExists() supplier.oldStores.fileInfo.(*SqlFileInfoStore).CreateIndexesIfNotExists() supplier.oldStores.job.(*SqlJobStore).CreateIndexesIfNotExists() + supplier.oldStores.userAccessToken.(*SqlUserAccessTokenStore).CreateIndexesIfNotExists() supplier.oldStores.preference.(*SqlPreferenceStore).DeleteUnusedFeatures() @@ -760,6 +763,10 @@ func (ss *SqlSupplier) Job() JobStore { return ss.oldStores.job } +func (ss *SqlSupplier) UserAccessToken() UserAccessTokenStore { + return ss.oldStores.userAccessToken +} + func (ss *SqlSupplier) DropAllTables() { ss.master.TruncateTables() } |