strapi/packages/strapi-admin/admin/src/containers/InstallPluginPage/saga.js

import { LOCATION_CHANGE } from 'react-router-redux';
import {
  call,
  cancel,
  fork,
  put,
  select,
  take,
  takeLatest,
} from 'redux-saga/effects';

import request from 'utils/request';

import { selectLocale } from '../LanguageProvider/selectors';
import {
  downloadPluginError,
  downloadPluginSucceeded,
  getPluginsSucceeded,
} from './actions';
import { DOWNLOAD_PLUGIN, GET_PLUGINS } from './constants';
import { makeSelectPluginToDownload } from './selectors';


export function* pluginDownload() {
  try {
    const pluginToDownload = yield select(makeSelectPluginToDownload());
    const opts = {
      method: 'POST',
      body: {
        plugin: pluginToDownload,
        port: window.location.port,
      },
    };
    const response = yield call(request, '/admin/plugins/install', opts, true);

    if (response.ok) {

      yield new Promise(resolve => {
        setTimeout(() => {
          resolve();
        }, 8000);
      });

      yield put(downloadPluginSucceeded());
      window.location.reload();
    }
  } catch(err) {
    yield put(downloadPluginError());
  }
}

export function* pluginsGet() {
  try {
    // Get current locale.
    const locale = yield select(selectLocale());

    const opts = {
      method: 'GET',
      headers: {
        'Content-Type': 'application/json',
      },
      params: {
        lang: locale,
      },
    };

    // Retrieve plugins list.
    const availablePlugins = yield call(request, 'https://marketplace.strapi.io/plugins', opts);

    yield put(getPluginsSucceeded(availablePlugins));
  } catch(err) {
    strapi.notification.error('notification.error');
  }
}



// Individual exports for testing
export default function* defaultSaga() {
  const loadPluginsWatcher = yield fork(takeLatest, GET_PLUGINS, pluginsGet);
  yield fork(takeLatest, DOWNLOAD_PLUGIN, pluginDownload);

  yield take(LOCATION_CHANGE);

  yield cancel(loadPluginsWatcher);
}