fix: clear cache for organizations when subscriptions updates
This commit is contained in:
@@ -1,6 +1,6 @@
|
|||||||
import fs from 'node:fs';
|
import fs from 'node:fs';
|
||||||
import path from 'node:path';
|
import path from 'node:path';
|
||||||
import { db } from '@openpanel/db';
|
import { db, getOrganizationByProjectIdCached } from '@openpanel/db';
|
||||||
import {
|
import {
|
||||||
sendSlackNotification,
|
sendSlackNotification,
|
||||||
slackInstaller,
|
slackInstaller,
|
||||||
@@ -201,6 +201,16 @@ export async function polarWebhook(
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const projects = await db.project.findMany({
|
||||||
|
where: {
|
||||||
|
organizationId: metadata.organizationId,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
for (const project of projects) {
|
||||||
|
await getOrganizationByProjectIdCached.clear(project.id);
|
||||||
|
}
|
||||||
|
|
||||||
await publishEvent('organization', 'subscription_updated', {
|
await publishEvent('organization', 'subscription_updated', {
|
||||||
organizationId: metadata.organizationId,
|
organizationId: metadata.organizationId,
|
||||||
});
|
});
|
||||||
|
|||||||
Reference in New Issue
Block a user