-
Notifications
You must be signed in to change notification settings - Fork 11
/
eventGatewayDownload.js
67 lines (56 loc) · 1.86 KB
/
eventGatewayDownload.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
const path = require('path')
const fs = require('fs')
const got = require('got')
// eslint-disable-next-line node/no-unpublished-require, import/no-extraneous-dependencies
const unzipper = require('unzipper')
const octokit = require('@octokit/rest')()
const version = require('./version')
const release = {
owner: 'serverless',
repo: 'event-gateway',
tag: version.EventGatewayVersion
}
const download = target => {
if (process.env.GH_API_KEY) {
octokit.authenticate({
type: 'token',
token: process.env.GH_API_KEY
})
}
return octokit.repos
.getReleaseByTag(release)
.then(response => {
const assets = response.data.assets
if (!assets || !Array.isArray(assets)) {
throw new Error('No assets in the latest release')
}
const toDownload = assets.find(asset => asset && asset.name && asset.name.includes(`${process.platform}_amd64`))
if (!toDownload) {
throw new Error('No asset found in the latest release that matches the platform')
}
return new Promise((resolve, reject) => {
const gotStream = got.stream(toDownload.browser_download_url)
// eslint-disable-next-line
const extractionStream = gotStream.pipe(unzipper.Extract({ path: target }))
extractionStream.on('close', resolve)
extractionStream.on('error', reject)
})
})
.catch(error => {
throw new Error((error.response && error.response.body) || (error && error.message))
})
}
const main = () => {
const target = path.join(__dirname, '../event-gateway', release.tag)
if (fs.existsSync(target)) {
return
}
// eslint-disable-next-line
console.log(`Downloading Event Gateway ${release.tag}....`)
download(target).then(() => {
fs.chmodSync(path.join(target, 'event-gateway'), '755')
// eslint-disable-next-line
console.log('Downloaded.')
})
}
main()