-
Notifications
You must be signed in to change notification settings - Fork 6
/
parser.rb
74 lines (57 loc) · 1.81 KB
/
parser.rb
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
require 'yaml'
require 'paxmex/schema'
class Paxmex::Parser
SCHEMATA = %w(epraw eptrn).reduce({}) { |h, fn| h.merge(fn => YAML::load(File.open("config/#{fn}.yml"))) }
def initialize(path, opts = {})
@path = path
@schema_key = opts[:schema]
end
def schema
@schema ||= Paxmex::Schema.new(SCHEMATA[@schema_key])
end
def raw
@raw ||= File.read(@path).chomp
end
def parse
return @parsed if @parsed
content = raw.split("\n")
# Parse the trailing section first so that we don't need
# to consider it when parsing recurring sections
trailer_section = schema.sections.detect(&:trailer?)
trailer_content = [content.slice!(-1)]
@parsed = parse_section(content: trailer_content, section: trailer_section)
schema.sections.reject(&:trailer?).each do |section|
@parsed.merge!(
parse_section(
content: section.recurring? ? content : [content.slice!(0)],
section: section))
end
@parsed
end
private
def parse_section(opts = {})
raise 'Content must be provided' unless content = opts[:content]
raise 'Section must be provided' unless section = opts[:section]
result = {}
abstract_section = section if section.abstract?
content.each do |section_content|
if abstract_section
start, final = abstract_section.type_field
section_type = section_content[start..final]
section = abstract_section.section_for_type(section_type)
end
result[section.key] ||= [] if section.recurring?
p = {}
section.fields.each do |field_name, positions|
start, final = positions
p[field_name] = section_content[start..final]
end
if section.recurring?
result[section.key] << p
else
result[section.key] = p
end
end
result
end
end