| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676 |
- #!/usr/bin/env node
- import { randomUUID } from 'node:crypto'
- import { existsSync, lstatSync, mkdirSync, readdirSync, readFileSync, unlinkSync, writeFileSync } from 'node:fs'
- import { spawnSync } from 'node:child_process'
- import { dirname, isAbsolute, join, resolve } from 'node:path'
- const MINIMUM_GIT = [2, 26, 0]
- const HOOKS_DIRECTORY = 'dsh-hooks'
- const OWNERSHIP_MARKER = '.dsh-lefthook-owned'
- const OWNERSHIP_MARKER_CONTENT = 'deepseek-harness worktree-local lefthook hooks\n'
- const INSTALL_LOCK = 'dsh-lefthook-install.lock'
- const INSTALL_LOCK_TIMEOUT_MS = 30_000
- const INSTALL_LOCK_POLL_MS = 50
- const ALLOW_HOOKS_PATH_OVERRIDE = 'DSH_LEFTHOOK_ALLOW_HOOKS_PATH_OVERRIDE'
- const CONDITIONAL_INCLUDE_PATTERN = '^includeif\\..*\\.path$'
- function errorCode(error) {
- return typeof error === 'object' && error !== null && 'code' in error
- ? error.code
- : undefined
- }
- function commandFailure(command, args, result) {
- const stderr = typeof result.stderr === 'string' ? result.stderr.trim() : ''
- const detail = result.error?.message ?? (stderr || `exit status ${String(result.status)}`)
- return new Error(`${command} ${args.join(' ')} failed: ${detail}`)
- }
- function capture(command, args, options = {}) {
- const result = spawnSync(command, args, {
- cwd: options.cwd,
- encoding: 'utf8',
- env: process.env,
- })
- if (result.status !== 0 && !options.allowStatuses?.includes(result.status)) {
- throw commandFailure(command, args, result)
- }
- return result
- }
- function git(args, root, options = {}) {
- return capture('git', args, { ...options, cwd: root })
- }
- function nulValues(result) {
- if (result.status !== 0) return []
- if (result.stdout === '') return ['']
- const output = result.stdout.endsWith('\0') ? result.stdout.slice(0, -1) : result.stdout
- return output.split('\0')
- }
- function stripGitLineTerminator(output) {
- const withoutLineFeed = output.endsWith('\n') ? output.slice(0, -1) : output
- return process.platform === 'win32' && withoutLineFeed.endsWith('\r')
- ? withoutLineFeed.slice(0, -1)
- : withoutLineFeed
- }
- function fileConfigValues(root, configPath, key) {
- return nulValues(git(
- ['config', '--file', configPath, '--null', '--get-all', key],
- root,
- { allowStatuses: [1] },
- ))
- }
- function fileConfigEntries(root, configPath, key) {
- const fields = nulValues(git(
- ['config', '--file', configPath, '--includes', '--null', '--show-origin', '--get-all', key],
- root,
- { allowStatuses: [1] },
- ))
- if (fields.length % 2 !== 0) {
- throw new Error(`git config returned invalid file entries for ${key}`)
- }
- const entries = []
- for (let index = 0; index < fields.length; index += 2) {
- entries.push({ origin: fields[index], value: fields[index + 1] })
- }
- return entries
- }
- function splitConfigNameValue(field, pattern) {
- const separator = field.indexOf('\n')
- if (separator < 0) throw new Error(`git config returned an invalid name and value for ${pattern}`)
- return { name: field.slice(0, separator), value: field.slice(separator + 1) }
- }
- function fileConfigMatchingEntries(root, configPath, pattern) {
- const fields = nulValues(git(
- ['config', '--file', configPath, '--includes', '--null', '--show-origin', '--get-regexp', pattern],
- root,
- { allowStatuses: [1] },
- ))
- if (fields.length % 2 !== 0) {
- throw new Error(`git config returned invalid matching file entries for ${pattern}`)
- }
- const entries = []
- for (let index = 0; index < fields.length; index += 2) {
- entries.push({ origin: fields[index], ...splitConfigNameValue(fields[index + 1], pattern) })
- }
- return entries
- }
- function scopedConfigMatchingEntries(root, pattern) {
- const fields = nulValues(git(
- ['config', '--includes', '--null', '--show-scope', '--show-origin', '--get-regexp', pattern],
- root,
- { allowStatuses: [1] },
- ))
- if (fields.length % 3 !== 0) {
- throw new Error(`git config returned invalid scoped entries for ${pattern}`)
- }
- const entries = []
- for (let index = 0; index < fields.length; index += 3) {
- entries.push({
- scope: fields[index],
- origin: fields[index + 1],
- ...splitConfigNameValue(fields[index + 2], pattern),
- })
- }
- return entries
- }
- function effectiveConfigEntry(root, key) {
- const fields = nulValues(git(
- ['config', '--null', '--show-scope', '--show-origin', '--get', key],
- root,
- { allowStatuses: [1] },
- ))
- if (fields.length === 0) return undefined
- if (fields.length !== 3) {
- throw new Error(`git config returned an invalid scoped value for ${key}`)
- }
- const [scope, origin, value] = fields
- return { origin, scope, value }
- }
- function parseGitBoolean(value, key) {
- const normalized = value.toLowerCase()
- if (normalized === '' || normalized === 'true' || normalized === 'yes' || normalized === 'on' || normalized === '1') return true
- if (normalized === 'false' || normalized === 'no' || normalized === 'off' || normalized === '0') return false
- throw new Error(`invalid Boolean value for ${key}: ${JSON.stringify(value)}`)
- }
- function assertSingle(values, key) {
- if (values.length > 1) throw new Error(`multiple ${key} values are not supported`)
- return values[0]
- }
- function worktreeConfigExtensionEnabled(root, commonConfigPath) {
- const extensionText = assertSingle(
- fileConfigValues(root, commonConfigPath, 'extensions.worktreeConfig'),
- 'extensions.worktreeConfig',
- )
- return extensionText === undefined
- ? false
- : parseGitBoolean(extensionText, 'extensions.worktreeConfig')
- }
- function hasDirectConfigEntries(root, configPath) {
- return git(['config', '--file', configPath, '--null', '--list'], root).stdout !== ''
- }
- function registeredWorktreeConfigPaths(commonDirectory) {
- const paths = [join(commonDirectory, 'config.worktree')]
- const linkedDirectory = join(commonDirectory, 'worktrees')
- try {
- const entries = readdirSync(linkedDirectory, { withFileTypes: true })
- .sort((left, right) => left.name.localeCompare(right.name))
- for (const entry of entries) {
- paths.push(join(linkedDirectory, entry.name, 'config.worktree'))
- }
- } catch (error) {
- if (errorCode(error) !== 'ENOENT') throw error
- }
- return paths
- }
- function assertDormantWorktreeConfigs(root, commonDirectory, commonConfigPath, currentConfigPath) {
- if (worktreeConfigExtensionEnabled(root, commonConfigPath)) return
- for (const configPath of registeredWorktreeConfigPaths(commonDirectory)) {
- if (!existsSync(configPath)) continue
- const configStat = lstatSync(configPath)
- if (!configStat.isFile() || configStat.isSymbolicLink()) {
- throw new Error(
- `cannot enable extensions.worktreeConfig while dormant worktree config ${JSON.stringify(configPath)} `
- + 'is not a regular file; inspect it and enable the extension explicitly, or remove it, before retrying',
- )
- }
- if (!hasDirectConfigEntries(root, configPath)) continue
- const isCurrent = normalizedPath(configPath) === normalizedPath(currentConfigPath)
- const owner = isCurrent ? 'current' : 'sibling'
- throw new Error(
- `cannot enable extensions.worktreeConfig while ${owner} dormant worktree config `
- + `${JSON.stringify(configPath)} contains user-owned settings that enabling the extension would activate; `
- + 'inspect and migrate those settings, then enable the extension explicitly or remove them before retrying',
- )
- }
- }
- function assertSupportedGit(root) {
- const version = git(['--version'], root).stdout.trim()
- const match = /git version (\d+)\.(\d+)(?:\.(\d+))?/.exec(version)
- if (match === null) throw new Error(`cannot determine Git version from ${JSON.stringify(version)}`)
- const actual = [Number(match[1]), Number(match[2]), Number(match[3] ?? 0)]
- for (let index = 0; index < MINIMUM_GIT.length; index += 1) {
- if (actual[index] > MINIMUM_GIT[index]) return
- if (actual[index] < MINIMUM_GIT[index]) {
- throw new Error(`Git 2.26 or newer is required for worktree-local hooks; found ${version}`)
- }
- }
- }
- function conditionalIncludeTarget(entry, root) {
- if (isAbsolute(entry.value)) return entry.value
- const sourcePath = configOriginPath(entry.origin, root)
- if (sourcePath === undefined) return undefined
- if (entry.value.startsWith('~/')) {
- const home = process.env.HOME
- return home === undefined ? undefined : resolve(home, entry.value.slice(2))
- }
- if (entry.value.startsWith('~') || entry.value.startsWith('%(')) return undefined
- return resolve(dirname(sourcePath), entry.value)
- }
- function inspectConditionalConfig(root, configPath, inspect, seen = new Set()) {
- const identity = normalizedPath(configPath)
- if (seen.has(identity)) return undefined
- seen.add(identity)
- if (!existsSync(configPath)) {
- return { configPath, detail: 'the included config does not exist and cannot be inspected' }
- }
- try {
- const subject = inspect(configPath)
- if (subject !== undefined) return { configPath, subject }
- for (const entry of fileConfigMatchingEntries(root, configPath, CONDITIONAL_INCLUDE_PATTERN)) {
- const target = conditionalIncludeTarget(entry, root)
- if (target === undefined) {
- return { configPath, detail: `the nested include path ${JSON.stringify(entry.value)} cannot be resolved safely` }
- }
- const nested = inspectConditionalConfig(root, target, inspect, seen)
- if (nested !== undefined) return nested
- }
- return undefined
- } catch (error) {
- return {
- configPath,
- detail: `the included config could not be inspected: ${error instanceof Error ? error.message : String(error)}`,
- }
- }
- }
- function conditionalIncludeRisk(root, entry, inspect) {
- const target = conditionalIncludeTarget(entry, root)
- if (target === undefined) {
- return { detail: `the include path ${JSON.stringify(entry.value)} cannot be resolved safely` }
- }
- return inspectConditionalConfig(root, target, inspect)
- }
- function migrationConfigSubject(root, configPath) {
- const worktreeEntry = fileConfigEntries(root, configPath, 'core.worktree')[0]
- if (worktreeEntry !== undefined) return `core.worktree (${configSource(worktreeEntry)})`
- const trueBareEntry = fileConfigEntries(root, configPath, 'core.bare')
- .find(entry => parseGitBoolean(entry.value, 'core.bare'))
- return trueBareEntry === undefined ? undefined : `core.bare=true (${configSource(trueBareEntry)})`
- }
- function hooksPathConfigSubject(root, configPath) {
- const entry = fileConfigEntries(root, configPath, 'core.hooksPath')[0]
- return entry === undefined ? undefined : `core.hooksPath (${configSource(entry)})`
- }
- function ensureWorktreeConfig(root, commonConfigPath) {
- const versions = fileConfigValues(root, commonConfigPath, 'core.repositoryFormatVersion')
- const versionText = assertSingle(versions, 'core.repositoryFormatVersion')
- const version = Number(versionText)
- if (!Number.isInteger(version) || version < 0) {
- throw new Error(`unsupported core.repositoryFormatVersion: ${JSON.stringify(versionText)}`)
- }
- const extensionEnabled = worktreeConfigExtensionEnabled(root, commonConfigPath)
- if (!extensionEnabled) {
- for (const entry of fileConfigMatchingEntries(root, commonConfigPath, CONDITIONAL_INCLUDE_PATTERN)) {
- const risk = conditionalIncludeRisk(
- root,
- entry,
- configPath => migrationConfigSubject(root, configPath),
- )
- if (risk !== undefined) {
- const reason = risk.subject ?? risk.detail
- throw new Error(
- `cannot enable extensions.worktreeConfig while common conditional include `
- + `${entry.origin}: ${entry.name}=${JSON.stringify(entry.value)} may provide migration-sensitive config (${reason}); `
- + 'audit and migrate it, then enable the extension explicitly',
- )
- }
- }
- }
- const worktreeEntry = fileConfigEntries(root, commonConfigPath, 'core.worktree')[0]
- if (worktreeEntry !== undefined) {
- throw new Error(
- `cannot enable extensions.worktreeConfig while core.worktree is in the common config (${configSource(worktreeEntry)}); `
- + 'move it to the main worktree config first',
- )
- }
- const bareEntries = fileConfigEntries(root, commonConfigPath, 'core.bare')
- const trueBareEntry = bareEntries.find(entry => parseGitBoolean(entry.value, 'core.bare'))
- if (trueBareEntry !== undefined) {
- throw new Error(
- `cannot enable extensions.worktreeConfig for a common config with core.bare=true (${configSource(trueBareEntry)})`,
- )
- }
- const directBareText = assertSingle(fileConfigValues(root, commonConfigPath, 'core.bare'), 'core.bare')
- const directBare = directBareText === undefined ? undefined : parseGitBoolean(directBareText, 'core.bare')
- if (version === 0) {
- git(['config', '--file', commonConfigPath, 'core.repositoryFormatVersion', '1'], root)
- }
- if (!extensionEnabled) {
- git(['config', '--file', commonConfigPath, 'extensions.worktreeConfig', 'true'], root)
- }
- if (directBare === false) {
- git(['config', '--file', commonConfigPath, '--unset-all', 'core.bare'], root)
- }
- }
- function readInstallLock(lockPath) {
- try {
- return readFileSync(lockPath, 'utf8')
- } catch (error) {
- if (errorCode(error) === 'ENOENT') return undefined
- throw error
- }
- }
- function installLockStat(lockPath) {
- try {
- return lstatSync(lockPath)
- } catch (error) {
- if (errorCode(error) === 'ENOENT') return undefined
- throw error
- }
- }
- function parseInstallLock(record) {
- const match = /^([1-9]\d*) ([0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12})\n$/i.exec(record)
- if (match === null) return undefined
- const owner = Number(match[1])
- return Number.isSafeInteger(owner) ? owner : undefined
- }
- function lockOwnerIsAlive(owner) {
- try {
- process.kill(owner, 0)
- return true
- } catch (error) {
- if (errorCode(error) === 'ESRCH') return false
- if (errorCode(error) === 'EPERM') return true
- throw error
- }
- }
- function manualLockRecoveryError(lockPath, condition) {
- return new Error(
- `${condition} Lefthook installer lock ${JSON.stringify(lockPath)}. `
- + 'Confirm no Lefthook installer is running, remove it manually, and retry.',
- )
- }
- function lockOwnershipChangedError(lockPath) {
- return new Error(`Lefthook installer lock ownership changed for ${lockPath}; refusing to remove it`)
- }
- function releaseInstallLock(lockPath, ownedRecord, ownedStat) {
- const currentStat = installLockStat(lockPath)
- if (
- currentStat === undefined
- || !currentStat.isFile()
- || currentStat.isSymbolicLink()
- || currentStat.dev !== ownedStat.dev
- || currentStat.ino !== ownedStat.ino
- || readInstallLock(lockPath) !== ownedRecord
- ) {
- throw lockOwnershipChangedError(lockPath)
- }
- try {
- unlinkSync(lockPath)
- } catch (error) {
- if (errorCode(error) === 'ENOENT') {
- throw lockOwnershipChangedError(lockPath)
- }
- throw error
- }
- }
- async function acquireInstallLock(commonDirectory) {
- const lockPath = join(commonDirectory, INSTALL_LOCK)
- const deadline = Date.now() + INSTALL_LOCK_TIMEOUT_MS
- const ownedRecord = `${String(process.pid)} ${randomUUID()}\n`
- while (true) {
- try {
- writeFileSync(lockPath, ownedRecord, { flag: 'wx', mode: 0o600 })
- const ownedStat = installLockStat(lockPath)
- if (ownedStat === undefined || !ownedStat.isFile() || ownedStat.isSymbolicLink()) {
- throw lockOwnershipChangedError(lockPath)
- }
- return () => releaseInstallLock(lockPath, ownedRecord, ownedStat)
- } catch (error) {
- if (errorCode(error) !== 'EEXIST') throw error
- const existingStat = installLockStat(lockPath)
- if (existingStat === undefined) continue
- if (!existingStat.isFile() || existingStat.isSymbolicLink()) {
- throw manualLockRecoveryError(lockPath, 'invalid')
- }
- const existingRecord = readInstallLock(lockPath)
- if (existingRecord === undefined) continue
- const owner = parseInstallLock(existingRecord)
- if (owner === undefined) throw manualLockRecoveryError(lockPath, 'invalid')
- if (!lockOwnerIsAlive(owner)) throw manualLockRecoveryError(lockPath, 'stale')
- if (Date.now() >= deadline) {
- throw new Error(`timed out waiting for Lefthook installer lock ${lockPath}`)
- }
- await new Promise(resolveWait => setTimeout(resolveWait, INSTALL_LOCK_POLL_MS))
- }
- }
- }
- function ensureOwnedHooksDirectory(hooksPath) {
- const markerPath = join(hooksPath, OWNERSHIP_MARKER)
- if (!existsSync(hooksPath)) {
- mkdirSync(hooksPath, { mode: 0o700 })
- writeFileSync(markerPath, OWNERSHIP_MARKER_CONTENT, { flag: 'wx', mode: 0o600 })
- return
- }
- const hooksStat = lstatSync(hooksPath)
- if (!hooksStat.isDirectory() || hooksStat.isSymbolicLink()) {
- throw new Error(`refusing to use non-directory or symlinked hooks path ${hooksPath}`)
- }
- if (!existsSync(markerPath)) {
- throw new Error(`refusing to overwrite unowned hooks directory ${hooksPath}`)
- }
- const markerStat = lstatSync(markerPath)
- if (!markerStat.isFile() || markerStat.isSymbolicLink() || readFileSync(markerPath, 'utf8') !== OWNERSHIP_MARKER_CONTENT) {
- throw new Error(`refusing to overwrite hooks directory with an invalid ownership marker: ${hooksPath}`)
- }
- }
- function environmentWithoutCommandGitConfig() {
- const env = { ...process.env }
- for (const key of Object.keys(env)) {
- const normalized = key.toUpperCase()
- if (
- normalized === 'GIT_CONFIG_PARAMETERS'
- || normalized === 'GIT_CONFIG_COUNT'
- || /^GIT_CONFIG_(?:KEY|VALUE)_\d+$/.test(normalized)
- ) {
- delete env[key]
- }
- }
- return env
- }
- function runLefthook(root, lefthook) {
- const args = ['install', '--force']
- const env = environmentWithoutCommandGitConfig()
- // Node refuses to spawn Windows `.cmd` shims directly; the quoted path is
- // re-parsed by cmd.exe, while POSIX can execute its extensionless shim.
- const result = process.platform === 'win32'
- ? spawnSync(`"${lefthook}"`, args, { cwd: root, env, stdio: 'inherit', shell: true })
- : spawnSync(lefthook, args, { cwd: root, env, stdio: 'inherit' })
- if (result.status !== 0) throw commandFailure(lefthook, args, result)
- }
- function configSource(entry) {
- return `${entry.origin}: ${JSON.stringify(entry.value)}`
- }
- function normalizedPath(path) {
- const normalized = resolve(path)
- return process.platform === 'win32' ? normalized.toLowerCase() : normalized
- }
- function configOriginPath(origin, root) {
- if (!origin.startsWith('file:')) return undefined
- const originPath = origin.slice('file:'.length)
- return isAbsolute(originPath) ? originPath : resolve(root, originPath)
- }
- function originIsFile(origin, root, configPath) {
- const originPath = configOriginPath(origin, root)
- return originPath !== undefined && normalizedPath(originPath) === normalizedPath(configPath)
- }
- function conditionalIncludeSource(entry) {
- return `${entry.origin}: ${entry.name}=${JSON.stringify(entry.value)}`
- }
- function conditionalIncludes(root, worktreeConfigPath) {
- const entries = scopedConfigMatchingEntries(root, CONDITIONAL_INCLUDE_PATTERN)
- entries.push(...fileConfigMatchingEntries(root, worktreeConfigPath, CONDITIONAL_INCLUDE_PATTERN)
- .map(entry => ({ ...entry, scope: 'worktree' })))
- const unique = new Map()
- for (const entry of entries) {
- unique.set(`${entry.scope}\0${entry.origin}\0${entry.name}\0${entry.value}`, entry)
- }
- return [...unique.values()]
- }
- function assertConditionalHooksPaths(root, worktreeConfigPath) {
- for (const entry of conditionalIncludes(root, worktreeConfigPath)) {
- const risk = conditionalIncludeRisk(
- root,
- entry,
- configPath => hooksPathConfigSubject(root, configPath),
- )
- if (risk === undefined) continue
- const reason = risk.subject ?? risk.detail
- if (entry.scope === 'command' || entry.scope === 'worktree') {
- throw new Error(
- `refusing ${entry.scope}-scoped conditional include ${conditionalIncludeSource(entry)}; `
- + `it may provide a user-owned core.hooksPath (${reason}) and cannot be overridden`,
- )
- }
- if (!['system', 'global', 'local'].includes(entry.scope)) {
- throw new Error(
- `refusing conditional include from unsupported ${entry.scope} scope ${conditionalIncludeSource(entry)}; `
- + `it may provide core.hooksPath (${reason})`,
- )
- }
- if (process.env[ALLOW_HOOKS_PATH_OVERRIDE] !== '1') {
- throw new Error(
- `refusing to replace core.hooksPath that may be provided by inherited conditional include `
- + `${conditionalIncludeSource(entry)} (${reason}). Inspect that include and rerun with `
- + `${ALLOW_HOOKS_PATH_OVERRIDE}=1 only if it may remain active in other worktrees`,
- )
- }
- }
- }
- function refuseInheritedHooksPath(entry) {
- throw new Error(
- `refusing to replace user-owned core.hooksPath (${configSource(entry)}). `
- + `Chain those hooks through lefthook.yml, or, if this inherited path may remain active only in other worktrees, `
- + `rerun with ${ALLOW_HOOKS_PATH_OVERRIDE}=1`,
- )
- }
- function refuseScopedHooksPath(entry) {
- if (entry.scope === 'command') {
- throw new Error(
- `refusing to replace command-scoped core.hooksPath (${configSource(entry)}); `
- + `${ALLOW_HOOKS_PATH_OVERRIDE} cannot override transient command configuration`,
- )
- }
- if (entry.scope === 'worktree') {
- throw new Error(
- `refusing to replace worktree-scoped core.hooksPath (${configSource(entry)}); `
- + 'a worktree-specific custom path must be integrated or removed explicitly',
- )
- }
- throw new Error(
- `refusing to replace core.hooksPath from unsupported ${entry.scope} scope (${configSource(entry)})`,
- )
- }
- async function main() {
- const probe = spawnSync('git', ['rev-parse', '--show-toplevel'], { encoding: 'utf8' })
- if (probe.status !== 0) return
- const root = stripGitLineTerminator(probe.stdout)
- const isWindows = process.platform === 'win32'
- const lefthook = join(root, 'node_modules', '.bin', isWindows ? 'lefthook.cmd' : 'lefthook')
- if (!existsSync(lefthook)) return
- assertSupportedGit(root)
- const gitDirectory = stripGitLineTerminator(git(['rev-parse', '--absolute-git-dir'], root).stdout)
- const commonOutput = stripGitLineTerminator(git(['rev-parse', '--git-common-dir'], root).stdout)
- const commonDirectory = isAbsolute(commonOutput) ? commonOutput : resolve(root, commonOutput)
- const commonConfigPath = join(commonDirectory, 'config')
- const worktreeConfigPath = join(gitDirectory, 'config.worktree')
- const hooksPath = join(gitDirectory, HOOKS_DIRECTORY)
- const releaseLock = await acquireInstallLock(commonDirectory)
- let installationError
- try {
- const worktreeEntries = fileConfigEntries(root, worktreeConfigPath, 'core.hooksPath')
- const includedWorktreeEntry = worktreeEntries.find(
- entry => !originIsFile(entry.origin, root, worktreeConfigPath),
- )
- if (includedWorktreeEntry !== undefined) {
- refuseScopedHooksPath({ ...includedWorktreeEntry, scope: 'worktree' })
- }
- const worktreePath = assertSingle(
- worktreeEntries.map(entry => entry.value),
- 'worktree core.hooksPath',
- )
- if (worktreePath !== undefined && worktreePath !== hooksPath) {
- refuseScopedHooksPath({ origin: `file:${worktreeConfigPath}`, scope: 'worktree', value: worktreePath })
- }
- const effectiveEntry = effectiveConfigEntry(root, 'core.hooksPath')
- if (effectiveEntry !== undefined) {
- const effectivePathIsOwned = effectiveEntry.scope === 'worktree'
- && effectiveEntry.value === hooksPath
- && worktreePath === hooksPath
- && originIsFile(effectiveEntry.origin, root, worktreeConfigPath)
- if (!effectivePathIsOwned) {
- if (effectiveEntry.scope === 'command' || effectiveEntry.scope === 'worktree') {
- refuseScopedHooksPath(effectiveEntry)
- }
- if (!['system', 'global', 'local'].includes(effectiveEntry.scope)) {
- refuseScopedHooksPath(effectiveEntry)
- }
- if (process.env[ALLOW_HOOKS_PATH_OVERRIDE] !== '1') {
- refuseInheritedHooksPath(effectiveEntry)
- }
- }
- }
- assertConditionalHooksPaths(root, worktreeConfigPath)
- assertDormantWorktreeConfigs(
- root,
- commonDirectory,
- commonConfigPath,
- worktreeConfigPath,
- )
- ensureOwnedHooksDirectory(hooksPath)
- ensureWorktreeConfig(root, commonConfigPath)
- let pathChanged = false
- try {
- git(['config', '--worktree', 'core.hooksPath', hooksPath], root)
- pathChanged = worktreePath === undefined
- const installedEntry = effectiveConfigEntry(root, 'core.hooksPath')
- if (
- installedEntry === undefined
- || installedEntry.scope !== 'worktree'
- || installedEntry.value !== hooksPath
- || !originIsFile(installedEntry.origin, root, worktreeConfigPath)
- ) {
- throw new Error('new worktree-local core.hooksPath did not become the effective direct worktree value')
- }
- runLefthook(root, lefthook)
- } catch (error) {
- if (pathChanged) {
- git(['config', '--worktree', '--unset-all', 'core.hooksPath'], root)
- }
- throw error
- }
- } catch (error) {
- installationError = error
- throw error
- } finally {
- try {
- releaseLock()
- } catch (releaseError) {
- if (installationError !== undefined) {
- throw new AggregateError(
- [installationError, releaseError],
- `Lefthook installation failed: ${String(installationError)}; installer lock release also failed: ${String(releaseError)}`,
- )
- }
- throw releaseError
- }
- }
- }
- try {
- await main()
- } catch (error) {
- console.error(`[install-lefthook] ${error instanceof Error ? error.message : String(error)}`)
- process.exitCode = 1
- }
|