yusufipek/OpenFrame
1
0
Fork 0
mirror of https://github.com/yusufipk/OpenFrame.git synced 2026-09-11 09:36:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(scripts): count a Bunny id referenced by url, not only by column

Browse Source 
A Bunny guid is stored twice per row: in `VideoVersion.videoId` and
`VideoAsset.providerVideoId` on its own, and inside `originalUrl` / `sourceUrl`
as `https://iframe.mediadelivery.net/embed/<library>/<guid>`. The lookup read
only the id columns.

They are written together so they normally agree, but this query decides what
gets deleted. A row whose id column was left empty or drifted while its url
still carried the guid would present a live video as an orphan, and the script
would delete media the product is still serving. Reading both makes a
disagreement harmless instead of destructive.

Bunny rows are now read in one pass rather than filtered per candidate id: the
url match is a substring test, and there are only as many of these rows as there
are Bunny videos in the product, so one small scan beats a LIKE per id.
This commit is contained in:
yusufipk
2026-07-26 19:24:13 +07:00
parent c0e7211052
commit 4e60b61edb
1 changed files with 37 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/bunny-orphan-cleanup.ts
+37 -16
View File
@@ -166,32 +166,53 @@ function chunk<T>(items: T[], size: number): T[][] {
return out;
}
/**
* Every Bunny id the database still points at.
*
* A Bunny id is stored in two places per row, and both are checked. `VideoVersion.videoId`
* and `VideoAsset.providerVideoId` hold the guid on its own, while `originalUrl` and
* `sourceUrl` embed the same guid inside
* `https://iframe.mediadelivery.net/embed/<library>/<guid>`. They are written together, so
* they normally agree, but this decides what gets deleted: a row whose id column was left
* empty or drifted while its url still carried the guid would make a live video look
* orphaned. Reading both makes disagreement harmless rather than destructive.
*/
async function findReferencedVideoIds(videoIds: string[]): Promise<Set<string>> {
const referenced = new Set<string>();
for (const group of chunk(videoIds, CHUNK_SIZE)) {
const [versionRows, assetRows] = await Promise.all([
db.videoVersion.findMany({
where: {
providerId: 'bunny',
videoId: { in: group },
},
select: { videoId: true },
where: { providerId: 'bunny' },
select: { videoId: true, originalUrl: true },
}),
db.videoAsset.findMany({
where: {
provider: 'BUNNY',
providerVideoId: { in: group },
},
select: { providerVideoId: true },
where: { provider: 'BUNNY' },
select: { providerVideoId: true, sourceUrl: true },
}),
]);
versionRows.forEach((row) => {
if (row.videoId) referenced.add(row.videoId);
});
assetRows.forEach((row) => {
if (row.providerVideoId) referenced.add(row.providerVideoId);
});
// Every Bunny row is read rather than filtered by id, because the url has to be
// searched for a guid it merely contains. There are as many of these rows as there
// are Bunny videos in the product, so this is one small scan instead of one LIKE per
// candidate id.
const ids = new Set(group);
const urls: string[] = [];
for (const row of versionRows) {
if (row.videoId && ids.has(row.videoId)) referenced.add(row.videoId);
if (row.originalUrl) urls.push(row.originalUrl);
}
for (const row of assetRows) {
if (row.providerVideoId && ids.has(row.providerVideoId)) referenced.add(row.providerVideoId);
if (row.sourceUrl) urls.push(row.sourceUrl);
}
for (const url of urls) {
for (const id of group) {
if (!referenced.has(id) && url.includes(id)) referenced.add(id);
}
}
}
return referenced;