@octokit/app - npm Package Compare versions

Comparing version 10.0.3 to 10.1.0

dist-node/index.js

@@ -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

dist-src/each-repository.js

@@ -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) {

dist-src/version.js

@@ -1,1 +0,1 @@
-export const VERSION = "10.0.3";
+export const VERSION = "10.1.0";

dist-types/each-repository.d.ts

 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;

dist-types/types.d.ts

@@ -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 {

dist-types/version.d.ts

@@ -1,1 +0,1 @@
-export declare const VERSION = "10.0.3";
+export declare const VERSION = "10.1.0";

package.json

 {
   "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": [

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

63916

increased by4.06%

Lines of code

990

increased by3.77%

No dependency changes