Class App has 23 methods (exceeds 20 allowed). Consider refactoring.

Open

class App
  include Mongoid::Document
  include Peas::ModelWorker

  GIT_RECEIVER_PATH = File.expand_path "#{Peas.root}/bin/git_receiver"

Method initialize has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

  def initialize(pea)
    info "Starting to watch #{pea.full_name}'s logs for archiving"
    socket = Peas::Switchboard.connection
    socket.puts "app_logs.#{pea._id}"

• Read up
  Read up

Method authenticate has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

  def authenticate
    @current_user = false
    api_key = read_line.strip
    if api_key.length >= 64
      if api_key == Setting.retrieve('peas.switchboard_key')

• Read up
  Read up

Method broadcasters has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def broadcasters(message)
      @job_broadcasters ||= {}
      # Broadcast to parent and current. But only both if they're actually different jobs.
      #
      # There's a potential race condition if broadcasting to @current_job *before* parent_job;

• Read up
  Read up

Method spawn_container has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def spawn_container
    # Common properties
    properties = {
      'Cmd' => ['/bin/bash', '-c', command],
      # The base Docker image to use. In this case the prebuilt image created by the buildstep

Method command has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

    def command(command, timeout: 60)
      output = []
      @write.puts "#{command} 2>&1; echo $?; echo 'PEAS_SH_COMPLETE'"
      begin
        Timeout.timeout(timeout) do

• Read up
  Read up

Method call has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def call(env)
      req = Rack::Request.new(env)
      method = req.request_method.downcase
      method[0..0] = method[0..0].upcase

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

Open

  def initialize(pea)
    info "Starting to watch #{pea.full_name}'s logs for archiving"
    socket = Peas::Switchboard.connection
    socket.puts "app_logs.#{pea._id}"

Method run has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def run
    loop do
      # Fetch all the running docker containers on the current host
      docker_ids = Docker::Container.all.map { |c| c.id }
      docker_ids.each do |id|

• Read up
  Read up

Method create_job has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def create_job(method, args)
        # UUID's are guaranteed to be practically unique, as in *extremely* unlikely to collide
        new_job_id = SecureRandom.uuid
        # @is_parent_caller differentiates the parent job as originally called (outside a worker process) and the parent
        # job as run by a worker process.

Method worker_manager has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def worker_manager(method, *args, &block)
        new_job_id = create_job method, args
        # Wait for job to finish before running subsequent tasks
        if block_given? || @block_until_complete
          socket = Peas::Switchboard.connection

• Read up
  Read up

Method stream_job has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

  def self.stream_job(job)
    API.stream_output "subscribe.job_progress.#{job}" do |line|
      if line.key? 'status'
        if line['status'] == 'failed'
          raise line['body']

• Read up
  Read up

Method call has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def call(env)
      req = Rack::Request.new(env)
      method = req.request_method.downcase
      method[0..0] = method[0..0].upcase

• Read up
  Read up

Method request has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  def request(verb, method, query = {}, auth = true, print = true)
    options = { query: query }
    options[:headers] = { 'x-api-key' => api_key } if auth
    request_args = [
      verb.to_s.downcase,

• Read up
  Read up

Method dispatch has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  def dispatch
    _, @port, @host = @socket.peeraddr
    debug "Received connection (ID: #{@socket.object_id}) from #{@host}:#{@port}"

    return unless authenticate

• Read up
  Read up

Method spawn_container has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  def spawn_container
    # Common properties
    properties = {
      'Cmd' => ['/bin/bash', '-c', command],
      # The base Docker image to use. In this case the prebuilt image created by the buildstep

• Read up
  Read up

Method broadcast has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def broadcast(message = {})
      raise 'broadcast() can only be used if method is part of a running job.' unless @current_job
      message = message.to_s unless message.is_a?(Hash)
      if message.is_a? String
        tmp_msg = message

• Read up
  Read up

Method api_domain has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  def self.api_domain
    git_domain = Git.sh 'git config peas.domain'
    domain =
    if ENV['PEAS_API_ENDPOINT']
      ENV['PEAS_API_ENDPOINT']

• Read up
  Read up

Method handle_status has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def handle_status(method, status, progress, &_block)
        if status == 'failed'
          if @is_parent_caller
            # Only raise an error in the parent worker that started off the whole process
            error_message = "Worker for #{@instance.class.name}.#{method} failed. Job aborted. " + progress['body']

• Read up
  Read up

Method request has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  def request(verb, method, query = {}, auth = true, print = true)