Labeler general refactoring (ver. 4)

src/api/get-changed-files.ts

@@ -0,0 +1,24 @@
+import * as core from '@actions/core';
+import * as github from '@actions/github';
+import {ClientType} from './types';
+
+export const getChangedFiles = async (
+ client: ClientType,
+ prNumber: number
+): Promise<string[]> => {
+ const listFilesOptions = client.rest.pulls.listFiles.endpoint.merge({
+ owner: github.context.repo.owner,
+ repo: github.context.repo.repo,
+ pull_number: prNumber
+ });
+
+ const listFilesResponse = await client.paginate(listFilesOptions);
+ const changedFiles = listFilesResponse.map((f: any) => f.filename);
+
+ core.debug('found changed files:');
+ for (const file of changedFiles) {
+ core.debug(' ' + file);
+ }
+
+ return changedFiles;
+};

src/api/get-changed-pull-requests.ts

@@ -0,0 +1,38 @@
+import * as core from '@actions/core';
+import * as github from '@actions/github';
+import {getChangedFiles} from './get-changed-files';
+import {ClientType} from './types';
+
+export async function* getPullRequests(
+ client: ClientType,
+ prNumbers: number[]
+) {
+ for (const prNumber of prNumbers) {
+ core.debug(`looking for pr #${prNumber}`);
+ let prData: any;
+ try {
+ const result = await client.rest.pulls.get({
+ owner: github.context.repo.owner,
+ repo: github.context.repo.repo,
+ pull_number: prNumber
+ });
+ prData = result.data;
+ } catch (error: any) {
+ core.warning(`Could not find pull request #${prNumber}, skipping`);
+ continue;
+ }
+
+ core.debug(`fetching changed files for pr #${prNumber}`);
+ const changedFiles: string[] = await getChangedFiles(client, prNumber);
+ if (!changedFiles.length) {
+ core.warning(`Pull request #${prNumber} has no changed files, skipping`);
+ continue;
+ }
+
+ yield {
+ data: prData,
+ number: prNumber,
+ changedFiles
+ };
+ }
+}

src/api/get-content.ts

@@ -0,0 +1,16 @@
+import * as github from '@actions/github';
+import {ClientType} from './types';
+
+export const getContent = async (
+ client: ClientType,
+ repoPath: string
+): Promise<string> => {
+ const response: any = await client.rest.repos.getContent({
+ owner: github.context.repo.owner,
+ repo: github.context.repo.repo,
+ path: repoPath,
+ ref: github.context.sha
+ });
+
+ return Buffer.from(response.data.content, response.data.encoding).toString();
+};

src/api/get-label-globs.ts

@@ -0,0 +1,70 @@
+import * as core from '@actions/core';
+import * as yaml from 'js-yaml';
+import fs from 'fs';
+import {ClientType} from './types';
+import {getContent} from './get-content';
+
+export interface MatchConfig {
+ all?: string[];
+ any?: string[];
+}
+
+export type StringOrMatchConfig = string | MatchConfig;
+
+export const getLabelGlobs = (
+ client: ClientType,
+ configurationPath: string
+): Promise<Map<string, StringOrMatchConfig[]>> =>
+ Promise.resolve()
+ .then(() => {
+ if (!fs.existsSync(configurationPath)) {
+ core.info(
+ `The configuration file (path: ${configurationPath}) was not found locally, fetching via the api`
+ );
+
+ return getContent(client, configurationPath);
+ }
+
+ core.info(
+ `The configuration file (path: ${configurationPath}) was found locally, reading from the file`
+ );
+
+ return fs.readFileSync(configurationPath, {
+ encoding: 'utf8'
+ });
+ })
+ .catch(error => {
+ if (error.name == 'HttpError' || error.name == 'NotFound') {
+ core.warning(
+ `The config file was not found at ${configurationPath}. Make sure it exists and that this action has the correct access rights.`
+ );
+ }
+ return Promise.reject(error);
+ })
+ .then(configuration => {
+ // loads (hopefully) a `{[label:string]: string | StringOrMatchConfig[]}`, but is `any`:
+ const configObject: any = yaml.load(configuration);
+
+ // transform `any` => `Map<string,StringOrMatchConfig[]>` or throw if yaml is malformed:
+ return getLabelGlobMapFromObject(configObject);
+ });
+
+function getLabelGlobMapFromObject(
+ configObject: any
+): Map<string, StringOrMatchConfig[]> {
+ const labelGlobs: Map<string, StringOrMatchConfig[]> = new Map();
+
+ for (const label in configObject) {
+ if (typeof configObject[label] === 'string') {
+ labelGlobs.set(label, [configObject[label]]);
+ } else if (configObject[label] instanceof Array) {
+ labelGlobs.set(label, configObject[label]);
+ } else {
+ throw Error(
+ `found unexpected type for label ${label} (should be string or array of globs)`
+ );
+ }
+ }
+
+ return labelGlobs;
+}

src/api/index.ts

@@ -0,0 +1,6 @@
+export * from './get-changed-files';
+export * from './get-changed-pull-requests';
+export * from './get-content';
+export * from './get-label-globs';
+export * from './set-labels';
+export * from './types';

src/api/set-labels.ts

@@ -0,0 +1,15 @@
+import * as github from '@actions/github';
+import {ClientType} from './types';
+
+export const setLabels = async (
+ client: ClientType,
+ prNumber: number,
+ labels: string[]
+) => {
+ await client.rest.issues.setLabels({
+ owner: github.context.repo.owner,
+ repo: github.context.repo.repo,
+ issue_number: prNumber,
+ labels: labels
+ });
+};

src/api/types.ts

@@ -0,0 +1,2 @@
+import * as github from '@actions/github';
+export type ClientType = ReturnType<typeof github.getOctokit>;

src/get-inputs/get-inputs.ts

@@ -0,0 +1,10 @@
+import * as core from '@actions/core';
+import {getPrNumbers} from './get-pr-numbers';
+
+export const getInputs = () => ({
+ token: core.getInput('repo-token'),
+ configPath: core.getInput('configuration-path', {required: true}),
+ syncLabels: !!core.getInput('sync-labels'),
+ dot: core.getBooleanInput('dot'),
+ prNumbers: getPrNumbers()
+});

src/get-inputs/get-pr-numbers.ts

@@ -0,0 +1,28 @@
+import * as core from '@actions/core';
+import * as github from '@actions/github';
+
+const getPrNumberFromContext = () =>
+ github.context.payload.pull_request?.number;
+
+export const getPrNumbers = (): number[] => {
+ const prInput = core.getMultilineInput('pr-number');
+
+ if (!prInput?.length) {
+ return [getPrNumberFromContext()].filter(Boolean) as number[];
+ }
+
+ const result: number[] = [];
+
+ for (const line of prInput) {
+ const prNumber = parseInt(line, 10);
+
+ if (isNaN(prNumber) && prNumber <= 0) {
+ core.warning(`'${prNumber}' is not a valid pull request number`);
+ continue;
+ }
+
+ result.push(prNumber);
+ }
+
+ return result;
+};

src/get-inputs/index.ts

@@ -0,0 +1 @@
+export * from './get-inputs';