diff --git a/app/pages/package/[[org]]/[name]/versions.vue b/app/pages/package/[[org]]/[name]/versions.vue index 8a3b9c507..5bb6bbff1 100644 --- a/app/pages/package/[[org]]/[name]/versions.vue +++ b/app/pages/package/[[org]]/[name]/versions.vue @@ -17,6 +17,15 @@ definePageMeta({ name: 'package-versions', }) +interface NpmWebsiteVersionDownload { + version: string + downloads: number +} + +interface NpmWebsiteVersionsResponse { + versions: NpmWebsiteVersionDownload[] +} + /** Number of flat items (headers + version rows) to render statically during SSR */ const SSR_COUNT = 20 @@ -49,6 +58,47 @@ const distTags = computed(() => versionSummary.value?.distTags ?? {}) const versionStrings = computed(() => versionSummary.value?.versions ?? []) const versionTimes = computed(() => versionSummary.value?.time ?? {}) +const { data: npmWebsiteVersions } = useLazyFetch( + () => `/api/registry/npmjs-versions/${encodeURIComponent(packageName.value)}`, + { + key: () => `npmjs-versions:${packageName.value}`, + deep: false, + default: () => ({ versions: [] }), + getCachedData(key, nuxtApp) { + return nuxtApp.static.data[key] ?? nuxtApp.payload.data[key] + }, + }, +) + +const numberFormatter = useNumberFormatter() +const versionDownloadsMap = computed( + () => + new Map( + (npmWebsiteVersions.value?.versions ?? []).map(({ version, downloads }) => [ + version, + downloads, + ]), + ), +) + +function getVersionDownloads(version: string): number | undefined { + return versionDownloadsMap.value.get(version) +} + +function getGroupDownloads(versions: string[]): number | undefined { + let total = 0 + let hasValue = false + + for (const version of versions) { + const downloads = getVersionDownloads(version) + if (downloads === undefined) continue + total += downloads + hasValue = true + } + + return hasValue ? total : undefined +} + // ─── Phase 2: full metadata (loaded on first group expand) ──────────────────── // Fetches deprecated status, provenance, and exact times needed for version rows. @@ -241,6 +291,14 @@ const flatItems = computed(() => { > +
+ {{ numberFormatter.format(getVersionDownloads(latestTagRow!.version)!) }} +
(() => { + + {{ numberFormatter.format(getVersionDownloads(row.version)!) }} + (() => { {{ item.label }} ({{ item.versions.length }}) - + + {{ numberFormatter.format(getGroupDownloads(item.versions)!) }} + + {{ item.versions[0] }} (() => {
+ + {{ numberFormatter.format(getVersionDownloads(item.version)!) }} + -
+
(() => { {{ item.label }} ({{ item.versions.length }}) - + + {{ numberFormatter.format(getGroupDownloads(item.versions)!) }} + + {{ item.versions[0] }} { + const pkgParam = getRouterParam(event, 'pkg') + if (!pkgParam) { + throw createError({ statusCode: 404, message: 'Package name is required' }) + } + + const packageName = decodeURIComponent(pkgParam) + + try { + const versions = await fetchNpmVersionDownloadsFromApi(packageName) + + return { + packageName, + versions, + } + } catch (error: unknown) { + handleApiError(error, { + statusCode: 502, + message: 'Failed to fetch version download data from npm API', + }) + } + }, + { + maxAge: CACHE_MAX_AGE_ONE_HOUR, + swr: true, + getKey: event => { + const pkg = getRouterParam(event, 'pkg') ?? '' + return `npmjs-versions:v2:${pkg}` + }, + }, +) diff --git a/server/utils/npm-website-versions.ts b/server/utils/npm-website-versions.ts new file mode 100644 index 000000000..cc6fcf5bf --- /dev/null +++ b/server/utils/npm-website-versions.ts @@ -0,0 +1,37 @@ +export interface NpmWebsiteVersionDownload { + version: string + downloads: number +} + +interface NpmApiVersionDownloadsResponse { + downloads: Record +} + +export async function fetchNpmVersionDownloadsFromApi( + packageName: string, +): Promise { + const encodedName = encodePackageName(packageName) + + const versionsResponse = await fetch(`https://api.npmjs.org/versions/${encodedName}/last-week`) + + if (!versionsResponse.ok) { + if (versionsResponse.status === 404) { + throw createError({ + statusCode: 404, + message: 'Package not found', + }) + } + + throw createError({ + statusCode: 502, + message: 'Failed to fetch version download data from npm API', + }) + } + + const versionsData = (await versionsResponse.json()) as NpmApiVersionDownloadsResponse + + return Object.entries(versionsData.downloads).map(([version, downloads]) => ({ + version, + downloads, + })) +}