in packages/app/src/cloudwatch.ts [66:92]
export async function unsubscribeGroups(
cloudwatchLogs: CloudWatchLogs,
groups: LogGroup[],
filterName: string,
): Promise<void> {
await Promise.all(
groups.map(async (group) => {
const subscriptions = await getSubscriptions(
cloudwatchLogs,
group.logGroupName!,
filterName,
);
for (const subscription of subscriptions) {
if (subscription.filterName === filterName) {
console.log(
`Removing subscription for ${group.logGroupName!} with name ${filterName}`,
);
await deleteSubscription(
cloudwatchLogs,
group.logGroupName!,
filterName,
);
}
}
}),
);
}