chore: format with Prettier

This commit is contained in:
Julien Fontanet 2023-11-20 12:34:30 +01:00
parent 781b070e74
commit 59f04b4a6b
28 changed files with 206 additions and 211 deletions

View File

@ -42,8 +42,8 @@ function get(node, i, keys) {
? node.value
: node
: node instanceof Node
? get(node.children.get(keys[i]), i + 1, keys)
: undefined
? get(node.children.get(keys[i]), i + 1, keys)
: undefined
}
function set(node, i, keys, value) {

View File

@ -22,41 +22,41 @@ const readChunk = (stream, size) =>
stream.errored != null
? Promise.reject(stream.errored)
: stream.closed || stream.readableEnded
? Promise.resolve(null)
: new Promise((resolve, reject) => {
if (size !== undefined) {
assert(size > 0)
? Promise.resolve(null)
: new Promise((resolve, reject) => {
if (size !== undefined) {
assert(size > 0)
// per Node documentation:
// > The size argument must be less than or equal to 1 GiB.
assert(size < 1073741824)
}
// per Node documentation:
// > The size argument must be less than or equal to 1 GiB.
assert(size < 1073741824)
}
function onEnd() {
resolve(null)
removeListeners()
}
function onError(error) {
reject(error)
removeListeners()
}
function onReadable() {
const data = stream.read(size)
if (data !== null) {
resolve(data)
function onEnd() {
resolve(null)
removeListeners()
}
}
function removeListeners() {
stream.removeListener('end', onEnd)
stream.removeListener('error', onError)
stream.removeListener('readable', onReadable)
}
stream.on('end', onEnd)
stream.on('error', onError)
stream.on('readable', onReadable)
onReadable()
})
function onError(error) {
reject(error)
removeListeners()
}
function onReadable() {
const data = stream.read(size)
if (data !== null) {
resolve(data)
removeListeners()
}
}
function removeListeners() {
stream.removeListener('end', onEnd)
stream.removeListener('error', onError)
stream.removeListener('readable', onReadable)
}
stream.on('end', onEnd)
stream.on('error', onError)
stream.on('readable', onReadable)
onReadable()
})
exports.readChunk = readChunk
/**
@ -111,42 +111,42 @@ async function skip(stream, size) {
return stream.errored != null
? Promise.reject(stream.errored)
: size === 0 || stream.closed || stream.readableEnded
? Promise.resolve(0)
: new Promise((resolve, reject) => {
let left = size
function onEnd() {
resolve(size - left)
removeListeners()
}
function onError(error) {
reject(error)
removeListeners()
}
function onReadable() {
const data = stream.read()
left -= data === null ? 0 : data.length
if (left > 0) {
// continue to read
} else {
// if more than wanted has been read, push back the rest
if (left < 0) {
stream.unshift(data.slice(left))
}
resolve(size)
? Promise.resolve(0)
: new Promise((resolve, reject) => {
let left = size
function onEnd() {
resolve(size - left)
removeListeners()
}
}
function removeListeners() {
stream.removeListener('end', onEnd)
stream.removeListener('error', onError)
stream.removeListener('readable', onReadable)
}
stream.on('end', onEnd)
stream.on('error', onError)
stream.on('readable', onReadable)
onReadable()
})
function onError(error) {
reject(error)
removeListeners()
}
function onReadable() {
const data = stream.read()
left -= data === null ? 0 : data.length
if (left > 0) {
// continue to read
} else {
// if more than wanted has been read, push back the rest
if (left < 0) {
stream.unshift(data.slice(left))
}
resolve(size)
removeListeners()
}
}
function removeListeners() {
stream.removeListener('end', onEnd)
stream.removeListener('error', onError)
stream.removeListener('readable', onReadable)
}
stream.on('end', onEnd)
stream.on('error', onError)
stream.on('readable', onReadable)
onReadable()
})
}
exports.skip = skip

View File

@ -82,8 +82,8 @@ const testMetric = (
typeof test === "string"
? test === type
: typeof test === "function"
? test(type)
: test.exec(type);
? test(type)
: test.exec(type);
const findMetric = (metrics: any, metricType: string) => {
let testResult;

View File

@ -23,8 +23,8 @@ function r(p) {
return v && v.__esModule
? v
: typeof v === 'object' || typeof v === 'function'
? Object.create(v, { default: { enumerable: true, value: v } })
: { default: v }
? Object.create(v, { default: { enumerable: true, value: v } })
: { default: v }
}
function e(p, i) {
dl(defaults, i, function () {

View File

@ -10,16 +10,14 @@ const { CancelToken } = require('promise-toolbox')
const { createClient } = require('../')
const {
createOutputStream,
formatProgress,
pipeline,
resolveRecord,
throttle,
} = require('./utils')
const { createOutputStream, formatProgress, pipeline, resolveRecord, throttle } = require('./utils')
defer(async ($defer, rawArgs) => {
const { raw, throttle: bps, _: args } = getopts(rawArgs, {
const {
raw,
throttle: bps,
_: args,
} = getopts(rawArgs, {
boolean: 'raw',
alias: {
raw: 'r',
@ -28,9 +26,7 @@ defer(async ($defer, rawArgs) => {
})
if (args.length < 2) {
return console.log(
'Usage: export-vdi [--raw] <XS URL> <VDI identifier> [<VHD file>]'
)
return console.log('Usage: export-vdi [--raw] <XS URL> <VDI identifier> [<VHD file>]')
}
const xapi = createClient({
@ -67,10 +63,5 @@ defer(async ($defer, rawArgs) => {
}, 1e3)
)
await pipeline(
exportStream,
progressStream,
throttle(bps),
createOutputStream(args[2])
)
await pipeline(exportStream, progressStream, throttle(bps), createOutputStream(args[2]))
})(process.argv.slice(2)).catch(console.error.bind(console, 'error'))

View File

@ -9,15 +9,14 @@ const { CancelToken } = require('promise-toolbox')
const { createClient } = require('../')
const {
createOutputStream,
formatProgress,
pipeline,
resolveRecord,
} = require('./utils')
const { createOutputStream, formatProgress, pipeline, resolveRecord } = require('./utils')
defer(async ($defer, rawArgs) => {
const { gzip, zstd, _: args } = getopts(rawArgs, {
const {
gzip,
zstd,
_: args,
} = getopts(rawArgs, {
boolean: ['gzip', 'zstd'],
})

View File

@ -17,7 +17,7 @@ defer(async ($defer, args) => {
const xapi = createClient({
allowUnauthorized: true,
url: args[0],
watchEvents: false
watchEvents: false,
})
await xapi.connect()
@ -28,8 +28,6 @@ defer(async ($defer, args) => {
// https://xapi-project.github.io/xen-api/importexport.html
await xapi.putResource(token, createInputStream(args[1]), '/import/', {
query: args[2] && { sr_id: await resolveRef(xapi, 'SR', args[2]) }
query: args[2] && { sr_id: await resolveRef(xapi, 'SR', args[2]) },
})
})(process.argv.slice(2)).catch(
console.error.bind(console, 'error')
)
})(process.argv.slice(2)).catch(console.error.bind(console, 'error'))

View File

@ -17,20 +17,21 @@ if (process.argv.length < 3) {
const xapi = createClient({
allowUnauthorized: true,
url: process.argv[2]
url: process.argv[2],
})
// ===================================================================
// Method call
xapi.connect().then(() => {
xapi.call('VM.get_all_records')
.then(function (vms) {
console.log('%s VMs fetched', size(vms))
})
.catch(function (error) {
console.error(error)
})
xapi
.call('VM.get_all_records')
.then(function (vms) {
console.log('%s VMs fetched', size(vms))
})
.catch(function (error) {
console.error(error)
})
})
// ===================================================================

View File

@ -2,7 +2,7 @@ export default (setting, defaultValue) =>
setting === undefined
? () => defaultValue
: typeof setting === 'function'
? setting
: typeof setting === 'object'
? method => setting[method] ?? setting['*'] ?? defaultValue
: () => setting
? setting
: typeof setting === 'object'
? method => setting[method] ?? setting['*'] ?? defaultValue
: () => setting

View File

@ -282,8 +282,8 @@ export class Xapi extends EventEmitter {
return isReadOnlyCall(method, args)
? this._roCall(method, args)
: this._readOnly
? Promise.reject(new Error(`cannot call ${method}() in read only mode`))
: this._sessionCall(method, args)
? Promise.reject(new Error(`cannot call ${method}() in read only mode`))
: this._sessionCall(method, args)
}
@cancelable

View File

@ -536,8 +536,8 @@ export default class Xapi extends XapiBase {
mapVdisSrs[vdi.$id] !== undefined
? hostXapi.getObject(mapVdisSrs[vdi.$id]).$ref
: isSrConnected(vdi.$SR)
? vdi.$SR.$ref
: getDefaultSrRef()
? vdi.$SR.$ref
: getDefaultSrRef()
}
}

View File

@ -546,8 +546,8 @@ export default class XenServers {
return xapi === undefined
? 'disconnected'
: this._serverIdsByPool[xapi.pool?.$id] === id
? 'connected'
: 'connecting'
? 'connected'
: 'connecting'
}
async getAllXenServers() {

View File

@ -285,8 +285,8 @@ const TimePicker = decorate([
step === 1
? optionsValues
: step !== undefined
? optionsValues.filter((_, i) => i % step === 0)
: value.split(',').map(Number),
? optionsValues.filter((_, i) => i % step === 0)
: value.split(',').map(Number),
// '*' => 1
// '*/2' => 2

View File

@ -93,10 +93,10 @@ const SelectCoresPerSocket = decorate([
state.valueExceedsCoresLimit
? _('vmCoresPerSocketExceedsCoresLimit', { maxCores })
: state.valueExceedsSocketsLimit
? _('vmCoresPerSocketExceedsSocketsLimit', {
maxSockets: MAX_VM_SOCKETS,
})
: _('vmCoresPerSocketNotDivisor')
? _('vmCoresPerSocketExceedsSocketsLimit', {
maxSockets: MAX_VM_SOCKETS,
})
: _('vmCoresPerSocketNotDivisor')
}
>
<Icon icon='error' size='lg' />

View File

@ -67,8 +67,8 @@ const getIds = value =>
value == null || typeof value === 'string' || isInteger(value)
? value
: Array.isArray(value)
? map(value, getIds)
: value.id
? map(value, getIds)
: value.id
const getOption = (object, container) => ({
label: container ? `${getLabel(object)} ${getLabel(container)}` : getLabel(object),
@ -159,11 +159,11 @@ class GenericSelect extends React.Component {
return isEmpty(missingObjects)
? objects
: withContainers
? {
...objects,
missingObjects,
}
: [...objects, ...missingObjects]
? {
...objects,
missingObjects,
}
: [...objects, ...missingObjects]
}
)

View File

@ -156,8 +156,8 @@ export const createFilter = (collection, predicate) =>
? EMPTY_ARRAY
: EMPTY_OBJECT
: predicate
? (isArrayLike(collection) ? filter : pickBy)(collection, predicate)
: collection
? (isArrayLike(collection) ? filter : pickBy)(collection, predicate)
: collection
)
)

View File

@ -673,12 +673,12 @@ export const getDetachedBackupsOrSnapshots = (backupsOrSnapshots, { jobs, schedu
vm === undefined
? 'missingVm'
: job === undefined
? 'missingJob'
: schedules[scheduleId] === undefined
? 'missingSchedule'
: !createPredicate(omit(job.vms, 'power_state'))(vm)
? 'missingVmInJob'
: undefined
? 'missingJob'
: schedules[scheduleId] === undefined
? 'missingSchedule'
: !createPredicate(omit(job.vms, 'power_state'))(vm)
? 'missingVmInJob'
: undefined
if (reason !== undefined) {
detachedBackupsOrSnapshots.push({

View File

@ -351,8 +351,8 @@ const NewMirrorBackup = decorate([
state.isMissingBackupMode
? 'mirrorBackupVms'
: state.isFull
? 'mirrorFullBackup'
: 'mirrorIncrementalBackup'
? 'mirrorFullBackup'
: 'mirrorIncrementalBackup'
)}
<Link className='btn btn-primary pull-right' target='_blank' to='/settings/remotes'>
<Icon icon='settings' /> <strong>{_('remotesSettings')}</strong>

View File

@ -525,8 +525,8 @@ export default class extends Component {
{isHtEnabled === null
? _('hyperThreadingNotAvailable')
: isHtEnabled
? _('stateEnabled')
: _('stateDisabled')}
? _('stateEnabled')
: _('stateDisabled')}
</td>
</tr>
<tr>

View File

@ -507,8 +507,8 @@ export default decorate([
type === 'VM'
? get(() => vms[task.data.id].name_label)
: type === 'pool'
? get(() => pools[task.data.id].name_label)
: 'xo'
? get(() => pools[task.data.id].name_label)
: 'xo'
if (task.tasks !== undefined) {
const subTaskWithIsFull = task.tasks.find(({ data = {} }) => data.isFull !== undefined)

View File

@ -62,10 +62,10 @@ const JobCallStateInfos = ({ end, error, isJobInterrupted }) => {
? ['skipped', 'jobCallSkipped']
: ['halted', 'failedJobCall']
: end !== undefined
? ['running', 'successfulJobCall']
: isJobInterrupted
? ['halted', 'jobInterrupted']
: ['busy', 'jobCallInProgess']
? ['running', 'successfulJobCall']
: isJobInterrupted
? ['halted', 'jobInterrupted']
: ['busy', 'jobCallInProgess']
return (
<Tooltip content={_(tooltip)}>

View File

@ -213,33 +213,33 @@ const NewNetwork = decorate([
pool: pool.id,
})
: isPrivate
? (() => {
const poolIds = [pool.id]
const pifIds = [pif.id]
for (const network of networks) {
poolIds.push(network.pool.id)
pifIds.push(network.pif.id)
}
return createPrivateNetwork({
poolIds,
pifIds,
name,
? (() => {
const poolIds = [pool.id]
const pifIds = [pif.id]
for (const network of networks) {
poolIds.push(network.pool.id)
pifIds.push(network.pif.id)
}
return createPrivateNetwork({
poolIds,
pifIds,
name,
description,
encapsulation,
encrypted,
mtu,
preferredCenter: networkCenter,
})
})()
: createNetwork({
description,
encapsulation,
encrypted,
mtu,
preferredCenter: networkCenter,
name,
nbd,
pif: pif == null ? undefined : pif.id,
pool: pool.id,
vlan,
})
})()
: createNetwork({
description,
mtu,
name,
nbd,
pif: pif == null ? undefined : pif.id,
pool: pool.id,
vlan,
})
}
_selectPool = pool => {

View File

@ -157,10 +157,10 @@ const BindLicensesButton = decorate([
getXoaPlan() === SOURCES
? _('poolSupportSourceUsers')
: !state.isXcpngPool
? _('poolSupportXcpngOnly')
: state.isBindLicenseAvailable
? undefined
: _('poolLicenseAlreadyFullySupported')
? _('poolSupportXcpngOnly')
: state.isBindLicenseAvailable
? undefined
: _('poolLicenseAlreadyFullySupported')
}
>
{_('bindXcpngLicenses')}

View File

@ -205,8 +205,8 @@ export default class TabPatches extends Component {
pool.HA_enabled
? _('highAvailabilityNotDisabledTooltip')
: needsCredentials
? _('xsCredentialsMissingShort')
: undefined
? _('xsCredentialsMissingShort')
: undefined
}
/>
</Col>

View File

@ -6,8 +6,8 @@ export const getRedirectionUrl = (vms = []) => {
return vmIds.length === 0
? undefined // no redirect
: vmIds.length === 1
? `/vms/${vmIds[0]}`
: `/home?s=${encodeURIComponent(
new CM.Property('id', new CM.Or(vmIds.map(vm => new CM.String(vm)))).toString()
)}&t=VM`
? `/vms/${vmIds[0]}`
: `/home?s=${encodeURIComponent(
new CM.Property('id', new CM.Or(vmIds.map(vm => new CM.String(vm)))).toString()
)}&t=VM`
}

View File

@ -206,8 +206,8 @@ class VifAllowedIps extends BaseComponent {
lockingMode === 'locked' && noIps
? _('vifLockedNetworkNoIps')
: lockingMode !== 'locked' && !noIps
? _('vifUnlockedNetworkWithIps')
: undefined
? _('vifUnlockedNetworkWithIps')
: undefined
return (
<Container>

View File

@ -16,19 +16,17 @@ require('@babel/register')
// ===================================================================
function defaultRequire (module) {
function defaultRequire(module) {
var value = require(module)
return value && value.__esModule ? value.default : value
}
// See https://github.com/joliss/js-string-escape/blob/master/index.js
function quote (string, q) {
function quote(string, q) {
string = string.split('')
if (q === undefined) {
q = string.indexOf("'") !== -1 && string.indexOf('"') === -1
? '"'
: "'"
q = string.indexOf("'") !== -1 && string.indexOf('"') === -1 ? '"' : "'"
}
var replacements = {
@ -36,7 +34,7 @@ function quote (string, q) {
'\n': '\\n',
'\r': '\\r',
'\u2028': '\\u2028',
'\u2029': '\\u2029'
'\u2029': '\\u2029',
}
replacements[q] = '\\' + q
@ -55,7 +53,7 @@ var LOCALES_DIR = join(__dirname, '../src/common/intl/locales/')
var LOCALE_RE = /^(.+)\.js(?:on)?$/
var messages = defaultRequire('../src/common/intl/messages')
function updateLocale (locale) {
function updateLocale(locale) {
var path = join(LOCALES_DIR, locale + '.js')
try {
@ -71,24 +69,31 @@ function updateLocale (locale) {
var content = [
'// See http://momentjs.com/docs/#/use-it/browserify/',
'import \'moment/locale/' + locale + '\'',
"import 'moment/locale/" + locale + "'",
'',
'import reactIntlData from \'react-intl/locale-data/' + locale + '\'',
'import { addLocaleData } from \'react-intl\'',
"import reactIntlData from 'react-intl/locale-data/" + locale + "'",
"import { addLocaleData } from 'react-intl'",
'addLocaleData(reactIntlData)',
'',
'// ===================================================================',
'',
'export default {'
'export default {',
]
content.push(map(messages, function (message, id) {
var translation = translations && translations[id]
return [
' // Original text: ', quote(message.defaultMessage, translation && '"'), '\n',
' ', id, ': ', translation ? quote(translation) : 'undefined'
].join('')
}).join(',\n\n'))
content.push(
map(messages, function (message, id) {
var translation = translations && translations[id]
return [
' // Original text: ',
quote(message.defaultMessage, translation && '"'),
'\n',
' ',
id,
': ',
translation ? quote(translation) : 'undefined',
].join('')
}).join(',\n\n')
)
content.push('}', '')
@ -97,14 +102,15 @@ function updateLocale (locale) {
// ===================================================================
(function main (args) {
;(function main(args) {
var locales = args.length
? args
: filter(map(readDir(LOCALES_DIR), function (entry) {
var matches = LOCALE_RE.exec(entry)
return matches && matches[1]
}))
: filter(
map(readDir(LOCALES_DIR), function (entry) {
var matches = LOCALE_RE.exec(entry)
return matches && matches[1]
})
)
forEach(locales, updateLocale)
})(process.argv.slice(2))

View File

@ -211,8 +211,8 @@ function versionToReleaseWeight(version) {
return semver.major(version) > 0
? RELEASE_WEIGHT.MAJOR
: semver.minor(version) > 0
? RELEASE_WEIGHT.MINOR
: RELEASE_WEIGHT.PATCH
? RELEASE_WEIGHT.MINOR
: RELEASE_WEIGHT.PATCH
}
/**