produceConsumeRest('consume')}>
+
{`${host}/stations/${stationName}/consume/batch?authorization=${userToken?.jwt_refresh_token}`}
diff --git a/ui_src/src/domain/stationOverview/components/updateSchemaModal/index.js b/ui_src/src/domain/stationOverview/components/updateSchemaModal/index.js
index af3f32e2e..2c52d639e 100644
--- a/ui_src/src/domain/stationOverview/components/updateSchemaModal/index.js
+++ b/ui_src/src/domain/stationOverview/components/updateSchemaModal/index.js
@@ -19,8 +19,6 @@ import { ReactComponent as TypeIcon } from 'assets/images/typeIcon.svg';
import { ReactComponent as CreatedByIcon } from 'assets/images/createdByIcon.svg';
import { ReactComponent as SchemaItemIcon } from 'assets/images/schemaItemIcon.svg';
import { httpRequest } from 'services/http';
-import { useGetAllowedActions } from 'services/genericServices';
-import { isCloud } from 'services/valueConvertor';
import Button from 'components/button';
import Copy from 'components/copy';
import SelectComponent from 'components/select';
@@ -39,7 +37,6 @@ const UpdateSchemaModal = ({ stationName, dispatch, close, schemaSelected }) =>
const [currentVersion, setCurrentversion] = useState();
const [isDiff, setIsDiff] = useState('Yes');
- const getAllowedActions = useGetAllowedActions();
const getUpdateSchema = async () => {
try {
setIsLoading(true);
@@ -67,10 +64,7 @@ const UpdateSchemaModal = ({ stationName, dispatch, close, schemaSelected }) =>
dispatch(data);
setUseschemaLoading(false);
}
- } catch (error) {
- } finally {
- isCloud() && getAllowedActions();
- }
+ } catch (error) {}
setUseschemaLoading(false);
};
diff --git a/ui_src/src/domain/stationOverview/components/useSchemaModal/index.js b/ui_src/src/domain/stationOverview/components/useSchemaModal/index.js
index 1633eaa13..5247ca006 100644
--- a/ui_src/src/domain/stationOverview/components/useSchemaModal/index.js
+++ b/ui_src/src/domain/stationOverview/components/useSchemaModal/index.js
@@ -15,7 +15,6 @@ import './style.scss';
import React, { useContext, useEffect, useMemo, useState, useRef } from 'react';
import { AddRounded } from '@material-ui/icons';
import { useHistory } from 'react-router-dom';
-import { useGetAllowedActions } from 'services/genericServices';
import { ReactComponent as PlaceholderSchemaIcon } from 'assets/images/placeholderSchema.svg';
import { ReactComponent as StopUsingIcon } from 'assets/images/stopUsingIcon.svg';
import DeleteItemsModal from 'components/deleteItemsModal';
@@ -23,7 +22,6 @@ import { ReactComponent as SearchIcon } from 'assets/images/searchIcon.svg';
import { ApiEndpoints } from 'const/apiEndpoints';
import SearchInput from 'components/searchInput';
import { httpRequest } from 'services/http';
-import { isCloud } from 'services/valueConvertor';
import Button from 'components/button';
import Modal from 'components/modal';
import LearnMore from 'components/learnMore';
@@ -33,7 +31,6 @@ import { Context } from 'hooks/store';
import SchemaItem from './schemaItem';
import { ReactComponent as StationIcon } from 'assets/images/stationsIconActive.svg';
import CreateStationForm from 'components/createStationForm';
-import LockFeature from 'components/lockFeature';
const UseSchemaModal = ({ stationName, handleSetSchema, close, type = 'schema' }) => {
const [stationState, stationDispatch] = useContext(StationStoreContext);
@@ -49,7 +46,6 @@ const UseSchemaModal = ({ stationName, handleSetSchema, close, type = 'schema' }
const [newStationModal, setNewStationModal] = useState(false);
const [creatingProsessd, setCreatingProsessd] = useState(false);
- const getAllowedActions = useGetAllowedActions();
const history = useHistory();
const getAllSchema = async () => {
@@ -86,8 +82,6 @@ const UseSchemaModal = ({ stationName, handleSetSchema, close, type = 'schema' }
}
} catch (error) {
setUseschemaLoading(false);
- } finally {
- isCloud() && getAllowedActions();
}
};
@@ -103,8 +97,6 @@ const UseSchemaModal = ({ stationName, handleSetSchema, close, type = 'schema' }
} catch (error) {
setDeleteModal(false);
setDetachLoader(false);
- } finally {
- isCloud() && getAllowedActions();
}
};
@@ -150,24 +142,11 @@ const UseSchemaModal = ({ stationName, handleSetSchema, close, type = 'schema' }
})}
-
(!isCloud() || (type === 'dls' && state?.allowedActions?.can_create_stations) || type !== 'dls') && createNew()}
- >
+
createNew()}>
Add new
- {type === 'dls' ? (
- isCloud() && !state?.allowedActions?.can_create_stations ? (
- <>
- station
{type === 'dls' ? (
diff --git a/ui_src/src/domain/stationOverview/index.js b/ui_src/src/domain/stationOverview/index.js
index 328d3f772..c3bd1ca25 100644
--- a/ui_src/src/domain/stationOverview/index.js
+++ b/ui_src/src/domain/stationOverview/index.js
@@ -23,7 +23,6 @@ import Loader from 'components/loader';
import { Context } from 'hooks/store';
import pathDomains from 'router';
import Reducer from './hooks/reducer';
-import { StringCodec, JSONCodec } from 'nats.ws';
const initializeState = {
stationMetaData: { is_native: true },
@@ -40,7 +39,6 @@ const StationOverview = () => {
const [state, dispatch] = useContext(Context);
const [isLoading, setisLoading] = useState(false);
const [isReloading, setisReloading] = useState(false);
- const [socketOn, setSocketOn] = useState(false);
const location = useLocation();
const [referredFunction, setReferredFunction] = useState(null);
@@ -92,75 +90,9 @@ const StationOverview = () => {
};
useEffect(() => {
- // if (socketOn) {
- // getStationDetails();
- // }
- // getStationDetails();
stationState?.stationPartition && getStationDetails();
}, [stationState?.stationPartition]);
- // const startListen = async () => {
- // const jc = JSONCodec();
- // const sc = StringCodec();
-
- // const listenForUpdates = async () => {
- // try {
- // if (sub) {
- // for await (const msg of sub) {
- // let data = jc.decode(msg.data);
- // sortData(data);
- // stationDispatch({ type: 'SET_SOCKET_DATA', payload: data });
- // if (!socketOn) {
- // setSocketOn(true);
- // }
- // }
- // }
- // } catch (err) {
- // console.error(`Error receiving data updates for station overview:`, err);
- // }
- // };
-
- // try {
- // const rawBrokerName = await state.socket?.request(
- // `$memphis_ws_subs.station_overview_data.${stationName}.${stationState?.stationPartition || -1}`,
- // sc.encode('SUB')
- // );
- // if (rawBrokerName) {
- // const brokerName = JSON.parse(sc.decode(rawBrokerName?._rdata))['name'];
- // sub = state.socket?.subscribe(`$memphis_ws_pubs.station_overview_data.${stationName}.${stationState?.stationPartition || -1}.${brokerName}`);
- // listenForUpdates();
- // }
- // } catch (err) {
- // console.error('Error subscribing to station overview data:', err);
- // }
- // };
-
- // const stopListen = async () => {
- // if (sub) {
- // try {
- // await sub.unsubscribe();
- // } catch (err) {
- // console.error('Error unsubscribing from station overview data:', err);
- // }
- // }
- // };
-
- // useEffect(() => {
- // if (state.socket) {
- // startListen();
- // }
- // return () => {
- // stopListen();
- // };
- // }, [state.socket, stationName]);
-
- // useEffect(() => {
- // if (sub && socketOn) {
- // stopListen();
- // startListen();
- // }
- // }, [stationState?.stationPartition, stationName]);
-
useEffect(() => {
setisLoading(true);
dispatch({ type: 'SET_ROUTE', payload: 'stations' });
diff --git a/ui_src/src/domain/stationOverview/stationObservabilty/ProduceConsumList/index.js b/ui_src/src/domain/stationOverview/stationObservabilty/ProduceConsumList/index.js
index 805e3b4d7..88535d13c 100644
--- a/ui_src/src/domain/stationOverview/stationObservabilty/ProduceConsumList/index.js
+++ b/ui_src/src/domain/stationOverview/stationObservabilty/ProduceConsumList/index.js
@@ -45,8 +45,6 @@ import { ApiEndpoints } from 'const/apiEndpoints';
import { httpRequest } from 'services/http';
import Spinner from 'components/spinner';
import TooltipComponent from 'components/tooltip/tooltip';
-import { isCloud } from 'services/valueConvertor';
-import { sendTrace } from 'services/genericServices';
import { BiLogoGoLang, BiLogoPython } from 'react-icons/bi';
import { SiDotnet } from 'react-icons/si';
import { DiJavascript1 } from 'react-icons/di';
@@ -138,13 +136,6 @@ const ProduceConsumList = ({ producer }) => {
setOpenRunBenchmark(true);
setOpenProducerPopover(false);
}
- },
- {
- action: 'Add a source',
- onClick: () => {
- setOpenConnectorModal(true);
- setOpenProducerPopover(false);
- }
}
];
@@ -169,13 +160,6 @@ const ProduceConsumList = ({ producer }) => {
setOpenRunBenchmark(true);
setOpenProducerPopover(false);
}
- },
- {
- action: 'Add a sink',
- onClick: () => {
- setOpenConnectorModal(true);
- setOpenProducerPopover(false);
- }
}
];
@@ -195,11 +179,6 @@ const ProduceConsumList = ({ producer }) => {
newConnecorList.splice(openConnectorPopoverItem, 1);
setConnectorsSinkList(newConnecorList);
}
- sendTrace('removeConnector', {
- type: type,
- connector: type === 'source' ? connectorsSourceList[openConnectorPopoverItem]?.type : connectorsSinkList[openConnectorPopoverItem]?.type,
- name: type === 'source' ? connectorsSourceList[openConnectorPopoverItem]?.name : connectorsSinkList[openConnectorPopoverItem]?.name
- });
setLoader(false);
setOpenConnectorPopover(false);
} catch (error) {
@@ -223,11 +202,6 @@ const ProduceConsumList = ({ producer }) => {
newConnecorList[openConnectorPopoverItem].is_active = true;
setConnectorsSinkList(newConnecorList);
}
- sendTrace('startConnector', {
- type: type,
- connector: type === 'source' ? connectorsSourceList[openConnectorPopoverItem]?.type : connectorsSinkList[openConnectorPopoverItem]?.type,
- name: type === 'source' ? connectorsSourceList[openConnectorPopoverItem]?.name : connectorsSinkList[openConnectorPopoverItem]?.name
- });
setLoader(false);
setOpenConnectorPopover(false);
} catch (error) {
@@ -250,11 +224,6 @@ const ProduceConsumList = ({ producer }) => {
newConnecorList[openConnectorPopoverItem].is_active = false;
setConnectorsSinkList(newConnecorList);
}
- sendTrace('stopConnector', {
- type: type,
- connector: type === 'source' ? connectorsSourceList[openConnectorPopoverItem]?.type : connectorsSinkList[openConnectorPopoverItem]?.type,
- name: type === 'source' ? connectorsSourceList[openConnectorPopoverItem]?.name : connectorsSinkList[openConnectorPopoverItem]?.name
- });
setLoader(false);
setOpenConnectorPopover(false);
} catch (error) {
@@ -445,10 +414,7 @@ const ProduceConsumList = ({ producer }) => {
- <>
- Producers ({(producersList?.length > 0 && countProducers(producersList).toLocaleString()) || 0}
- {isCloud() && '/' + stationState?.stationSocketData?.max_amount_of_allowed_producers?.toLocaleString()})
-
+ <>Producers ({(producersList?.length > 0 && countProducers(producersList).toLocaleString()) || 0}
{
- setIsActive(!isDeactive);
- }, [isDeactive]);
-
- useEffect(() => {
- let func = functionItem;
- func.stars = Math.random() + 4;
- func.rates = Math.floor(Math.random() * (80 - 50 + 1)) + 50;
- func.forks = Math.floor(Math.random() * (100 - 80 + 1)) + 80;
- setSelectedFunction(func);
- getFunctionDetails();
- }, [functionItem]);
-
- const functionContextMenuStyles = {
- borderRadius: '8px',
- paddingTop: '5px',
- paddingBottom: '5px',
- marginBottom: '10px',
- width: '150px'
- };
-
- const getFunctionDetails = async () => {
- try {
- const response = await httpRequest('GET', `${ApiEndpoints.GET_FUNCTION_DETAILS}?function_id=${functionItem?.id}`);
- setAverageProcessingTime(response?.metrics?.average_processing_time);
- } catch (e) {
- return;
- }
- };
-
- const getFunctionsOverview = async () => {
- try {
- const data = await httpRequest(
- 'GET',
- `${ApiEndpoints.GET_FUNCTIONS_OVERVIEW}?station_name=${stationState?.stationMetaData?.name}&partition=${stationState?.stationPartition || 1}`
- );
- stationDispatch({ type: 'SET_STATION_FUNCTIONS', payload: data });
- } catch (e) {
- return;
- }
- };
-
- const handleDeactivate = async () => {
- const bodyRequest = {
- function_id: functionItem?.id,
- station_name: stationName,
- partition: partiotionNumber,
- visible_step: functionItem?.visible_step
- };
- try {
- await httpRequest('POST', ApiEndpoints.DEACTIVATE_FUNCTION, bodyRequest);
- changeActivition(false);
- } catch (error) {
- return;
- }
- };
-
- const handleActivate = async () => {
- const bodyRequest = {
- function_id: functionItem?.id,
- station_name: stationName,
- partition: partiotionNumber,
- visible_step: functionItem?.visible_step
- };
- try {
- await httpRequest('POST', ApiEndpoints.ACTIVATE_FUNCTION, bodyRequest);
- changeActivition(true);
- } catch (error) {
- return;
- }
- };
-
- const handleDelete = async () => {
- const bodyRequest = {
- function_id: functionItem?.id,
- station_name: stationName,
- partition: partiotionNumber,
- visible_step: functionItem?.visible_step
- };
- try {
- await httpRequest('POST', ApiEndpoints.DETACH_FUNCTION, bodyRequest);
- getFunctionsOverview();
- onDeleteFunction();
- } catch (error) {
- return;
- }
- };
-
- const functionContextMenu = (
-
-
{
- e.stopPropagation();
- setPopoverFunctionContextMenu(false);
- setOpenFunctionDetails(true);
- }}
- >
-
-
-
{
- e.stopPropagation();
- setPopoverFunctionContextMenu(false);
- functionItem?.activated ? handleDeactivate() : handleActivate();
- }}
- >
-
-
{functionItem?.activated ? 'Deactivate' : 'Activate'}
-
-
-
{
- e.stopPropagation();
- setPopoverFunctionContextMenu(false);
- handleDelete();
- }}
- >
-
-
-
isActive && onClick && onClick()}>
-
-
-
-
-
- {
-
-
-
-
- }
-
-
-
-
{
- setPopoverFunctionContextMenu(!popoverFunctionContextMenu);
- e && onClickMenu();
- }}
- open={popoverFunctionContextMenu}
- >
- e.stopPropagation()} />
-
-
-
-
-
-
- {selectedFunction?.name}
-
-
avg processing: {averageProcessingTime}/ms
-
-
-
-
-
-
-
-
{
- e.stopPropagation();
- setOpenFunctionDetails(false);
- }}
- destroyOnClose={true}
- open={openFunctionDetails}
- maskStyle={{ background: 'rgba(16, 16, 16, 0.2)' }}
- closeIcon={
-
-
-
- {functionDetails?.function?.function_name}
-
-
- {functionDetails?.function?.repo}
-
-
-
-
-
-
-
setTabValue(tabValue)} />
- {tabValue === tabValuesList[0] && (
-
-
-
-
-
Total invocations
-
{functionDetails?.metrics?.total_invocations?.toLocaleString() || 0}
-
-
-
-
-
-
-
Av. Processing time
-
- {functionDetails?.metrics?.average_processing_time}
- /ms
-
-
-
-
-
-
-
Error rate
-
{functionDetails?.metrics?.error_rate}%
-
-
-
-
-
-
Ordering
-
{functionDetails?.ordering_matter ? 'Yes' : 'No'}
-
-
-
- {attachedFunctionDlsMsgs && attachedFunctionDlsMsgs?.length > 0 ? (
- <>
-
-
- Time
- Text
-
-
- {attachedFunctionDlsMsgs?.map((message, index) => {
- return (
-
setSelectedMsg(message)}
- key={`dls-${index}`}
- >
- {parsingDate(message?.message?.time_sent, true, true)}
- {messageParser('json', message?.message?.data)}
-
- );
- })}
-
-
- {selectedMsg && loadMessageData && (
-
-
- )}
- {selectedMsg && !loadMessageData && (
-
-
- ) : (
-
- )}
-
- )}
- {tabValue === tabValuesList[3] &&
-
Inputs
-
-
-
- {inputsColumns?.map((column, index) => {
- return (
-
- {column.title}
-
- );
- })}
-
- {(!inputs || Object.entries(inputs)?.length === 0) && (
-
-
This function has no inputs
-
- )}
-
- {Object.entries(inputs)?.map((key, index) => {
- return (
-
-
- {key[0]}
-
-
- {key[1]}
-
-
- );
- })}
-
-
-
-
-
-
-
- Function Inputs Variables
-
-
-
-
- }
- open={open}
- clickOutside={() => clickOutside()}
- rBtnClick={onFinish}
- rBtnText={rBtnText}
- >
-
-
- These variables serve as dynamic placeholders, holding different values crucial for the function’s logic.
-
- Functions Inputs can be configured in the{' '}
- window.open('https://docs.memphis.dev/memphis/functions', '_blank')}>
- memphis.yaml
-
-
-
-
-
-
-
-
- );
-};
-
-export default FunctionInputsModal;
diff --git a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionInputsModal/style.scss b/ui_src/src/domain/stationOverview/stationObservabilty/components/functionInputsModal/style.scss
deleted file mode 100644
index a6bf71107..000000000
--- a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionInputsModal/style.scss
+++ /dev/null
@@ -1,29 +0,0 @@
-.function-inputs-modal {
- width: 100%;
- display: flex;
- justify-content: space-between;
- height: 100%;
- overflow-y: auto;
- .info {
- width: 300px;
- font-family: 'Inter';
- font-size: 14px;
- font-style: normal;
- font-weight: 400;
- .link {
- color: #6557ff;
- cursor: pointer;
- }
- }
- .inputs-container {
- height: 100%;
- min-height: 230px;
- width: auto;
- overflow-y: auto;
- .input-row {
- display: flex;
- margin-bottom: 10px;
- gap: 10px;
- }
- }
-}
diff --git a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionLogs/index.js b/ui_src/src/domain/stationOverview/stationObservabilty/components/functionLogs/index.js
deleted file mode 100644
index 7b3a4e1e5..000000000
--- a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionLogs/index.js
+++ /dev/null
@@ -1,52 +0,0 @@
-// Copyright 2022-2023 The Memphis.dev Authors
-// Licensed under the Memphis Business Source License 1.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// Changed License: [Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0), as published by the Apache Foundation.
-//
-// https://github.com/memphisdev/memphis/blob/master/LICENSE
-//
-// Additional Use Grant: You may make use of the Licensed Work (i) only as part of your own product or service, provided it is not a message broker or a message queue product or service; and (ii) provided that you do not use, provide, distribute, or make available the Licensed Work as a Service.
-// A "Service" is a commercial offering, product, hosted, or managed service, that allows third parties (other than your own employees and contractors acting on your behalf) to access and/or use the Licensed Work or a substantial set of the features or functionality of the Licensed Work to third parties as a software-as-a-service, platform-as-a-service, infrastructure-as-a-service or other similar services that compete with Licensor products or services.
-
-import './style.scss';
-
-import React, { useEffect, useState } from 'react';
-import { ApiEndpoints } from 'const/apiEndpoints';
-import { httpRequest } from 'services/http';
-import Spinner from 'components/spinner';
-
-const FunctionLogs = ({ functionId }) => {
- const [logs, setLogs] = useState([]);
- const [loader, setLoader] = useState(false);
-
- useEffect(() => {
- getAttachedFunctionLogs();
- }, []);
-
- const getAttachedFunctionLogs = async () => {
- setLoader(true);
- try {
- const data = await httpRequest('GET', `${ApiEndpoints.GET_ATTACHED_FUNCTION_LOGS}?function_id=${functionId}`);
- setLogs(data);
- setLoader(false);
- } catch (e) {
- setLoader(false);
- }
- };
-
- return (
-
- {loader && (
-
-
- )}
- {!loader && logs?.map((item) => item.log).join('')}
- {!loader && !logs?.length && 'No logs to show'}
-
- );
-};
-
-export default FunctionLogs;
diff --git a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionLogs/style.scss b/ui_src/src/domain/stationOverview/stationObservabilty/components/functionLogs/style.scss
deleted file mode 100644
index a8cb30101..000000000
--- a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionLogs/style.scss
+++ /dev/null
@@ -1,10 +0,0 @@
-.logs-container {
- white-space: pre;
- height: 150px;
- overflow-y: scroll;
- .spinner {
- width: 100%;
- display: flex;
- justify-content: center;
- }
-}
diff --git a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionsApplyModal/index.js b/ui_src/src/domain/stationOverview/stationObservabilty/components/functionsApplyModal/index.js
deleted file mode 100644
index 9052fa7be..000000000
--- a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionsApplyModal/index.js
+++ /dev/null
@@ -1,78 +0,0 @@
-// Copyright 2022-2023 The Memphis.dev Authors
-// Licensed under the Memphis Business Source License 1.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// Changed License: [Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0), as published by the Apache Foundation.
-//
-// https://github.com/memphisdev/memphis-broker/blob/master/LICENSE
-//
-// Additional Use Grant: You may make use of the Licensed Work (i) only as part of your own product or service, provided it is not a message broker or a message queue product or service; and (ii) provided that you do not use, provide, distribute, or make available the Licensed Work as a Service.
-// A "Service" is a commercial offering, product, hosted, or managed service, that allows third parties (other than your own employees and contractors acting on your behalf) to access and/or use the Licensed Work or a substantial set of the features or functionality of the Licensed Work to third parties as a software-as-a-service, platform-as-a-service, infrastructure-as-a-service or other similar services that compete with Licensor products or services.
-
-import './style.scss';
-
-import { useState, useEffect } from 'react';
-import Button from 'components/button';
-
-import { ReactComponent as CheckIcon } from 'assets/images/checkIcon.svg';
-
-const FunctionsApplyModal = ({ onCancel, onApply, successText }) => {
- const [selected, setSelected] = useState(0);
-
- const handleSelect = (index) => {
- setSelected(index);
- };
- const content = [
- {
- title: 'No',
- value: false
- },
- {
- title: 'Yes',
- value: true
- }
- ];
- return (
- <>
-
- {content.map((item, index) => (
-
handleSelect(index)}>
-
-
{item.title}
- {[selected].includes(index) ?
:
}
-
-
{item.subtitle}
-
- ))}
-
-
- onApply(content[selected]?.value)}
- />
-
-
- );
-};
-
-export default FunctionsApplyModal;
diff --git a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionsApplyModal/style.scss b/ui_src/src/domain/stationOverview/stationObservabilty/components/functionsApplyModal/style.scss
deleted file mode 100644
index 16c8f8a0c..000000000
--- a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionsApplyModal/style.scss
+++ /dev/null
@@ -1,70 +0,0 @@
-.select-section {
- padding-bottom: 10px;
-
- .modal-card {
- display: flex;
- padding: 10px 16px;
- width: 100%;
- gap: 4px;
- flex-direction: column;
- border-radius: 8px;
- border: 1px solid #eaecf0;
- background: #fff;
- margin-bottom: 12px;
- cursor: pointer;
-
- &__top-row {
- display: flex;
- align-items: center;
- justify-content: space-between;
- width: 100%;
-
- svg {
- width: 16px;
- height: 16px;
- path {
- fill: #6557ff;
- }
- }
-
- .empty-circle {
- width: 16px;
- height: 16px;
- border-radius: 50%;
- border: 1px solid #d0d5dd;
- }
- }
-
- &__title {
- color: #101828;
- font-family: 'InterMedium';
- font-size: 16px;
- }
- &__subtitle {
- color: #475467;
- font-family: 'Inter';
- font-size: 14px;
- }
-
- &.selected {
- border: 1px solid #6557ff;
- background: rgba(101, 87, 255, 0.1);
-
- .modal-card__title {
- color: #6557ff;
- }
- }
- }
-}
-
-.modal-buttons {
- width: 100%;
- display: flex;
- justify-content: space-between;
- align-items: center;
- gap: 17px;
-
- .button-container {
- width: 100%;
- }
-}
diff --git a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionsModal/index.js b/ui_src/src/domain/stationOverview/stationObservabilty/components/functionsModal/index.js
deleted file mode 100644
index 2eacd8af3..000000000
--- a/ui_src/src/domain/stationOverview/stationObservabilty/components/functionsModal/index.js
+++ /dev/null
@@ -1,320 +0,0 @@
-// Copyright 2022-2023 The Memphis.dev Authors
-// Licensed under the Memphis Business Source License 1.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// Changed License: [Apache License, Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0), as published by the Apache Foundation.
-//
-// https://github.com/memphisdev/memphis-broker/blob/master/LICENSE
-//
-// Additional Use Grant: You may make use of the Licensed Work (i) only as part of your own product or service, provided it is not a message broker or a message queue product or service; and (ii) provided that you do not use, provide, distribute, or make available the Licensed Work as a Service.
-// A "Service" is a commercial offering, product, hosted, or managed service, that allows third parties (other than your own employees and contractors acting on your behalf) to access and/or use the Licensed Work or a substantial set of the features or functionality of the Licensed Work to third parties as a software-as-a-service, platform-as-a-service, infrastructure-as-a-service or other similar services that compete with Licensor products or services.
-
-import './style.scss';
-
-import { useState, useEffect, useContext } from 'react';
-import { LoadingOutlined } from '@ant-design/icons';
-import { Spin } from 'antd';
-import CustomTabs from 'components/Tabs';
-import FunctionBox from 'domain/functions/components/functionBox';
-import FunctionDetails from 'domain/functions/components/functionDetails';
-import { getFunctionsTabs } from 'services/valueConvertor';
-import SearchInput from 'components/searchInput';
-import { ApiEndpoints } from 'const/apiEndpoints';
-import { httpRequest } from 'services/http';
-import FunctionsApplyModal from '../functionsApplyModal';
-import FunctionInputsModal from '../functionInputsModal';
-import Modal from 'components/modal';
-import { ReactComponent as SearchIcon } from 'assets/images/searchIcon.svg';
-import { ReactComponent as CheckShieldIcon } from 'assets/images/checkShieldIcon.svg';
-import { ReactComponent as FunctionsModalIcon } from 'assets/images/vueSaxIcon.svg';
-import { StationStoreContext } from 'domain/stationOverview';
-import { showMessages } from 'services/genericServices';
-import { OWNER } from 'const/globalConst';
-import RefreshButton from 'components/refreshButton';
-
-const FunctionsModal = ({ open, clickOutside, applyFunction, referredFunction }) => {
- const [functionList, setFunctionList] = useState([]);
- const [isIntegrated, setIsIntegrated] = useState(false);
- const [isLoading, setIsLoading] = useState(false);
- const [refreshIndeicator, setRefreshIndicator] = useState(false);
- const [tabValue, setTabValue] = useState('all');
- const [searchInput, setSearchInput] = useState('');
- const [isApplyModalOpen, setIsApplyModalOpen] = useState(false);
- const [isInputsModalOpen, setIsInputsModalOpen] = useState(false);
- const [filteredData, setFilteredData] = useState([]);
- const [clickedFunction, setClickedFunction] = useState(null);
- const [selectedFunction, setSelectedFunction] = useState(null);
- const [stationState, stationDispatch] = useContext(StationStoreContext);
- const [tabsCounter, setTabsCounter] = useState([0, 0, 0]);
-
- const TABS = getFunctionsTabs();
-
- useEffect(() => {
- getAllFunctions();
- setClickedFunction(null);
- }, [open]);
-
- useEffect(() => {
- const memphisCount = filteredData?.filter((func) => func?.owner === OWNER)?.length;
- const privateCount = filteredData?.filter((func) => func?.owner !== OWNER)?.length;
- setTabsCounter([memphisCount + privateCount, memphisCount, privateCount]);
- }, [filteredData]);
-
- useEffect(() => {
- let shouldRefresh = false;
- shouldRefresh = functionList?.some((func) => {
- return func?.installed_in_progress;
- });
- setRefreshIndicator(shouldRefresh);
- }, [functionList]);
-
- useEffect(() => {
- let result = functionList;
- if (tabValue === 'Private') {
- result = result?.filter((func) => func?.owner !== OWNER);
- } else if (tabValue === 'Memphis') {
- result = result?.filter((func) => func?.owner === OWNER);
- }
- if (searchInput.length > 0) {
- result = result?.filter(
- (func) =>
- func?.function_name?.toLowerCase()?.includes(searchInput?.toLowerCase()) || func?.description?.toLowerCase()?.includes(searchInput.toLowerCase())
- );
- }
- setFilteredData(result);
- }, [tabValue, searchInput, functionList]);
-
- const getAllFunctions = async () => {
- setIsLoading(true);
- try {
- const data = await httpRequest('GET', ApiEndpoints.GET_ALL_FUNCTIONS);
- setIsIntegrated(data?.scm_integrated);
-
- let updatedData = { ...data };
-
- const installed = updatedData?.installed
- ?.map((func, index) => {
- if (func?.owner === OWNER) {
- func.stars = Math.random() + 4;
- func.rates = Math.floor(Math.random() * (80 - 50 + 1)) + 50;
- func.forks = Math.floor(Math.random() * (100 - 80 + 1)) + 80;
- }
- return func;
- })
- ?.sort((a, b) => (a.function_name > b.function_name ? 1 : -1));
-
- const other = updatedData?.other
- ?.filter((func) => func?.is_valid)
- ?.map((func, index) => {
- if (func?.owner === OWNER) {
- func.stars = Math.random() + 4;
- func.rates = Math.floor(Math.random() * (80 - 50 + 1)) + 50;
- func.forks = Math.floor(Math.random() * (100 - 80 + 1)) + 80;
- }
- return func;
- })
- ?.sort((a, b) => (a.function_name > b.function_name ? 1 : -1));
-
- setFunctionList([...installed, ...other] || []);
- setTimeout(() => {
- setIsLoading(false);
- }, 500);
- } catch (error) {
- setIsLoading(false);
- }
- };
- const handleSearch = (e) => {
- setSearchInput(e.target.value);
- };
-
- const onFunctionApply = async (selectedFunction, ordering) => {
- let inputsObject = {};
- selectedFunction?.inputs?.forEach((item) => {
- inputsObject[item.name] = item.value;
- });
- const requestBody = {
- function_id: selectedFunction?.id,
- visible_step: stationState?.stationFunctions?.functions?.length + 1,
- ordering_matter: ordering,
- activate: true,
- inputs: inputsObject
- };
- applyFunction(requestBody);
- };
-
- const handleUnInstall = async (clickedFunction) => {
- const bodyRequest = {
- function_name: clickedFunction?.function_name,
- repo: clickedFunction?.repo,
- owner: clickedFunction?.owner,
- branch: clickedFunction?.branch,
- scm_type: clickedFunction?.scm,
- compute_engine: clickedFunction?.compute_engine
- };
- try {
- await httpRequest('DELETE', ApiEndpoints.UNINSTALL_FUNCTION, bodyRequest);
- getAllFunctions();
- setClickedFunction(null);
- } catch (e) {
- } finally {
- }
- };
-
- const handleInstall = async (clickedFunction) => {
- const bodyRequest = {
- function_name: clickedFunction?.function_name,
- repo: clickedFunction?.repo,
- owner: clickedFunction?.owner,
- branch: clickedFunction?.branch,
- scm_type: clickedFunction?.scm,
- by_memphis: clickedFunction?.by_memphis
- };
- try {
- await httpRequest('POST', ApiEndpoints.INSTALL_FUNCTION, bodyRequest);
- showMessages('success', `We are ${clickedFunction?.updates_available ? 'updating' : 'installing'} the function for you. We will let you know once its done`);
- getAllFunctions();
- } catch (e) {
- return;
- }
- };
-
- const handleInputsChange = (inputs) => {
- const newFunction = { ...selectedFunction };
- newFunction.inputs = inputs;
- setSelectedFunction(newFunction);
- };
-
- const antIcon = (
-
- );
- return (
- <>
-
-
- {clickedFunction ? (
-
{
- setClickedFunction(null);
- }}
- clickApply={() => {
- setSelectedFunction(clickedFunction);
- clickedFunction?.inputs?.length > 0
- ? setIsInputsModalOpen(true)
- : stationState?.stationFunctions?.functions?.length === 0
- ? setIsApplyModalOpen(true)
- : onFunctionApply(clickedFunction);
- }}
- handleUnInstall={() => handleUnInstall(clickedFunction)}
- handleInstall={() => handleInstall(clickedFunction)}
- />
- ) : (
- <>
-
-
-
-
Functions
-
- Say Goodbye to Manual Business Logic! Use Functions Instead of Building Complicated Clients.
-
-
-
setTabValue(tabValue)} tabsCounter={tabsCounter} />
-
-
- ) : (
-
- {filteredData?.map((functionItem, index) => (
- {
- setSelectedFunction(functionItem);
- functionItem?.inputs?.length > 0
- ? setIsInputsModalOpen(true)
- : stationState?.stationFunctions?.functions?.length === 0
- ? setIsApplyModalOpen(true)
- : onFunctionApply(functionItem);
- }}
- onClick={() => {
- setClickedFunction(functionItem);
- }}
- startInstallation={() => getAllFunctions()}
- />
- ))}
-
- )}
-
-
setIsInputsModalOpen(false)}
- handleInputsChange={(inputs) => handleInputsChange(inputs)}
- rBtnClick={() => {
- stationState?.stationFunctions?.functions?.length === 0 ? setIsApplyModalOpen(true) : onFunctionApply(selectedFunction);
- setIsInputsModalOpen(false);
- }}
- rBtnText={stationState?.stationFunctions?.functions?.length === 0 ? 'Next' : 'Apply'}
- clickedFunction={selectedFunction}
- />
-
-
-
- Events Orderding
- Should Functions maintain the initial order of the events as they received?
-
- }
- open={isApplyModalOpen}
- clickOutside={() => setIsApplyModalOpen(false)}
- displayButtons={false}
- >
-
-