feat: introduce action event step in flow step

This commit is contained in:
Ali BARIN
2022-01-28 20:48:56 +01:00
committed by Ömer Faruk Aydın
parent 2416ce13a7
commit e7c537f217
11 changed files with 86 additions and 33 deletions

View File

@@ -229,9 +229,6 @@
"key": "myTweet", "key": "myTweet",
"description": "Will be triggered when you tweet something new.", "description": "Will be triggered when you tweet something new.",
"subSteps": [ "subSteps": [
{
"name": "Choose app & event"
},
{ {
"name": "Choose account" "name": "Choose account"
}, },
@@ -245,9 +242,6 @@
"key": "userTweet", "key": "userTweet",
"description": "Will be triggered when a specific user tweet something new.", "description": "Will be triggered when a specific user tweet something new.",
"subSteps": [ "subSteps": [
{
"name": "Choose app & event"
},
{ {
"name": "Choose account" "name": "Choose account"
}, },
@@ -273,9 +267,6 @@
"key": "createTweet", "key": "createTweet",
"description": "Will create a tweet.", "description": "Will create a tweet.",
"subSteps": [ "subSteps": [
{
"name": "Choose app & event"
},
{ {
"name": "Choose account" "name": "Choose account"
}, },

View File

@@ -7,15 +7,16 @@ import RequestWithCurrentUser from '../../types/express/request-with-current-use
type Params = { type Params = {
input: { input: {
id: number, id: number;
key: string, key: string;
appKey: string, appKey: string;
parameters: string;
flow: { flow: {
id: number, id: number;
}, };
connection: { connection: {
id: number id: number;
}, };
} }
} }
const updateStepResolver = async (params: Params, req: RequestWithCurrentUser) => { const updateStepResolver = async (params: Params, req: RequestWithCurrentUser) => {
@@ -35,6 +36,7 @@ const updateStepResolver = async (params: Params, req: RequestWithCurrentUser) =
key: input.key, key: input.key,
appKey: input.appKey, appKey: input.appKey,
connectionId: input.connection.id, connectionId: input.connection.id,
parameters: input.parameters,
}); });
return step; return step;

View File

@@ -23,6 +23,7 @@ const stepType = new GraphQLObjectType({
}, },
}), }),
}, },
parameters: { type: GraphQLString },
connection: { type: ConnectionType }, connection: { type: ConnectionType },
position: { type: GraphQLInt }, position: { type: GraphQLInt },
}, },
@@ -51,6 +52,7 @@ export const stepInputType = new GraphQLInputObjectType({
}, },
}), }),
}, },
parameters: { type: GraphQLString },
previousStep: { previousStep: {
type: new GraphQLInputObjectType({ type: new GraphQLInputObjectType({
name: 'PreviousStepInput', name: 'PreviousStepInput',

View File

@@ -15,7 +15,7 @@ class Step extends Base {
type!: StepEnumType; type!: StepEnumType;
connectionId: number; connectionId: number;
position: number; position: number;
parameters: any; parameters: string;
static tableName = 'steps'; static tableName = 'steps';
@@ -31,7 +31,7 @@ class Step extends Base {
type: { type: 'string', enum: ['action', 'trigger'] }, type: { type: 'string', enum: ['action', 'trigger'] },
connectionId: { type: ['integer', null] }, connectionId: { type: ['integer', null] },
position: { type: 'integer' }, position: { type: 'integer' },
parameters: { type: ['object', null] }, parameters: { type: ['string', null] },
}, },
}; };

View File

@@ -53,6 +53,7 @@ export default function Editor(props: EditorProps): React.ReactElement {
const mutationInput: Record<string, unknown> = { const mutationInput: Record<string, unknown> = {
id: step.id, id: step.id,
key: step.key, key: step.key,
parameters: JSON.stringify(step.parameters, null, 2),
connection: { connection: {
id: step.connection?.id id: step.connection?.id
}, },

View File

@@ -1,5 +1,5 @@
import * as React from 'react'; import * as React from 'react';
import { useParams } from 'react-router-dom'; import { Link, useParams } from 'react-router-dom';
import { useQuery } from '@apollo/client'; import { useQuery } from '@apollo/client';
import Stack from '@mui/material/Stack'; import Stack from '@mui/material/Stack';
import Box from '@mui/material/Box'; import Box from '@mui/material/Box';
@@ -14,6 +14,7 @@ import Editor from 'components/Editor';
import useFormatMessage from 'hooks/useFormatMessage'; import useFormatMessage from 'hooks/useFormatMessage';
import { GET_FLOW } from 'graphql/queries/get-flow'; import { GET_FLOW } from 'graphql/queries/get-flow';
import type { Flow } from 'types/flow'; import type { Flow } from 'types/flow';
import * as URLS from 'config/urls';
export default function EditorLayout(): React.ReactElement { export default function EditorLayout(): React.ReactElement {
const { flowId } = useParams(); const { flowId } = useParams();
@@ -26,7 +27,11 @@ export default function EditorLayout(): React.ReactElement {
<Stack direction="column" height="100%"> <Stack direction="column" height="100%">
<Stack direction="row" bgcolor="white" justifyContent="space-between" alignItems="center" boxShadow={1} py={1} px={1}> <Stack direction="row" bgcolor="white" justifyContent="space-between" alignItems="center" boxShadow={1} py={1} px={1}>
<Box display="flex" flex={1} alignItems="center"> <Box display="flex" flex={1} alignItems="center">
<IconButton size="small"> <IconButton
size="small"
component={Link}
to={URLS.APPS}
>
<ArrowBackIosNewIcon fontSize="small" /> <ArrowBackIosNewIcon fontSize="small" />
</IconButton> </IconButton>

View File

@@ -27,21 +27,37 @@ type FlowStepProps = {
onChange?: (step: Step) => void; onChange?: (step: Step) => void;
} }
const optionGenerator = (app: App): { label: string; value: string; } => ({ const optionGenerator = (app: Record<string, unknown>): { label: string; value: string; } => ({
label: app.name, label: app.name as string,
value: app.key, value: app.key as string,
}); });
const getOption = (options: Record<string, unknown>[], appKey: string) => options.find(app => app.value === appKey); const getOption = (options: Record<string, unknown>[], appKey: unknown) => options.find(app => app.value === appKey as string);
const parseStep = (step: any) => {
try {
const parameters = JSON.parse(step.parameters);
return {
...step,
parameters,
}
} catch (err) {
// highly likely that step does not have any parameters and thus, the error is thrown
return step;
}
};
export default function FlowStep(props: FlowStepProps): React.ReactElement | null { export default function FlowStep(props: FlowStepProps): React.ReactElement | null {
const { collapsed, index, onChange } = props; const { collapsed, index, onChange } = props;
const [step, setStep] = React.useState<Step>(props.step); const [step, setStep] = React.useState<Step>(() => parseStep(props.step));
const isTrigger = step.type === StepType.Trigger;
const isAction = step.type === StepType.Action;
const initialRender = React.useRef<boolean>(true); const initialRender = React.useRef<boolean>(true);
const formatMessage = useFormatMessage(); const formatMessage = useFormatMessage();
const [currentSubstep, setCurrentSubstep] = React.useState<number | null>(0); const [currentSubstep, setCurrentSubstep] = React.useState<number | null>(0);
const { data } = useQuery(GET_APPS) const { data } = useQuery(GET_APPS)
const apps: App[] = data?.getApps; const apps: App[] = data?.getApps;
const app = apps?.find((currentApp: App) => currentApp.key === step.appKey);
// emit the step change to the parent component // emit the step change to the parent component
React.useEffect(() => { React.useEffect(() => {
@@ -52,21 +68,35 @@ export default function FlowStep(props: FlowStepProps): React.ReactElement | nul
} }
}, [step, onChange]); }, [step, onChange]);
const appAndEventOptions = React.useMemo(() => apps?.map(optionGenerator), [apps]); const appAndEventOptions = React.useMemo(() => apps?.map((app) => optionGenerator(app)), [apps]);
const actionOptions = React.useMemo(() => app?.triggers?.map((trigger) => optionGenerator(trigger)) ?? [], [app?.key]);
const onAppAndEventChange = React.useCallback((event: React.SyntheticEvent, selectedOption: unknown) => { const onAppChange = React.useCallback((event: React.SyntheticEvent, selectedOption: unknown) => {
if (typeof selectedOption === 'object') { if (typeof selectedOption === 'object') {
const typedSelectedOption = selectedOption as { value: string; }; const typedSelectedOption = selectedOption as { value: string; };
const option: { value: string } = typedSelectedOption; const option: { value: string } = typedSelectedOption;
const appKey = option.value as string; const appKey = option.value as string;
setStep((step) => ({ ...step, appKey })); setStep((step) => ({ ...step, appKey, parameters: {} }));
}
}, []);
const onEventChange = React.useCallback((event: React.SyntheticEvent, selectedOption: unknown) => {
if (typeof selectedOption === 'object') {
const typedSelectedOption = selectedOption as { value: string; };
const option: { value: string } = typedSelectedOption;
const eventKey = option.value as string;
setStep((step) => ({
...step,
parameters: {
...step.parameters,
eventKey,
}
}));
} }
}, []); }, []);
if (!apps) return null; if (!apps) return null;
const app = apps.find((currentApp: App) => currentApp.key === step.appKey);
const onOpen = () => collapsed && props.onOpen?.(); const onOpen = () => collapsed && props.onOpen?.();
const onClose = () => props.onClose?.(); const onClose = () => props.onClose?.();
@@ -81,7 +111,7 @@ export default function FlowStep(props: FlowStepProps): React.ReactElement | nul
<div> <div>
<Typography variant="caption"> <Typography variant="caption">
{ {
step.type === StepType.Trigger ? isTrigger ?
formatMessage('flowStep.triggerType') : formatMessage('flowStep.triggerType') :
formatMessage('flowStep.actionType') formatMessage('flowStep.actionType')
} }
@@ -110,7 +140,25 @@ export default function FlowStep(props: FlowStepProps): React.ReactElement | nul
sx={{ width: 300 }} sx={{ width: 300 }}
renderInput={(params) => <TextField {...params} label="Choose app & event" />} renderInput={(params) => <TextField {...params} label="Choose app & event" />}
value={getOption(appAndEventOptions, step.appKey)} value={getOption(appAndEventOptions, step.appKey)}
onChange={onAppAndEventChange} onChange={onAppChange}
/>
</ListItem>
</Collapse>
<ListItemButton onClick={() => toggleSubstep(1)}>
Action event
</ListItemButton>
<Collapse in={currentSubstep === 1} timeout="auto" unmountOnExit>
<ListItem sx={{ pt: 2 }}>
<Autocomplete
disablePortal
id="combo-box-demo"
options={actionOptions}
sx={{ width: 300 }}
renderInput={(params) => <TextField {...params} label="Choose app & event" />}
value={getOption(actionOptions, step?.parameters?.eventKey)}
onChange={onEventChange}
/> />
</ListItem> </ListItem>
</Collapse> </Collapse>

View File

@@ -20,5 +20,6 @@ export const CREATE_FLOW = '/editor/create';
export const FLOW_EDITOR = (flowId: string): string => `/editor/${flowId}`; export const FLOW_EDITOR = (flowId: string): string => `/editor/${flowId}`;
export const FLOWS = '/flows'; export const FLOWS = '/flows';
export const FLOW = (flowId: string): string => `/flows/${flowId}`; // TODO: revert this back to /flows/:flowId once we have a proper single flow page
export const FLOW = (flowId: string): string => `/editor/${flowId}`;
export const FLOW_PATTERN = '/flows/:flowId'; export const FLOW_PATTERN = '/flows/:flowId';

View File

@@ -7,6 +7,7 @@ export const UPDATE_STEP = gql`
type type
key key
appKey appKey
parameters
connection { connection {
id id
} }

View File

@@ -14,6 +14,7 @@ export const GET_FLOW = gql`
connection { connection {
id id
} }
parameters
} }
} }
} }

View File

@@ -10,6 +10,7 @@ export type Step = {
appKey: string; appKey: string;
type: StepType; type: StepType;
previousStepId: number | null; previousStepId: number | null;
parameters: Record<string, unknown>;
connection: { connection: {
id: number; id: number;
}; };