[MM-16484] Migrate UserAccessToken.Get to Sync by default (#11316)

* [MM-16484] Migrate UserAccessToken.Get to Sync by default

* [MM-16484] Fix shadowing error for err variable

* [MM-16484] Remove redundant else

app/session.go

@@ -384,16 +384,15 @@ func (a *App) GetUserAccessTokensForUser(userId string, page, perPage int) ([]*m
 }
 
 func (a *App) GetUserAccessToken(tokenId string, sanitize bool) (*model.UserAccessToken, *model.AppError) {
-	result := <-a.Srv.Store.UserAccessToken().Get(tokenId)
+	token, err := a.Srv.Store.UserAccessToken().Get(tokenId)
-	if result.Err != nil {
+	if err != nil {
-		return nil, result.Err
+		return nil, err
 	}
-	token := result.Data.(*model.UserAccessToken)
+
 	if sanitize {
 		token.Token = ""
 	}
 	return token, nil
-
 }
 
 func (a *App) SearchUserAccessTokens(term string) ([]*model.UserAccessToken, *model.AppError) {

store/sqlstore/user_access_token_store.go

@@ -149,20 +149,17 @@ func (s SqlUserAccessTokenStore) deleteTokensByUser(transaction *gorp.Transactio
 	return result
 }
 
-func (s SqlUserAccessTokenStore) Get(tokenId string) store.StoreChannel {
+func (s SqlUserAccessTokenStore) Get(tokenId string) (*model.UserAccessToken, *model.AppError) {
-	return store.Do(func(result *store.StoreResult) {
+	token := model.UserAccessToken{}
-		token := model.UserAccessToken{}
 
-		if err := s.GetReplica().SelectOne(&token, "SELECT * FROM UserAccessTokens WHERE Id = :Id", map[string]interface{}{"Id": tokenId}); err != nil {
+	if err := s.GetReplica().SelectOne(&token, "SELECT * FROM UserAccessTokens WHERE Id = :Id", map[string]interface{}{"Id": tokenId}); err != nil {
-			if err == sql.ErrNoRows {
+		if err == sql.ErrNoRows {
-				result.Err = model.NewAppError("SqlUserAccessTokenStore.Get", "store.sql_user_access_token.get.app_error", nil, err.Error(), http.StatusNotFound)
+			return nil, model.NewAppError("SqlUserAccessTokenStore.Get", "store.sql_user_access_token.get.app_error", nil, err.Error(), http.StatusNotFound)
-			} else {
-				result.Err = model.NewAppError("SqlUserAccessTokenStore.Get", "store.sql_user_access_token.get.app_error", nil, err.Error(), http.StatusInternalServerError)
-			}
 		}
+		return nil, model.NewAppError("SqlUserAccessTokenStore.Get", "store.sql_user_access_token.get.app_error", nil, err.Error(), http.StatusInternalServerError)
+	}
 
-		result.Data = &token
+	return &token, nil
-	})
 }
 
 func (s SqlUserAccessTokenStore) GetAll(offset, limit int) ([]*model.UserAccessToken, *model.AppError) {

store/store.go

@@ -518,7 +518,7 @@ type UserAccessTokenStore interface {
 	Save(token *model.UserAccessToken) StoreChannel
 	Delete(tokenId string) StoreChannel
 	DeleteAllForUser(userId string) StoreChannel
-	Get(tokenId string) StoreChannel
+	Get(tokenId string) (*model.UserAccessToken, *model.AppError)
 	GetAll(offset int, limit int) ([]*model.UserAccessToken, *model.AppError)
 	GetByToken(tokenString string) StoreChannel
 	GetByUser(userId string, page, perPage int) StoreChannel

store/storetest/mocks/UserAccessTokenStore.go

@@ -46,19 +46,28 @@ func (_m *UserAccessTokenStore) DeleteAllForUser(userId string) store.StoreChann
 }
 
 // Get provides a mock function with given fields: tokenId
-func (_m *UserAccessTokenStore) Get(tokenId string) store.StoreChannel {
+func (_m *UserAccessTokenStore) Get(tokenId string) (*model.UserAccessToken, *model.AppError) {
 	ret := _m.Called(tokenId)
 
-	var r0 store.StoreChannel
+	var r0 *model.UserAccessToken
-	if rf, ok := ret.Get(0).(func(string) store.StoreChannel); ok {
+	if rf, ok := ret.Get(0).(func(string) *model.UserAccessToken); ok {
 		r0 = rf(tokenId)
 	} else {
 		if ret.Get(0) != nil {
-			r0 = ret.Get(0).(store.StoreChannel)
+			r0 = ret.Get(0).(*model.UserAccessToken)
 		}
 	}
 
-	return r0
+	var r1 *model.AppError
+	if rf, ok := ret.Get(1).(func(string) *model.AppError); ok {
+		r1 = rf(tokenId)
+	} else {
+		if ret.Get(1) != nil {
+			r1 = ret.Get(1).(*model.AppError)
+		}
+	}
+
+	return r0, r1
 }
 
 // GetAll provides a mock function with given fields: offset, limit

store/storetest/user_access_token_store.go

@@ -35,9 +35,9 @@ func testUserAccessTokenSaveGetDelete(t *testing.T, ss store.Store) {
 		t.Fatal(result.Err)
 	}
 
-	if result := <-ss.UserAccessToken().Get(uat.Id); result.Err != nil {
+	if result, terr := ss.UserAccessToken().Get(uat.Id); terr != nil {
-		t.Fatal(result.Err)
+		t.Fatal(terr)
-	} else if received := result.Data.(*model.UserAccessToken); received.Token != uat.Token {
+	} else if result.Token != uat.Token {
 		t.Fatal("received incorrect token after save")
 	}