✨ sync in storage

egorgasay · Mar 30, 2024 · 4f16997 · 4f16997
1 parent ac67f5e
commit 4f16997
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 24 deletions.
diff --git a/internal/service/syncer/syncer.go b/internal/service/syncer/syncer.go
@@ -57,7 +57,7 @@ func (s Syncer) syncServer(server domains.Server) error {
 
 	currentSyncID := s.repo.GetUserChangeID()
 
-	if syncID != currentSyncID {
+	if syncID == currentSyncID {
 		return nil
 	}
 

diff --git a/internal/storage/storage.go b/internal/storage/storage.go
@@ -376,29 +376,6 @@ func (s *Storage) GetUserIDByName(username string) (r gost.Result[int]) {
 	return r.Ok(*find)
 }
 
-func (s *Storage) GetUsersFromSyncID(syncID uint64) (r gost.Result[[]models.User]) {
-	s.users.RLock()
-	defer s.users.RUnlock()
-
-	var find []models.User
-
-	s.users.Iter(func(k int, v models.User) (stop bool) {
-		if v.GetChangeID() < syncID {
-			find = append(find, v)
-		}
-		return false
-	})
-
-	return r.Ok(find)
-}
-
-func (s *Storage) GetCurrentSyncID() uint64 {
-	s.users.RLock()
-	defer s.users.RUnlock()
-
-	return s.users.changeID
-}
-
 func (s *Storage) GetUsersFromChangeID(id uint64) gost.Result[[]models.User] {
 	s.users.RLock()
 	defer s.users.RUnlock()