transfer-out: transfer out

scripts/lib/publishing.ts

@@ -0,0 +1,144 @@
+import { execSync } from 'child_process'
+import { fetch } from 'cross-fetch'
+import { existsSync, readdirSync, readFileSync, writeFileSync } from 'fs'
+import path from 'path'
+import { compare, parse } from 'semver'
+
+export type PackageDetails = {
+	name: string
+	dir: string
+	localDeps: string[]
+	version: string
+}
+
+function getPackageDetails(dir: string): PackageDetails | null {
+	const packageJsonPath = path.join(dir, 'package.json')
+	if (!existsSync(packageJsonPath)) {
+		return null
+	}
+	const packageJson = JSON.parse(readFileSync(path.join(dir, 'package.json'), 'utf8'))
+	if (packageJson.private) {
+		return null
+	}
+	return {
+		name: packageJson.name,
+		dir,
+		version: packageJson.version,
+		localDeps: Object.keys(packageJson.dependencies ?? {}).filter((dep) =>
+			dep.startsWith('@tldraw')
+		),
+	}
+}
+
+export function getAllPackageDetails(): Record<string, PackageDetails> {
+	const dirs = readdirSync('bublic/packages')
+	const results = dirs
+		.map((dir) => getPackageDetails(path.join('bublic/packages', dir)))
+		.filter((x): x is PackageDetails => Boolean(x))
+
+	return Object.fromEntries(results.map((result) => [result.name, result]))
+}
+
+export function setAllVersions(version: string) {
+	const packages = getAllPackageDetails()
+	for (const packageDetails of Object.values(packages)) {
+		const manifest = JSON.parse(readFileSync(path.join(packageDetails.dir, 'package.json'), 'utf8'))
+		manifest.version = version
+		writeFileSync(
+			path.join(packageDetails.dir, 'package.json'),
+			JSON.stringify(manifest, null, '\t') + '\n'
+		)
+	}
+
+	const lernaJson = JSON.parse(readFileSync('lerna.json', 'utf8'))
+	lernaJson.version = version
+	writeFileSync('lerna.json', JSON.stringify(lernaJson, null, '\t') + '\n')
+
+	execSync('yarn')
+}
+
+export function getLatestVersion() {
+	const packages = getAllPackageDetails()
+
+	const allVersions = Object.values(packages).map((p) => parse(p.version)!)
+	allVersions.sort(compare)
+
+	const latestVersion = allVersions[allVersions.length - 1]
+
+	if (!latestVersion) {
+		throw new Error('Could not find latest version')
+	}
+
+	return latestVersion
+}
+
+function topologicalSortPackages(packages: Record<string, PackageDetails>) {
+	const sorted: PackageDetails[] = []
+	const visited = new Set<string>()
+
+	function visit(packageName: string, path: string[]) {
+		if (visited.has(packageName)) {
+			return
+		}
+		visited.add(packageName)
+		const packageDetails = packages[packageName]
+		if (!packageDetails) {
+			throw new Error(`Could not find package ${packageName}. path: ${path.join(' -> ')}`)
+		}
+		packageDetails.localDeps.forEach((dep) => visit(dep, [...path, dep]))
+		sorted.push(packageDetails)
+	}
+
+	Object.keys(packages).forEach((packageName) => visit(packageName, [packageName]))
+
+	return sorted
+}
+
+export async function publish() {
+	const npmToken = process.env.NPM_TOKEN
+	if (!npmToken) {
+		throw new Error('NPM_TOKEN not set')
+	}
+
+	execSync(`yarn config set npmAuthToken ${npmToken}`, { stdio: 'inherit' })
+	execSync(`yarn config set npmRegistryServer https://registry.npmjs.org`, { stdio: 'inherit' })
+
+	const packages = getAllPackageDetails()
+
+	const publishOrder = topologicalSortPackages(packages)
+
+	for (const packageDetails of publishOrder) {
+		const prereleaseTag = parse(packageDetails.version)?.prerelease[0] ?? 'latest'
+		console.log(
+			`Publishing ${packageDetails.name} with version ${packageDetails.version} under tag @${prereleaseTag}`
+		)
+
+		execSync(`yarn npm publish --tag ${prereleaseTag} --tolerate-republish --access public`, {
+			stdio: 'inherit',
+			cwd: packageDetails.dir,
+		})
+		let waitAttempts = 10
+
+		loop: while (waitAttempts > 0) {
+			try {
+				// fetch the new package directly from the npm registry
+				const newVersion = packageDetails.version
+				const unscopedName = packageDetails.name.replace('@tldraw/', '')
+
+				const url = `https://registry.npmjs.org/@tldraw/${unscopedName}/-/${unscopedName}-${newVersion}.tgz`
+				console.log('looking for package at url: ', url)
+				const res = await fetch(url, {
+					method: 'HEAD',
+				})
+				if (res.status >= 400) {
+					throw new Error(`Package not found: ${res.status}`)
+				}
+				break loop
+			} catch (e) {
+				console.log('Waiting for package to be published... attemptsRemaining', waitAttempts)
+				waitAttempts--
+				await new Promise((resolve) => setTimeout(resolve, 3000))
+			}
+		}
+	}
+}