Skip to content

Commit eab6c83

Browse files
Sg312Vikhyath Mondreti
Sg312
authored and
Vikhyath Mondreti
committed
fix(catalog): preserve credential gates for automation discovery
1 parent 119c9f4 commit eab6c83

10 files changed

Lines changed: 200 additions & 37 deletions

File tree

‎apps/docs/openapi-v2-resources.json‎

Lines changed: 80 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14164,6 +14164,26 @@
1416414164
"description": "Whether the field is hidden in the editor.",
1416514165
"type": "boolean"
1416614166
},
14167+
"reactiveCondition": {
14168+
"description": "Credential-kind requirement for this field or option; inspect the selected credential before using it.",
14169+
"type": "object",
14170+
"properties": {
14171+
"watchFields": {
14172+
"type": "array",
14173+
"items": {
14174+
"type": "string"
14175+
},
14176+
"description": "Credential selector fields; the first populated value identifies the credential."
14177+
},
14178+
"requiredType": {
14179+
"type": "string",
14180+
"enum": ["oauth", "service_account"],
14181+
"description": "Credential kind required for this field or option to apply."
14182+
}
14183+
},
14184+
"required": ["watchFields", "requiredType"],
14185+
"additionalProperties": false
14186+
},
1416714187
"condition": {
1416814188
"description": "Condition under which the field applies at all.",
1416914189
"$ref": "#/components/schemas/V2CatalogCondition"
@@ -14182,6 +14202,26 @@
1418214202
"description": "Human-readable option label.",
1418314203
"type": "string"
1418414204
},
14205+
"reactiveCondition": {
14206+
"description": "Credential-kind requirement for this field or option; inspect the selected credential before using it.",
14207+
"type": "object",
14208+
"properties": {
14209+
"watchFields": {
14210+
"type": "array",
14211+
"items": {
14212+
"type": "string"
14213+
},
14214+
"description": "Credential selector fields; the first populated value identifies the credential."
14215+
},
14216+
"requiredType": {
14217+
"type": "string",
14218+
"enum": ["oauth", "service_account"],
14219+
"description": "Credential kind required for this field or option to apply."
14220+
}
14221+
},
14222+
"required": ["watchFields", "requiredType"],
14223+
"additionalProperties": false
14224+
},
1418514225
"hasIcon": {
1418614226
"description": "Whether the option renders with an icon. The icon itself is not published.",
1418714227
"type": "boolean"
@@ -14931,12 +14971,52 @@
1493114971
"label": {
1493214972
"type": "string",
1493314973
"description": "Human-readable option label."
14974+
},
14975+
"reactiveCondition": {
14976+
"description": "Credential-kind requirement for this field or option; inspect the selected credential before using it.",
14977+
"type": "object",
14978+
"properties": {
14979+
"watchFields": {
14980+
"type": "array",
14981+
"items": {
14982+
"type": "string"
14983+
},
14984+
"description": "Credential selector fields; the first populated value identifies the credential."
14985+
},
14986+
"requiredType": {
14987+
"type": "string",
14988+
"enum": ["oauth", "service_account"],
14989+
"description": "Credential kind required for this field or option to apply."
14990+
}
14991+
},
14992+
"required": ["watchFields", "requiredType"],
14993+
"additionalProperties": false
1493414994
}
1493514995
},
1493614996
"required": ["id", "label"],
1493714997
"additionalProperties": false
1493814998
}
1493914999
},
15000+
"reactiveCondition": {
15001+
"description": "Credential-kind requirement for this field or option; inspect the selected credential before using it.",
15002+
"type": "object",
15003+
"properties": {
15004+
"watchFields": {
15005+
"type": "array",
15006+
"items": {
15007+
"type": "string"
15008+
},
15009+
"description": "Credential selector fields; the first populated value identifies the credential."
15010+
},
15011+
"requiredType": {
15012+
"type": "string",
15013+
"enum": ["oauth", "service_account"],
15014+
"description": "Credential kind required for this field or option to apply."
15015+
}
15016+
},
15017+
"required": ["watchFields", "requiredType"],
15018+
"additionalProperties": false
15019+
},
1494015020
"condition": {
1494115021
"description": "Condition under which the field applies.",
1494215022
"$ref": "#/components/schemas/V2CatalogCondition"

‎apps/sim/lib/api/contracts/v2/catalog.ts‎

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,6 +102,15 @@ const catalogDependsOnSchema = z.union([
102102
}),
103103
])
104104

