Add action for testElasticsearch. (#183)

packages/mattermost-redux/src/action_types/admin.js

@@ -94,6 +94,10 @@ export default keyMirror({
  RECEIVED_COMPLIANCE_REPORT: null,
  RECEIVED_COMPLIANCE_REPORTS: null,
  RECEIVED_CLUSTER_STATUS: null,
- RECEIVED_SAML_CERT_STATUS: null
+ RECEIVED_SAML_CERT_STATUS: null,
+
+ TEST_ELASTICSEARCH_REQUEST: null,
+ TEST_ELASTICSEARCH_SUCCESS: null,
+ TEST_ELASTICSEARCH_FAILURE: null
 });
 

packages/mattermost-redux/src/actions/admin.js

@@ -219,3 +219,12 @@ export function removeIdpSamlCertificate() {
  AdminTypes.DELETE_SAML_IDP_FAILURE
  );
 }
+
+export function testElasticsearch() {
+ return bindClientFunc(
+ Client4.testElasticsearch,
+ AdminTypes.TEST_ELASTICSEARCH_REQUEST,
+ AdminTypes.TEST_ELASTICSEARCH_SUCCESS,
+ AdminTypes.TEST_ELASTICSEARCH_FAILURE
+ );
+}

packages/mattermost-redux/src/client/client4.js

@@ -1489,6 +1489,13 @@ export default class Client4 {
  );
  };
 
+ testElasticsearch = async () => {
+ return this.doFetch(
+ `${this.getBaseRoute()}/elasticsearch/test`,
+ {method: 'post'}
+ );
+ };
+
  // Client Helpers
 
  doFetch = async (url, options) => {

packages/mattermost-redux/src/reducers/requests/admin.js

@@ -216,6 +216,16 @@ function removeIdpSamlCertificate(state = initialRequestState(), action) {
  );
 }
 
+function testElasticsearch(state = initialRequestState(), action) {
+ return handleRequest(
+ AdminTypes.TEST_ELASTICSEARCH_REQUEST,
+ AdminTypes.TEST_ELASTICSEARCH_SUCCESS,
+ AdminTypes.TEST_ELASTICSEARCH_FAILURE,
+ state,
+ action
+ );
+}
+
 export default combineReducers({
  getLogs,
  getAudits,
@@ -237,6 +247,7 @@ export default combineReducers({
  uploadIdpSamlCertificate,
  removePublicSamlCertificate,
  removePrivateSamlCertificate,
- removeIdpSamlCertificate
+ removeIdpSamlCertificate,
+ testElasticsearch
 });
 

packages/mattermost-redux/test/actions/admin.test.js

@@ -471,4 +471,18 @@ describe('Actions.Admin', () => {
  throw new Error('removeIdpSamlCertificate request failed err=' + request.error);
  }
  });
+
+ it('testElasticsearch', async () => {
+ nock(Client4.getBaseRoute()).
+ post('/elasticsearch/test').
+ reply(200, OK_RESPONSE);
+
+ await Actions.testElasticsearch()(store.dispatch, store.getState);
+
+ const state = store.getState();
+ const request = state.requests.admin.testElasticsearch;
+ if (request.status === RequestStatus.FAILURE) {
+ throw new Error('testElasticsearch request failed err=' + request.error);
+ }
+ });
 });