Class: OpenC3::TriggerGroupMicroservice

Inherits:
Microservice show all
Defined in:
lib/openc3/microservices/trigger_group_microservice.rb

Overview

The trigger microservice starts a manager then gets the activities from the sorted set in redis and updates the schedule for the manager. Timeline will then wait for an update on the timeline stream this will trigger an update again to the schedule.

Constant Summary collapse

TRIGGER_METRIC_NAME = 
'update_triggers_duration_seconds'.freeze

Instance Attribute Summary collapse

Attributes inherited from Microservice

#count, #custom, #error, #logger, #microservice_status_thread, #secrets, #state

Instance Method Summary collapse

Methods inherited from Microservice

#as_json, run

Constructor Details

#initialize(*args) ⇒ TriggerGroupMicroservice

Returns a new instance of TriggerGroupMicroservice.



553
554
555
556
557
558
559
560
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 553

def initialize(*args)
  super(*args)
  @group = TriggerGroupShare.get_group(name: @name)
  @share = TriggerGroupShare.new(scope: @scope)
  @manager = TriggerGroupManager.new(name: @name, logger: @logger, scope: @scope, group: @group, share: @share)
  @manager_thread = nil
  @read_topic = true
end

Instance Attribute Details

#group ⇒ Object (readonly)

Returns the value of attribute group.



551
552
553
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 551

def group
  @group
end

#manager ⇒ Object (readonly)

Returns the value of attribute manager.



551
552
553
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 551

def manager
  @manager
end

#manager_thread ⇒ Object (readonly)

Returns the value of attribute manager_thread.



551
552
553
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 551

def manager_thread
  @manager_thread
end

#name ⇒ Object (readonly)

Returns the value of attribute name.



551
552
553
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 551

def name
  @name
end

#scope ⇒ Object (readonly)

Returns the value of attribute scope.



551
552
553
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 551

def scope
  @scope
end

#share ⇒ Object (readonly)

Returns the value of attribute share.



551
552
553
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 551

def share
  @share
end

Instance Method Details

#block_for_updates ⇒ Object 



592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 592

def block_for_updates
  @read_topic = true
  while @read_topic
    begin
      AutonomicTopic.read_topics(@topics) do |_topic, _msg_id, msg_hash, _redis|
        @logger.debug "TriggerGroupMicroservice block_for_updates: #{msg_hash.to_s}"
        if msg_hash['type'] == 'trigger'
          data = JSON.parse(msg_hash['data'], :allow_nan => true, :create_additions => true)
          public_send(topic_lookup_functions[msg_hash['kind']], data)
        end
      end
    rescue StandardError => e
      @logger.error "TriggerGroupMicroservice failed to read topics #{@topics}\n#{e.formatted}"
    end
  end
end

#created_trigger_event(data) ⇒ Object

Add the trigger to the share.



619
620
621
622
623
624
625
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 619

def created_trigger_event(data)
  @logger.debug "TriggerGroupMicroservice created_trigger_event #{data}"
  if data['group'] == @group
    @share.trigger_base.add(trigger: data)
    @manager.refresh()
  end
end

#deleted_trigger_event(data) ⇒ Object

Remove the trigger from the share.



628
629
630
631
632
633
634
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 628

def deleted_trigger_event(data)
  @logger.debug "TriggerGroupMicroservice deleted_trigger_event #{data}"
  if data['group'] == @group
    @share.trigger_base.remove(trigger: data)
    @manager.refresh()
  end
end

#no_op(data) ⇒ Object 



609
610
611
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 609

def no_op(data)
  @logger.debug "TriggerGroupMicroservice web socket event: #{data}"
end

#refresh_event(data) ⇒ Object 



613
614
615
616
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 613

def refresh_event(data)
  @logger.debug "TriggerGroupMicroservice web socket schedule refresh: #{data}"
  @read_topic = false
end

#run ⇒ Object 



562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 562

def run
  @logger.info "TriggerGroupMicroservice running"
  @manager_thread = Thread.new { @manager.run }
  loop do
    start = Process.clock_gettime(Process::CLOCK_MONOTONIC)
    triggers = TriggerModel.all(scope: @scope, group: @group)
    @share.trigger_base.update(triggers: triggers)
    diff = Process.clock_gettime(Process::CLOCK_MONOTONIC) - start # seconds as a float
    metric_labels = { 'trigger_group' => @group, 'thread' => 'microservice' }
    @metric.add_sample(name: TRIGGER_METRIC_NAME, value: diff, labels: metric_labels)
    break if @cancel_thread

    block_for_updates()
    break if @cancel_thread
  end
  @logger.info "TriggerGroupMicroservice exiting"
end

#shutdown ⇒ Object 



636
637
638
639
640
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 636

def shutdown
  @read_topic = false
  @manager.shutdown()
  super
end

#topic_lookup_functions ⇒ Object 



580
581
582
583
584
585
586
587
588
589
590
 
# File 'lib/openc3/microservices/trigger_group_microservice.rb', line 580

def topic_lookup_functions
  return {
    'created' => :created_trigger_event,
    'updated' => :created_trigger_event,
    'deleted' => :deleted_trigger_event,
    'enabled' => :created_trigger_event,
    'disabled' => :created_trigger_event,
    'activated' => :created_trigger_event,
    'deactivated' => :created_trigger_event,
  }
end