mirror of
https://git.tuxpa.in/a/code-server.git
synced 2024-12-27 04:35:25 +00:00
eae5d8c807
These conflicts will be resolved in the following commits. We do it this way so that PR review is possible.
95 lines
4.0 KiB
JavaScript
95 lines
4.0 KiB
JavaScript
/*---------------------------------------------------------------------------------------------
|
|
* Copyright (c) Microsoft Corporation. All rights reserved.
|
|
* Licensed under the MIT License. See License.txt in the project root for license information.
|
|
*--------------------------------------------------------------------------------------------*/
|
|
'use strict';
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
const fs = require("fs");
|
|
const crypto = require("crypto");
|
|
const azure = require("azure-storage");
|
|
const mime = require("mime");
|
|
const cosmos_1 = require("@azure/cosmos");
|
|
const retry_1 = require("./retry");
|
|
if (process.argv.length !== 6) {
|
|
console.error('Usage: node createAsset.js PLATFORM TYPE NAME FILE');
|
|
process.exit(-1);
|
|
}
|
|
function hashStream(hashName, stream) {
|
|
return new Promise((c, e) => {
|
|
const shasum = crypto.createHash(hashName);
|
|
stream
|
|
.on('data', shasum.update.bind(shasum))
|
|
.on('error', e)
|
|
.on('close', () => c(shasum.digest('hex')));
|
|
});
|
|
}
|
|
async function doesAssetExist(blobService, quality, blobName) {
|
|
const existsResult = await new Promise((c, e) => blobService.doesBlobExist(quality, blobName, (err, r) => err ? e(err) : c(r)));
|
|
return existsResult.exists;
|
|
}
|
|
async function uploadBlob(blobService, quality, blobName, filePath, fileName) {
|
|
const blobOptions = {
|
|
contentSettings: {
|
|
contentType: mime.lookup(filePath),
|
|
contentDisposition: `attachment; filename="${fileName}"`,
|
|
cacheControl: 'max-age=31536000, public'
|
|
}
|
|
};
|
|
await new Promise((c, e) => blobService.createBlockBlobFromLocalFile(quality, blobName, filePath, blobOptions, err => err ? e(err) : c()));
|
|
}
|
|
function getEnv(name) {
|
|
const result = process.env[name];
|
|
if (typeof result === 'undefined') {
|
|
throw new Error('Missing env: ' + name);
|
|
}
|
|
return result;
|
|
}
|
|
async function main() {
|
|
const [, , platform, type, fileName, filePath] = process.argv;
|
|
const quality = getEnv('VSCODE_QUALITY');
|
|
const commit = getEnv('BUILD_SOURCEVERSION');
|
|
console.log('Creating asset...');
|
|
const stat = await new Promise((c, e) => fs.stat(filePath, (err, stat) => err ? e(err) : c(stat)));
|
|
const size = stat.size;
|
|
console.log('Size:', size);
|
|
const stream = fs.createReadStream(filePath);
|
|
const [sha1hash, sha256hash] = await Promise.all([hashStream('sha1', stream), hashStream('sha256', stream)]);
|
|
console.log('SHA1:', sha1hash);
|
|
console.log('SHA256:', sha256hash);
|
|
const blobName = commit + '/' + fileName;
|
|
const storageAccount = process.env['AZURE_STORAGE_ACCOUNT_2'];
|
|
const blobService = azure.createBlobService(storageAccount, process.env['AZURE_STORAGE_ACCESS_KEY_2'])
|
|
.withFilter(new azure.ExponentialRetryPolicyFilter(20));
|
|
const blobExists = await doesAssetExist(blobService, quality, blobName);
|
|
if (blobExists) {
|
|
console.log(`Blob ${quality}, ${blobName} already exists, not publishing again.`);
|
|
return;
|
|
}
|
|
console.log('Uploading blobs to Azure storage...');
|
|
await uploadBlob(blobService, quality, blobName, filePath, fileName);
|
|
console.log('Blobs successfully uploaded.');
|
|
const asset = {
|
|
platform,
|
|
type,
|
|
url: `${process.env['AZURE_CDN_URL']}/${quality}/${blobName}`,
|
|
hash: sha1hash,
|
|
sha256hash,
|
|
size
|
|
};
|
|
// Remove this if we ever need to rollback fast updates for windows
|
|
if (/win32/.test(platform)) {
|
|
asset.supportsFastUpdate = true;
|
|
}
|
|
console.log('Asset:', JSON.stringify(asset, null, ' '));
|
|
const client = new cosmos_1.CosmosClient({ endpoint: process.env['AZURE_DOCUMENTDB_ENDPOINT'], key: process.env['AZURE_DOCUMENTDB_MASTERKEY'] });
|
|
const scripts = client.database('builds').container(quality).scripts;
|
|
await retry_1.retry(() => scripts.storedProcedure('createAsset').execute('', [commit, asset, true]));
|
|
}
|
|
main().then(() => {
|
|
console.log('Asset successfully created');
|
|
process.exit(0);
|
|
}, err => {
|
|
console.error(err);
|
|
process.exit(1);
|
|
});
|