1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
| import { BlockEnum } from '../../types'
| import type { NodeDefault } from '../../types'
| import { AuthorizationType, BodyType, Method } from './types'
| import type { BodyPayload, HttpNodeType } from './types'
| import {
| ALL_CHAT_AVAILABLE_BLOCKS,
| ALL_COMPLETION_AVAILABLE_BLOCKS,
| } from '@/app/components/workflow/blocks'
|
| const nodeDefault: NodeDefault<HttpNodeType> = {
| defaultValue: {
| variables: [],
| method: Method.get,
| url: '',
| authorization: {
| type: AuthorizationType.none,
| config: null,
| },
| headers: '',
| params: '',
| body: {
| type: BodyType.none,
| data: [],
| },
| timeout: {
| max_connect_timeout: 0,
| max_read_timeout: 0,
| max_write_timeout: 0,
| },
| retry_config: {
| retry_enabled: true,
| max_retries: 3,
| retry_interval: 100,
| },
| },
| getAvailablePrevNodes(isChatMode: boolean) {
| const nodes = isChatMode
| ? ALL_CHAT_AVAILABLE_BLOCKS
| : ALL_COMPLETION_AVAILABLE_BLOCKS.filter(type => type !== BlockEnum.End)
| return nodes
| },
| getAvailableNextNodes(isChatMode: boolean) {
| const nodes = isChatMode ? ALL_CHAT_AVAILABLE_BLOCKS : ALL_COMPLETION_AVAILABLE_BLOCKS
| return nodes
| },
| checkValid(payload: HttpNodeType, t: any) {
| let errorMessages = ''
|
| if (!errorMessages && !payload.url)
| errorMessages = t('workflow.errorMsg.fieldRequired', { field: t('workflow.nodes.http.api') })
|
| if (!errorMessages
| && payload.body.type === BodyType.binary
| && ((!(payload.body.data as BodyPayload)[0]?.file) || (payload.body.data as BodyPayload)[0]?.file?.length === 0)
| )
| errorMessages = t('workflow.errorMsg.fieldRequired', { field: t('workflow.nodes.http.binaryFileVariable') })
|
| return {
| isValid: !errorMessages,
| errorMessage: errorMessages,
| }
| },
| }
|
| export default nodeDefault
|
|
