Contents

require 'di'
require 'ADB'

require 'stf/client'
require 'stf/log/log'
require 'stf/errors'
require 'stf/model/session'

module Stf
  class StartOneDebugSessionInteractor

    include Log
    include ADB

    def execute(device)
      return false if device.nil?
      serial = device.serial

      begin
        success = DI[:stf].add_device serial
        if success
          logger.info "Device added #{serial}"
        else
          logger.error "Can't add device #{serial}"
          raise
        end

        result = DI[:stf].start_debug serial
        if result.success
          logger.info "Debug started #{serial}"
        else
          logger.error "Can't start debugging session for device #{serial}"
          raise
        end

        execute_adb_with 30, "connect #{result.remoteConnectUrl}"

        shell('echo adbtest', {serial: "#{result.remoteConnectUrl}"}, 30)
        raise ADBError, "Could not execute shell test" unless stdout_contains "adbtest"

        return true

      rescue StandardError, SignalException => e
        begin
          # we will try clean anyway
          DI[:stf].remove_device serial
          if test ?d, '/custom-metrics'
            File.open('/custom-metrics/openstf_connect_fail', 'a') do |f|
              message = (!e.nil? || !e.message.nil?) ? e.message : ""
              f.write("openstf_connect_fail,reason=\"#{escape(message)}\",serial=\"#{escape(serial)}\" count=1i #{Time.now.to_i}\n")
            end
          end
        rescue
        end

        logger.error "Failed to connect to #{serial}: " + e&.message
        return false
      end
    end

    def escape(s)
      s.gsub(/["]/, '\"').gsub(/[ ]/, '\ ').gsub(/[=]/, '\=').gsub(/[,]/, '\,')
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
stf-client-0.3.0.rc8	lib/stf/interactor/start_one_debug_session_interactor.rb