Files
Michael Kriese f64ec3975a fix(cache): build all cache keys with a shared helper (#46811)
* refactor(datasource): separate registry URLs in cache keys with a colon

Co-Authored-By: Claude Opus 5.5 <michael.kriese+claude-code@mend.io>
Co-Authored-By: Claude Sonnet 5.5 <michael.kriese+claude-code@mend.io>

* fix(datasource/go): separate the remaining cache key parts with a colon

Co-Authored-By: Claude Opus 5.5 <michael.kriese+claude-code@mend.io>

* refactor(datasource): build cache keys with a shared colon-joining helper

Co-Authored-By: Claude Opus 5.5 <michael.kriese+claude-code@mend.io>

* refactor: build all cache keys with buildCacheKey

Co-Authored-By: Claude Opus 5.5 <michael.kriese+claude-code@mend.io>

* refactor(http): keep GET package cache keys as the bare URL

Co-Authored-By: Claude Opus 5.5 <michael.kriese+claude-code@mend.io>

* refactor(cache): extend cache key helper to memory cache keys

Co-Authored-By: Claude Opus 5.5 <michael.kriese+claude-code@mend.io>

* refactor(datasource/go): prefix the goproxy cache keys with their purpose

Co-Authored-By: Claude Opus 5.5 <michael.kriese+claude-code@mend.io>

---------

Co-authored-by: Claude Opus 5.5 <michael.kriese+claude-code@mend.io>
2026-10-10 10:46:09 +00:00

123 lines
3.7 KiB
TypeScript

import { buildCacheKey } from '../../../util/cache/package/key.ts';
import { asTimestamp } from '../../../util/timestamp.ts';
import * as Unity3dVersioning from '../../versioning/unity3d/index.ts';
import { Datasource } from '../datasource.ts';
import type { GetReleasesConfig, ReleaseResult } from '../types.ts';
import { UnityReleasesJSON } from './schema.ts';
export class Unity3dDatasource extends Datasource {
static readonly baseUrl =
'https://services.api.unity.com/unity/editor/release/v1/releases';
static readonly homepage = 'https://unity.com/';
static readonly streams: Record<string, string> = {
lts: `${Unity3dDatasource.baseUrl}?stream=LTS`,
tech: `${Unity3dDatasource.baseUrl}?stream=TECH`,
alpha: `${Unity3dDatasource.baseUrl}?stream=ALPHA`,
beta: `${Unity3dDatasource.baseUrl}?stream=BETA`,
};
static readonly legacyStreams: Record<string, string> = {
lts: `${Unity3dDatasource.homepage}releases/editor/lts-releases.xml`,
stable: `${Unity3dDatasource.homepage}releases/editor/releases.xml`,
beta: `${Unity3dDatasource.homepage}releases/editor/beta/latest.xml`,
};
static readonly limit: number = 25;
static readonly id = 'unity3d';
override getDefaultRegistryUrls(_packageName: string): string[] {
return [Unity3dDatasource.streams.lts];
}
override readonly defaultVersioning = Unity3dVersioning.id;
override readonly registryStrategy = 'merge';
override readonly releaseTimestampSupport = true;
override readonly releaseTimestampNote =
'The release timestamp is determined from the `releaseDate` field in the results.';
constructor() {
super(Unity3dDatasource.id);
}
translateStream(registryUrl: string): string {
const legacyKey = Object.keys(Unity3dDatasource.legacyStreams).find(
(key) => Unity3dDatasource.legacyStreams[key] === registryUrl,
);
if (legacyKey) {
if (legacyKey === 'stable') {
return Unity3dDatasource.streams.lts;
}
return Unity3dDatasource.streams[legacyKey];
}
return registryUrl;
}
async getByStream(
registryUrl: string | undefined,
withHash: boolean,
): Promise<ReleaseResult | null> {
const translatedRegistryUrl = this.translateStream(registryUrl!);
const isStable: boolean =
translatedRegistryUrl === Unity3dDatasource.streams.lts;
let total: number | null = null;
const result: ReleaseResult = {
releases: [],
homepage: Unity3dDatasource.homepage,
registryUrl: translatedRegistryUrl,
};
for (
let offset = 0;
total === null || offset < total;
offset += Unity3dDatasource.limit
) {
const response = await this.http.getJson(
`${translatedRegistryUrl}&limit=${Unity3dDatasource.limit}&offset=${offset}`,
UnityReleasesJSON,
);
for (const release of response.body.results) {
result.releases.push({
version: withHash
? `${release.version} (${release.shortRevision})`
: release.version,
releaseTimestamp: asTimestamp(release.releaseDate),
changelogUrl: release.releaseNotes.url,
isStable,
});
}
total ??= response.body.total;
}
return result;
}
private async fetchReleases({
packageName,
registryUrl,
}: GetReleasesConfig): Promise<ReleaseResult | null> {
return await this.getByStream(
registryUrl,
packageName === 'm_EditorVersionWithRevision',
);
}
getReleases(config: GetReleasesConfig): Promise<ReleaseResult | null> {
return this.cached(
{
key: buildCacheKey(config.registryUrl, config.packageName),
fallback: true,
},
() => this.fetchReleases(config),
);
}
}