Class: TacScribe::EventQueue

Inherits:
TacviewClient::BaseProcessor
  • Object
show all
Defined in:
lib/tac_scribe/event_queue.rb

Overview

Processes the events emitted by the Ruby Tacview Client

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ EventQueue

Returns a new instance of EventQueue.



11
12
13
14
 
# File 'lib/tac_scribe/event_queue.rb', line 11

def initialize
  @events = Queue.new
  self.events_written = 0
end

Instance Attribute Details

#events_written ⇒ Object

Returns the value of attribute events_written.



9
10
11
 
# File 'lib/tac_scribe/event_queue.rb', line 9

def events_written
  @events_written
end

Instance Method Details

#clear ⇒ Object 



16
17
18
 
# File 'lib/tac_scribe/event_queue.rb', line 16

def clear
  @events.clear
end

#delete_object(object_id) ⇒ Object

Process a delete event for an object

Parameters:

  • object_id (String) —

    A hexadecimal number representing the object ID



54
55
56
57
 
# File 'lib/tac_scribe/event_queue.rb', line 54

def delete_object(object_id)
  self.events_written += 1
  @events << { type: :delete_object, object_id: object_id }
end

#set_property(property:, value:) ⇒ Object

Set a property

Parameters:

  • property (String) —

    The name of the property to be set

  • value (String) —

    The value of the property to be set



71
72
73
74
75
76
77
78
79
80
 
# File 'lib/tac_scribe/event_queue.rb', line 71

def set_property(property:, value:)
  case property
  when 'ReferenceLatitude'
    @events << { type: :set_latitude, value: BigDecimal(value) }
  when 'ReferenceLongitude'
    @events << { type: :set_longitude, value: BigDecimal(value) }
  when 'ReferenceTime'
    @reference_time = @time = Time.parse(value)
  end
end

#shift ⇒ Object 



24
25
26
 
# File 'lib/tac_scribe/event_queue.rb', line 24

def shift
  @events.shift
end

#size ⇒ Object 



20
21
22
 
# File 'lib/tac_scribe/event_queue.rb', line 20

def size
  @events.size
end

#update_object(event) ⇒ Object

Process an update event for an object

On the first appearance of the object there are usually more fields including pilot names, object type etc.

For existing objects these events are almost always lat/lon/alt updates only

Parameters:

  • event (Hash) —

    A parsed ACMI line. This hash will always include the fields listed below but may also include others depending on the source line.

Options Hash (event):

  • :object_id (String) —

    The hexadecimal format object ID.

  • :latitude (BigDecimal) —

    The object latitude in WGS 84 format.

  • :longitude (BigDecimal) —

    The object latitude in WGS 84 format.

  • :altitude (BigDecimal) —

    The object altitude above sea level in meters to 1 decimal place.



45
46
47
48
 
# File 'lib/tac_scribe/event_queue.rb', line 45

def update_object(event)
  self.events_written += 1
  @events << { type: :update_object, event: event, time: @time }
end

#update_time(time) ⇒ Object

Process a time update event

Parameters:

  • time (BigDecimal) —

    A time update in seconds from the ReferenceTime to 2 decimal places



63
64
65
 
# File 'lib/tac_scribe/event_queue.rb', line 63

def update_time(time)
  @time = @reference_time + time
end