set event trigger headers from console (close 523) (#812)

console/src/components/Services/Data/TablePermissions/Permissions.js

@@ -452,21 +452,21 @@ class Permissions extends Component {
         const bulkSelect = permsState.bulkSelect;
         const currentInputSelection = bulkSelect.filter(e => e === role)
           .length ? (
-          <input
-            onChange={dispatchBulkSelect}
-            checked="checked"
-            data-role={role}
-            className={styles.bulkSelect}
-            type="checkbox"
-          />
-        ) : (
-          <input
-            onChange={dispatchBulkSelect}
-            data-role={role}
-            className={styles.bulkSelect}
-            type="checkbox"
-          />
-        );
+            <input
+              onChange={dispatchBulkSelect}
+              checked="checked"
+              data-role={role}
+              className={styles.bulkSelect}
+              type="checkbox"
+            />
+          ) : (
+            <input
+              onChange={dispatchBulkSelect}
+              data-role={role}
+              className={styles.bulkSelect}
+              type="checkbox"
+            />
+          );
         _permissionsRowHtml.push(
           <td key={-1}>
             <div>

console/src/components/Services/EventTrigger/Add/AddActions.js

@@ -27,6 +27,11 @@ const UPDATE_TABLE_LIST = 'AddTrigger/UPDATE_TABLE_LIST';
 const TOGGLE_COLUMNS = 'AddTrigger/TOGGLE_COLUMNS';
 const TOGGLE_QUERY_TYPE_SELECTED = 'AddTrigger/TOGGLE_QUERY_TYPE_SELECTED';
 const TOGGLE_QUERY_TYPE_DESELECTED = 'AddTrigger/TOGGLE_QUERY_TYPE_DESELECTED';
+const REMOVE_HEADER = 'AddTrigger/REMOVE_HEADER';
+const SET_HEADERKEY = 'AddTrigger/SET_HEADERKEY';
+const SET_HEADERTYPE = 'AddTrigger/SET_HEADERTYPE';
+const SET_HEADERVALUE = 'AddTrigger/SET_HEADERVALUE';
+const ADD_HEADER = 'AddTrigger/ADD_HEADER';
 
 const setTriggerName = value => ({ type: SET_TRIGGERNAME, value });
 const setTableName = value => ({ type: SET_TABLENAME, value });
@@ -35,6 +40,24 @@ const setWebhookURL = value => ({ type: SET_WEBHOOK_URL, value });
 const setRetryNum = value => ({ type: SET_RETRY_NUM, value });
 const setRetryInterval = value => ({ type: SET_RETRY_INTERVAL, value });
 const setDefaults = () => ({ type: SET_DEFAULTS });
+const addHeader = () => ({ type: ADD_HEADER });
+const removeHeader = i => ({ type: REMOVE_HEADER, index: i });
+const setHeaderKey = (key, index) => ({
+  type: SET_HEADERKEY,
+  key,
+  index,
+});
+const setHeaderType = (headerType, index) => ({
+  type: SET_HEADERTYPE,
+  headerType,
+  index,
+});
+const setHeaderValue = (headerValue, index) => ({
+  type: SET_HEADERVALUE,
+  headerValue,
+  index,
+});
+
 // General error during validation.
 // const validationError = (error) => ({type: VALIDATION_ERROR, error: error});
 const validationError = error => {
@@ -82,6 +105,19 @@ const createTrigger = () => {
     if (currentState.retryConf) {
       payload.args.retry_conf = currentState.retryConf;
     }
+
+    // create header payload
+    const headers = [];
+    currentState.headers.map(header => {
+      if (header.key !== '' && header.type !== '') {
+        if (header.type === 'static') {
+          headers.push({ name: header.key, value: header.value });
+        } else if (header.type === 'env') {
+          headers.push({ name: header.key, value_from_env: header.value });
+        }
+      }
+    });
+    payload.args.headers = headers;
     const upQueryArgs = [];
     upQueryArgs.push(payload);
     const downQueryArgs = [];
@@ -196,6 +232,49 @@ const setOperationSelection = (type, isChecked) => {
 
 const addTriggerReducer = (state = defaultState, action) => {
   switch (action.type) {
+    case ADD_HEADER:
+      return {
+        ...state,
+        headers: [...state.headers, { key: '', type: '', value: '' }],
+      };
+    case REMOVE_HEADER:
+      return {
+        ...state,
+        headers: [
+          ...state.headers.slice(0, action.index),
+          ...state.headers.slice(action.index + 1),
+        ],
+      };
+    case SET_HEADERKEY:
+      const i = action.index;
+      return {
+        ...state,
+        headers: [
+          ...state.headers.slice(0, i),
+          { ...state.headers[i], key: action.key },
+          ...state.headers.slice(i + 1),
+        ],
+      };
+    case SET_HEADERTYPE:
+      const ij = action.index;
+      return {
+        ...state,
+        headers: [
+          ...state.headers.slice(0, ij),
+          { ...state.headers[ij], type: action.headerType },
+          ...state.headers.slice(ij + 1),
+        ],
+      };
+    case SET_HEADERVALUE:
+      const ik = action.index;
+      return {
+        ...state,
+        headers: [
+          ...state.headers.slice(0, ik),
+          { ...state.headers[ik], value: action.headerValue },
+          ...state.headers.slice(ik + 1),
+        ],
+      };
     case SET_DEFAULTS:
       return {
         ...defaultState,
@@ -280,6 +359,11 @@ const addTriggerReducer = (state = defaultState, action) => {
 
 export default addTriggerReducer;
 export {
+  addHeader,
+  setHeaderKey,
+  setHeaderValue,
+  setHeaderType,
+  removeHeader,
   setTriggerName,
   setTableName,
   setSchemaName,

console/src/components/Services/EventTrigger/Add/AddState.js

@@ -11,6 +11,7 @@ const defaultState = {
   lastError: null,
   internalError: null,
   lastSuccess: null,
+  headers: [{ key: '', type: '', value: '' }],
 };
 
 export default defaultState;

console/src/components/Services/EventTrigger/Add/AddTrigger.js

@@ -5,6 +5,11 @@ import * as tooltip from './Tooltips';
 import OverlayTrigger from 'react-bootstrap/lib/OverlayTrigger';
 
 import {
+  removeHeader,
+  setHeaderKey,
+  setHeaderValue,
+  setHeaderType,
+  addHeader,
   setTriggerName,
   setTableName,
   setSchemaName,
@@ -16,6 +21,7 @@ import {
   setOperationSelection,
   setDefaults,
 } from './AddActions';
+import { listDuplicate } from '../../../../utils/data';
 import { showErrorNotification } from '../Notification';
 import { createTrigger } from './AddActions';
 import { fetchTableListBySchema } from './AddActions';
@@ -80,6 +86,27 @@ class AddTrigger extends Component {
         customMsg =
           'Please select a minimum of one column for update operation';
       }
+    } else if (this.props.headers.length === 1) {
+      if (this.props.headers[0].key !== '') {
+        // let the default value through and ignore it while querying?
+        // Need a better method
+        if (this.props.headers[0].type === '') {
+          isValid = false;
+          errorMsg = 'No type selected for trigger header';
+          customMsg = 'Please select a type for the trigger header';
+        }
+      }
+    } else if (this.props.headers.length > 1) {
+      // repitition check
+      const repeatList = listDuplicate(
+        this.props.headers.map(header => header.key)
+      );
+      if (repeatList.length > 0) {
+        isValid = false;
+        errorMsg = 'Duplicate entries in trigger headers';
+        customMsg = `You have the following column names repeated: [${repeatList}]`;
+      }
+      // Check for empty header keys and key/value validation?
     }
     if (isValid) {
       this.props.dispatch(createTrigger());
@@ -107,6 +134,7 @@ class AddTrigger extends Component {
       lastError,
       lastSuccess,
       internalError,
+      headers,
     } = this.props;
     const styles = require('../TableCommon/Table.scss');
     let createBtnText = 'Create';
@@ -188,6 +216,72 @@ class AddTrigger extends Component {
       return null;
     };
 
+    const heads = headers.map((header, i) => {
+      let removeIcon;
+      if (i + 1 === headers.length) {
+        removeIcon = <i className={`${styles.fontAwosomeClose}`} />;
+      } else {
+        removeIcon = (
+          <i
+            className={`${styles.fontAwosomeClose} fa-lg fa fa-times`}
+            onClick={() => {
+              dispatch(removeHeader(i));
+            }}
+          />
+        );
+      }
+      return (
+        <div key={i} className={`${styles.display_flex} form-group`}>
+          <input
+            type="text"
+            className={`${styles.input} form-control ${styles.add_mar_right}`}
+            value={header.key}
+            placeholder="key"
+            onChange={e => {
+              dispatch(setHeaderKey(e.target.value, i));
+            }}
+            data-test={`header-${i}`}
+          />
+          <select
+            value={header.type}
+            className={`${styles.select} ${styles.selectWidth} form-control ${
+              styles.add_pad_left
+            } ${styles.add_mar_right}`}
+            onChange={e => {
+              dispatch(setHeaderType(e.target.value, i));
+              if (i + 1 === headers.length) {
+                dispatch(addHeader());
+              }
+            }}
+            data-test={`header-type-${i}`}
+          >
+            {header.type === '' ? (
+              <option disabled value="">
+                -- value type --
+              </option>
+            ) : null}
+            <option value="static" key="0" title="static">
+              static
+            </option>
+            <option value="env" key="1" title="env">
+              from env variable
+            </option>
+          </select>{' '}
+          <input
+            type="text"
+            className={`${styles.input} form-control ${styles.add_mar_right}`}
+            value={header.value}
+            placeholder="value"
+            onChange={e => {
+              dispatch(setHeaderValue(e.target.value, i));
+            }}
+            data-test={`header-value-${i}`}
+          />{' '}
+          {removeIcon}
+        </div>
+      );
+    });
+
     return (
       <div
         className={`${styles.addTablesBody} ${styles.main_wrapper} ${
@@ -515,6 +609,12 @@ class AddTrigger extends Component {
                       />
                     </div>
                   </div>
+                  <div
+                    className={styles.add_mar_bottom + ' ' + styles.add_mar_top}
+                  >
+                    <h4 className={styles.subheading_text}>Headers</h4>
+                    {heads}
+                  </div>
                 </div>
               ) : null}
               <hr />

console/src/components/Services/EventTrigger/Settings/Settings.js

@@ -70,6 +70,25 @@ class Settings extends Component {
                     {triggerSchema.retry_interval > 1 ? 'seconds' : 'second'}
                   </td>
                 </tr>
+                {'headers' in triggerSchema ? (
+                  <tr>
+                    <td>Headers</td>
+                    <td>
+                      <AceEditor
+                        mode="json"
+                        theme="github"
+                        name="headers"
+                        value={JSON.stringify(triggerSchema.headers, null, 4)}
+                        minLines={4}
+                        maxLines={100}
+                        width="100%"
+                        showPrintMargin={false}
+                        showGutter={false}
+                        readOnly
+                      />
+                    </td>
+                  </tr>
+                ) : null}
                 <tr>
                   <td>Operation / Columns</td>
                   <td>
@@ -83,6 +102,7 @@ class Settings extends Component {
                       width="100%"
                       showPrintMargin={false}
                       showGutter={false}
+                      readOnly
                     />
                   </td>
                 </tr>