Fix build

app.go

@@ -11,11 +11,6 @@ import (
 	"k8s.io/utils/clock"
 )
 
-type Source interface {
-	GetUsers() ([]SourceUser, error)
-	GetGroupsWithMembers() ([]SourceGroupWithMembers, error)
-}
-
 type App struct {
 	syncInterval      *time.Duration
 	usernameReplaces  []ReplacementPair

azure_fake.go

@@ -17,6 +17,10 @@ func (a *AzureFake) setGroups(groups []SourceGroupWithMembers) {
 	a.groups = groups
 }
 
+func (a *AzureFake) GetSourceType() SourceType {
+	return AzureSourceType
+}
+
 func (a *AzureFake) GetUsers() ([]SourceUser, error) {
 	return a.users, nil
 }

azure_real.go

@@ -98,6 +98,10 @@ func handleNil[T any](s *T) T {
 	return result
 }
 
+func (a *AzureReal) GetSourceType() SourceType {
+	return AzureSourceType
+}
+
 func (a *AzureReal) GetUsers() ([]SourceUser, error) {
 	ctx, cancel := context.WithTimeout(context.Background(), a.timeout)
 	defer cancel()

diff.go

@@ -45,7 +45,7 @@ func (a *App) syncUsers() (map[ObjectID]YtsaurusUser, error) {
 		}
 	}
 
-	ytUsers, err := a.ytsaurus.GetUsers()
+	ytUsers, err := a.ytsaurus.GetUsers(a.source.GetSourceType())
 	if err != nil {
 		return nil, errors.Wrap(err, "failed to get YTsaurus users")
 	}
@@ -118,7 +118,7 @@ func (a *App) syncGroups(usersMap map[ObjectID]YtsaurusUser) error {
 	if err != nil {
 		return errors.Wrap(err, "failed to get Source groups")
 	}
-	ytGroups, err := a.ytsaurus.GetGroupsWithMembers()
+	ytGroups, err := a.ytsaurus.GetGroupsWithMembers(a.source.GetSourceType())
 	if err != nil {
 		return errors.Wrap(err, "failed to get YTsaurus groups")
 	}

ldap.go

@@ -33,6 +33,10 @@ func NewLdap(cfg *LdapConfig, logger appLoggerType) (*Ldap, error) {
 	}, nil
 }
 
+func (source *Ldap) GetSourceType() SourceType {
+	return LdapSourceType
+}
+
 func (source *Ldap) GetUsers() ([]SourceUser, error) {
 	res, err := source.Connection.Search(&ldap.SearchRequest{
 		BaseDN:     source.Config.BaseDN,

source_models.go → source.go

@@ -14,6 +14,12 @@ const (
 	AzureSourceType SourceType = "azure"
 )
 
+type Source interface {
+	GetUsers() ([]SourceUser, error)
+	GetGroupsWithMembers() ([]SourceGroupWithMembers, error)
+	GetSourceType() SourceType
+}
+
 type SourceUser interface {
 	GetID() ObjectID
 	GetName() string