105+
const catalogCredentialConditionSchema = z.object({
106+
watchFields: z
107+
.array(z.string())
108+
.describe('Credential selector fields; the first populated value identifies the credential.'),
109+
requiredType: z
110+
.enum(['oauth', 'service_account'])
111+
.describe('Credential kind required for this field or option to apply.'),
112+
})
113+
105114
/** One configuration field on a block. */
106115
export const v2BlockFieldSchema = z
107116
.object({
@@ -126,6 +135,11 @@ export const v2BlockFieldSchema = z
126135
'Where the field renders: `basic`, `advanced`, `both`, `trigger`, or `trigger-advanced`.'
127136
),
128137
hidden: z.boolean().optional().describe('Whether the field is hidden in the editor.'),
138+
reactiveCondition: catalogCredentialConditionSchema
139+
.optional()
140+
.describe(
141+
'Credential-kind requirement for this field or option; inspect the selected credential before using it.'
142+
),
129143
condition: v2CatalogConditionSchema
130144
.optional()
131145
.describe('Condition under which the field applies at all.'),
@@ -134,6 +148,11 @@ export const v2BlockFieldSchema = z
134148
z.object({
135149
id: z.string().describe('Value stored when this option is selected.'),
136150
label: z.string().optional().describe('Human-readable option label.'),
151+
reactiveCondition: catalogCredentialConditionSchema
152+
.optional()
153+
.describe(
154+
'Credential-kind requirement for this field or option; inspect the selected credential before using it.'
155+
),
137156
hasIcon: z
138157
.boolean()
139158
.optional()
@@ -557,10 +576,20 @@ const v2BlockTriggerSchema = z.object({
557576
z.object({
558577
id: z.string().describe('Value stored when this option is selected.'),
559578
label: z.string().describe('Human-readable option label.'),
579+
reactiveCondition: catalogCredentialConditionSchema
580+
.optional()
581+
.describe(
582+
'Credential-kind requirement for this field or option; inspect the selected credential before using it.'
583+
),
560584
})
561585
)
562586
.optional()
563587
.describe('Selectable options.'),
588+
reactiveCondition: catalogCredentialConditionSchema
589+
.optional()
590+
.describe(
591+
'Credential-kind requirement for this field or option; inspect the selected credential before using it.'
592+
),
564593
condition: v2CatalogConditionSchema
565594
.optional()
566595
.describe('Condition under which the field applies.'),

‎apps/sim/lib/catalog/projection/block-detail.ts‎

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,9 @@ import {
77
resolveOperationIds,
88
} from '@/lib/catalog/projection/block-summary'
99
import {
10+
type CatalogCredentialCondition,
1011
type CatalogSubBlock,
12+
copyCredentialCondition,
1113
normalizeCondition,
1214
projectSubBlock,
1315
} from '@/lib/catalog/projection/subblock'
@@ -98,7 +100,8 @@ export interface CatalogTriggerConfigField {
98100
description?: string
99101
placeholder?: string
100102
default?: unknown
101-
options?: { id: string; label: string }[]
103+
options?: { id: string; label: string; reactiveCondition?: CatalogCredentialCondition }[]
104+
reactiveCondition?: CatalogCredentialCondition
102105
condition?: CatalogSubBlock['condition']
103106
}
104107

@@ -357,10 +360,15 @@ export function projectBlockTriggers(block: BlockConfig): CatalogBlockTrigger[]
357360
field.options = subBlock.options.map((option) => ({
358361
id: option.id,
359362
label: option.label || option.id,
363+
...(option.reactiveCondition
364+
? { reactiveCondition: copyCredentialCondition(option.reactiveCondition) }
365+
: {}),
360366
}))
361367
}
362368
const condition = normalizeCondition(subBlock.condition)
363369
if (condition) field.condition = condition
370+
if (subBlock.reactiveCondition)
371+
field.reactiveCondition = copyCredentialCondition(subBlock.reactiveCondition)
364372

365373
configFields[subBlock.id] = field
366374
}

‎apps/sim/lib/catalog/projection/catalog-sweep.test.ts‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,6 +106,21 @@ function expectSerializable(projection: unknown, label: string): void {
106106
walk(projection, label)
107107
}
108108

109+
it('preserves credential gates in the Slack trigger contract sent to clients', () => {
110+
const config = getBlockRegistry().slack_v2
111+
const wire = v2BlockDetailSchema.parse(projectBlockDetail(config, { deployment: HOSTED }))
112+
const trigger = wire.triggers.find(({ id }) => id === 'slack_oauth')!
113+
expect(trigger.configFields.streamResponse).toMatchObject({
114+
reactiveCondition: { watchFields: ['customBotCredential'], requiredType: 'service_account' },
115+
condition: { field: 'eventType', value: ['message', 'app_mention'] },
116+
})
117+
expect(
118+
trigger.configFields.eventType.options?.find(({ id }) => id === 'assistant_thread_started')
119+
).toMatchObject({
120+
reactiveCondition: { watchFields: ['customBotCredential'], requiredType: 'oauth' },
121+
})
122+
})
123+
109124
describe('block catalog projection sweep', () => {
110125
const blocks = Object.values(getBlockRegistry())
111126

‎apps/sim/lib/catalog/projection/subblock.ts‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,18 @@ import { useProvidersStore } from '@/stores/providers'
1212
* never describe the same field differently.
1313
*/
1414

15+
/** Credential-kind gate authored by the block, preserved for non-editor clients. */
16+
export type CatalogCredentialCondition = NonNullable<SubBlockConfig['reactiveCondition']>
17+
18+
export function copyCredentialCondition(
19+
condition: CatalogCredentialCondition
20+
): CatalogCredentialCondition {
21+
return { watchFields: [...condition.watchFields], requiredType: condition.requiredType }
22+
}
23+
1524
/** One selectable option on a dropdown, combobox, or multi-select field. */
1625
export interface CatalogSubBlockOption {
26+
reactiveCondition?: CatalogCredentialCondition
1727
id: string
1828
label?: string
1929
/** Whether the option renders with an icon. The icon component itself is never published. */
@@ -66,6 +76,7 @@ export interface CatalogSubBlock {
6676
hidden?: boolean
6777
/** The condition under which the field applies at all. */
6878
condition?: CatalogCondition
79+
reactiveCondition?: CatalogCredentialCondition
6980
options?: CatalogSubBlockOption[]
7081
min?: number
7182
max?: number
@@ -316,6 +327,8 @@ export function resolveSubBlockOptions(
316327
const projected: CatalogSubBlockOption = { id: String(option.id) }
317328
if (typeof option.label === 'string') projected.label = option.label
318329
if (option.icon) projected.hasIcon = true
330+
if (option.reactiveCondition)
331+
projected.reactiveCondition = copyCredentialCondition(option.reactiveCondition)
319332
normalized.push(projected)
320333
}
321334

@@ -352,6 +365,8 @@ export function projectSubBlock(subBlock: SubBlockConfig): CatalogSubBlock {
352365
assignDefined(projected, 'placeholder', subBlock.placeholder)
353366
assignDefined(projected, 'mode', subBlock.mode)
354367
assignDefined(projected, 'hidden', subBlock.hidden)
368+
if (subBlock.reactiveCondition)
369+
projected.reactiveCondition = copyCredentialCondition(subBlock.reactiveCondition)
355370
assignDefined(projected, 'canonicalParamId', subBlock.canonicalParamId)
356371
assignDefined(projected, 'defaultValue', subBlock.defaultValue)
357372
assignDefined(projected, 'min', subBlock.min)

‎apps/sim/lib/webhooks/slack-stream-config.test.ts‎

Lines changed: 25 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -66,26 +66,29 @@ describe('Slack stream response config', () => {
6666
).toBe('Running')
6767
})
6868

69-
it('rejects non-reply events and malformed output selectors', () => {
70-
expect(() =>
71-
normalizeSlackStreamResponseConfig(
72-
{
73-
eventType: 'reaction_added',
74-
streamResponse: true,
75-
streamOutputs: ['block.content'],
76-
},
77-
{}
78-
)
79-
).toThrow('reply-capable')
80-
expect(() =>
81-
normalizeSlackStreamResponseConfig(
82-
{
83-
eventType: 'message',
84-
streamResponse: true,
85-
streamOutputs: ['block_content'],
86-
},
87-
{}
88-
)
89-
).toThrow('Invalid Slack stream output selector')
90-
})
69+
it.each(['reaction_added', 'assistant_thread_started'])(
70+
'rejects unsupported streaming event %s and malformed output selectors',
71+
(eventType) => {
72+
expect(() =>
73+
normalizeSlackStreamResponseConfig(
74+
{
75+
eventType,
76+
streamResponse: true,
77+
streamOutputs: ['block.content'],
78+
},
79+
{}
80+
)
81+
).toThrow('reply-capable')
82+
expect(() =>
83+
normalizeSlackStreamResponseConfig(
84+
{
85+
eventType: 'message',
86+
streamResponse: true,
87+
streamOutputs: ['block_content'],
88+
},
89+
{}
90+
)
91+
).toThrow('Invalid Slack stream output selector')
92+
}
93+
)
9194
})

‎apps/sim/lib/webhooks/slack-stream-config.ts‎

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,12 +5,7 @@ import {
55
resolveOutputBlockRef,
66
} from '@/lib/workflows/streaming/output-selector'
77
import { normalizeName } from '@/executor/constants'
8-
9-
export const SLACK_STREAM_RESPONSE_EVENTS = [
10-
'message',
11-
'app_mention',
12-
'assistant_thread_started',
13-
] as const
8+
import { SLACK_STREAM_RESPONSE_EVENTS } from '@/triggers/slack/shared'
149

1510
export interface SlackStreamOutputConfig {
1611
workflowId?: string

0 commit comments

Comments
 (0)