Mirroristas/pockethost
2
0
Fork 0
mirror of https://github.com/pockethost/pockethost.git synced 2025-06-08 07:06:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix linux arch download

Browse Source
This commit is contained in:
Ben Allfree 2022-12-26 10:44:55 +00:00
parent 3e05508bfb
commit e2d7bf6ec2
1 changed files with 21 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
packages/daemon/src/services/PocketBaseService.ts
View File

@ -36,7 +36,7 @@ export type PocketbaseServiceConfig = {
export type PocketbaseProcess = { export type PocketbaseProcess = {
url: string url: string
pid: number | undefined pid: number | undefined
kill: () => void kill: () => boolean
exited: Promise<number | null> exited: Promise<number | null>
} }
@ -52,23 +52,23 @@ export type Releases = Release[]
export const downloadAndExtract = async (url: string, binPath: string) => { export const downloadAndExtract = async (url: string, binPath: string) => {
await new Promise<void>(async (resolve, reject) => { await new Promise<void>(async (resolve, reject) => {
console.log(`Fetching ${url}`) dbg(`Fetching ${url}`)
const res = await fetch(url) const res = await fetch(url)
if (!res.body) { if (!res.body) {
throw new Error(`Body expected for ${url}`) throw new Error(`Body expected for ${url}`)
} }
console.log(`Extracting ${url}`) dbg(`Extracting ${url}`)
const stream = res.body.pipe(Extract({ path: dirname(binPath) })) const stream = res.body.pipe(Extract({ path: dirname(binPath) }))
stream.on('close', () => { stream.on('close', () => {
console.log(`Close ${url}`) dbg(`Close ${url}`)
resolve() resolve()
}) })
stream.on('error', (e) => { stream.on('error', (e) => {
console.error(`Error ${url} ${e}`) error(`Error ${url} ${e}`)
reject() reject()
}) })
stream.on('end', () => { stream.on('end', () => {
console.log(`End ${url}`) dbg(`End ${url}`)
resolve() resolve()
}) })
}) })
@ -83,9 +83,9 @@ export const createPocketbaseService = async (
const tm = createTimerManager({}) const tm = createTimerManager({})
const osName = type().toLowerCase() const osName = type().toLowerCase()
const cpuArchitecture = process.arch const cpuArchitecture = process.arch === 'x64' ? 'amd64' : process.arch
console.log({ osName, cpuArchitecture }) dbg({ osName, cpuArchitecture })
const versions: { [_: string]: Promise<string> } = {} const versions: { [_: string]: Promise<string> } = {}
let maxVersion = '' let maxVersion = ''
@ -100,9 +100,10 @@ export const createPocketbaseService = async (
const sanitizedTagName = tag_name.slice(1) const sanitizedTagName = tag_name.slice(1)
if (prerelease) return if (prerelease) return
const path = join(cachePath, tag_name) const path = join(cachePath, tag_name)
const url = assets.find( const url = assets.find((v) => {
(v) => v.name.includes(osName) && v.name.includes(cpuArchitecture) dbg(v.name)
)?.browser_download_url return v.name.includes(osName) && v.name.includes(cpuArchitecture)
})?.browser_download_url
if (!url) return if (!url) return
const p = new Promise<string>(async (resolve) => { const p = new Promise<string>(async (resolve) => {
@ -119,12 +120,18 @@ export const createPocketbaseService = async (
versions[sanitizedTagName] = p versions[sanitizedTagName] = p
}) })
await Promise.all(promises).catch((e) => { await Promise.all(promises).catch((e) => {
console.error(e) error(e)
}) })
if (keys(versions).length === 0) {
throw new Error(
`No version found, probably mismatched architecture and OS (${osName}/${cpuArchitecture})`
)
}
maxVersion = `^${rsort(keys(versions))[0]}` maxVersion = `^${rsort(keys(versions))[0]}`
return true return true
} }
await check() await check().catch(error)
tm.repeat(check, checkIntervalMs) tm.repeat(check, checkIntervalMs)
const getLatestVersion = () => maxVersion const getLatestVersion = () => maxVersion
@ -176,7 +183,7 @@ export const createPocketbaseService = async (
const exited = new Promise<number | null>((resolve) => { const exited = new Promise<number | null>((resolve) => {
ls.on('exit', (code) => { ls.on('exit', (code) => {
dbg(`${slug} exited with code ${code}`) dbg(`${slug} exited with code ${code}`)
onUnexpectedStop?.(code) if (code) onUnexpectedStop?.(code)
resolve(code) resolve(code)
}) })
}) })