|
const fs = require("fs"); |
|
const path = require("path"); |
|
const zlib = require("zlib");const crypto = require('crypto'); |
|
const request = require("request"); |
|
|
|
const { getGlobalDefaultAccount } = require('firebase-tools/lib/auth'); // see https://gist.github.com/puf/e00c34dd82b35c56e91adbc3a9b1c412#gistcomment-3718572 |
|
|
|
const api = require('firebase-tools/lib/api'); |
|
|
|
const isDryRun = process.argv[4] !== "commit"; |
|
|
|
if (!process.argv[2] || !process.argv[3]) { |
|
console.error(` |
|
ERROR: Must supply a site name and file to deploy. Usage: |
|
node deployFile.js <site_name> <file_to_deploy> [commit]`); |
|
process.exit(1); |
|
} |
|
|
|
const site = process.argv[2]; |
|
const file = process.argv[3]; |
|
|
|
requireAuth(getGlobalDefaultAccount(), ['https://www.googleapis.com/auth/cloud-platform']).then(async () => { |
|
try { |
|
// Steps in this script: |
|
// 1. Determine version of the latest release |
|
// 2. Get list of files in that version |
|
// 3. Determine the hash of our local file |
|
// 4. Create a new version |
|
// 5. Send list of files from previous version, with our own local file in there too |
|
// 6. Upload our local file if the Hosting server requests it |
|
// 7. Finalize our new version |
|
// 8. Create a release on this new version |
|
|
|
// Determine the latest release |
|
console.log("Determining latest release...") |
|
var response = await api.request('GET', `/v1beta1/sites/${site}/releases`, { auth: true, origin: api.hostingApiOrigin }); |
|
|
|
let releases = response.body.releases; |
|
|
|
releases.forEach((release) => { console.log(/*release.name, */release.version.status, release.version.createTime, release.version.fileCount, release.version.name); }) |
|
let latestVersion = releases[0].version.name; |
|
|
|
// Get the files in the latest version |
|
console.log("Getting files in latest version...") |
|
response = await api.request('GET', `/v1beta1/${latestVersion}/files`, { auth: true, origin: api.hostingApiOrigin }); |
|
console.log(response.body); |
|
var files = {}; |
|
response.body.files.forEach(file => { |
|
files[file.path] = file.hash; |
|
}) |
|
|
|
// prep our own file that we're uploading |
|
const hasher = crypto.createHash("sha256"); |
|
const gzipper = zlib.createGzip({ level: 9 }); |
|
|
|
var zipstream = fs.createReadStream(process.cwd()+file).pipe(gzipper); |
|
zipstream.pipe(hasher); |
|
|
|
files[file] = await new Promise(function(resolve, reject) { |
|
zipstream.on("end", function() { |
|
resolve(hasher.read().toString("hex")); |
|
}); |
|
zipstream.on("error", reject); |
|
}); |
|
console.log(files[file]); |
|
|
|
// Create a new version |
|
console.log("Creating new version...") |
|
response = await api.request('POST', `/v1beta1/sites/${site}/versions`, { auth: true, origin: api.hostingApiOrigin }); |
|
console.log(response.body); |
|
let version = response.body.name; |
|
|
|
// Send file info for the new version to the server, to hear what we need to upload |
|
console.log("Sending file listing for new version...") |
|
response = await api.request('POST', `/v1beta1/${version}:populateFiles`, { |
|
auth: true, |
|
origin: api.hostingApiOrigin, |
|
data: { files: files } |
|
}) |
|
console.log(response.body); |
|
|
|
let requiredHashes = response.body.uploadRequiredHashes; |
|
let uploadUrl = response.body.uploadUrl; |
|
|
|
if (requiredHashes && requiredHashes.indexOf(files[file]) >= 0) { |
|
console.log(`Uploading ${file}...`) |
|
let reqOpts = await api.addRequestHeaders({ |
|
url: uploadUrl +"/"+ files[file], |
|
}) |
|
await new Promise(function(resolve, reject) { |
|
fs.createReadStream(process.cwd()+file).pipe(zlib.createGzip({ level: 9 })).pipe( |
|
request.post(reqOpts, function(err, res) { |
|
if (err) { |
|
return reject(err); |
|
} else if (res.statusCode !== 200) { |
|
console.error( |
|
"HTTP ERROR", |
|
res.statusCode, |
|
":", |
|
res.headers, |
|
res.body |
|
); |
|
return reject(new Error("Unexpected error while uploading file.")); |
|
} |
|
resolve(); |
|
}) |
|
); |
|
}); |
|
} |
|
|
|
if (!isDryRun) { |
|
console.log("Finalizing new version..."); |
|
response = await api.request('PATCH', `/v1beta1/${version}?updateMask=status`, { |
|
origin: api.hostingApiOrigin, |
|
auth: true, |
|
data: { status: "FINALIZED" }, |
|
}) |
|
console.log(response.body); |
|
|
|
console.log("Releasing new version..."); |
|
response = await api.request('POST', `/v1beta1/sites/${site}/releases?version_name=${version}`, { |
|
auth: true, |
|
origin: api.hostingApiOrigin, |
|
data: { message: "Deployed from test.js" || null }, |
|
} |
|
); |
|
console.log(response.body); |
|
} |
|
else { |
|
console.log("Dry run only.") |
|
// Delete the version we just created, just to be nice |
|
console.log("Deleting new version...") |
|
response = await api.request('DELETE', `/v1beta1/${version}`, { auth: true, origin: api.hostingApiOrigin }); |
|
console.log(response.body); |
|
} |
|
} catch (error) { |
|
console.error(error); |
|
} |
|
}); |
@puf Are you sure, that the hash your generating for a file locally is the same on the server?
In my project the resulting hashes for a file in a version are different, if I send the same file via
firebase deployand if I use the script.I also think it is wrong to make a hash of a compressed file to. So the hash depends on the level of compression. The server delivers the file uncompressed at the end.
I'm just trying to understand the logic.