Module: NexusCli::ArtifactActions

Included in:
OSSRemote, ProRemote
Defined in:
lib/nexus_cli/mixins/artifact_actions.rb

Overview

Author:

Instance Method Summary collapse

Instance Method Details

#delete_artifact(coordinates) ⇒ Object 



82
83
84
85
86
87
88
89
90
91
 
# File 'lib/nexus_cli/mixins/artifact_actions.rb', line 82

def delete_artifact(coordinates)
  artifact = Artifact.new(coordinates)
  response = nexus.delete(nexus_url("content/repositories/#{configuration['repository']}/#{artifact.group_id.gsub(".", "/")}/#{artifact.artifact_id.gsub(".", "/")}/#{artifact.version}"))
  case response.status
  when 204
    return true
  else
    raise UnexpectedStatusCodeException.new(response.status)
  end
end

#get_artifact_info(coordinates) ⇒ String

Retrieves information about the given [artifact] and returns it in as a [String] of XML.



100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
 
# File 'lib/nexus_cli/mixins/artifact_actions.rb', line 100

def get_artifact_info(coordinates)
  artifact = Artifact.new(coordinates)
  query = {:g => artifact.group_id, :a => artifact.artifact_id, :e => artifact.extension, :v => artifact.version, :r => configuration['repository']}
  query.merge!({:c => artifact.classifier}) unless artifact.classifier.nil?
  response = nexus.get(nexus_url("service/local/artifact/maven/resolve"), query)
  case response.status
  when 200
    return response.content
  when 404
    raise ArtifactNotFoundException
  when 503
    raise CouldNotConnectToNexusException
  else
    raise UnexpectedStatusCodeException.new(response.status)
  end
end

#pull_artifact(coordinates, destination = nil) ⇒ Hash

Retrieves a file from the Nexus server using the given [String] coordinates. Optionally provide a destination [String].



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/nexus_cli/mixins/artifact_actions.rb', line 15

def pull_artifact(coordinates, destination=nil)
  artifact = Artifact.new(coordinates)

  if artifact.version.casecmp("latest")
    artifact.version = REXML::Document.new(get_artifact_info(coordinates)).elements["//version"].text
  end

  file_name = artifact.file_name
  destination = File.join(File.expand_path(destination || "."), file_name)
  query = {:g => artifact.group_id, :a => artifact.artifact_id, :e => artifact.extension, :v => artifact.version, :r => configuration['repository']}
  query.merge!({:c => artifact.classifier}) unless artifact.classifier.nil?
  response = nexus.get(nexus_url("service/local/artifact/maven/redirect"), :query => query)
  case response.status
  when 301, 307
    # Follow redirect and stream in chunks.
    artifact_file = File.open(destination, "wb") do |io|
      nexus.get(response.content.gsub(/If you are not automatically redirected use this url: /, "")) do |chunk|
        io.write(chunk)
      end
    end
  when 404
    raise ArtifactNotFoundException
  else
    raise UnexpectedStatusCodeException.new(response.status)
  end
  {
    :file_name => file_name,
    :file_path => File.expand_path(destination),
    :version   => artifact.version,
    :size      => File.size(File.expand_path(destination))
  }
end

#push_artifact(coordinates, file) ⇒ Boolean

Pushes the given [file] to the Nexus server under the given [artifact] identifier.



55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/nexus_cli/mixins/artifact_actions.rb', line 55

def push_artifact(coordinates, file)
  artifact = Artifact.new(coordinates)
  put_string = "content/repositories/#{configuration['repository']}/#{artifact.group_id.gsub(".", "/")}/#{artifact.artifact_id.gsub(".", "/")}/#{artifact.version}/#{artifact.file_name}"
  response = nexus.put(nexus_url(put_string), File.open(file))

  case response.status
  when 201
    pom_name = "#{artifact.artifact_id}-#{artifact.version}.pom"
    put_string = "content/repositories/#{configuration['repository']}/#{artifact.group_id.gsub(".", "/")}/#{artifact.artifact_id.gsub(".", "/")}/#{artifact.version}/#{pom_name}"
    pom_file = generate_fake_pom(pom_name, artifact)
    nexus.put(nexus_url(put_string), File.open(pom_file))
    delete_string = "/service/local/metadata/repositories/#{configuration['repository']}/content/#{artifact.group_id.gsub(".", "/")}/#{artifact.artifact_id.gsub(".", "/")}"
    nexus.delete(nexus_url(delete_string))
    return true
  when 400
    raise BadUploadRequestException
  when 401
    raise PermissionsException
  when 403
    raise PermissionsException
  when 404
    raise NexusHTTP404.new(response.content)
  else
    raise UnexpectedStatusCodeException.new(response.status)
  end
end

#search_for_artifacts(coordinates) ⇒ Array<String>

Searches for an artifact using the given identifier.

Examples:

com.artifact:my-artifact



1.0.0     `nexus-cli pull com.artifact:my-artifact:tgz:1.0.0`
2.0.0     `nexus-cli pull com.artifact:my-artifact:tgz:2.0.0`
3.0.0     `nexus-cli pull com.artifact:my-artifact:tgz:3.0.0`



128
129
130
131
132
133
134
135
136
137
 
# File 'lib/nexus_cli/mixins/artifact_actions.rb', line 128

def search_for_artifacts(coordinates)
  group_id, artifact_id = coordinates.split(":")
  response = nexus.get(nexus_url("service/local/data_index"), :query => {:g => group_id, :a => artifact_id})
  case response.status
  when 200
    return response.content
  else
    raise UnexpectedStatusCodeException.new(response.status)
  end
end

#transfer_artifact(coordinates, from_repository, to_repository) ⇒ Object 



139
140
141
 
# File 'lib/nexus_cli/mixins/artifact_actions.rb', line 139

def transfer_artifact(coordinates, from_repository, to_repository)
  do_transfer_artifact(coordinates, from_repository, to_repository)
end