Method: Deb::S3::CLI#delete

Defined in:

lib/deb/s3/cli.rb

#delete(package) ⇒ Object

# File 'lib/deb/s3/cli.rb', line 477

def delete(package)
  if package.nil?
    error("You must specify a package name.")
  end

  versions = options[:versions]
  if versions.nil?
    warn("===> WARNING: Deleting all versions of #{package}")
  else
    log("Versions to delete: #{versions.join(', ')}")
  end

  arch = options[:arch]
  if arch.nil?
    error("You must specify the architecture of the package to remove.")
  end

  configure_s3_client

  begin
    if options[:lock]
      log("Checking for existing lock file")
      log("Locking repository for updates")
      Deb::S3::Lock.lock(options[:codename], component, options[:arch], options[:cache_control])
      @lock_acquired = true
    end

    # retrieve the existing manifests
    log("Retrieving existing manifests")
    release  = Deb::S3::Release.retrieve(options[:codename], options[:origin], options[:suite])
    if arch == 'all'
      selected_arch = release.architectures
    else
      selected_arch = [arch]
    end
    all_found = 0
    selected_arch.each { |ar|
      manifest = Deb::S3::Manifest.retrieve(options[:codename], component, ar, options[:cache_control], false, options[:skip_package_upload])

      deleted = manifest.delete_package(package, versions)
      all_found += deleted.length
      if deleted.length == 0
          if versions.nil?
              sublog("No packages were deleted. #{package} not found in arch #{ar}.")
              next
          else
              sublog("No packages were deleted. #{package} versions #{versions.join(', ')} could not be found in arch #{ar}.")
              next
          end
      else
          deleted.each { |p|
              sublog("Deleting #{p.name} version #{p.full_version} from arch #{ar}")
          }
      end

      log("Uploading new manifests to S3")
      manifest.write_to_s3 {|f| sublog("Transferring #{f}") }
      release.update_manifest(manifest)
      release.write_to_s3 {|f| sublog("Transferring #{f}") }

      log("Update complete.")
    }
    if all_found == 0
      if versions.nil?
        error("No packages were deleted. #{package} not found.")
      else
        error("No packages were deleted. #{package} versions #{versions.join(', ')} could not be found.")
      end
    end
  ensure
    if options[:lock] && @lock_acquired
      Deb::S3::Lock.unlock(options[:codename], component, options[:arch], options[:cache_control])
      log("Lock released.")
    end
  end
end