Merge pull request #549 from LydiaCai1203/feat-download-repolist

Feat download repolist

Author: yokowu

backend/biz/git/usecase/identity.go

@@ -73,6 +73,40 @@ func (u *GitIdentityUsecase) gitClienter(identity *db.GitIdentity) domain.GitCli
 	return gitpkg.NewCachedGitClient(inner, u.repoCache, identity.UserID.String()+":"+identity.ID.String())
 }
 
+// prefetchRepositories 异步预拉取仓库列表以预热缓存
+func (u *GitIdentityUsecase) prefetchRepositories(identity *db.GitIdentity) {
+	go func() {
+		defer func() {
+			if r := recover(); r != nil {
+				u.logger.Warn("prefetch: panic recovered", "error", r, "identity_id", identity.ID)
+			}
+		}()
+		ctx, cancel := context.WithTimeout(context.Background(), 60*time.Second)
+		defer cancel()
+		if _, err := u.fetchRepositories(ctx, identity, false); err != nil {
+			u.logger.WarnContext(ctx, "prefetch: failed to fetch repositories", "error", err, "identity_id", identity.ID)
+		}
+	}()
+}
+
+// fetchRepositories 拉取 identity 关联的仓库列表
+func (u *GitIdentityUsecase) fetchRepositories(ctx context.Context, identity *db.GitIdentity, flush bool) ([]domain.AuthRepository, error) {
+	client := u.gitClienter(identity)
+	if client == nil {
+		return nil, nil
+	}
+	token, err := u.tokenProvider.GetToken(ctx, identity.ID)
+	if err != nil {
+		return nil, fmt.Errorf("get token: %w", err)
+	}
+	return client.Repositories(ctx, &domain.RepositoryOptions{
+		Token:     token,
+		InstallID: identity.InstallationID,
+		IsOAuth:   identity.OauthRefreshToken != "",
+		Flush:     flush,
+	})
+}
+
 // Get 获取单个 Git 身份认证（仅限当前用户）
 func (u *GitIdentityUsecase) Get(ctx context.Context, uid uuid.UUID, id uuid.UUID, flush bool) (*domain.GitIdentity, error) {
 	identity, err := u.repo.GetByUserID(ctx, uid, id)
@@ -85,24 +119,12 @@ func (u *GitIdentityUsecase) Get(ctx context.Context, uid uuid.UUID, id uuid.UUI
 	}
 	gi := cvt.From(identity, &domain.GitIdentity{})
 
-	if client := u.gitClienter(identity); client != nil {
-		token, err := u.tokenProvider.GetToken(ctx, identity.ID)
-		if err != nil {
-			u.logger.WarnContext(ctx, "failed to get token", "error", err, "platform", identity.Platform, "identity_id", identity.ID)
-			return gi, nil
-		}
-		repos, err := client.Repositories(ctx, &domain.RepositoryOptions{
-			Token:     token,
-			InstallID: identity.InstallationID,
-			IsOAuth:   identity.OauthRefreshToken != "",
-			Flush:     flush,
-		})
-		if err != nil {
-			u.logger.WarnContext(ctx, "failed to get authorized repositories", "error", err, "platform", identity.Platform, "identity_id", identity.ID)
-			return gi, nil
-		}
-		gi.AuthorizedRepositories = repos
+	repos, err := u.fetchRepositories(ctx, identity, flush)
+	if err != nil {
+		u.logger.WarnContext(ctx, "failed to get authorized repositories", "error", err, "platform", identity.Platform, "identity_id", identity.ID)
+		return gi, nil
 	}
+	gi.AuthorizedRepositories = repos
 
 	return gi, nil
 }
@@ -114,6 +136,7 @@ func (u *GitIdentityUsecase) Add(ctx context.Context, uid uuid.UUID, req *domain
 		u.logger.ErrorContext(ctx, "failed to create git identity", "error", err, "user_id", uid)
 		return nil, err
 	}
+	u.prefetchRepositories(identity)
 	return cvt.From(identity, &domain.GitIdentity{}), nil
 }
 
@@ -125,6 +148,9 @@ func (u *GitIdentityUsecase) Update(ctx context.Context, uid uuid.UUID, req *dom
 	}
 	u.tokenProvider.ClearCache(req.ID)
 	u.repoCache.Delete(uid.String() + ":" + req.ID.String())
+	if identity, err := u.repo.Get(ctx, req.ID); err == nil {
+		u.prefetchRepositories(identity)
+	}
 	return nil
 }
 

backend/pkg/git/gitlab/operation.go

@@ -62,6 +62,8 @@ func (g *Gitlab) listProjects(ctx context.Context, client *gitlab.Client) ([]dom
 	opt := &gitlab.ListProjectsOptions{
 		ListOptions: gitlab.ListOptions{PerPage: 100},
 		Membership:  ptr(true),
+		OrderBy:     ptr("updated_at"),
+		Sort:        ptr("desc"),
 	}
 	var all []*gitlab.Project
 	for {