uploadIntegration(integrationImport: IntegrationImportState): Observable<any> {
    const apiHttpService = this.apiHttpService.setEndpointUrl(integrationImportEndpoints.uploadIntegration);
    const [file] = [
      integrationImport,
      integrationImport.file
    ];

    return apiHttpService.post(file);
  }

 validateCustomConnectorInfo(customConnectorRequest: CustomConnectorRequest): Observable<ApiConnectorData> {
   const apiHttpService = this.apiHttpService.setEndpointUrl(apiConnectorEndpoints.validateCustomConnectorInfo);
   const { specificationFile, connectorTemplateId } = customConnectorRequest;
   if (specificationFile) {
     return apiHttpService.upload<ApiConnectorData>({
       specification: specificationFile
     }, {
       connectorSettings: { connectorTemplateId }
     });
   } else {
     return apiHttpService.post<ApiConnectorData>(customConnectorRequest);
   }
 }

  updateCustomConnector(customConnectorRequest: CustomConnectorRequest): Observable<any> {
    const apiHttpService = this.apiHttpService.setEndpointUrl(apiConnectorEndpoints.selectApiConnector, { id: customConnectorRequest.id });
    const [rawConnector, icon] = [
      customConnectorRequest,
      customConnectorRequest.iconFile
    ];

    const connector = this.sanitizeCustomConnectorRequest(rawConnector);

    if (icon) {
      return apiHttpService.upload({ icon }, { connector }, { method: 'PUT' });
    } else {
      return apiHttpService.put(connector);
    }
  }

 undeploy(integration: Integration): Observable<any> {
   return this.apiHttpService.setEndpointUrl(integrationEndpoints.updateState, {
     id: integration.id,
     version: integration.deploymentVersion,
   }).post({
     targetState: UNPUBLISHED
   });
 }

 fetchMetadata(
   connection: Connection,
   action: Action,
   configuredProperties: any
 ): Observable<any> {
   return this.apiHttpService.setEndpointUrl(integrationEndpoints.metadata, {
     connectionId: connection.id,
     actionId: action.id
   }).post(configuredProperties);
 }

  createCustomConnector(customConnectorRequest: CustomConnectorRequest): Observable<any> {
    const apiHttpService = this.apiHttpService.setEndpointUrl(apiConnectorEndpoints.submitCustomConnector);
    const [rawConnectorSettings, icon, specification] = [
      customConnectorRequest,
      customConnectorRequest.iconFile,
      customConnectorRequest.specificationFile
    ];

    const connectorSettings = this.sanitizeCustomConnectorRequest(rawConnectorSettings);

    if (specification || icon) {
      const payload = {};
      if (specification) {
        payload['specification'] = specification;
      }
      if (icon) {
        payload['icon'] = icon;
      }
      return apiHttpService.upload(payload, { connectorSettings });
    } else {
      return apiHttpService.post(connectorSettings);
    }
  }

 deploy(integration: Integration | IntegrationDeployment): Observable<any> {
   let url, state, method;
   if ('integrationVersion' in integration) {
     // it's an IntegrationDeployment
     url = integrationEndpoints.updateState;
     state = { targetState: PUBLISHED };
     method = 'post';
   } else {
     // it's an Integration
     url = integrationEndpoints.publish;
     state = { };
     method = 'put';
   }
   return this.apiHttpService.setEndpointUrl(url, { id: integration.id, version: integration.version })[method](state);
 }

 delete(integration: BaseEntity): Observable<any> {
   return this.apiHttpService
     .setEndpointUrl(integrationEndpoints.integration, { id: integration.id })
     .delete();
 }

 update(integration: Integration): Observable<any> {
   return this.apiHttpService
     .setEndpointUrl(integrationEndpoints.integration, { id: integration.id })
     .put(integration);
 }

 create(integration: Integration): Observable<any> {
   return this.apiHttpService
     .setEndpointUrl(integrationEndpoints.integrations)
     .post(integration);
 }