449 lines
13 KiB
JavaScript
449 lines
13 KiB
JavaScript
import Lbry from 'lbry';
|
|
import { doWalletReconnect } from 'redux/actions/wallet';
|
|
import * as SETTINGS from 'constants/settings';
|
|
import * as DAEMON_SETTINGS from 'constants/daemon_settings';
|
|
import * as ACTIONS from 'constants/action_types';
|
|
import * as SHARED_PREFERENCES from 'constants/shared_preferences';
|
|
import { doToast } from 'redux/actions/notifications';
|
|
import analytics from 'analytics';
|
|
import SUPPORTED_LANGUAGES from 'constants/supported_languages';
|
|
import { launcher } from 'util/autoLaunch';
|
|
import { makeSelectClientSetting } from 'redux/selectors/settings';
|
|
import { doSyncLoop, doSyncUnsubscribe, doSetSyncLock } from 'redux/actions/sync';
|
|
import { doAlertWaitingForSync, doGetAndPopulatePreferences } from 'redux/actions/app';
|
|
import { selectPrefsReady } from 'redux/selectors/sync';
|
|
import { Lbryio } from 'lbryinc';
|
|
import { getDefaultLanguage } from 'util/default-languages';
|
|
import { getSubsetFromKeysArray } from 'util/sync-settings';
|
|
|
|
const { DEFAULT_LANGUAGE } = require('config');
|
|
const { SDK_SYNC_KEYS, CLIENT_SYNC_KEYS } = SHARED_PREFERENCES;
|
|
|
|
export const IS_MAC = process.platform === 'darwin';
|
|
const UPDATE_IS_NIGHT_INTERVAL = 5 * 60 * 1000;
|
|
|
|
export function doFetchDaemonSettings() {
|
|
return (dispatch) => {
|
|
Lbry.settings_get().then((settings) => {
|
|
analytics.toggleInternal(settings.share_usage_data);
|
|
dispatch({
|
|
type: ACTIONS.DAEMON_SETTINGS_RECEIVED,
|
|
data: {
|
|
settings,
|
|
},
|
|
});
|
|
});
|
|
};
|
|
}
|
|
|
|
export function doFindFFmpeg() {
|
|
return (dispatch) => {
|
|
dispatch({
|
|
type: ACTIONS.FINDING_FFMPEG_STARTED,
|
|
});
|
|
return Lbry.ffmpeg_find().then((done) => {
|
|
dispatch(doGetDaemonStatus());
|
|
dispatch({
|
|
type: ACTIONS.FINDING_FFMPEG_COMPLETED,
|
|
});
|
|
});
|
|
};
|
|
}
|
|
|
|
export function doGetDaemonStatus() {
|
|
return (dispatch) => {
|
|
return Lbry.status().then((status) => {
|
|
dispatch({
|
|
type: ACTIONS.DAEMON_STATUS_RECEIVED,
|
|
data: {
|
|
status,
|
|
},
|
|
});
|
|
return status;
|
|
});
|
|
};
|
|
}
|
|
|
|
export function doClearDaemonSetting(key) {
|
|
return (dispatch, getState) => {
|
|
const state = getState();
|
|
const ready = selectPrefsReady(state);
|
|
|
|
if (!ready && key !== DAEMON_SETTINGS.LBRYUM_SERVERS) {
|
|
return dispatch(doAlertWaitingForSync());
|
|
}
|
|
|
|
const clearKey = {
|
|
key,
|
|
};
|
|
// not if syncLocked
|
|
Lbry.settings_clear(clearKey).then((defaultSettings) => {
|
|
if (SDK_SYNC_KEYS.includes(key)) {
|
|
dispatch({
|
|
type: ACTIONS.SHARED_PREFERENCE_SET,
|
|
data: { key: key, value: null },
|
|
});
|
|
}
|
|
if (key === DAEMON_SETTINGS.LBRYUM_SERVERS) {
|
|
dispatch(doWalletReconnect());
|
|
}
|
|
});
|
|
Lbry.settings_get().then((settings) => {
|
|
analytics.toggleInternal(settings.share_usage_data);
|
|
dispatch({
|
|
type: ACTIONS.DAEMON_SETTINGS_RECEIVED,
|
|
data: {
|
|
settings,
|
|
},
|
|
});
|
|
});
|
|
};
|
|
}
|
|
// if doPopulate is applying settings, we don't want to cause a loop; doNotDispatch = true.
|
|
export function doSetDaemonSetting(key, value, doNotDispatch = false) {
|
|
return (dispatch, getState) => {
|
|
const state = getState();
|
|
const ready = selectPrefsReady(state);
|
|
|
|
if (!ready) {
|
|
return dispatch(doAlertWaitingForSync());
|
|
}
|
|
|
|
const newSettings = {
|
|
key,
|
|
value: !value && value !== false ? null : value,
|
|
};
|
|
Lbry.settings_set(newSettings).then((newSetting) => {
|
|
if (SDK_SYNC_KEYS.includes(key) && !doNotDispatch) {
|
|
dispatch({
|
|
type: ACTIONS.SHARED_PREFERENCE_SET,
|
|
data: { key: key, value: newSetting[key] },
|
|
});
|
|
}
|
|
// hardcoding this in lieu of a better solution
|
|
if (key === DAEMON_SETTINGS.LBRYUM_SERVERS) {
|
|
dispatch(doWalletReconnect());
|
|
// todo: add sdk reloadsettings() (or it happens automagically?)
|
|
}
|
|
});
|
|
Lbry.settings_get().then((settings) => {
|
|
analytics.toggleInternal(settings.share_usage_data);
|
|
dispatch({
|
|
type: ACTIONS.DAEMON_SETTINGS_RECEIVED,
|
|
data: {
|
|
settings,
|
|
},
|
|
});
|
|
});
|
|
};
|
|
}
|
|
|
|
export function doSaveCustomWalletServers(servers) {
|
|
return {
|
|
type: ACTIONS.SAVE_CUSTOM_WALLET_SERVERS,
|
|
data: servers,
|
|
};
|
|
}
|
|
|
|
export function doSetClientSetting(key, value, pushPrefs) {
|
|
return (dispatch, getState) => {
|
|
const state = getState();
|
|
const ready = selectPrefsReady(state);
|
|
|
|
if (!ready && pushPrefs) {
|
|
return dispatch(doAlertWaitingForSync());
|
|
}
|
|
|
|
dispatch({
|
|
type: ACTIONS.CLIENT_SETTING_CHANGED,
|
|
data: {
|
|
key,
|
|
value,
|
|
},
|
|
});
|
|
|
|
if (pushPrefs) {
|
|
dispatch(doPushSettingsToPrefs());
|
|
}
|
|
};
|
|
}
|
|
|
|
export function doUpdateIsNight() {
|
|
return {
|
|
type: ACTIONS.UPDATE_IS_NIGHT,
|
|
};
|
|
}
|
|
|
|
export function doUpdateIsNightAsync() {
|
|
return (dispatch) => {
|
|
dispatch(doUpdateIsNight());
|
|
|
|
setInterval(() => dispatch(doUpdateIsNight()), UPDATE_IS_NIGHT_INTERVAL);
|
|
};
|
|
}
|
|
|
|
export function doSetDarkTime(value, options) {
|
|
const { fromTo, time } = options;
|
|
return (dispatch, getState) => {
|
|
const state = getState();
|
|
const darkModeTimes = state.settings.clientSettings[SETTINGS.DARK_MODE_TIMES];
|
|
const { hour, min } = darkModeTimes[fromTo];
|
|
const newHour = time === 'hour' ? value : hour;
|
|
const newMin = time === 'min' ? value : min;
|
|
const modifiedTimes = {
|
|
[fromTo]: {
|
|
hour: newHour,
|
|
min: newMin,
|
|
formattedTime: newHour + ':' + newMin,
|
|
},
|
|
};
|
|
const mergedTimes = { ...darkModeTimes, ...modifiedTimes };
|
|
|
|
dispatch(doSetClientSetting(SETTINGS.DARK_MODE_TIMES, mergedTimes));
|
|
dispatch(doUpdateIsNight());
|
|
};
|
|
}
|
|
|
|
export function doGetWalletSyncPreference() {
|
|
const SYNC_KEY = 'enable-sync';
|
|
return (dispatch) => {
|
|
return Lbry.preference_get({ key: SYNC_KEY }).then((result) => {
|
|
const enabled = result && result[SYNC_KEY];
|
|
if (enabled !== null) {
|
|
dispatch(doSetClientSetting(SETTINGS.ENABLE_SYNC, enabled));
|
|
}
|
|
return enabled;
|
|
});
|
|
};
|
|
}
|
|
|
|
export function doSetWalletSyncPreference(pref) {
|
|
const SYNC_KEY = 'enable-sync';
|
|
return (dispatch) => {
|
|
return Lbry.preference_set({ key: SYNC_KEY, value: pref }).then((result) => {
|
|
const enabled = result && result[SYNC_KEY];
|
|
if (enabled !== null) {
|
|
dispatch(doSetClientSetting(SETTINGS.ENABLE_SYNC, enabled));
|
|
}
|
|
return enabled;
|
|
});
|
|
};
|
|
}
|
|
|
|
export function doPushSettingsToPrefs() {
|
|
return (dispatch, getState) => {
|
|
const state = getState();
|
|
const {
|
|
settings: { clientSettings },
|
|
} = state;
|
|
const sharedPreferences = Object.assign({}, state.sharedPreferences);
|
|
const selectedClientSettings = getSubsetFromKeysArray(clientSettings, CLIENT_SYNC_KEYS);
|
|
const newSharedPreferences = { ...sharedPreferences, ...selectedClientSettings };
|
|
|
|
return new Promise((resolve, reject) => {
|
|
dispatch({
|
|
type: ACTIONS.SYNC_CLIENT_SETTINGS,
|
|
data: newSharedPreferences,
|
|
});
|
|
resolve();
|
|
});
|
|
};
|
|
}
|
|
|
|
export function doEnterSettingsPage() {
|
|
return async (dispatch, getState) => {
|
|
const state = getState();
|
|
const syncEnabled = makeSelectClientSetting(SETTINGS.ENABLE_SYNC)(state);
|
|
const hasVerifiedEmail = state.user && state.user.user && state.user.user.has_verified_email;
|
|
|
|
dispatch(doSyncUnsubscribe());
|
|
if (syncEnabled && hasVerifiedEmail) {
|
|
await dispatch(doSyncLoop(true));
|
|
} else {
|
|
await dispatch(doGetAndPopulatePreferences());
|
|
}
|
|
dispatch(doSetSyncLock(true));
|
|
};
|
|
}
|
|
|
|
export function doExitSettingsPage() {
|
|
return (dispatch) => {
|
|
dispatch(doSetSyncLock(false));
|
|
dispatch(doPushSettingsToPrefs());
|
|
// syncLoop is restarted in store.js sharedStateCB if necessary
|
|
};
|
|
}
|
|
|
|
export function doFetchLanguage(language) {
|
|
return (dispatch, getState) => {
|
|
const { settings } = getState();
|
|
|
|
if (settings.language !== language || (settings.loadedLanguages && !settings.loadedLanguages.includes(language))) {
|
|
// this should match the behavior/logic in index-web.html
|
|
fetch('https://lbry.com/i18n/get/lbry-desktop/app-strings/' + language + '.json')
|
|
.then((r) => r.json())
|
|
.then((j) => {
|
|
window.i18n_messages[language] = j;
|
|
dispatch({
|
|
type: ACTIONS.DOWNLOAD_LANGUAGE_SUCCESS,
|
|
data: {
|
|
language,
|
|
},
|
|
});
|
|
})
|
|
.catch((e) => {
|
|
dispatch({
|
|
type: ACTIONS.DOWNLOAD_LANGUAGE_FAILURE,
|
|
});
|
|
});
|
|
}
|
|
};
|
|
}
|
|
|
|
export function doSetHomepage(code) {
|
|
return (dispatch, getState) => {
|
|
let languageCode;
|
|
if (code === getDefaultLanguage()) {
|
|
languageCode = null;
|
|
} else {
|
|
languageCode = code;
|
|
}
|
|
dispatch(doSetClientSetting(SETTINGS.HOMEPAGE, languageCode));
|
|
};
|
|
}
|
|
|
|
export function doSetLanguage(language) {
|
|
return (dispatch, getState) => {
|
|
const { settings } = getState();
|
|
const { daemonSettings } = settings;
|
|
const { share_usage_data: shareSetting } = daemonSettings;
|
|
const isSharingData = shareSetting;
|
|
let languageSetting;
|
|
if (language === getDefaultLanguage()) {
|
|
languageSetting = null;
|
|
} else {
|
|
languageSetting = language;
|
|
}
|
|
|
|
if (
|
|
settings.language !== languageSetting ||
|
|
(settings.loadedLanguages && !settings.loadedLanguages.includes(language))
|
|
) {
|
|
// this should match the behavior/logic in index-web.html
|
|
fetch('https://lbry.com/i18n/get/lbry-desktop/app-strings/' + language + '.json')
|
|
.then((r) => r.json())
|
|
.then((j) => {
|
|
window.i18n_messages[language] = j;
|
|
dispatch({
|
|
type: ACTIONS.DOWNLOAD_LANGUAGE_SUCCESS,
|
|
data: {
|
|
language,
|
|
},
|
|
});
|
|
})
|
|
.then(() => {
|
|
// set on localStorage so it can be read outside of redux
|
|
window.localStorage.setItem(SETTINGS.LANGUAGE, language);
|
|
dispatch(doSetClientSetting(SETTINGS.LANGUAGE, languageSetting));
|
|
if (isSharingData) {
|
|
Lbryio.call('user', 'language', {
|
|
language: language,
|
|
});
|
|
}
|
|
})
|
|
.catch((e) => {
|
|
window.localStorage.setItem(SETTINGS.LANGUAGE, DEFAULT_LANGUAGE);
|
|
dispatch(doSetClientSetting(SETTINGS.LANGUAGE, DEFAULT_LANGUAGE));
|
|
const languageName = SUPPORTED_LANGUAGES[language] ? SUPPORTED_LANGUAGES[language] : language;
|
|
dispatch(
|
|
doToast({
|
|
message: __('Failed to load %language% translations.', { language: languageName }),
|
|
isError: true,
|
|
})
|
|
);
|
|
});
|
|
}
|
|
};
|
|
}
|
|
|
|
export function doSetAutoLaunch(value) {
|
|
return (dispatch, getState) => {
|
|
const state = getState();
|
|
const autoLaunch = makeSelectClientSetting(SETTINGS.AUTO_LAUNCH)(state);
|
|
|
|
if (IS_MAC || process.env.NODE_ENV !== 'production') {
|
|
return;
|
|
}
|
|
|
|
if (value === undefined) {
|
|
launcher.isEnabled().then((isEnabled) => {
|
|
if (isEnabled) {
|
|
if (!autoLaunch) {
|
|
launcher.disable().then(() => {
|
|
dispatch(doSetClientSetting(SETTINGS.AUTO_LAUNCH, false));
|
|
});
|
|
}
|
|
} else {
|
|
if (autoLaunch || autoLaunch === null || autoLaunch === undefined) {
|
|
launcher.enable().then(() => {
|
|
dispatch(doSetClientSetting(SETTINGS.AUTO_LAUNCH, true));
|
|
});
|
|
}
|
|
}
|
|
});
|
|
} else if (value === true) {
|
|
launcher.isEnabled().then(function (isEnabled) {
|
|
if (!isEnabled) {
|
|
launcher.enable().then(() => {
|
|
dispatch(doSetClientSetting(SETTINGS.AUTO_LAUNCH, true));
|
|
});
|
|
} else {
|
|
dispatch(doSetClientSetting(SETTINGS.AUTO_LAUNCH, true));
|
|
}
|
|
});
|
|
} else {
|
|
// value = false
|
|
launcher.isEnabled().then(function (isEnabled) {
|
|
if (isEnabled) {
|
|
launcher.disable().then(() => {
|
|
dispatch(doSetClientSetting(SETTINGS.AUTO_LAUNCH, false));
|
|
});
|
|
} else {
|
|
dispatch(doSetClientSetting(SETTINGS.AUTO_LAUNCH, false));
|
|
}
|
|
});
|
|
}
|
|
};
|
|
}
|
|
|
|
export function doSetAppToTrayWhenClosed(value) {
|
|
return (dispatch) => {
|
|
window.localStorage.setItem(SETTINGS.TO_TRAY_WHEN_CLOSED, value);
|
|
dispatch(doSetClientSetting(SETTINGS.TO_TRAY_WHEN_CLOSED, value));
|
|
};
|
|
}
|
|
|
|
export function toggleVideoTheaterMode() {
|
|
return (dispatch, getState) => {
|
|
const state = getState();
|
|
const videoTheaterMode = makeSelectClientSetting(SETTINGS.VIDEO_THEATER_MODE)(state);
|
|
|
|
dispatch(doSetClientSetting(SETTINGS.VIDEO_THEATER_MODE, !videoTheaterMode));
|
|
};
|
|
}
|
|
|
|
export function toggleAutoplayNext() {
|
|
return (dispatch, getState) => {
|
|
const state = getState();
|
|
const ready = selectPrefsReady(state);
|
|
const autoplayNext = makeSelectClientSetting(SETTINGS.AUTOPLAY_NEXT)(state);
|
|
|
|
dispatch(doSetClientSetting(SETTINGS.AUTOPLAY_NEXT, !autoplayNext, ready));
|
|
|
|
dispatch(
|
|
doToast({
|
|
message: autoplayNext ? __('Autoplay Next is off.') : __('Autoplay Next is on.'),
|
|
})
|
|
);
|
|
};
|
|
}
|