busbar-sf-agentscript 0.0.2

AgentScript parser, graph analysis, and LSP for Salesforce Agentforce
Documentation 
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114

//! Connection block parser.
//!
//! Parses `connection <name>:` blocks for escalation routing.
//!
//! # Syntax
//!
//! ```text
//! connection messaging:
//!    escalation_message: "I'm connecting you with a specialist."
//!    outbound_route_type: "OmniChannelFlow"
//!    outbound_route_name: "SpecialistQueue"
//! ```

use crate::ast::{ConnectionBlock, ConnectionEntry, Spanned};
use crate::lexer::Token;
use chumsky::prelude::*;

use super::primitives::{
    dedent, indent, newline, skip_block_noise, spanned_ident, spanned_string, to_ast_span,
    ParserInput, Span,
};

/// Parse a connection entry (key: value pair).
fn connection_entry<'tokens, 'src: 'tokens>() -> impl Parser<
    'tokens,
    ParserInput<'tokens, 'src>,
    Spanned<ConnectionEntry>,
    extra::Err<Rich<'tokens, Token<'src>, Span>>,
> + Clone {
    spanned_ident()
        .then_ignore(just(Token::Colon))
        .then(spanned_string())
        .map_with(|(name, value), e| {
            Spanned::new(ConnectionEntry { name, value }, to_ast_span(e.span()))
        })
}

/// Parse a connection block: `connection <name>:`
pub(crate) fn connection_block<'tokens, 'src: 'tokens>() -> impl Parser<
    'tokens,
    ParserInput<'tokens, 'src>,
    Spanned<ConnectionBlock>,
    extra::Err<Rich<'tokens, Token<'src>, Span>>,
> + Clone {
    just(Token::Connection)
        .ignore_then(spanned_ident())
        .then_ignore(just(Token::Colon))
        .then_ignore(newline())
        .then_ignore(skip_block_noise())
        .then_ignore(indent())
        .then(
            connection_entry()
                .separated_by(skip_block_noise())
                .allow_trailing()
                .collect::<Vec<_>>(),
        )
        .then_ignore(skip_block_noise())
        .then_ignore(dedent())
        .map_with(|(name, entries), e| {
            Spanned::new(ConnectionBlock { name, entries }, to_ast_span(e.span()))
        })
}

/// Parse a `connections:` wrapper block containing named connection sub-blocks.
///
/// # Syntax
///
/// ```text
/// connections:
///    messaging:
///       escalation_message: "I'm connecting you with a specialist."
///       outbound_route_type: "OmniChannelFlow"
///       outbound_route_name: "SpecialistQueue"
/// ```
///
/// Each named sub-block is equivalent to a `connection <name>:` block.
pub(crate) fn connections_wrapper_block<'tokens, 'src: 'tokens>() -> impl Parser<
    'tokens,
    ParserInput<'tokens, 'src>,
    Vec<Spanned<ConnectionBlock>>,
    extra::Err<Rich<'tokens, Token<'src>, Span>>,
> + Clone {
    // Each named sub-block: `messaging:` with indented key-value entries
    let named_sub_block = spanned_ident()
        .then_ignore(just(Token::Colon))
        .then_ignore(newline())
        .then_ignore(skip_block_noise())
        .then_ignore(indent())
        .then(
            connection_entry()
                .separated_by(skip_block_noise())
                .allow_trailing()
                .collect::<Vec<_>>(),
        )
        .then_ignore(skip_block_noise())
        .then_ignore(dedent())
        .map_with(|(name, entries), e| {
            Spanned::new(ConnectionBlock { name, entries }, to_ast_span(e.span()))
        });

    just(Token::Connections)
        .ignore_then(just(Token::Colon))
        .ignore_then(newline())
        .ignore_then(skip_block_noise())
        .ignore_then(indent())
        .ignore_then(
            named_sub_block
                .separated_by(skip_block_noise())
                .allow_trailing()
                .collect::<Vec<_>>(),
        )
        .then_ignore(skip_block_noise())
        .then_ignore(dedent())
}