Commit checks from forks are now included

test/getCommitChecks.js

@@ -0,0 +1,16 @@
+'use strict';
+
+const test = require('tape');
+
+const { getCommitChecks } = require('../utils/getCommitChecks');
+const mock = require('./mocks/getCommitChecks');
+
+test('evaluateCommitStatus', (t) => {
+	t.equal(
+		getCommitChecks(mock.commitChecks),
+		mock.expected,
+		mock.description,
+	);
+
+	t.end();
+});

utils/buildQuery.js

@@ -26,6 +26,12 @@ const pullRequestQuery = (name, owner, pr, sha) => `
 					commits(last: 1) {
 						nodes {
 							commit {
+								oid
+								author {
+									user {
+										url
+									}
+								}
 								statusCheckRollup {
 									state
 									contexts(last: 100) {
@@ -70,6 +76,13 @@ const commitStatusQuery = (name, owner, sha) => `
 			... on Commit {
 				statusCheckRollup {
 					state
+					commit {
+						author {
+							user {
+								url
+							}
+						}
+					}
 					contexts(last: 100) {
 						totalCount
 						pageInfo {

utils/getCommitChecks.js

@@ -0,0 +1,109 @@
+/* eslint-disable no-shadow */
+/* eslint-disable no-unused-vars */
+
+'use strict';
+
+const { graphql } = require('@octokit/graphql');
+
+let owner, name, token, repo, pr, sha, search;
+
+const modifiedNodes = [];
+
+const runCommitQuery = async ({ name, owner, sha, token }) => {
+	const q = `
+		repository(name: "${name}", owner: "${owner}") {
+			commit: object(expression: "${sha}") {
+				... on Commit {
+					statusCheckRollup {
+						state
+						contexts(last: 100) {
+							totalCount
+							pageInfo {
+								endCursor
+								hasNextPage
+							}
+						nodes {
+							__typename
+							... on CheckRun {
+								status
+								name
+								conclusion
+							}
+							... on StatusContext {
+								state
+								context
+								description
+							}
+						}
+					}
+				}
+			}
+		}
+	}
+`;
+
+	try {
+		const response = await graphql(`{${q}}`, {
+			headers: {
+				authorization: `token ${token}`,
+			},
+		});
+		return response.repository.commit?.statusCheckRollup?.contexts?.nodes;
+	} catch (error) {
+		console.log(error);
+		return null;
+	}
+};
+
+const doNodes = async (ogNode) => {
+	const node = JSON.parse(JSON.stringify(ogNode));
+	// console.log(JSON.stringify(node,undefined,2));
+	const { commit } = node;
+	const {
+		author: {
+			user: { url },
+		},
+		oid,
+	} = commit;
+
+	await runCommitQuery({
+		name,
+		owner: url.slice(url.lastIndexOf('/') + 1),
+		sha: oid,
+		token,
+	}).then((commitChecks) => {
+		const prchecks = commit.statusCheckRollup?.contexts.nodes ?? [];
+		const allChecks = prchecks.concat(commitChecks || []);
+		// modify the values only if checks are found
+		if (allChecks.length > 0) {
+			commit.statusCheckRollup.contexts.nodes = allChecks;
+			commit.statusCheckRollup.contexts.totalCount = allChecks.length;
+		}
+
+	});
+	modifiedNodes.push(node);
+};
+
+const getCommitChecks = async (response, data) => {
+	({ repo, pr, sha, token } = data);
+	[owner, name] = repo.split('/');
+	({ search } = response);
+
+	await search.edges.reduce(async (prev, edge) => {
+		await prev;
+		return edge.node.commits.nodes.reduce(
+			async (prev, node) => {
+				await prev;
+				return doNodes(node);
+			},
+			Promise.resolve(),
+		);
+	}, Promise.resolve());
+
+	return modifiedNodes;
+
+};
+
+module.exports = {
+	getCommitChecks,
+};

utils/resolveIndentifier.js

@@ -2,10 +2,12 @@
 
 const exec = require('child_process').execSync;
 
+// function to resolve the identifier to it's sha
 module.exports = (identifier, short = false) => {
-	const command = short ? `git show ${identifier} -s --format="%h"` : `git show ${identifier} -s --format="%H"`;
 	try {
-		return String(exec(command));
+		const command = short ? `git show ${identifier} -s --format="%h"` : `git show ${identifier} -s --format="%H"`;
+		const stdout = String(exec(command));
+		return stdout;
 	} catch (e) {
 		return null;
 	}

utils/runQuery.js

@@ -2,6 +2,7 @@
 
 const { graphql } = require('@octokit/graphql');
 const buildQuery = require('./buildQuery');
+const { getCommitChecks } = require('./getCommitChecks');
 
 module.exports = async function runQuery({ commit, repo, pr, sha, token }) {
 	const [owner, name] = repo.split('/');
@@ -12,6 +13,8 @@ module.exports = async function runQuery({ commit, repo, pr, sha, token }) {
 				authorization: `token ${token}`,
 			},
 		});
+		const nodes = await getCommitChecks(response, { commit, repo, pr, sha, token });
+		response.search.edges[0].node.commits.nodes = nodes;
 	} catch (err) {
 		throw err.message;
 	}