17ab7a86ef
Summary: See D37139129 Reviewed By: lblasa Differential Revision: D37236435 fbshipit-source-id: 927e9f741bfedb65165f5d24f0acfb775925cdc7
113 lines
3.3 KiB
TypeScript
113 lines
3.3 KiB
TypeScript
/**
|
|
* Copyright (c) Meta Platforms, Inc. and affiliates.
|
|
*
|
|
* This source code is licensed under the MIT license found in the
|
|
* LICENSE file in the root directory of this source tree.
|
|
*
|
|
* @format
|
|
*/
|
|
|
|
import {DownloadablePluginDetails} from 'flipper-common';
|
|
import {State, Store} from '../reducers/index';
|
|
import {
|
|
PluginDownloadStatus,
|
|
pluginDownloadStarted,
|
|
pluginDownloadFinished,
|
|
} from '../reducers/pluginDownloads';
|
|
import {sideEffect} from '../utils/sideEffect';
|
|
import {reportPlatformFailures, reportUsage} from 'flipper-common';
|
|
import {loadPlugin} from '../reducers/pluginManager';
|
|
import {showErrorNotification} from '../utils/notifications';
|
|
import {pluginInstalled} from '../reducers/plugins';
|
|
import {getAllClients} from '../reducers/connections';
|
|
import {getRenderHostInstance} from 'flipper-frontend-core';
|
|
|
|
export default (store: Store) => {
|
|
sideEffect(
|
|
store,
|
|
{name: 'handlePluginDownloads', throttleMs: 1000, fireImmediately: true},
|
|
(state) => state.pluginDownloads,
|
|
(state, store) => {
|
|
for (const download of Object.values(state)) {
|
|
if (download.status === PluginDownloadStatus.QUEUED) {
|
|
reportUsage(
|
|
'plugin-auto-update:download',
|
|
{
|
|
version: download.plugin.version,
|
|
startedByUser: download.startedByUser ? '1' : '0',
|
|
},
|
|
download.plugin.id,
|
|
);
|
|
reportPlatformFailures(
|
|
handlePluginDownload(
|
|
download.plugin,
|
|
download.startedByUser,
|
|
store,
|
|
),
|
|
'plugin-auto-update:download',
|
|
).catch(() => {});
|
|
}
|
|
}
|
|
},
|
|
);
|
|
return async () => {};
|
|
};
|
|
|
|
async function handlePluginDownload(
|
|
plugin: DownloadablePluginDetails,
|
|
startedByUser: boolean,
|
|
store: Store,
|
|
) {
|
|
const {title, version, downloadUrl} = plugin;
|
|
const dispatch = store.dispatch;
|
|
console.log(
|
|
`Downloading plugin "${title}" v${version} from "${downloadUrl}".`,
|
|
);
|
|
try {
|
|
dispatch(pluginDownloadStarted({plugin}));
|
|
const installedPlugin = await getRenderHostInstance().flipperServer!.exec(
|
|
'plugin-start-download',
|
|
plugin,
|
|
);
|
|
dispatch(pluginInstalled(installedPlugin));
|
|
if (pluginIsDisabledForAllConnectedClients(store.getState(), plugin)) {
|
|
dispatch(
|
|
loadPlugin({
|
|
plugin: installedPlugin,
|
|
enable: startedByUser,
|
|
notifyIfFailed: startedByUser,
|
|
}),
|
|
);
|
|
}
|
|
console.log(
|
|
`Successfully downloaded and installed plugin "${title}" v${version} from "${downloadUrl}".`,
|
|
);
|
|
} catch (error) {
|
|
console.error(
|
|
`Failed to download plugin "${title}" v${version} from "${downloadUrl}".`,
|
|
error,
|
|
);
|
|
if (startedByUser) {
|
|
showErrorNotification(
|
|
`Failed to download plugin "${title}" v${version}.`,
|
|
'Please check that you are on VPN/Lighthouse.',
|
|
);
|
|
}
|
|
throw error;
|
|
} finally {
|
|
dispatch(pluginDownloadFinished({plugin}));
|
|
}
|
|
}
|
|
|
|
function pluginIsDisabledForAllConnectedClients(
|
|
state: State,
|
|
plugin: DownloadablePluginDetails,
|
|
) {
|
|
return (
|
|
!state.plugins.clientPlugins.has(plugin.id) ||
|
|
!getAllClients(state.connections).some((c) =>
|
|
state.connections.enabledPlugins[c.query.app]?.includes(plugin.id),
|
|
)
|
|
);
|
|
}
|