oak-nginx 0.0.11

Nginx web server configuration language parser with support for web server configuration and routing processing.
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

/// Element types for the Nginx parser.
pub mod element_type;

use crate::{
    language::NginxLanguage,
    lexer::{NginxLexer, token_type::NginxTokenType},
};
use oak_core::{
    GreenNode, OakError,
    parser::{ParseCache, ParseOutput, Parser, ParserState},
    source::{Source, TextEdit},
};

/// Parser for Nginx configuration files.
pub struct NginxParser<'a> {
    /// The language configuration.
    pub language: &'a NginxLanguage,
}

impl<'a> NginxParser<'a> {
    /// Creates a new Nginx parser with the given language configuration.
    pub fn new(language: &'a NginxLanguage) -> Self {
        Self { language }
    }

    fn parse_directive<'b, S: Source + ?Sized>(&self, state: &mut ParserState<'b, NginxLanguage, S>) {
        if state.at(NginxTokenType::CommentToken) {
            let checkpoint = state.checkpoint();
            state.bump();
            state.finish_at(checkpoint, crate::parser::element_type::NginxElementType::Comment);
            return;
        }

        let is_block_directive = matches!(state.peek_kind(), Some(NginxTokenType::HttpKeyword | NginxTokenType::ServerKeyword | NginxTokenType::LocationKeyword | NginxTokenType::EventsKeyword | NginxTokenType::UpstreamKeyword));

        if is_block_directive {
            self.parse_block(state);
        }
        else {
            let checkpoint = state.checkpoint();
            state.bump(); // directive name
            while state.not_at_end() && !state.at(NginxTokenType::Semicolon) && !state.at(NginxTokenType::LeftBrace) {
                let p_checkpoint = state.checkpoint();
                state.bump();
                state.finish_at(p_checkpoint, crate::parser::element_type::NginxElementType::Parameter);
            }
            if state.at(NginxTokenType::Semicolon) {
                state.bump();
            }
            state.finish_at(checkpoint, crate::parser::element_type::NginxElementType::Directive);
        }
    }

    fn parse_block<'b, S: Source + ?Sized>(&self, state: &mut ParserState<'b, NginxLanguage, S>) {
        let checkpoint = state.checkpoint();
        state.bump(); // block keyword (http, server, etc.)

        // Optional parameters for location or upstream
        while state.not_at_end() && !state.at(NginxTokenType::LeftBrace) {
            let p_checkpoint = state.checkpoint();
            state.bump();
            state.finish_at(p_checkpoint, crate::parser::element_type::NginxElementType::Parameter);
        }

        if state.at(NginxTokenType::LeftBrace) {
            state.bump();
            while state.not_at_end() && !state.at(NginxTokenType::RightBrace) {
                self.parse_directive(state);
            }
            if state.at(NginxTokenType::RightBrace) {
                state.bump();
            }
        }
        state.finish_at(checkpoint, crate::parser::element_type::NginxElementType::Block);
    }
}

impl<'a> Parser<NginxLanguage> for NginxParser<'a> {
    fn parse<'b, S: Source + ?Sized>(&self, text: &'b S, edits: &[TextEdit], cache: &'b mut impl ParseCache<NginxLanguage>) -> ParseOutput<'b, NginxLanguage> {
        let lexer = NginxLexer::new(self.language);
        oak_core::parser::parse_with_lexer(&lexer, text, edits, cache, |state| {
            let checkpoint = state.checkpoint();
            while state.not_at_end() {
                self.parse_directive(state);
            }

            Ok(state.finish_at(checkpoint, crate::parser::element_type::NginxElementType::Root))
        })
    }
}