anchor.diff:    response = http.request(req)
   
     body = JSON.parse(response.body)
  -  body["id"]
  +  body['id']
   end
   
   def post_to_new_importer(oid, s3_filename, compression, is_full_import, app_key, auth)
  
positive.code:   response = http.request(req)
  
    body = JSON.parse(response.body)
    body["response"]["data"]
  end
  
  def send_to_new_importer(org_slug, path, compression, is_full_import)
    s3 = AWS::S3.new(:access_key_id => '<%= @aws_access_key_id %>', :secret_access_key => '<%= @aws_secret_access_key %>')
    bucket = s3.buckets['onboarding.evertrue.com']
    now = DateTime.now.strftime("%Q")
    s3_filename = "#{now}-#{File.basename(path)}"
    bucket.objects["#{org_slug}/data/#{s3_filename}"].write(Pathname.new(path))
  
  
negative.code:   http.use_ssl = true
  
    req = Net::HTTP::Post.new(uri.request_uri)
    req['Content-Type'] = 'application/json'
    req.body = {
      's3_filename' => s3_filename,
      'compression' => compression,
      'prune' => is_full_import
    }
  
    response = http.request(req)
    raise "Error sending oid: #{oid}, file: #{s3_filename}. Response: #{response.code}, body: #{response.body}" unless response.code.to_i == 200
  
    body = JSON.parse(response.body)
    body['id']
  end
  
  def queue_to_new_importer(oid, job_id, app_key, auth)
  