import { remote, ipcRenderer, shell } from 'electron'; import { action, computed, observable, reaction, } from 'mobx'; import moment from 'moment'; import key from 'keymaster'; import { getDoNotDisturb } from '@meetfranz/electron-notification-state'; import AutoLaunch from 'auto-launch'; import prettyBytes from 'pretty-bytes'; import ms from 'ms'; import Store from './lib/Store'; import Request from './lib/Request'; import { CHECK_INTERVAL, DEFAULT_APP_SETTINGS } from '../config'; import { isMac, isLinux, isWindows } from '../environment'; import locales from '../i18n/translations'; import { gaEvent, gaPage } from '../lib/analytics'; import { onVisibilityChange } from '../helpers/visibility-helper'; import { getLocale } from '../helpers/i18n-helpers'; import { getServiceIdsFromPartitions, removeServicePartitionDirectory } from '../helpers/service-helpers.js'; const debug = require('debug')('Franz:AppStore'); const { app, systemPreferences } = remote; const mainWindow = remote.getCurrentWindow(); const defaultLocale = DEFAULT_APP_SETTINGS.locale; const autoLauncher = new AutoLaunch({ name: 'Franz', }); export default class AppStore extends Store { updateStatusTypes = { CHECKING: 'CHECKING', AVAILABLE: 'AVAILABLE', NOT_AVAILABLE: 'NOT_AVAILABLE', DOWNLOADED: 'DOWNLOADED', FAILED: 'FAILED', }; @observable healthCheckRequest = new Request(this.api.app, 'health'); @observable getAppCacheSizeRequest = new Request(this.api.local, 'getAppCacheSize'); @observable clearAppCacheRequest = new Request(this.api.local, 'clearAppCache'); @observable autoLaunchOnStart = true; @observable isOnline = navigator.onLine; @observable timeOfflineStart; @observable updateStatus = null; @observable locale = defaultLocale; @observable isSystemMuteOverridden = false; @observable isSystemDarkModeEnabled = false; @observable isClearingAllCache = false; @observable isFullScreen = mainWindow.isFullScreen(); @observable isFocused = true; dictionaries = []; constructor(...args) { super(...args); // Register action handlers this.actions.app.notify.listen(this._notify.bind(this)); this.actions.app.setBadge.listen(this._setBadge.bind(this)); this.actions.app.launchOnStartup.listen(this._launchOnStartup.bind(this)); this.actions.app.openExternalUrl.listen(this._openExternalUrl.bind(this)); this.actions.app.checkForUpdates.listen(this._checkForUpdates.bind(this)); this.actions.app.installUpdate.listen(this._installUpdate.bind(this)); this.actions.app.resetUpdateStatus.listen(this._resetUpdateStatus.bind(this)); this.actions.app.healthCheck.listen(this._healthCheck.bind(this)); this.actions.app.muteApp.listen(this._muteApp.bind(this)); this.actions.app.toggleMuteApp.listen(this._toggleMuteApp.bind(this)); this.actions.app.clearAllCache.listen(this._clearAllCache.bind(this)); this.registerReactions([ this._offlineCheck.bind(this), this._setLocale.bind(this), this._muteAppHandler.bind(this), ]); } async setup() { this._appStartsCounter(); // Focus the active service window.addEventListener('focus', this.actions.service.focusActiveService); // Online/Offline handling window.addEventListener('online', () => { this.isOnline = true; }); window.addEventListener('offline', () => { this.isOnline = false; }); mainWindow.on('enter-full-screen', () => { this.isFullScreen = true; }); mainWindow.on('leave-full-screen', () => { this.isFullScreen = false; }); this.isOnline = navigator.onLine; // Check if Franz should launch on start // Needs to be delayed a bit this._autoStart(); // Check if system is muted // There are no events to subscribe so we need to poll everey 5s this._systemDND(); setInterval(() => this._systemDND(), ms('5s')); // Check for updates once every 4 hours setInterval(() => this._checkForUpdates(), CHECK_INTERVAL); // Check for an update in 30s (need a delay to prevent Squirrel Installer lock file issues) setTimeout(() => this._checkForUpdates(), ms('30s')); ipcRenderer.on('autoUpdate', (event, data) => { if (data.available) { this.updateStatus = this.updateStatusTypes.AVAILABLE; if (isMac) { app.dock.bounce(); } } if (data.available !== undefined && !data.available) { this.updateStatus = this.updateStatusTypes.NOT_AVAILABLE; } if (data.downloaded) { this.updateStatus = this.updateStatusTypes.DOWNLOADED; if (isMac) { app.dock.bounce(); } } if (data.error) { this.updateStatus = this.updateStatusTypes.FAILED; } }); // Handle deep linking (franz://) ipcRenderer.on('navigateFromDeepLink', (event, data) => { debug('Navigate from deep link', data); let { url } = data; if (!url) return; url = url.replace(/\/$/, ''); this.stores.router.push(url); }); // Set active the next service key( '⌘+pagedown, ctrl+pagedown, ⌘+alt+right, ctrl+tab', () => { this.actions.service.setActiveNext(); }, ); // Set active the prev service key( '⌘+pageup, ctrl+pageup, ⌘+alt+left, ctrl+shift+tab', () => { this.actions.service.setActivePrev(); }, ); // Global Mute key( '⌘+shift+m ctrl+shift+m', () => { this.actions.app.toggleMuteApp(); }, ); this.locale = this._getDefaultLocale(); this._healthCheck(); this.isSystemDarkModeEnabled = systemPreferences.isDarkMode(); onVisibilityChange((isVisible) => { this.isFocused = isVisible; debug('Window is visible/focused', isVisible); }); // analytics autorun reaction(() => this.stores.router.location.pathname, (pathname) => { gaPage(pathname); }); console.log('router location', this.stores.router.location); } @computed get cacheSize() { return prettyBytes(this.getAppCacheSizeRequest.execute().result || 0); } // Actions @action _notify({ title, options, notificationId, serviceId = null, }) { if (this.stores.settings.all.app.isAppMuted) return; const notification = new window.Notification(title, options); notification.onclick = (e) => { if (serviceId) { this.actions.service.sendIPCMessage({ channel: `notification-onclick:${notificationId}`, args: e, serviceId, }); this.actions.service.setActive({ serviceId }); if (isWindows) { mainWindow.restore(); } else if (isLinux) { mainWindow.show(); } } }; } @action _setBadge({ unreadDirectMessageCount, unreadIndirectMessageCount }) { let indicator = unreadDirectMessageCount; if (indicator === 0 && unreadIndirectMessageCount !== 0) { indicator = '•'; } else if (unreadDirectMessageCount === 0 && unreadIndirectMessageCount === 0) { indicator = 0; } else { indicator = parseInt(indicator, 10); } ipcRenderer.send('updateAppIndicator', { indicator }); } @action _launchOnStartup({ enable }) { this.autoLaunchOnStart = enable; try { if (enable) { autoLauncher.enable(); } else { autoLauncher.disable(); } } catch (err) { console.warn(err); } gaEvent('App', enable ? 'enable autostart' : 'disable autostart'); } @action _openExternalUrl({ url }) { shell.openExternal(url); } @action _checkForUpdates() { this.updateStatus = this.updateStatusTypes.CHECKING; ipcRenderer.send('autoUpdate', { action: 'check' }); this.actions.recipe.update(); } @action _installUpdate() { ipcRenderer.send('autoUpdate', { action: 'install' }); } @action _resetUpdateStatus() { this.updateStatus = null; } @action _healthCheck() { this.healthCheckRequest.execute(); } @action _muteApp({ isMuted, overrideSystemMute = true }) { this.isSystemMuteOverridden = overrideSystemMute; this.actions.settings.update({ type: 'app', data: { isAppMuted: isMuted, }, }); } @action _toggleMuteApp() { this._muteApp({ isMuted: !this.stores.settings.all.app.isAppMuted }); } @action async _clearAllCache() { this.isClearingAllCache = true; const clearAppCache = this.clearAppCacheRequest.execute(); const allServiceIds = await getServiceIdsFromPartitions(); const allOrphanedServiceIds = allServiceIds.filter(id => !this.stores.services.all.find(s => id.replace('service-', '') === s.id)); await Promise.all(allOrphanedServiceIds.map(id => removeServicePartitionDirectory(id))); await Promise.all(this.stores.services.all.map(s => this.actions.service.clearCache({ serviceId: s.id }))); await clearAppCache._promise; this.getAppCacheSizeRequest.execute(); this.isClearingAllCache = false; } // Reactions _offlineCheck() { if (!this.isOnline) { this.timeOfflineStart = moment(); } else { const deltaTime = moment().diff(this.timeOfflineStart); if (deltaTime > ms('30m')) { this.actions.service.reloadAll(); } } } _setLocale() { let locale; if (this.stores.user.isLoggedIn) { locale = this.stores.user.data.locale; } if (locale && Object.prototype.hasOwnProperty.call(locales, locale) && locale !== this.locale) { this.locale = locale; } else if (!locale) { this.locale = this._getDefaultLocale(); } debug(`Set locale to "${this.locale}"`); } _getDefaultLocale() { return getLocale({ locale: app.getLocale(), locales, defaultLocale, fallbackLocale: DEFAULT_APP_SETTINGS.fallbackLocale, }); } _muteAppHandler() { const showMessageBadgesEvenWhenMuted = this.stores.ui.showMessageBadgesEvenWhenMuted; if (!showMessageBadgesEvenWhenMuted) { this.actions.app.setBadge({ unreadDirectMessageCount: 0, unreadIndirectMessageCount: 0 }); } } // Helpers _appStartsCounter() { this.actions.settings.update({ type: 'stats', data: { appStarts: (this.stores.settings.all.stats.appStarts || 0) + 1, }, }); } async _autoStart() { this.autoLaunchOnStart = await this._checkAutoStart(); if (this.stores.settings.all.stats.appStarts === 1) { debug('Set app to launch on start'); this.actions.app.launchOnStartup({ enable: true, }); } } async _checkAutoStart() { return autoLauncher.isEnabled() || false; } _systemDND() { const dnd = getDoNotDisturb(); if (dnd !== this.stores.settings.all.app.isAppMuted && !this.isSystemMuteOverridden) { this.actions.app.muteApp({ isMuted: dnd, overrideSystemMute: false, }); } } }