Method: OpenC3::MicroserviceOperator#update

Defined in:

lib/openc3/operators/microservice_operator.rb

#update ⇒ Object

# File 'lib/openc3/operators/microservice_operator.rb', line 177

def update
  @previous_microservices = @microservices.dup
  # Get all the microservice configuration
  @microservices = MicroserviceModel.all

  # Filter to just this shard
  @microservices = @microservices.select do |microservice_name, microservice_config|
    microservice_shard = microservice_config['shard'] || 0
    microservice_shard == @shard
  end

  # Detect new and changed microservices
  @new_microservices = {}
  @changed_microservices = {}
  @removed_microservices = {}
  @microservices.each do |microservice_name, microservice_config|
    if @previous_microservices[microservice_name]
      if @previous_microservices[microservice_name] != microservice_config
        if not microservice_config['ignore_changes']
          handle_changed_microservice(microservice_name, microservice_config)
        end
      end
    else
      handle_new_microservice(microservice_name, microservice_config)
    end
  end

  # Detect removed microservices
  @previous_microservices.each do |microservice_name, microservice_config|
    unless @microservices[microservice_name]
      handle_removed_microservice(microservice_name, microservice_config)
    end
  end

  # Convert to processes
  @mutex.synchronize do
    @new_microservices.each do |microservice_name, microservice_config|
      cmd_array, work_dir, env, scope, container = convert_microservice_to_process_definition(microservice_name, microservice_config)
      if cmd_array
        process = OperatorProcess.new(cmd_array, work_dir: work_dir, env: env, scope: scope, container: container, config: microservice_config)
        @new_processes[microservice_name] = process
        @processes[microservice_name] = process
      end
    end

    @changed_microservices.each do |microservice_name, microservice_config|
      cmd_array, work_dir, env, scope, container = convert_microservice_to_process_definition(microservice_name, microservice_config)
      if cmd_array
        process = @processes[microservice_name]
        if process
          process.process_definition = cmd_array
          process.work_dir = work_dir
          process.new_temp_dir = nil
          process.env = env
          @changed_processes[microservice_name] = process
        else
          # This shouldn't be possible, but still needs to be handled
          Logger.error("Changed microservice #{microservice_name} does not exist. Creating new...", scope: scope)
          process = OperatorProcess.new(cmd_array, work_dir: work_dir, env: env, scope: scope, container: container, config: microservice_config)
          @new_processes[microservice_name] = process
          @processes[microservice_name] = process
        end
      end
    end

    @removed_microservices.each do |microservice_name, _microservice_config|
      process = @processes[microservice_name]
      @processes.delete(microservice_name)
      @removed_processes[microservice_name] = process
    end
  end
end