ckaczor/azuredatastudio
1
0
Fork 0
mirror of https://github.com/ckaczor/azuredatastudio.git synced 2026-02-16 10:58:30 -05:00
Code Issues Packages Projects Releases Wiki Activity

update sqlite extension for smoke

Browse Source
This commit is contained in:
Anthony Dresser
2020-04-23 21:26:18 -07:00
parent 89cf3ff515
commit c6f87ff088
1 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
test/smoke/src/sql/main.ts
View File

@@ -20,11 +20,14 @@ const PLATFORM = '${PLATFORM}';
const RUNTIME = '${RUNTIME}'; const RUNTIME = '${RUNTIME}';
const VERSION = '${VERSION}'; const VERSION = '${VERSION}';
const sqliteUrl = `https://github.com/anthonydresser/azuredatastudio-sqlite/releases/download/1.0.5/azuredatastudio-sqlite-${PLATFORM}-${RUNTIME}-${VERSION}.zip`; const sqliteUrl = `https://github.com/anthonydresser/azuredatastudio-sqlite/releases/download/1.0.6/azuredatastudio-sqlite-${PLATFORM}-${RUNTIME}-${VERSION}.zip`;
export async function setup(app: ApplicationOptions): Promise<void> { export async function setup(app: ApplicationOptions): Promise<void> {
const requestUrl = sqliteUrl.replace(PLATFORM, process.platform).replace(RUNTIME, getRuntime(app.web || app.remote || false)).replace(VERSION, getVersion(app.web || app.remote || false)); const requestUrl = sqliteUrl.replace(PLATFORM, process.platform).replace(RUNTIME, getRuntime(app.web || app.remote || false)).replace(VERSION, getVersion(app.web || app.remote || false));
const zip = await fetch(requestUrl); const zip = await fetch(requestUrl);
if (!zip) {
throw new Error('Could not get extension for current platform');
}
return new Promise<void>((resolve, reject) => { return new Promise<void>((resolve, reject) => {
yazl.fromBuffer(zip, (e, zipFile) => { yazl.fromBuffer(zip, (e, zipFile) => {
if (e || !zipFile) { if (e || !zipFile) {
@@ -76,15 +79,21 @@ function getVersion(remote: boolean) {
return target; return target;
} }
function fetch(url: string): Promise<Buffer> { function fetch(url: string): Promise<Buffer | undefined> {
return new Promise<Buffer>((resolve, reject) => { return new Promise<Buffer>((resolve, reject) => {
const buffers: Buffer[] = []; const buffers: Buffer[] = [];
const req = request(url, res => { const req = request(url, async res => {
if (res.headers.location) { if (res.headers.location) {
resolve(fetch(res.headers.location)); resolve(await fetch(res.headers.location));
} else { } else {
res.on('data', chunk => buffers.push(chunk)); res.on('data', chunk => buffers.push(chunk));
res.on('end', () => resolve(Buffer.concat(buffers))); res.on('end', () => {
if (buffers.length > 0) {
resolve(Buffer.concat(buffers));
} else {
resolve(undefined);
}
});
res.on('error', e => reject(e)); res.on('error', e => reject(e));
} }
}); });