Class: DxLite

Inherits:
Object
  • Object
show all
Includes:
RXFReadWriteModule
Defined in:
lib/dxlite.rb

Overview

DxLite can perform the following:

  • read or write an XML file

  • read or write a JSON file (in Dynarex format)

  • import an Array of records (Hash objects)

note: It cannot read a Dynarex file in

the raw Dynarex format (.txt plain text)

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(s = nil, autosave: false, order: 'ascending', debug: false) ⇒ DxLite

Returns a new instance of DxLite.



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
 
# File 'lib/dxlite.rb', line 28

def initialize(s=nil, autosave: false, order: 'ascending', debug: false)

  @autosave, @debug = autosave, debug

  return unless s
  buffer, type = RXFReader.read(s)

  @filepath = s if type == :file or type == :dfs

  puts 'type: ' + type.inspect if @debug
  puts 'buffer: ' + buffer.inspect if @debug

  @records = []

  case type

  when :dfs

    read buffer

  when :file

    read buffer

  when :text

    new_summary(s, order)

  when :url

    read buffer

  end

end

Instance Attribute Details

#filepath ⇒ Object

Returns the value of attribute filepath.



25
26
27
 
# File 'lib/dxlite.rb', line 25

def filepath
  @filepath
end

#records ⇒ Object (readonly)

Returns the value of attribute records.



26
27
28
 
# File 'lib/dxlite.rb', line 26

def records
  @records
end

#schema ⇒ Object (readonly)

Returns the value of attribute schema.



26
27
28
 
# File 'lib/dxlite.rb', line 26

def schema
  @schema
end

#summary ⇒ Object

Returns the value of attribute summary.



25
26
27
 
# File 'lib/dxlite.rb', line 25

def summary
  @summary
end

Instance Method Details

#all ⇒ Object 



64
65
66
67
68
69
70
71
72
73
 
# File 'lib/dxlite.rb', line 64

def all()

  @records.map do |h|

    puts 'h: ' + h.inspect if @debug
    RecordX.new(h[:body], self, h[:id], h[:created],
                h[:last_modified])
  end

end

#create(rawh, id: nil, custom_attributes: {created: Time.now}) ⇒ Object 



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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
 
# File 'lib/dxlite.rb', line 85

def create(rawh, id: nil, custom_attributes: {created: Time.now})

  if @debug then
    puts 'create:: rawh: ' + rawh.inspect
    puts 'custom_attributes: ' + custom_attributes.inspect
  end

  key = @summary[:default_key]

  if key then

    r = records.find {|x| x[:body][key.to_sym] == rawh[key.to_sym]}
    if r then
      r[:last_modified] = Time.now.to_s
      return false
    end

  end

  if id.nil? then

    puts '@records: ' + @records.inspect if @debug

    if @records then
      id = @records.map {|x| x[:id].to_i}.max.to_i + 1
    else
      @records = []
      id = 1
    end

  end

  h2 = custom_attributes

  fields = rawh.keys
  puts 'fields: ' + fields.inspect if @debug

  h3 = fields.map {|x| [x.to_sym, nil] }.to_h.merge(rawh)
  h = {id: id.to_s, created: h2[:created], last_modified: nil, body: h3}
  @records << h

  save() if @autosave

  RecordX.new(h[:body], self, h[:id], h[:created], h[:last_modified])

end

#delete(id) ⇒ Object 



75
76
77
78
79
80
81
82
83
 
# File 'lib/dxlite.rb', line 75

def delete(id)
  found = @records.find {|x| x[:id] == id}

  if found then
    @records.delete found
    save() if @autosave
  end

end

#fields ⇒ Object 



132
133
134
 
# File 'lib/dxlite.rb', line 132

def fields()
  @fields
end

#inspect ⇒ Object 



147
148
149
150
 
# File 'lib/dxlite.rb', line 147

def inspect()
  "#<DxLite:%s @debug=%s, @summary=%s, ...>" % [object_id, @debug,
                                                @summary.inspect]
end

#parse(obj = nil) ⇒ Object Also known as: import

Parses 1 or more lines of text to create or update existing records.



154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
 
# File 'lib/dxlite.rb', line 154

