Class: RubyTDMS::ObjectParser

Inherits:
Object
  • Object
show all
Defined in:
lib/ruby_tdms/object_parser.rb

Class Method Summary collapse

Class Method Details

.parse_stream(stream, document, segment) ⇒ Object

Given a Segment, parse the next object. If no objects remain, return nil.



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

def parse_stream(stream, document, segment)
  path = Path.new raw: stream.read_utf8_string
  raw_index = stream.read_u32

  if path == '/'
    # File object
    Objects::File.new(path, document, segment).tap { |obj| obj.parse_stream stream }
  else
    case raw_index
      when 0xFFFFFFFF
        # No data stored, indicating a group object
        Objects::Group.new(path, document, segment).tap { |obj| obj.parse_stream stream }
      when 0x69120000
        # "DAQmx Format Changing scaler"
        # TODO: Implement support for this
        raise NotImplementedError, 'DAQmx Format Changing scaler support is not implemented'
      when 0x69130000
        # "DAQmx Digital Line scaler"
        # TODO: Implement support for this
        raise NotImplementedError, 'DAQmx Digital Line scaler support is not implemented'
      when 0x00000000
        # Identical to previous segment, so clone the channel object and have it update streaming parameters
        previous_channel = document.objects.reverse.find { |object| object.path == path }
        Objects::Channel.new(path, document, segment).tap { |obj|
          obj.continue_stream stream, raw_index, previous_channel
          group = document.objects.find { |object| object.is_a? Objects::Group and object.path == Path.new(parts: path.to_a[0..-2]) }
          group.channels << obj if group
        }
      else
        Objects::Channel.new(path, document, segment).tap { |obj|
          obj.parse_stream stream, raw_index
          group = document.objects.find { |object| object.is_a? Objects::Group and object.path == Path.new(parts: path.to_a[0..-2]) }
          group.channels << obj if group
        }
    end

  end
end