@octokit/webhooks
Advanced tools
Comparing version 12.0.4 to 12.0.5
@@ -469,2 +469,3 @@ "use strict"; | ||
// pkg/dist-src/verify-and-receive.js | ||
var import_aggregate_error2 = __toESM(require("aggregate-error")); | ||
var import_webhooks_methods = require("@octokit/webhooks-methods"); | ||
@@ -485,6 +486,14 @@ async function verifyAndReceive(state, event) { | ||
} | ||
let payload; | ||
try { | ||
payload = JSON.parse(event.payload); | ||
} catch (error) { | ||
error.message = "Invalid JSON"; | ||
error.status = 400; | ||
throw new import_aggregate_error2.default([error]); | ||
} | ||
return state.eventHandler.receive({ | ||
id: event.id, | ||
name: event.name, | ||
payload: JSON.parse(event.payload) | ||
payload | ||
}); | ||
@@ -504,3 +513,3 @@ } | ||
// pkg/dist-src/middleware/node/get-payload.js | ||
var import_aggregate_error2 = __toESM(require("aggregate-error")); | ||
var import_aggregate_error3 = __toESM(require("aggregate-error")); | ||
function getPayload(request) { | ||
@@ -512,14 +521,5 @@ if (request.body) | ||
request.setEncoding("utf8"); | ||
request.on("error", (error) => reject(new import_aggregate_error2.default([error]))); | ||
request.on("error", (error) => reject(new import_aggregate_error3.default([error]))); | ||
request.on("data", (chunk) => data += chunk); | ||
request.on("end", () => { | ||
try { | ||
JSON.parse(data); | ||
resolve(data); | ||
} catch (error) { | ||
error.message = "Invalid JSON"; | ||
error.status = 400; | ||
reject(new import_aggregate_error2.default([error])); | ||
} | ||
}); | ||
request.on("end", () => resolve(data)); | ||
}); | ||
@@ -526,0 +526,0 @@ } |
@@ -10,12 +10,3 @@ import AggregateError from "aggregate-error"; | ||
request.on("data", (chunk) => data += chunk); | ||
request.on("end", () => { | ||
try { | ||
JSON.parse(data); | ||
resolve(data); | ||
} catch (error) { | ||
error.message = "Invalid JSON"; | ||
error.status = 400; | ||
reject(new AggregateError([error])); | ||
} | ||
}); | ||
request.on("end", () => resolve(data)); | ||
}); | ||
@@ -22,0 +13,0 @@ } |
@@ -0,1 +1,2 @@ | ||
import AggregateError from "aggregate-error"; | ||
import { verify } from "@octokit/webhooks-methods"; | ||
@@ -16,6 +17,14 @@ async function verifyAndReceive(state, event) { | ||
} | ||
let payload; | ||
try { | ||
payload = JSON.parse(event.payload); | ||
} catch (error) { | ||
error.message = "Invalid JSON"; | ||
error.status = 400; | ||
throw new AggregateError([error]); | ||
} | ||
return state.eventHandler.receive({ | ||
id: event.id, | ||
name: event.name, | ||
payload: JSON.parse(event.payload) | ||
payload | ||
}); | ||
@@ -22,0 +31,0 @@ } |
import type { EmitterWebhookEventWithStringPayloadAndSignature, State } from "./types"; | ||
export declare function verifyAndReceive(state: State & { | ||
secret: string; | ||
}, event: EmitterWebhookEventWithStringPayloadAndSignature): Promise<any>; | ||
}, event: EmitterWebhookEventWithStringPayloadAndSignature): Promise<void>; |
@@ -430,2 +430,3 @@ // pkg/dist-src/createLogger.js | ||
// pkg/dist-src/verify-and-receive.js | ||
import AggregateError2 from "aggregate-error"; | ||
import { verify } from "@octokit/webhooks-methods"; | ||
@@ -446,6 +447,14 @@ async function verifyAndReceive(state, event) { | ||
} | ||
let payload; | ||
try { | ||
payload = JSON.parse(event.payload); | ||
} catch (error) { | ||
error.message = "Invalid JSON"; | ||
error.status = 400; | ||
throw new AggregateError2([error]); | ||
} | ||
return state.eventHandler.receive({ | ||
id: event.id, | ||
name: event.name, | ||
payload: JSON.parse(event.payload) | ||
payload | ||
}); | ||
@@ -465,3 +474,3 @@ } | ||
// pkg/dist-src/middleware/node/get-payload.js | ||
import AggregateError2 from "aggregate-error"; | ||
import AggregateError3 from "aggregate-error"; | ||
function getPayload(request) { | ||
@@ -473,14 +482,5 @@ if (request.body) | ||
request.setEncoding("utf8"); | ||
request.on("error", (error) => reject(new AggregateError2([error]))); | ||
request.on("error", (error) => reject(new AggregateError3([error]))); | ||
request.on("data", (chunk) => data += chunk); | ||
request.on("end", () => { | ||
try { | ||
JSON.parse(data); | ||
resolve(data); | ||
} catch (error) { | ||
error.message = "Invalid JSON"; | ||
error.status = 400; | ||
reject(new AggregateError2([error])); | ||
} | ||
}); | ||
request.on("end", () => resolve(data)); | ||
}); | ||
@@ -487,0 +487,0 @@ } |
{ | ||
"name": "@octokit/webhooks", | ||
"version": "12.0.4", | ||
"version": "12.0.5", | ||
"description": "GitHub webhook events toolset for Node.js", | ||
@@ -5,0 +5,0 @@ "keywords": [], |
Sorry, the diff of this file is not supported yet
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
180902