@octokit/app
Advanced tools
Comparing version 10.0.3 to 10.1.0
@@ -189,3 +189,3 @@ 'use strict'; | ||
const VERSION = "10.0.3"; | ||
const VERSION = "10.1.0"; | ||
@@ -300,15 +300,35 @@ function webhooks(appOctokit, options) { | ||
} | ||
async function eachRepository(app, callback) { | ||
const i = eachRepositoryIterator(app)[Symbol.asyncIterator](); | ||
async function eachRepository(app, queryOrCallback, callback) { | ||
const i = eachRepositoryIterator(app, callback ? queryOrCallback : undefined)[Symbol.asyncIterator](); | ||
let result = await i.next(); | ||
while (!result.done) { | ||
await callback(result.value); | ||
if (callback) { | ||
await callback(result.value); | ||
} else { | ||
await queryOrCallback(result.value); | ||
} | ||
result = await i.next(); | ||
} | ||
} | ||
function eachRepositoryIterator(app) { | ||
function singleInstallationIterator(app, installationId) { | ||
return { | ||
[Symbol.asyncIterator]() { | ||
return _wrapAsyncGenerator(function* () { | ||
yield { | ||
octokit: yield _awaitAsyncGenerator(app.getInstallationOctokit(installationId)) | ||
}; | ||
})(); | ||
} | ||
}; | ||
} | ||
function eachRepositoryIterator(app, query) { | ||
return { | ||
[Symbol.asyncIterator]() { | ||
return _wrapAsyncGenerator(function* () { | ||
const iterator = query ? singleInstallationIterator(app, query.installationId) : app.eachInstallation.iterator(); | ||
var _iteratorNormalCompletion = true; | ||
@@ -320,3 +340,3 @@ var _didIteratorError = false; | ||
try { | ||
for (var _iterator = _asyncIterator(app.eachInstallation.iterator()), _step, _value; _step = yield _awaitAsyncGenerator(_iterator.next()), _iteratorNormalCompletion = _step.done, _value = yield _awaitAsyncGenerator(_step.value), !_iteratorNormalCompletion; _iteratorNormalCompletion = true) { | ||
for (var _iterator = _asyncIterator(iterator), _step, _value; _step = yield _awaitAsyncGenerator(_iterator.next()), _iteratorNormalCompletion = _step.done, _value = yield _awaitAsyncGenerator(_step.value), !_iteratorNormalCompletion; _iteratorNormalCompletion = true) { | ||
const { | ||
@@ -323,0 +343,0 @@ octokit |
@@ -7,14 +7,31 @@ import { composePaginateRest } from "@octokit/plugin-paginate-rest"; | ||
} | ||
export async function eachRepository(app, callback) { | ||
const i = eachRepositoryIterator(app)[Symbol.asyncIterator](); | ||
export async function eachRepository(app, queryOrCallback, callback) { | ||
const i = eachRepositoryIterator(app, callback ? queryOrCallback : undefined)[Symbol.asyncIterator](); | ||
let result = await i.next(); | ||
while (!result.done) { | ||
await callback(result.value); | ||
if (callback) { | ||
await callback(result.value); | ||
} | ||
else { | ||
await queryOrCallback(result.value); | ||
} | ||
result = await i.next(); | ||
} | ||
} | ||
export function eachRepositoryIterator(app) { | ||
function singleInstallationIterator(app, installationId) { | ||
return { | ||
async *[Symbol.asyncIterator]() { | ||
for await (const { octokit } of app.eachInstallation.iterator()) { | ||
yield { | ||
octokit: await app.getInstallationOctokit(installationId), | ||
}; | ||
}, | ||
}; | ||
} | ||
export function eachRepositoryIterator(app, query) { | ||
return { | ||
async *[Symbol.asyncIterator]() { | ||
const iterator = query | ||
? singleInstallationIterator(app, query.installationId) | ||
: app.eachInstallation.iterator(); | ||
for await (const { octokit } of iterator) { | ||
const repositoriesIterator = composePaginateRest.iterator(octokit, "GET /installation/repositories"); | ||
@@ -21,0 +38,0 @@ for await (const { data: repositories } of repositoriesIterator) { |
@@ -1,1 +0,1 @@ | ||
export const VERSION = "10.0.3"; | ||
export const VERSION = "10.1.0"; |
import { App } from "./index"; | ||
import { EachRepositoryFunction, EachRepositoryInterface } from "./types"; | ||
import { EachRepositoryFunction, EachRepositoryInterface, EachRepositoryQuery } from "./types"; | ||
export declare function eachRepositoryFactory(app: App): EachRepositoryInterface; | ||
export declare function eachRepository(app: App, callback: EachRepositoryFunction): Promise<void>; | ||
export declare function eachRepositoryIterator(app: App): { | ||
export declare function eachRepository(app: App, queryOrCallback: EachRepositoryQuery | EachRepositoryFunction, callback?: EachRepositoryFunction): Promise<void>; | ||
export declare function eachRepositoryIterator(app: App, query?: EachRepositoryQuery): { | ||
[Symbol.asyncIterator](): AsyncGenerator<{ | ||
@@ -7,0 +7,0 @@ octokit: import("@octokit/core").Octokit; |
@@ -35,5 +35,9 @@ import { Octokit } from "@octokit/core"; | ||
export declare type EachRepositoryFunction = (options: EachRepositoryFunctionOptions) => unknown | Promise<unknown>; | ||
export declare type EachRepositoryQuery = { | ||
installationId: number; | ||
}; | ||
export interface EachRepositoryInterface { | ||
(callback: EachRepositoryFunction): Promise<void>; | ||
iterator: () => AsyncIterable<EachRepositoryFunctionOptions>; | ||
(query: EachRepositoryQuery, callback: EachRepositoryFunction): Promise<void>; | ||
iterator: (query?: EachRepositoryQuery) => AsyncIterable<EachRepositoryFunctionOptions>; | ||
} | ||
@@ -40,0 +44,0 @@ export interface GetInstallationOctokitInterface { |
@@ -1,1 +0,1 @@ | ||
export declare const VERSION = "10.0.3"; | ||
export declare const VERSION = "10.1.0"; |
{ | ||
"name": "@octokit/app", | ||
"description": "GitHub Apps toolset for Node.js", | ||
"version": "10.0.3", | ||
"version": "10.1.0", | ||
"license": "MIT", | ||
@@ -6,0 +6,0 @@ "files": [ |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
63916
990