class UC3Code::CodeArtifactClient

# File app/lib/client/code/codeartifact.rb, line 16
def initialize
  @client = Aws::CodeArtifact::Client.new(region: UC3::UC3Client.region)
  @client.describe_domain(domain: ARTDOMAIN)
  super(enabled: enabled)
rescue StandardError => e
  super(enabled: false, message: e.to_s)
end

# File app/lib/client/code/codeartifact.rb, line 137
def artifact(artifact, version, asset)
  res = @client.get_package_version_asset(
    domain: ARTDOMAIN,
    repository: ARTREPOSITORY,
    format: ARTFORMAT,
    namespace: ARTNAMESPACE,
    package: artifact,
    package_version: version,
    asset: asset
  )
  return '' if res.nil?

  res.asset
end

# File app/lib/client/code/codeartifact.rb, line 175
def artifact_manifest(artifact, version, asset)
  res = {}
  Zip::File.open_buffer(artifact(artifact, version, asset)) do |z|
    z.each do |entry|
      next if entry.name.end_with?('/')

      res[entry.name] = {
        dir: File.dirname(entry.name),
        name: File.basename(entry.name),
        size: entry.size,
        ext: File.basename(entry.name).split('.').last,
        mrt: File.basename(entry.name).start_with?('mrt-')
      }
    end
  end
  res
end

# File app/lib/client/code/codeartifact.rb, line 193
def artifact_manifest_table(res)
  table = AdminUI::FilterTable.new(
    columns: [
      AdminUI::Column.new(:dir, header: 'Dir', filterable: true),
      AdminUI::Column.new(:name, header: 'Name'),
      AdminUI::Column.new(:ext, header: 'Ext', filterable: true),
      AdminUI::Column.new(:mrt, header: 'Merritt', filterable: true),
      AdminUI::Column.new(:size, header: 'Size')
    ]
  )
  res.keys.sort.each do |path|
    table.add_row(
      AdminUI::Row.make_row(
        table.columns,
        res[path]
      )
    )
  end
  table
end

# File app/lib/client/code/codeartifact.rb, line 152
def artifact_table(arr)
  table = AdminUI::FilterTable.new(
    columns: [
      AdminUI::Column.new(:published, header: 'Published'),
      AdminUI::Column.new(:package, header: 'Package'),
      AdminUI::Column.new(:version, header: 'Version'),
      AdminUI::Column.new(:semantic, header: 'Semantic'),
      AdminUI::Column.new(:pom, header: 'POM'),
      AdminUI::Column.new(:assets, header: 'Assets'),
      AdminUI::Column.new(:command, header: 'Command')
    ]
  )
  arr.each do |row|
    table.add_row(
      AdminUI::Row.make_row(
        table.columns,
        row
      )
    )
  end
  table
end

# File app/lib/client/code/codeartifact.rb, line 214
def delete_artifact(tag, artifact)
  @client.delete_package_versions(
    domain: ARTDOMAIN,
    repository: ARTREPOSITORY,
    format: ARTFORMAT,
    namespace: ARTNAMESPACE,
    package: artifact,
    versions: [tag]
  )
end

# File app/lib/client/code/codeartifact.rb, line 24
def enabled
  !@client.nil?
end

# File app/lib/client/code/codeartifact.rb, line 53
def list_package_artifacts(repohash: {})
  res = []
  return res unless enabled

  repohash.fetch(:artifacts, []).each do |artifact|
    begin
      pv = @client.list_package_versions(
        domain: ARTDOMAIN,
        repository: ARTREPOSITORY,
        package: artifact,
        format: ARTFORMAT,
        namespace: ARTNAMESPACE
      )
    rescue StandardError
      # puts "Client ERR: #{e}: #{@client}"
      return res
    end
    pv.versions.each do |v|
      rec = {
        status: v.status,
        version: v.version,
        semantic: UC3::UC3Client.semantic_prefix_tag?(v.version),
        package: artifact,
        domain: ARTDOMAIN,
        repository: ARTREPOSITORY,
        format: ARTFORMAT,
        namespace: ARTNAMESPACE,
        assets: [],
        pom: nil,
        command: ''
      }
      rec[:published] = @client.describe_package_version(
        domain: ARTDOMAIN,
        repository: ARTREPOSITORY,
        format: ARTFORMAT,
        namespace: ARTNAMESPACE,
        package: artifact,
        package_version: v.version
      ).package_version.published_time
      @client.list_package_version_assets({
        domain: ARTDOMAIN,
        repository: ARTREPOSITORY,
        format: ARTFORMAT,
        namespace: ARTNAMESPACE,
        package: artifact,
        package_version: v.version
      }).assets.each do |asset|
        if asset.name.downcase.end_with?('.pom')
          rec[:pom] = {
            value: asset.name,
            href: "/source/artifact/#{artifact}/#{v.version}/#{asset.name}"
          }
        elsif asset.name.downcase.end_with?('.war')
          rec[:assets] << {
            value: asset.name,
            href: "/source/artifact_manifest/#{artifact}/#{v.version}/#{asset.name}"
          }
          rec[:command] = [
            {
              value: 'download cmd',
              href: "/source/artifact_command/#{artifact}/#{v.version}/#{asset.name}",
              cssclass: 'button'
            }
          ]
          unless UC3::UC3Client.keep_artifact_version?(v.version)
            rec[:command] << {
              value: 'Delete',
              href: "/source/artifacts/delete/#{v.version}",
              cssclass: 'button',
              post: true,
              disabled: false,
              data: artifact
            }
          end
        else
          rec[:assets] << asset.name
        end
      end
      res << rec
    end
  end
  res
end

# File app/lib/client/code/codeartifact.rb, line 28
def list_package_versions(repohash: {})
  res = {}
  return res unless enabled

  repohash.fetch(:artifacts, []).each do |artifact|
    begin
      pv = @client.list_package_versions(
        domain: ARTDOMAIN,
        repository: ARTREPOSITORY,
        package: artifact,
        format: ARTFORMAT,
        namespace: ARTNAMESPACE
      )
    rescue StandardError
      # puts "Client ERR: #{e}: #{@client}"
      return res
    end
    pv.versions.each do |v|
      res[v.version] = res.fetch(v.version, [])
      res[v.version] << artifact
    end
  end
  res
end