import uuid from 'uuid'; import {parse as urlParse, format as urlFormat} from 'url'; import {DEBOUNCE_MILLIS} from './constants'; import * as querystring from './querystring'; const URL_PATH_CHARACTER_WHITELIST = '+,;@=:'; export function getBasicAuthHeader (username, password) { const name = 'Authorization'; const header = `${username || ''}:${password || ''}`; const authString = new Buffer(header, 'utf8').toString('base64'); const value = `Basic ${authString}`; return {name, value}; } export function filterHeaders (headers, name) { if (!Array.isArray(headers) || !name) { return []; } return headers.filter(h => { if (!h || !h.name) { return false; } else { return h.name.toLowerCase() === name.toLowerCase(); } }); } export function hasAuthHeader (headers) { return filterHeaders(headers, 'authorization').length > 0; } export function hasAcceptHeader (headers) { return filterHeaders(headers, 'accept').length > 0; } export function hasUserAgentHeader (headers) { return filterHeaders(headers, 'user-agent').length > 0; } export function getSetCookieHeaders (headers) { return filterHeaders(headers, 'set-cookie'); } export function getContentTypeHeader (headers) { const matches = filterHeaders(headers, 'content-type'); return matches.length ? matches[0] : null; } export function getContentLengthHeader (headers) { const matches = filterHeaders(headers, 'content-length'); return matches.length ? matches[0] : null; } export function setDefaultProtocol (url, defaultProto = 'http:') { // Default the proto if it doesn't exist if (url.indexOf('://') === -1) { url = `${defaultProto}//${url}`; } return url; } /** * Generate an ID of the format "_" * @param prefix * @returns {string} */ export function generateId (prefix) { const id = uuid.v4().replace(/-/g, ''); if (prefix) { return `${prefix}_${id}`; } else { return id; } } export function flexibleEncodeComponent (str, ignore = '') { // Sometimes spaces screw things up because of url.parse str = str.replace(/%20/g, ' '); const ignoredChars = ignore.split(''); // Do a special encode of ignored chars, so they aren't touched. // This first pass, surrounds them with a special tag (anything unique // will work), so it can change them back later // Example: will replace %40 with __LEAVE_40_LEAVE__, and we'll change // it back to %40 at the end. for (const c of ignoredChars) { const code = encodeURIComponent(c).replace('%', ''); // Replace encoded versions const re = new RegExp(encodeURIComponent(c), 'g'); str = str.replace(re, `__ENCODED_${code}_ENCODED__`); // Replace raw versions const re2 = new RegExp(`[${c}]`, 'g'); str = str.replace(re2, `__RAW_${code}_RAW__`); } try { str = decodeURIComponent(str); } catch (e) { // Malformed (probably not encoded) so assume it's decoded already } // Encode it str = encodeURIComponent(str); // Put back the encoded version of the ignored chars for (const c of ignoredChars) { const code = encodeURIComponent(c).replace('%', ''); // Put back encoded versions const re = new RegExp(`__ENCODED_${code}_ENCODED__`, 'g'); str = str.replace(re, encodeURIComponent(c)); // Put back raw versions const re2 = new RegExp(`__RAW_${code}_RAW__`, 'g'); str = str.replace(re2, c); } return str; } export function prepareUrlForSending (url) { const urlWithProto = setDefaultProtocol(url); // Parse the URL into components const parsedUrl = urlParse(urlWithProto); // ~~~~~~~~~~~ // // 1. Pathname // // ~~~~~~~~~~~ // if (parsedUrl.pathname) { const segments = parsedUrl.pathname.split('/'); parsedUrl.pathname = segments.map( s => flexibleEncodeComponent(s, URL_PATH_CHARACTER_WHITELIST) ).join('/'); } // ~~~~~~~~~~~~~~ // // 2. Querystring // // ~~~~~~~~~~~~~~ // if (parsedUrl.query) { const qsParams = querystring.deconstructToParams(parsedUrl.query); const encodedQsParams = []; for (const {name, value} of qsParams) { encodedQsParams.push({ name: flexibleEncodeComponent(name), value: flexibleEncodeComponent(value) }); } parsedUrl.query = querystring.buildFromParams(encodedQsParams); parsedUrl.search = `?${parsedUrl.query}`; } return urlFormat(parsedUrl); } export function delay (milliseconds = DEBOUNCE_MILLIS) { return new Promise(resolve => setTimeout(resolve, milliseconds)); } export function removeVowels (str) { return str.replace(/[aeiouyAEIOUY]/g, ''); } export function keyedDebounce (callback, millis = DEBOUNCE_MILLIS) { let timeout = null; let results = {}; return function (key, ...args) { results[key] = args; clearTimeout(timeout); timeout = setTimeout(() => { if (!Object.keys(results).length) { return; } callback(results); results = {}; }, millis); }; } export function debounce (callback, millis = DEBOUNCE_MILLIS) { // For regular debounce, just use a keyed debounce with a fixed key return keyedDebounce(results => { callback.apply(null, results['__key__']); }, millis).bind(null, '__key__'); } export function describeByteSize (bytes) { bytes = Math.round(bytes * 10) / 10; let size; // NOTE: We multiply these by 2 so we don't end up with // values like 0 GB let unit = 'B'; if (bytes < 1024 * 2) { size = bytes; unit = 'B'; } else if (bytes < 1024 * 1024 * 2) { size = bytes / 1024; unit = 'KB'; } else if (bytes < 1024 * 1024 * 1024 * 2) { size = bytes / 1024 / 1024; unit = 'MB'; } else { size = bytes / 1024 / 1024 / 1024; unit = 'GB'; } const rounded = Math.round(size * 10) / 10; return `${rounded} ${unit}`; } export function nullFn () { // Do nothing } export function preventDefault (e) { e.preventDefault(); }