OpenC3/cosmos

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    def _extract_target_command_parameter_names(method_name, *args)
      target_name = nil
      command_name = nil
      parameter_name = nil
      case args.length

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

    def deploy_decomlog_microservice(gem_path, variables, topics, instance = nil, parent = nil)
      microservice_name = "#{@scope}__DECOMLOG#{instance}__#{@name}"
      microservice = MicroserviceModel.new(
        name: microservice_name,
        folder_name: @folder_name,

• Read up
  Read up

Function exec has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  async exec(
    method,
    params,
    kwparams = {},
    headerOptions = {},

Method handle_limits_values has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def handle_limits_values(item, value, limits_set, ignore_persistence)
      # Retrieve limits settings for the specified limits_set
      limits = item.limits.values[limits_set]

      # Use the default limits set if limits aren't specified for the

Method build_cmd_output_string has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def build_cmd_output_string(target_name, cmd_name, cmd_params, raw = false)
      if raw
        output_string = 'cmd_raw("'
      else
        output_string = 'cmd("'

Method write has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def write(packet)
      raise "Interface not connected for write: #{@name}" unless connected?
      raise "Interface not writable: #{@name}" unless write_allowed?

      _write do

Method instrument_script_implementation has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def self.instrument_script_implementation(ruby_lex_utils,
                                            comments_removed_text,
                                            _num_lines,
                                            filename,
                                            mark_private = false)

Method api has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def api
    OpenC3.in_span('jsonrpc_api') do |span|
      req = Rack::Request.new(request.env)

      if request.post?

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    for (let i = 0; i < len; i++) {
      converted = this.decode_openc3_type(data[0][i])
      if (converted !== null) {
        data[0][i] = converted
      }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    for (let i = 0; i < len; i++) {
      converted = this.decode_openc3_type(data[0][i])
      if (converted !== null) {
        data[0][i] = converted
      }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  get: function (
    path,
    { params, headers = acceptOnlyDefaultHeaders, noScope, noAuth } = {}
  ) {
    return request('get', path, { params, headers, noScope, noAuth })

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  delete: function (
    path,
    { params, headers = acceptOnlyDefaultHeaders, noScope, noAuth } = {}
  ) {
    return request('delete', path, { params, headers, noScope, noAuth })

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  class ScriptWebSocketApi < WebSocketApi
    def initialize(url: nil, write_timeout: 10.0, read_timeout: 10.0, connect_timeout: 5.0, authentication: nil, scope: $openc3_scope)
      url = generate_url() unless url
      super(url: url, write_timeout: write_timeout, read_timeout: read_timeout, connect_timeout: connect_timeout, authentication: authentication, scope: scope)
    end

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  class CmdTlmWebSocketApi < WebSocketApi
    def initialize(url: nil, write_timeout: 10.0, read_timeout: 10.0, connect_timeout: 5.0, authentication: nil, scope: $openc3_scope)
      url = generate_url() unless url
      super(url: url, write_timeout: write_timeout, read_timeout: read_timeout, connect_timeout: connect_timeout, authentication: authentication, scope: scope)
    end

• Read up
  Read up

Function applySetting has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    applySetting(style, setting) {
      switch (setting[0]) {
        case 'TEXTALIGN':
          style['text-align'] = setting[1].toLowerCase() + ' !important'
          style['--text-align'] = setting[1].toLowerCase()

Method wait_check_tolerance has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def wait_check_tolerance(*args, type: :CONVERTED, scope: $openc3_scope, token: $openc3_token, &block)
      raise "Invalid type '#{type}' for wait_check_tolerance" unless %i(RAW CONVERTED).include?(type)

      target_name, packet_name, item_name, expected_value, tolerance, timeout, polling_rate = _wait_tolerance_process_args(args)
      start_time = Time.now.sys

Method write has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def self.write(event, scope:)
      case event[:type]
      when :LIMITS_CHANGE
        # The current_limits hash keeps only the current limits state of items
        # It is used by the API to determine the overall limits state

Method read_item has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def read_item(item, buffer)
      item_name = item.name
      case item_name
      when 'HTTP_STATUS'
        return nil unless @packet.extra

Method initialize has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def initialize
    # Create local file cache location
    @cache_dir = Dir.mktmpdir
    FileUtils.mkdir_p(@cache_dir)
    at_exit do

Method initialize has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def initialize(key, start_time_nsec, end_time_nsec, item_key: nil, scope:, token: nil)
    key = key.upcase
    @key = key
    @item_key = item_key
    key_split = key.split('__')