azuredatastudio/extensions/notebook/src/test/common/utils.test.ts

/*---------------------------------------------------------------------------------------------
 *  Copyright (c) Microsoft Corporation. All rights reserved.
 *  Licensed under the Source EULA. See License.txt in the project root for license information.
 *--------------------------------------------------------------------------------------------*/

import * as should from 'should';
import { promises as fs } from 'fs';
import * as uuid from 'uuid';
import * as os from 'os';
import * as path from 'path';
import * as utils from '../../common/utils';
import { MockOutputChannel } from './stubs';
import * as vscode from 'vscode';
import * as azdata from 'azdata';
import { sleep } from './testUtils';

describe('Utils Tests', function () {

	it('getKnoxUrl', () => {
		const host = '127.0.0.1';
		const port = '8080';
		should(utils.getKnoxUrl(host, port)).endWith('/gateway');
	});

	it('getLivyUrl', () => {
		const host = '127.0.0.1';
		const port = '8080';
		should(utils.getLivyUrl(host, port)).endWith('/gateway/default/livy/v1/');
	});

	it('mkDir', async () => {
		const dirPath = path.join(os.tmpdir(), uuid.v4());
		await should(fs.stat(dirPath)).be.rejected();
		await utils.mkDir(dirPath, new MockOutputChannel());
		should.exist(await fs.stat(dirPath), `Folder ${dirPath} did not exist after creation`);
	});

	it('getErrorMessage Error', () => {
		const errMsg = 'Test Error';
		should(utils.getErrorMessage(new Error(errMsg))).equal(errMsg);
	});

	it('getErrorMessage string', () => {
		const errMsg = 'Test Error';
		should(utils.getErrorMessage(errMsg)).equal(errMsg);
	});

	it('getOSPlatformId', async () => {
		should(utils.getOSPlatformId()).not.throw();
	});

	describe('comparePackageVersions', () => {
		const version1 = '1.0.0.0';
		const version1Revision = '1.0.0.1';
		const version2 = '2.0.0.0';
		const shortVersion1 = '1';

		it('same id', () => {
			should(utils.comparePackageVersions(version1, version1)).equal(0);
		});

		it('first version lower', () => {
			should(utils.comparePackageVersions(version1, version2)).equal(-1);
		});

		it('second version lower', () => {
			should(utils.comparePackageVersions(version2, version1)).equal(1);
		});

		it('short first version is padded correctly', () => {
			should(utils.comparePackageVersions(shortVersion1, version1)).equal(0);
		});

		it('short second version is padded correctly when', () => {
			should(utils.comparePackageVersions(version1, shortVersion1)).equal(0);
		});

		it('correctly compares version with only minor version difference', () => {
			should(utils.comparePackageVersions(version1Revision, version1)).equal(1);
		});
	});

	describe('sortPackageVersions', () => {

		it('empty', () => {
			should(utils.sortPackageVersions([])).deepEqual([]);
		});

		it('single', () => {
			const single = ['1'];
			should(utils.sortPackageVersions(single)).deepEqual(single);
		});

		it('inorder', () => {
			const inorder = ['1', '2', '3'];
			should(utils.sortPackageVersions(inorder)).deepEqual(inorder);
		});

		it('inorder descending', () => {
			const inorder = ['1', '2', '3'];
			const inorderSortedDescending = ['3', '2', '1'];
			should(utils.sortPackageVersions(inorder, false)).deepEqual(inorderSortedDescending);
		});

		it('reverse order', () => {
			const reverseOrder = ['3', '2', '1'];
			const reverseOrderSorted = ['1', '2', '3'];
			should(utils.sortPackageVersions(reverseOrder)).deepEqual(reverseOrderSorted);
		});

		it('reverse order descending', () => {
			const reverseOrder = ['3', '2', '1'];
			const reverseOrderSortedDescending = ['3', '2', '1'];
			should(utils.sortPackageVersions(reverseOrder, false)).deepEqual(reverseOrderSortedDescending);
		});

		it('random', () => {
			const random = ['1', '42', '100', '0'];
			const randomSorted = ['0', '1', '42', '100'];
			should(utils.sortPackageVersions(random)).deepEqual(randomSorted);
		});

		it('random descending', () => {
			const random = ['1', '42', '100', '0'];
			const randomSortedDescending = ['100', '42', '1', '0'];
			should(utils.sortPackageVersions(random, false)).deepEqual(randomSortedDescending);
		});

		it('different lengths', () => {
			const random = ['1.0.0', '42', '100.0', '0.1', '1.0.1'];
			const randomSorted = ['0.1', '1.0.0', '1.0.1', '42', '100.0'];
			should(utils.sortPackageVersions(random)).deepEqual(randomSorted);
		});
	});

	describe('executeBufferedCommand', () => {

		it('runs successfully', async () => {
			await utils.executeBufferedCommand('echo hello', {}, new MockOutputChannel());
		});

		it('errors correctly with invalid command', async () => {
			await should(utils.executeBufferedCommand('invalidcommand', {}, new MockOutputChannel())).be.rejected();
		});
	});

	describe('executeStreamedCommand', () => {

		it('runs successfully', async () => {
			await utils.executeStreamedCommand('echo hello', {}, new MockOutputChannel());
		});

		it('errors correctly with invalid command', async () => {
			await should(utils.executeStreamedCommand('invalidcommand', {}, new MockOutputChannel())).be.rejected();
		});
	});

	describe('isEditorTitleFree', () => {
		afterEach(async () => {
			await vscode.commands.executeCommand('workbench.action.closeActiveEditor');
		});

		it('title is free', () => {
			should(utils.isEditorTitleFree('MyTitle')).be.true();
		});

		it('title is not free with text document sharing name', async () => {
			const editorTitle = 'Untitled-1';
			should(utils.isEditorTitleFree(editorTitle)).be.true('Title should be free before opening text document');
			await vscode.workspace.openTextDocument();
			should(utils.isEditorTitleFree(editorTitle)).be.false('Title should not be free after opening text document');
		});

		it('title is not free with notebook document sharing name', async () => {
			const editorTitle = 'MyUntitledNotebook';
			should(utils.isEditorTitleFree(editorTitle)).be.true('Title should be free before opening notebook');
			await azdata.nb.showNotebookDocument(vscode.Uri.parse(`untitled:${editorTitle}`));
			should(utils.isEditorTitleFree('MyUntitledNotebook')).be.false('Title should not be free after opening notebook');
		});

		it('title is not free with notebook document sharing name created through command', async () => {
			const editorTitle = 'Notebook-0';
			should(utils.isEditorTitleFree(editorTitle)).be.true('Title should be free before opening notebook');
			await vscode.commands.executeCommand('_notebook.command.new');
			should(utils.isEditorTitleFree(editorTitle)).be.false('Title should not be free after opening notebook');
		});
	});

	describe('getClusterEndpoints', () => {
		const baseServerInfo: azdata.ServerInfo = {
			serverMajorVersion: -1,
			serverMinorVersion: -1,
			serverReleaseVersion: -1,
			engineEditionId: -1,
			serverVersion: '',
			serverLevel: '',
			serverEdition: '',
			isCloud: false,
			azureVersion: -1,
			osVersion: '',
			options: {}
		};
		it('empty endpoints does not error', () => {
			const serverInfo = Object.assign({}, baseServerInfo);
			serverInfo.options['clusterEndpoints'] = [];
			should(utils.getClusterEndpoints(serverInfo).length).equal(0);
		});

		it('endpoints without endpoint field are created successfully', () => {
			const serverInfo = Object.assign({}, baseServerInfo);
			const ipAddress = 'localhost';
			const port = '123';
			serverInfo.options['clusterEndpoints'] = [{ ipAddress: ipAddress, port: port }];
			const endpoints = utils.getClusterEndpoints(serverInfo);
			should(endpoints.length).equal(1);
			should(endpoints[0].endpoint).equal('https://localhost:123');
		});

		it('endpoints with endpoint field are created successfully', () => {
			const endpoint = 'https://myActualEndpoint:8080';
			const serverInfo = Object.assign({}, baseServerInfo);
			serverInfo.options['clusterEndpoints'] = [{ endpoint: endpoint, ipAddress: 'localhost', port: '123' }];
			const endpoints = utils.getClusterEndpoints(serverInfo);
			should(endpoints.length).equal(1);
			should(endpoints[0].endpoint).equal(endpoint);
		});
	});

	describe('getHostAndPortFromEndpoint', () => {
		it('valid endpoint is parsed correctly', () => {
			const host = 'localhost';
			const port = '123';
			const hostAndIp = utils.getHostAndPortFromEndpoint(`https://${host}:${port}`);
			should(hostAndIp).deepEqual({ host: host, port: port });
		});

		it('invalid endpoint is returned as is', () => {
			const host = 'localhost';
			const hostAndIp = utils.getHostAndPortFromEndpoint(`https://${host}`);
			should(hostAndIp).deepEqual({ host: host, port: undefined });
		});
	});

	describe('exists', () => {
		it('runs as expected', async () => {
			const filename = path.join(os.tmpdir(), `NotebookUtilsTest_${uuid.v4()}`);
			try {
				should(await utils.exists(filename)).be.false();
				await fs.writeFile(filename, '');
				should(await utils.exists(filename)).be.true();
			} finally {
				try {
					await fs.unlink(filename);
				} catch { /* no-op */ }
			}
		});
	});

	describe('getIgnoreSslVerificationConfigSetting', () => {
		it('runs as expected', async () => {
			should(utils.getIgnoreSslVerificationConfigSetting()).be.true();
		});
	});

	describe('debounce', () => {
		class DebounceTest {
			public fnCalled = 0;
			public getterCalled = 0;

			@utils.debounce(100)
			fn(): void {
				this.fnCalled++;
			}

			@utils.debounce(100)
			get getter(): number {
				this.getterCalled++;
				return -1;
			}
		}

		it('decorates function correctly', async () => {
			const debounceTestObj = new DebounceTest();
			debounceTestObj.fn();
			debounceTestObj.fn();
			await sleep(500);
			should(debounceTestObj.fnCalled).equal(1);
			debounceTestObj.fn();
			debounceTestObj.fn();
			await sleep(500);
			should(debounceTestObj.fnCalled).equal(2);
		});

		it('decorates getter correctly', async () => {
			const debounceTestObj = new DebounceTest();
			let getterValue = debounceTestObj.getter;
			getterValue = debounceTestObj.getter;
			await sleep(500);
			should(debounceTestObj.getterCalled).equal(1);
			getterValue = debounceTestObj.getter;
			getterValue = debounceTestObj.getter;
			await sleep(500);
			should(debounceTestObj.getterCalled).equal(2);
			should(getterValue).be.undefined();
		});

		it('decorating setter not supported', async () => {
			should(() => {
				class UnsupportedTest {
					@utils.debounce(100)
					set setter(value: number) { }
				}
				new UnsupportedTest();
			}).throw();
		});
	});

	describe('getRandomToken', function (): void {
		it('Should have default length and be hex only', async function (): Promise<void> {

			let token = await utils.getRandomToken();
			should(token).have.length(48);
			let validChars = ['0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'];
			for (let i = 0; i < token.length; i++) {
				let char = token.charAt(i);
				should(validChars.indexOf(char)).be.greaterThan(-1);
			}
		});
	});

	describe('isBookItemPinned', function (): void {
		it('Should NOT pin an unknown book within a workspace', async function (): Promise<void> {

			let notebookUri = path.join(path.sep, 'randomfolder', 'randomsubfolder', 'content', 'randomnotebook.ipynb');
			let isNotebookPinned = utils.isBookItemPinned(notebookUri);

			should(isNotebookPinned).be.false('Random notebooks should not be pinned');
		});
	});

	describe('getPinnedNotebooks', function (): void {
		it('Should NOT have any pinned notebooks', async function (): Promise<void> {
			let pinnedNotebooks: utils.IBookNotebook[] = utils.getPinnedNotebooks();

			should(pinnedNotebooks.length).equal(0, 'Should not have any pinned notebooks');
		});
	});
});