{_('promptUpgradeReloadMessage')}
, - }).then(() => window.location.reload()) - } - updateSource = source -} - if (+process.env.XOA_PLAN < 5) { xoaUpdater.start() + + let updateSource + const promptForReload = (source, force) => { + if (force || (updateSource && source !== updateSource)) { + confirm({ + title: _('promptUpgradeReloadTitle'), + body:{_('promptUpgradeReloadMessage')}
, + }).then(() => window.location.reload()) + } + updateSource = source + } + xoaUpdater.on('upgradeSuccessful', source => promptForReload(source, !source)) xoaUpdater.on('upToDate', promptForReload) } // FIXME: can't translate -const states = { +const LABELS_BY_STATE = { disconnected: 'Disconnected', + error: 'An error occured', + registerNeeded: 'Registration required', updating: 'Updating', + upgradeNeeded: 'Upgrade required', upgrading: 'Upgrading', upToDate: 'Up to Date', - upgradeNeeded: 'Upgrade required', - registerNeeded: 'Registration required', - error: 'An error occured', } -const update = () => xoaUpdater.update() -const upgrade = ({ runningJobsExist }) => - runningJobsExist - ? confirm({ - title: _('upgradeWarningTitle'), - body: _('upgradeWarningMessage'), - }).then(() => xoaUpdater.upgrade()) - : xoaUpdater.upgrade() +const LEVELS_TO_CLASSES = { + info: 'text-info', + success: 'text-success', + warning: 'text-warning', + error: 'text-danger', +} -@addSubscriptions({ - backupNgJobs: subscribeBackupNgJobs, - jobs: subscribeJobs, -}) -@connectStore(state => { - return { - configuration: state.xoaConfiguration, - log: state.xoaUpdaterLog, - registration: state.xoaRegisterState, - state: state.xoaUpdaterState, - trial: state.xoaTrialState, - } -}) -@injectIntl -export default class XoaUpdates extends Component { - // These 3 inputs are "controlled" http://facebook.github.io/react/docs/forms.html#controlled-components - _handleProxyHostChange = event => - this.setState({ proxyHost: event.target.value || '' }) - _handleProxyPortChange = event => - this.setState({ proxyPort: event.target.value || '' }) - _handleProxyUserChange = event => - this.setState({ proxyUser: event.target.value || '' }) +const PROXY_ENTRIES = ['proxyHost', 'proxyPassword', 'proxyPort', 'proxyUser'] +const initialProxyState = () => zipObject(PROXY_ENTRIES) - _handleConfigReset = () => { - const { configuration } = this.props - const { proxyPassword } = this.refs - proxyPassword.value = '' - this.setState(configuration) - } +const REGISTRATION_ENTRIES = ['email', 'password'] +const initialRegistrationState = () => zipObject(REGISTRATION_ENTRIES) - _register = async () => { - const { email, password } = this.state +const helper = (obj1, obj2, prop) => + defined(() => obj1[prop], () => obj2[prop], '') - const { registration } = this.props - const alreadyRegistered = registration.state === 'registered' +const Updates = decorate([ + addSubscriptions({ + backupNgJobs: subscribeBackupNgJobs, + jobs: subscribeJobs, + }), + connectStore([ + 'xoaConfiguration', + 'xoaRegisterState', + 'xoaTrialState', + 'xoaUpdaterLog', + 'xoaUpdaterState', + ]), + provideState({ + initialState: () => ({ + ...initialProxyState(), + ...initialRegistrationState(), + askRegisterAgain: false, + }), + effects: { + async configure () { + await xoaUpdater.configure( + pick(this.state, [ + 'proxyHost', + 'proxyPassword', + 'proxyPort', + 'proxyUser', + ]) + ) + return this.effects.resetProxyConfig() + }, + initialize () { + return this.effects.update() + }, + linkState, + async register () { + const { state } = this - if (alreadyRegistered) { - try { - await confirm({ - title: _('alreadyRegisteredModal'), - body: ( -- {_('alreadyRegisteredModalText', { email: registration.email })} -
- ), - }) - } catch (error) { - return - } - } - this.setState({ askRegisterAgain: false }) - return xoaUpdater - .register(email, password, alreadyRegistered) - .then(() => this.setState({ email: '', password: '' })) - } - - _configure = async () => { - const { proxyHost, proxyPort, proxyUser } = this.state - const { proxyPassword } = this.refs - return xoaUpdater - .configure({ - proxyHost, - proxyPort, - proxyUser, - proxyPassword: proxyPassword.value, - }) - .then(config => { - this.setState({ - proxyHost: undefined, - proxyPort: undefined, - proxyUser: undefined, - }) - proxyPassword.value = '' - }) - } - - _trialAllowed = trial => trial.state === 'default' && exposeTrial(trial.trial) - _trialAvailable = trial => - trial.state === 'default' && isTrialRunning(trial.trial) - _trialConsumed = trial => - trial.state === 'default' && - !isTrialRunning(trial.trial) && - !exposeTrial(trial.trial) - _updaterDown = trial => isEmpty(trial) || trial.state === 'ERROR' - _toggleAskRegisterAgain = () => - this.setState({ askRegisterAgain: !this.state.askRegisterAgain }) - - _startTrial = async () => { - try { - await confirm({ - title: _('trialReadyModal'), - body:{_('trialReadyModalText')}
, - }) - return xoaUpdater - .requestTrial() - .then(() => xoaUpdater.update()) - .catch(err => error('Request Trial', err.message || String(err))) - } catch (_) {} - } - - componentWillMount () { - this.setState({ askRegisterAgain: false }) - serverVersion.then(serverVersion => { - this.setState({ serverVersion }) - }) - update() - } - - _getRunningJobsExist = createSelector( - () => this.props.jobs, - () => this.props.backupNgJobs, - (jobs, backupNgJobs) => - jobs !== undefined && - backupNgJobs !== undefined && - some(jobs.concat(backupNgJobs), job => job.runId !== undefined) - ) - - render () { - const textClasses = { - info: 'text-info', - success: 'text-success', - warning: 'text-warning', - error: 'text-danger', - } - - const { log, registration, state, trial } = this.props - let { configuration } = this.props // Configuration from the store - - const alreadyRegistered = registration.state === 'registered' - - configuration = assign({}, configuration) - const { proxyHost, proxyPort, proxyUser } = this.state // Edited non-saved configuration values override in view - let configEdited = false - proxyHost !== undefined && - (configuration.proxyHost = proxyHost) && - (configEdited = true) - proxyPort !== undefined && - (configuration.proxyPort = proxyPort) && - (configEdited = true) - proxyUser !== undefined && - (configuration.proxyUser = proxyUser) && - (configEdited = true) - - const { formatMessage } = this.props.intl - return ( -- {_('currentVersion')}{' '} - {`xo-server ${this.state.serverVersion}`} /{' '} - {`xo-web ${pkg.version}`} + {_('alreadyRegisteredModalText', { + email: this.props.registration.email, + })}
- {includes(['error', 'disconnected'], state) && ( -- - {_('updaterTroubleshootingLink')} - + ), + }) + } catch (_) { + return + } + } + + state.askRegisterAgain = false + const { email, password } = state + await xoaUpdater.register(email, password, isRegistered) + + return initialRegistrationState() + }, + resetProxyConfig: initialProxyState, + async startTrial () { + try { + await confirm({ + title: _('trialReadyModal'), + body:
{_('trialReadyModalText')}
, + }) + } catch (_) { + return + } + try { + await xoaUpdater.requestTrial() + await xoaUpdater.update() + } catch (err) { + error('Request Trial', err.message || String(err)) + } + }, + toggleState, + update: () => xoaUpdater.update(), + upgrade: () => xoaUpdater.upgrade(), + }, + computed: { + areJobsRunning: (_, { jobs, backupNgJobs }) => + jobs !== undefined && + backupNgJobs !== undefined && + some(jobs.concat(backupNgJobs), job => job.runId !== undefined), + isDisconnected: (_, { xoaUpdaterState }) => + xoaUpdater === 'disconnected' || xoaUpdaterState === 'error', + isProxyConfigEdited: state => + PROXY_ENTRIES.some(entry => state[entry] !== undefined), + isRegistered: (_, { xoaRegisterState }) => + xoaRegisterState.state === 'register', + isTrialAllowed: (_, { xoaTrialState }) => + xoaTrialState.state === 'default' && exposeTrial(xoaTrialState.trial), + isTrialAvailable: (_, { xoaTrialState }) => + xoaTrialState.state === 'default' && + isTrialRunning(xoaTrialState.trial), + isTrialConsumed: (_, { xoaTrialState }) => + xoaTrialState.state === 'default' && + !isTrialRunning(xoaTrialState.trial) && + !exposeTrial(xoaTrialState.trial), + isUpdaterDown: (_, { xoaTrialState }) => + isEmpty(xoaTrialState) || xoaTrialState.state === 'ERROR', + serverVersion: () => serverVersion, + }, + }), + injectState, + injectIntl, + ({ + effects, + intl: { formatMessage }, + state, + xoaConfiguration, + xoaRegisterState, + xoaTrialState, + xoaUpdaterLog, + xoaUpdaterState, + }) => ( ++ {_('currentVersion')} {`xo-server ${state.serverVersion}`} /{' '} + {`xo-web ${pkg.version}`} +
+ {state.isDisconnected && ( ++ + {_('updaterTroubleshootingLink')} + +
+ )} ++ + {log.date} + + :{' '} +
- )} -- {log.date} - :{' '} - -
- ))} -{_('trialRegistration')}
- )} - {registration.state === 'registered' && ( -- {_('trialAvailableUntil', { - date: new Date(trial.trial.end), - })} -
- )} - {this._trialConsumed(trial) &&{_('trialConsumed')}
} + ))} +{trial.message}
} - {trial.state === 'untrustedTrial' && ( -{trial.message}
+ {state.isRegistered ? ( +{_('trialRegistration')}
)}+ {_('trialAvailableUntil', { + date: new Date(xoaTrialState.trial.end), + })} +
+ )} + {state.isTrialConsumed &&{_('trialConsumed')}
} +{_('trialLocked')}
+ {xoaTrialState.state === 'trustedTrial' && ( +{xoaTrialState.message}
+ )} + {xoaTrialState.state === 'untrustedTrial' && ( +{xoaTrialState.message}
)}{_('trialLocked')}
+ )} +