zyc/devperf
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 同步全部分支的 Git 提交，不再仅限默认分支
All checks were successful
Build and Deploy / build-and-deploy (push) Successful in 46m54s
Details

Browse Source 
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
zyc 2026-04-21 10:57:04 +08:00
parent 4fa69ca2bc
commit 7cd8bc1b9b
2 changed files with 46 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
backend/src/api/gitea-client.ts
View File

@ -58,12 +58,22 @@ export async function getRepos(): Promise<GiteaRepo[]> {
return Array.isArray(data) ? data : [];
}
export async function getCommits(owner: string, repo: string, since?: string): Promise<GiteaCommit[]> {
export interface GiteaBranch {
name: string;
}
export async function getBranches(owner: string, repo: string): Promise<GiteaBranch[]> {
const data = await giteaGet<GiteaBranch[]>(`/repos/${owner}/${repo}/branches?limit=50`);
return Array.isArray(data) ? data : [];
}
export async function getCommits(owner: string, repo: string, since?: string, branch?: string): Promise<GiteaCommit[]> {
// 分页拉取所有 commit（每页 50，最多 10 页 = 500 条）
const all: GiteaCommit[] = [];
for (let page = 1; page <= 10; page++) {
let path = `/repos/${owner}/${repo}/commits?limit=50&page=${page}`;
if (since) path += `&since=${since}`;
if (branch) path += `&sha=${encodeURIComponent(branch)}`;
const data = await giteaGet<GiteaCommit[]>(path);
if (!Array.isArray(data) || data.length === 0) break;
all.push(...data);

14
backend/src/sync/sync-gitea.ts
View File

@ -70,9 +70,16 @@ export async function syncGitea(): Promise<void> {
for (const repo of reposToSync) {
try {
// Sync commits
const commits = await giteaClient.getCommits(repo.owner, repo.name);
// Sync commits from all branches
const branches = await giteaClient.getBranches(repo.owner, repo.name);
const seenShas = new Set<string>();
for (const branch of branches) {
const commits = await giteaClient.getCommits(repo.owner, repo.name, undefined, branch.name);
for (const commit of commits) {
if (seenShas.has(commit.sha)) continue;
seenShas.add(commit.sha);
const existingCommit = await db.query.gitCommits.findFirst({
where: eq(gitCommits.sha, commit.sha),
});
@ -101,6 +108,7 @@ export async function syncGitea(): Promise<void> {
recordsProcessed++;
}
}
}
// Sync PRs
const prs = await giteaClient.getPullRequests(repo.owner, repo.name);
@ -143,7 +151,7 @@ export async function syncGitea(): Promise<void> {
recordsProcessed++;
}
console.info(`[SYNC] Repo ${repo.owner}/${repo.name}: synced`);
console.info(`[SYNC] Repo ${repo.owner}/${repo.name}: synced (${branches.length} branches)`);
} catch (repoErr) {
const msg = repoErr instanceof Error ? repoErr.message : 'Unknown error';
console.error(`[SYNC] Repo ${repo.owner}/${repo.name} failed:`, msg);