def parse(obj=nil)

  @records ||= []

  if obj.is_a? Array then

    unless schema() then
      puts 'obj.first: ' + obj.first.inspect if @debug
      cols = obj.first.keys.map {|c| c == 'id' ? 'uid' : c}
      puts 'after cols' if @debug
      new_summary "items/item(%s)" % cols.join(', ')
    end

    obj.each do |x|
      #puts 'x: ' + x.inspect if @debug
      self.create x, id: nil
    end

    return self

  end
end

#parse_xml(buffer) ⇒ Object 



179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
 
# File 'lib/dxlite.rb', line 179

def parse_xml(buffer)

  doc = Rexle.new(buffer.force_encoding('UTF-8'))

  asummary = doc.root.xpath('summary/*').map do |node|
    puts 'node: '  + node.xml.inspect if @debug
    [node.name, node.text.to_s]
  end

  summary = Hash[asummary]
  summary[:schema] = summary['schema']
  %w(recordx_type format_mask schema).each {|x| summary.delete x}

  @schema = summary[:schema]
  puts 'schema: ' + schema.inspect if @debug

  @fields = @schema[/\(([^\)]+)/,1].split(/ *, */)
  puts 'fields: ' + @fields.inspect if @debug

  @summary = summary

  a = doc.root.xpath('records/*').each do |node|

    h = Hash[@fields.map {|field| [field.to_sym, node.text(field).to_s] }]
    self.create h, id: nil, custom_attributes: node.attributes

  end

end

#record(id) ⇒ Object Also known as: find, find_by_id 



136
137
138
139
140
141
142
 
# File 'lib/dxlite.rb', line 136

def record(id)

  h = @records.find {|x| x[:id] == id }
  return unless h
  RecordX.new(h[:body], self, h[:id], h[:created], h[:last_modified])

end

#save(file = @filepath) ⇒ Object 



209
210
211
212
213
214
215
216
 
# File 'lib/dxlite.rb', line 209

def save(file=@filepath)

  return unless file
  @filepath = file

  s = File.extname(file) == '.json' ? to_json() : to_xml()
  FileX.write file, s
end

#to_a ⇒ Object 



218
219
220
 
# File 'lib/dxlite.rb', line 218

def to_a()
  @records.map {|x| x[:body]}
end

#to_h ⇒ Object 



222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
 
# File 'lib/dxlite.rb', line 222

def to_h()

  root_name = schema()[/^\w+/]
  record_name = schema()[/(?<=\/)[^\(]+/]

  records = @records.map {|h| {record_name.to_sym => h} }
  records.reverse! if @summary[:order] == 'descending'

  h = {
    root_name.to_sym =>
    {
      summary: @summary,
      records: records
    }
  }

end

#to_json(pretty: true) ⇒ Object 



240
241
242
 
# File 'lib/dxlite.rb', line 240

def to_json(pretty: true)
  pretty ? JSON.pretty_generate(to_h()) : to_h()
end

#to_xml ⇒ Object 



244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
 
# File 'lib/dxlite.rb', line 244

def to_xml()

  root_name = schema()[/^\w+/]
  record_name = schema()[/(?<=\/)[^\(]+/]

  a = RexleBuilder.build  do |xml|

    xml.send(root_name.to_sym) do
      xml.summary({}, @summary)
      xml.records do

        all().each do |x|

          h = {id: x.id, created: x.created, last_modified: x.last_modified}
          puts 'x.to_h: ' + x.to_h.inspect if @debug
          xml.send(record_name.to_sym, h, x.to_h)

        end

      end
    end
  end

  Rexle.new(a).xml pretty: true


end

#update(id, obj) ⇒ Object

Updates a record from an id and a hash containing field name and field value.

dynarex.update 4, name: Jeff, age: 38



275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
 
# File 'lib/dxlite.rb', line 275

def update(id, obj)

  if @debug then
    puts 'inside update'.info
    puts ('id: ' + id.inspect).debug
    puts ('obj.class: '  + obj.class.inspect).debug
  end

  r = @records.find {|x| x[:id] == id}

  if r then

    r[:body].merge!(obj)
    save() if @autosave

  end

end