mirror of
https://github.com/farcasclaudiu/Flowise.git
synced 2026-06-28 23:01:09 +03:00
Fix merge conflicts
This commit is contained in:
@@ -1433,7 +1433,36 @@ export class App {
|
|||||||
upload.array('files'),
|
upload.array('files'),
|
||||||
(req: Request, res: Response, next: NextFunction) => getRateLimiter(req, res, next),
|
(req: Request, res: Response, next: NextFunction) => getRateLimiter(req, res, next),
|
||||||
async (req: Request, res: Response) => {
|
async (req: Request, res: Response) => {
|
||||||
await this.buildChatflow(req, res, socketIO)
|
const chatflow = await this.AppDataSource.getRepository(ChatFlow).findOneBy({
|
||||||
|
id: req.params.id
|
||||||
|
})
|
||||||
|
if (!chatflow) return res.status(404).send(`Chatflow ${req.params.id} not found`)
|
||||||
|
let isDomainAllowed = true
|
||||||
|
logger.info(`[server]: Request originated from ${req.headers.origin}`)
|
||||||
|
if (chatflow.chatbotConfig) {
|
||||||
|
const parsedConfig = JSON.parse(chatflow.chatbotConfig)
|
||||||
|
// check whether the first one is not empty. if it is empty that means the user set a value and then removed it.
|
||||||
|
const isValidAllowedOrigins = parsedConfig.allowedOrigins?.length && parsedConfig.allowedOrigins[0] !== ''
|
||||||
|
if (isValidAllowedOrigins) {
|
||||||
|
const originHeader = req.headers.origin as string
|
||||||
|
const origin = new URL(originHeader).host
|
||||||
|
isDomainAllowed =
|
||||||
|
parsedConfig.allowedOrigins.filter((domain: string) => {
|
||||||
|
try {
|
||||||
|
const allowedOrigin = new URL(domain).host
|
||||||
|
return origin === allowedOrigin
|
||||||
|
} catch (e) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
}).length > 0
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (isDomainAllowed) {
|
||||||
|
await this.buildChatflow(req, res, socketIO)
|
||||||
|
} else {
|
||||||
|
return res.status(401).send(`This site is not allowed to access this chatbot`)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|||||||
@@ -493,13 +493,14 @@ export const clearSessionMemory = async (
|
|||||||
* @returns {string}
|
* @returns {string}
|
||||||
*/
|
*/
|
||||||
export const getVariableValue = (
|
export const getVariableValue = (
|
||||||
paramValue: string,
|
paramValue: string | object,
|
||||||
reactFlowNodes: IReactFlowNode[],
|
reactFlowNodes: IReactFlowNode[],
|
||||||
question: string,
|
question: string,
|
||||||
chatHistory: IMessage[],
|
chatHistory: IMessage[],
|
||||||
isAcceptVariable = false
|
isAcceptVariable = false
|
||||||
) => {
|
) => {
|
||||||
let returnVal = paramValue
|
const isObject = typeof paramValue === 'object'
|
||||||
|
let returnVal = isObject ? JSON.stringify(paramValue) : paramValue
|
||||||
const variableStack = []
|
const variableStack = []
|
||||||
const variableDict = {} as IVariableDict
|
const variableDict = {} as IVariableDict
|
||||||
let startIdx = 0
|
let startIdx = 0
|
||||||
@@ -596,7 +597,7 @@ export const getVariableValue = (
|
|||||||
})
|
})
|
||||||
return returnVal
|
return returnVal
|
||||||
}
|
}
|
||||||
return returnVal
|
return isObject ? JSON.parse(returnVal) : returnVal
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
@@ -7,6 +7,7 @@ import {
|
|||||||
IconSearch,
|
IconSearch,
|
||||||
IconMessage,
|
IconMessage,
|
||||||
IconPictureInPictureOff,
|
IconPictureInPictureOff,
|
||||||
|
IconLink,
|
||||||
IconMicrophone,
|
IconMicrophone,
|
||||||
IconThumbUp
|
IconThumbUp
|
||||||
} from '@tabler/icons'
|
} from '@tabler/icons'
|
||||||
@@ -20,6 +21,7 @@ const icons = {
|
|||||||
IconSearch,
|
IconSearch,
|
||||||
IconMessage,
|
IconMessage,
|
||||||
IconPictureInPictureOff,
|
IconPictureInPictureOff,
|
||||||
|
IconLink,
|
||||||
IconMicrophone,
|
IconMicrophone,
|
||||||
IconThumbUp
|
IconThumbUp
|
||||||
}
|
}
|
||||||
@@ -52,6 +54,13 @@ const settings = {
|
|||||||
url: '',
|
url: '',
|
||||||
icon: icons.IconThumbUp
|
icon: icons.IconThumbUp
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
id: 'allowedDomains',
|
||||||
|
title: 'Allowed Domains',
|
||||||
|
type: 'item',
|
||||||
|
url: '',
|
||||||
|
icon: icons.IconLink
|
||||||
|
},
|
||||||
{
|
{
|
||||||
id: 'enableSpeechToText',
|
id: 'enableSpeechToText',
|
||||||
title: 'Speech to Text',
|
title: 'Speech to Text',
|
||||||
|
|||||||
@@ -0,0 +1,215 @@
|
|||||||
|
import { createPortal } from 'react-dom'
|
||||||
|
import { useDispatch } from 'react-redux'
|
||||||
|
import { useState, useEffect } from 'react'
|
||||||
|
import PropTypes from 'prop-types'
|
||||||
|
import { enqueueSnackbar as enqueueSnackbarAction, closeSnackbar as closeSnackbarAction, SET_CHATFLOW } from 'store/actions'
|
||||||
|
|
||||||
|
// material-ui
|
||||||
|
import {
|
||||||
|
Button,
|
||||||
|
IconButton,
|
||||||
|
Dialog,
|
||||||
|
DialogContent,
|
||||||
|
OutlinedInput,
|
||||||
|
DialogTitle,
|
||||||
|
DialogActions,
|
||||||
|
Box,
|
||||||
|
List,
|
||||||
|
InputAdornment
|
||||||
|
} from '@mui/material'
|
||||||
|
import { IconX, IconTrash, IconPlus } from '@tabler/icons'
|
||||||
|
|
||||||
|
// Project import
|
||||||
|
import { StyledButton } from 'ui-component/button/StyledButton'
|
||||||
|
|
||||||
|
// store
|
||||||
|
import { HIDE_CANVAS_DIALOG, SHOW_CANVAS_DIALOG } from 'store/actions'
|
||||||
|
import useNotifier from 'utils/useNotifier'
|
||||||
|
|
||||||
|
// API
|
||||||
|
import chatflowsApi from 'api/chatflows'
|
||||||
|
|
||||||
|
const AllowedDomainsDialog = ({ show, dialogProps, onCancel, onConfirm }) => {
|
||||||
|
const portalElement = document.getElementById('portal')
|
||||||
|
const dispatch = useDispatch()
|
||||||
|
|
||||||
|
useNotifier()
|
||||||
|
|
||||||
|
const enqueueSnackbar = (...args) => dispatch(enqueueSnackbarAction(...args))
|
||||||
|
const closeSnackbar = (...args) => dispatch(closeSnackbarAction(...args))
|
||||||
|
|
||||||
|
const [inputFields, setInputFields] = useState([''])
|
||||||
|
|
||||||
|
const [chatbotConfig, setChatbotConfig] = useState({})
|
||||||
|
|
||||||
|
const addInputField = () => {
|
||||||
|
setInputFields([...inputFields, ''])
|
||||||
|
}
|
||||||
|
const removeInputFields = (index) => {
|
||||||
|
const rows = [...inputFields]
|
||||||
|
rows.splice(index, 1)
|
||||||
|
setInputFields(rows)
|
||||||
|
}
|
||||||
|
|
||||||
|
const handleChange = (index, evnt) => {
|
||||||
|
const { value } = evnt.target
|
||||||
|
const list = [...inputFields]
|
||||||
|
list[index] = value
|
||||||
|
setInputFields(list)
|
||||||
|
}
|
||||||
|
|
||||||
|
const onSave = async () => {
|
||||||
|
try {
|
||||||
|
let value = {
|
||||||
|
allowedOrigins: [...inputFields]
|
||||||
|
}
|
||||||
|
chatbotConfig.allowedOrigins = value.allowedOrigins
|
||||||
|
const saveResp = await chatflowsApi.updateChatflow(dialogProps.chatflow.id, {
|
||||||
|
chatbotConfig: JSON.stringify(chatbotConfig)
|
||||||
|
})
|
||||||
|
if (saveResp.data) {
|
||||||
|
enqueueSnackbar({
|
||||||
|
message: 'Allowed Origins Saved',
|
||||||
|
options: {
|
||||||
|
key: new Date().getTime() + Math.random(),
|
||||||
|
variant: 'success',
|
||||||
|
action: (key) => (
|
||||||
|
<Button style={{ color: 'white' }} onClick={() => closeSnackbar(key)}>
|
||||||
|
<IconX />
|
||||||
|
</Button>
|
||||||
|
)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
dispatch({ type: SET_CHATFLOW, chatflow: saveResp.data })
|
||||||
|
}
|
||||||
|
onConfirm()
|
||||||
|
} catch (error) {
|
||||||
|
const errorData = error.response.data || `${error.response.status}: ${error.response.statusText}`
|
||||||
|
enqueueSnackbar({
|
||||||
|
message: `Failed to save Allowed Origins: ${errorData}`,
|
||||||
|
options: {
|
||||||
|
key: new Date().getTime() + Math.random(),
|
||||||
|
variant: 'error',
|
||||||
|
persist: true,
|
||||||
|
action: (key) => (
|
||||||
|
<Button style={{ color: 'white' }} onClick={() => closeSnackbar(key)}>
|
||||||
|
<IconX />
|
||||||
|
</Button>
|
||||||
|
)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
if (dialogProps.chatflow && dialogProps.chatflow.chatbotConfig) {
|
||||||
|
try {
|
||||||
|
let chatbotConfig = JSON.parse(dialogProps.chatflow.chatbotConfig)
|
||||||
|
setChatbotConfig(chatbotConfig || {})
|
||||||
|
if (chatbotConfig.allowedOrigins) {
|
||||||
|
let inputFields = [...chatbotConfig.allowedOrigins]
|
||||||
|
setInputFields(inputFields)
|
||||||
|
} else {
|
||||||
|
setInputFields([''])
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
setInputFields([''])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return () => {}
|
||||||
|
}, [dialogProps])
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
if (show) dispatch({ type: SHOW_CANVAS_DIALOG })
|
||||||
|
else dispatch({ type: HIDE_CANVAS_DIALOG })
|
||||||
|
return () => dispatch({ type: HIDE_CANVAS_DIALOG })
|
||||||
|
}, [show, dispatch])
|
||||||
|
|
||||||
|
const component = show ? (
|
||||||
|
<Dialog
|
||||||
|
onClose={onCancel}
|
||||||
|
open={show}
|
||||||
|
fullWidth
|
||||||
|
maxWidth='sm'
|
||||||
|
aria-labelledby='alert-dialog-title'
|
||||||
|
aria-describedby='alert-dialog-description'
|
||||||
|
>
|
||||||
|
<DialogTitle sx={{ fontSize: '1rem' }} id='alert-dialog-title'>
|
||||||
|
{dialogProps.title || 'Allowed Origins'}
|
||||||
|
</DialogTitle>
|
||||||
|
<DialogContent>
|
||||||
|
<div
|
||||||
|
style={{
|
||||||
|
display: 'flex',
|
||||||
|
flexDirection: 'column'
|
||||||
|
}}
|
||||||
|
>
|
||||||
|
<span>Your chatbot will only work when used from the following domains.</span>
|
||||||
|
</div>
|
||||||
|
<Box sx={{ '& > :not(style)': { m: 1 }, pt: 2 }}>
|
||||||
|
<List>
|
||||||
|
{inputFields.map((origin, index) => {
|
||||||
|
return (
|
||||||
|
<div key={index} style={{ display: 'flex', width: '100%' }}>
|
||||||
|
<Box sx={{ width: '100%', mb: 1 }}>
|
||||||
|
<OutlinedInput
|
||||||
|
sx={{ width: '100%' }}
|
||||||
|
key={index}
|
||||||
|
type='text'
|
||||||
|
onChange={(e) => handleChange(index, e)}
|
||||||
|
size='small'
|
||||||
|
value={origin}
|
||||||
|
name='origin'
|
||||||
|
placeholder='https://example.com'
|
||||||
|
endAdornment={
|
||||||
|
<InputAdornment position='end' sx={{ padding: '2px' }}>
|
||||||
|
{inputFields.length > 1 && (
|
||||||
|
<IconButton
|
||||||
|
sx={{ height: 30, width: 30 }}
|
||||||
|
size='small'
|
||||||
|
color='error'
|
||||||
|
disabled={inputFields.length === 1}
|
||||||
|
onClick={() => removeInputFields(index)}
|
||||||
|
edge='end'
|
||||||
|
>
|
||||||
|
<IconTrash />
|
||||||
|
</IconButton>
|
||||||
|
)}
|
||||||
|
</InputAdornment>
|
||||||
|
}
|
||||||
|
/>
|
||||||
|
</Box>
|
||||||
|
<Box sx={{ width: '5%', mb: 1 }}>
|
||||||
|
{index === inputFields.length - 1 && (
|
||||||
|
<IconButton color='primary' onClick={addInputField}>
|
||||||
|
<IconPlus />
|
||||||
|
</IconButton>
|
||||||
|
)}
|
||||||
|
</Box>
|
||||||
|
</div>
|
||||||
|
)
|
||||||
|
})}
|
||||||
|
</List>
|
||||||
|
</Box>
|
||||||
|
</DialogContent>
|
||||||
|
<DialogActions>
|
||||||
|
<Button onClick={onCancel}>Cancel</Button>
|
||||||
|
<StyledButton variant='contained' onClick={onSave}>
|
||||||
|
Save
|
||||||
|
</StyledButton>
|
||||||
|
</DialogActions>
|
||||||
|
</Dialog>
|
||||||
|
) : null
|
||||||
|
|
||||||
|
return createPortal(component, portalElement)
|
||||||
|
}
|
||||||
|
|
||||||
|
AllowedDomainsDialog.propTypes = {
|
||||||
|
show: PropTypes.bool,
|
||||||
|
dialogProps: PropTypes.object,
|
||||||
|
onCancel: PropTypes.func,
|
||||||
|
onConfirm: PropTypes.func
|
||||||
|
}
|
||||||
|
|
||||||
|
export default AllowedDomainsDialog
|
||||||
@@ -18,6 +18,7 @@ import AnalyseFlowDialog from 'ui-component/dialog/AnalyseFlowDialog'
|
|||||||
import ViewMessagesDialog from 'ui-component/dialog/ViewMessagesDialog'
|
import ViewMessagesDialog from 'ui-component/dialog/ViewMessagesDialog'
|
||||||
import StarterPromptsDialog from 'ui-component/dialog/StarterPromptsDialog'
|
import StarterPromptsDialog from 'ui-component/dialog/StarterPromptsDialog'
|
||||||
import ChatFeedbackDialog from 'ui-component/dialog/ChatFeedbackDialog'
|
import ChatFeedbackDialog from 'ui-component/dialog/ChatFeedbackDialog'
|
||||||
|
import AllowedDomainsDialog from 'ui-component/dialog/AllowedDomainsDialog'
|
||||||
|
|
||||||
// API
|
// API
|
||||||
import chatflowsApi from 'api/chatflows'
|
import chatflowsApi from 'api/chatflows'
|
||||||
@@ -56,6 +57,8 @@ const CanvasHeader = ({ chatflow, handleSaveFlow, handleDeleteFlow, handleLoadFl
|
|||||||
const [viewMessagesDialogProps, setViewMessagesDialogProps] = useState({})
|
const [viewMessagesDialogProps, setViewMessagesDialogProps] = useState({})
|
||||||
const [chatFeedbackDialogOpen, setChatFeedbackDialogOpen] = useState(false)
|
const [chatFeedbackDialogOpen, setChatFeedbackDialogOpen] = useState(false)
|
||||||
const [chatFeedbackDialogProps, setChatFeedbackDialogProps] = useState({})
|
const [chatFeedbackDialogProps, setChatFeedbackDialogProps] = useState({})
|
||||||
|
const [allowedDomainsDialogOpen, setAllowedDomainsDialogOpen] = useState(false)
|
||||||
|
const [allowedDomainsDialogProps, setAllowedDomainsDialogProps] = useState({})
|
||||||
|
|
||||||
const updateChatflowApi = useApi(chatflowsApi.updateChatflow)
|
const updateChatflowApi = useApi(chatflowsApi.updateChatflow)
|
||||||
const canvas = useSelector((state) => state.canvas)
|
const canvas = useSelector((state) => state.canvas)
|
||||||
@@ -77,6 +80,12 @@ const CanvasHeader = ({ chatflow, handleSaveFlow, handleDeleteFlow, handleLoadFl
|
|||||||
chatflow: chatflow
|
chatflow: chatflow
|
||||||
})
|
})
|
||||||
setChatFeedbackDialogOpen(true)
|
setChatFeedbackDialogOpen(true)
|
||||||
|
} else if (setting === 'allowedDomains') {
|
||||||
|
setAllowedDomainsDialogProps({
|
||||||
|
title: 'Allowed Domains - ' + chatflow.name,
|
||||||
|
chatflow: chatflow
|
||||||
|
})
|
||||||
|
setAllowedDomainsDialogOpen(true)
|
||||||
} else if (setting === 'analyseChatflow') {
|
} else if (setting === 'analyseChatflow') {
|
||||||
setAnalyseDialogProps({
|
setAnalyseDialogProps({
|
||||||
title: 'Analyse Chatflow',
|
title: 'Analyse Chatflow',
|
||||||
@@ -420,6 +429,12 @@ const CanvasHeader = ({ chatflow, handleSaveFlow, handleDeleteFlow, handleLoadFl
|
|||||||
onConfirm={() => setChatFeedbackDialogOpen(false)}
|
onConfirm={() => setChatFeedbackDialogOpen(false)}
|
||||||
onCancel={() => setChatFeedbackDialogOpen(false)}
|
onCancel={() => setChatFeedbackDialogOpen(false)}
|
||||||
/>
|
/>
|
||||||
|
<AllowedDomainsDialog
|
||||||
|
show={allowedDomainsDialogOpen}
|
||||||
|
dialogProps={allowedDomainsDialogProps}
|
||||||
|
onConfirm={() => setAllowedDomainsDialogOpen(false)}
|
||||||
|
onCancel={() => setAllowedDomainsDialogOpen(false)}
|
||||||
|
/>
|
||||||
<ViewMessagesDialog
|
<ViewMessagesDialog
|
||||||
show={viewMessagesDialogOpen}
|
show={viewMessagesDialogOpen}
|
||||||
dialogProps={viewMessagesDialogProps}
|
dialogProps={viewMessagesDialogProps}
|
||||||
|
|||||||
@@ -50,7 +50,7 @@ const CanvasNode = ({ data }) => {
|
|||||||
const onDialogClicked = () => {
|
const onDialogClicked = () => {
|
||||||
const dialogProps = {
|
const dialogProps = {
|
||||||
data,
|
data,
|
||||||
inputParams: data.inputParams.filter((param) => param.additionalParams),
|
inputParams: data.inputParams.filter((inputParam) => !inputParam.hidden).filter((param) => param.additionalParams),
|
||||||
confirmButtonName: 'Save',
|
confirmButtonName: 'Save',
|
||||||
cancelButtonName: 'Cancel'
|
cancelButtonName: 'Cancel'
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user