Josh Gross
94 lines
2.6 KiB
TypeScript
94 lines
2.6 KiB
TypeScript
import Webhook from "./webhook";
|
|
|
|
// Store any repeated body parameters in an array
|
|
// and replace them in the webhook with an index in the array
|
|
export function deduplicateWebhooks(webhooks: Record<string, Record<string, Webhook>>): any[] {
|
|
/**
|
|
* Build a map of all objects by name
|
|
*/
|
|
const objectsByName: Record<string, any[]> = {};
|
|
const objectCount: Record<string, number> = {};
|
|
|
|
for (const webhook of iterateWebhooks(webhooks)) {
|
|
for (const param of webhook.bodyParameters) {
|
|
objectsByName[param.name] ||= [];
|
|
const index = findOrAdd(param, objectsByName[param.name]);
|
|
const key = `${param.name}:${index}`;
|
|
objectCount[key] ||= 0;
|
|
objectCount[key]++;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Replace any duplicated body parameters with an index
|
|
*/
|
|
const duplicatedBodyParams: any[] = [];
|
|
const bodyParamIndexMap: Record<string, number> = {};
|
|
|
|
for (const webhook of iterateWebhooks(webhooks)) {
|
|
const newParams: any[] = [];
|
|
for (const param of webhook.bodyParameters) {
|
|
const index = find(param, objectsByName[param.name]);
|
|
const key = `${param.name}:${index}`;
|
|
if (objectCount[key] > 1) {
|
|
newParams.push(indexForParam(param, index, bodyParamIndexMap, duplicatedBodyParams));
|
|
} else {
|
|
// If an object is only used once, keep it inline
|
|
newParams.push(param);
|
|
}
|
|
}
|
|
|
|
webhook.bodyParameters = newParams;
|
|
}
|
|
|
|
return duplicatedBodyParams;
|
|
}
|
|
|
|
function* iterateWebhooks(webhooks: Record<string, Record<string, Webhook>>) {
|
|
for (const webhookActions of Object.values(webhooks)) {
|
|
for (const webhook of Object.values(webhookActions)) {
|
|
yield webhook;
|
|
}
|
|
}
|
|
}
|
|
|
|
function findOrAdd(param: any, objects: any[]): number {
|
|
for (const [index, object] of objects.entries()) {
|
|
if (JSON.stringify(object) === JSON.stringify(param)) {
|
|
return index;
|
|
}
|
|
}
|
|
|
|
return objects.push(param) - 1;
|
|
}
|
|
|
|
function find(param: any, objects: any[]): number {
|
|
for (const [index, object] of objects.entries()) {
|
|
if (JSON.stringify(object) === JSON.stringify(param)) {
|
|
return index;
|
|
}
|
|
}
|
|
|
|
throw new Error(`Could not find object ${param.name}`);
|
|
}
|
|
|
|
function indexForParam(
|
|
param: any,
|
|
paramNameIndex: number,
|
|
objectIndexMap: Record<string, number>,
|
|
duplicatedBodyParams: any[]
|
|
): number {
|
|
const key = `${param.name}:${paramNameIndex}`;
|
|
|
|
const existingIndex = objectIndexMap[key];
|
|
if (existingIndex !== undefined) {
|
|
// Object has already been added to the array
|
|
return existingIndex;
|
|
}
|
|
|
|
// Add the object to the array
|
|
const objIdx = duplicatedBodyParams.push(param) - 1;
|
|
objectIndexMap[key] = objIdx;
|
|
return objIdx;
|
|
}
|