Fixed incomplete GitHub sync (#5310)
- Added await when fetching Github data to prevent the process from exiting before saving to database Co-authored-by: Ady Beraud <a.beraud96@gmail.com>
This commit is contained in:
@ -1,57 +0,0 @@
|
|||||||
import { graphql } from '@octokit/graphql';
|
|
||||||
import { desc } from 'drizzle-orm';
|
|
||||||
|
|
||||||
import { findOne } from '@/database/database';
|
|
||||||
import { issueModel, pullRequestModel } from '@/database/model';
|
|
||||||
import { fetchAssignableUsers } from '@/github-sync/contributors/fetch-assignable-users';
|
|
||||||
import { saveIssuesToDB } from '@/github-sync/contributors/save-issues-to-db';
|
|
||||||
import { savePRsToDB } from '@/github-sync/contributors/save-prs-to-db';
|
|
||||||
import { searchIssuesPRs } from '@/github-sync/contributors/search-issues-prs';
|
|
||||||
import { IssueNode, PullRequestNode } from '@/github-sync/contributors/types';
|
|
||||||
|
|
||||||
export const dynamic = 'force-dynamic';
|
|
||||||
|
|
||||||
export async function GET() {
|
|
||||||
if (!global.process.env.GITHUB_TOKEN) {
|
|
||||||
return new Response('No GitHub token provided', { status: 500 });
|
|
||||||
}
|
|
||||||
|
|
||||||
const query = graphql.defaults({
|
|
||||||
headers: {
|
|
||||||
Authorization: 'bearer ' + global.process.env.GITHUB_TOKEN,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
const assignableUsers = await fetchAssignableUsers(query);
|
|
||||||
|
|
||||||
const mostRecentPR = findOne(
|
|
||||||
pullRequestModel,
|
|
||||||
desc(pullRequestModel.updatedAt),
|
|
||||||
);
|
|
||||||
|
|
||||||
const mostRecentIssue = findOne(issueModel, desc(issueModel.updatedAt));
|
|
||||||
|
|
||||||
if (!mostRecentPR || !mostRecentIssue) {
|
|
||||||
return new Response('Run Init command first', { status: 400 });
|
|
||||||
}
|
|
||||||
|
|
||||||
const fetchedPRs = (await searchIssuesPRs(
|
|
||||||
query,
|
|
||||||
null,
|
|
||||||
false,
|
|
||||||
[],
|
|
||||||
)) as Array<PullRequestNode>;
|
|
||||||
const fetchedIssues = (await searchIssuesPRs(
|
|
||||||
query,
|
|
||||||
null,
|
|
||||||
true,
|
|
||||||
[],
|
|
||||||
)) as Array<IssueNode>;
|
|
||||||
|
|
||||||
savePRsToDB(fetchedPRs, assignableUsers);
|
|
||||||
saveIssuesToDB(fetchedIssues, assignableUsers);
|
|
||||||
|
|
||||||
return new Response('Data synced', {
|
|
||||||
status: 200,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
@ -39,8 +39,8 @@ export const fetchAndSaveGithubData = async () => {
|
|||||||
[],
|
[],
|
||||||
)) as Array<IssueNode>;
|
)) as Array<IssueNode>;
|
||||||
|
|
||||||
savePRsToDB(fetchedPRs, assignableUsers);
|
await savePRsToDB(fetchedPRs, assignableUsers);
|
||||||
saveIssuesToDB(fetchedIssues, assignableUsers);
|
await saveIssuesToDB(fetchedIssues, assignableUsers);
|
||||||
|
|
||||||
console.log('data synched!');
|
console.log('data synched!');
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user