summaryrefslogtreecommitdiff
path: root/ext/psych/parser.c
blob: a9b06676ef4f7d08888069dea0eb9df6aa6ff81c (plain)
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
#include <psych.h>

static VALUE parse_string(VALUE self, VALUE string)
{
  yaml_parser_t parser;
  yaml_event_t event;

  yaml_parser_initialize(&parser);

  yaml_parser_set_input_string(
      &parser,
      StringValuePtr(string),
      RSTRING_LEN(string)
  );

  int done = 0;

  VALUE handler = rb_iv_get(self, "@handler");

  while(!done) {
    if(!yaml_parser_parse(&parser, &event)) {
      yaml_parser_delete(&parser);
      rb_raise(rb_eRuntimeError, "couldn't parse YAML");
    }

    switch(event.type) {
      case YAML_STREAM_START_EVENT:
        rb_funcall(handler, rb_intern("start_stream"), 1,
            INT2NUM((long)event.data.stream_start.encoding)
        );
        break;
      case YAML_DOCUMENT_START_EVENT:
        {
          // Grab the document version
          VALUE version = event.data.document_start.version_directive ?
            rb_ary_new3(
              (long)2,
              INT2NUM((long)event.data.document_start.version_directive->major),
              INT2NUM((long)event.data.document_start.version_directive->minor)
            ) : rb_ary_new();

          // Get a list of tag directives (if any)
          VALUE tag_directives = rb_ary_new();
          if(event.data.document_start.tag_directives.start) {
            yaml_tag_directive_t *start =
              event.data.document_start.tag_directives.start;
            yaml_tag_directive_t *end =
              event.data.document_start.tag_directives.end;
            for(; start != end; start++) {
              VALUE pair = rb_ary_new3((long)2,
                  start->handle ? rb_str_new2(start->handle) : Qnil,
                  start->prefix ? rb_str_new2(start->prefix) : Qnil
              );
              rb_ary_push(tag_directives, pair);
            }
          }
          rb_funcall(handler, rb_intern("start_document"), 3,
              version, tag_directives,
              event.data.document_start.implicit == 1 ? Qtrue : Qfalse
          );
        }
        break;
      case YAML_STREAM_END_EVENT:
        rb_funcall(handler, rb_intern("end_stream"), 0);
        done = 1;
        break;
    }
  }

  return self;
}

VALUE cPsychParser;

void Init_psych_parser()
{
  cPsychParser = rb_define_class_under(mPsych, "Parser", rb_cObject);

  rb_define_private_method(cPsychParser, "parse_string", parse_string, 1);
}