Skip to content

[client][repository_actions] add ability to pass in override and add … #116

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
lucheng404 wants to merge 1 commit into
base: master
Choose a base branch
from
Open

[client][repository_actions] add ability to pass in override and add … #116

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
60 changes: 31 additions & 29 deletions lib/nexus_cli/mixins/repository_actions.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,22 +3,22 @@
module NexusCli
# @author Kyle Allan <kallan@riotgames.com>
module RepositoryActions

# Creates a repository that the Nexus uses to hold artifacts.
#
#
# @param name [String] the name of the repository to create
# @param proxy [Boolean] true if this is a proxy repository
# @param url [String] the url for the proxy repository to point to
# @param id [String] the id of repository
# @param id [String] the id of repository
# @param policy [String] repository policy (RELEASE|SNAPSHOT)
# @param provider [String] repo provider (maven2 by default)
#
#
# @return [Boolean] returns true on success
def create_repository(name, proxy, url, id, policy, provider)
def create_repository(name, proxy, url, id, policy, provider, param_overrides={})
json = if proxy
create_proxy_repository_json(name, url, id, policy, provider)
create_proxy_repository_json(name, url, id, policy, provider, param_overrides)
else
create_hosted_repository_json(name, id, policy, provider)
create_hosted_repository_json(name, id, policy, provider, param_overrides)
end
response = nexus.post(nexus_url("service/local/repositories"), :body => json, :header => DEFAULT_CONTENT_TYPE_HEADER)
case response.status
Expand All @@ -32,10 +32,10 @@ def create_repository(name, proxy, url, id, policy, provider)
end

# Deletes the given repository
#
#
# @param name [String] the name of the repositroy to delete, transformed
# into an id.
#
#
# @return [Boolean] true if the repository is deleted, false otherwise.
def delete_repository(name)
response = nexus.delete(nexus_url("service/local/repositories/#{sanitize_for_id(name)}"))
Expand All @@ -51,10 +51,10 @@ def delete_repository(name)

# Find information about the repository with the given
# [name].
#
#
# @param name [String] the name of the repository, transformed
# into an id.
#
#
# @return [String] A String of XML with information about the desired
# repository.
def get_repository_info(name)
Expand All @@ -72,11 +72,11 @@ def get_repository_info(name)
end

# Creates a group repository with the given name.
#
#
# @param name [String] the name to give the new repository
# @param id [String] an alternative id to use for the new repository
# @param provider [String] the type of Maven provider for this repository
#
#
# @return [Boolean] true if the group repository is created, false otherwise
def create_group_repository(name, id, provider)
response = nexus.post(nexus_url("service/local/repo_groups"), :body => create_group_repository_json(name, id, provider), :header => DEFAULT_CONTENT_TYPE_HEADER)
Expand All @@ -92,9 +92,9 @@ def create_group_repository(name, id, provider)

# Gets information about the given group repository with
# the given [group_id].
#
#
# @param group_id [String] the id of the group repository to find
#
#
# @return [String] a JSON String of information about the given group repository
def get_group_repository(group_id)
response = nexus.get(nexus_url("service/local/repo_groups/#{sanitize_for_id(group_id)}"), :header => DEFAULT_ACCEPT_HEADER)
Expand All @@ -110,10 +110,10 @@ def get_group_repository(group_id)

# Checks if a the given [repository_to_check] is a member
# of the given group repository - [group_ip].
#
#
# @param group_id [String] the group repository to look in
# @param repository_to_check [String] the repository that might be a member of the group
#
#
# @return [Boolean] true if the [repository_to_check] is a member of group repository, false otherwise
def repository_in_group?(group_id, repository_to_check)
group_repository = JSON.parse(get_group_repository(group_id))
Expand All @@ -124,10 +124,10 @@ def repository_in_group?(group_id, repository_to_check)

# Adds the given [repository_to_add_id] to the given group repository,
# [group_id].
#
#
# @param group_id [String] the group repository to add to
# @param repository_to_add_id [String] the repository to added to the group
#
#
# @return [Boolean] true if the repository is successfully added, false otherwise
def add_to_group_repository(group_id, repository_to_add_id)
raise RepositoryInGroupException if repository_in_group?(group_id, repository_to_add_id)
Expand All @@ -144,10 +144,10 @@ def add_to_group_repository(group_id, repository_to_add_id)

# Removes the given [repository_to_remove_id] from the group repository,
# [group_id].
#
#
# @param group_id [String] the group repository to remove from
# @param repository_to_remove_id [String] the repository to remove from the group
#
#
# @return [Boolean] true if the repisotory is successfully remove, false otherwise
def remove_from_group_repository(group_id, repository_to_remove_id)
raise RepositoryNotInGroupException unless repository_in_group?(group_id, repository_to_remove_id)
Expand All @@ -161,9 +161,9 @@ def remove_from_group_repository(group_id, repository_to_remove_id)
end

# Deletes the given group repository.
#
#
# @param group_id [String] the group repository to delete
#
#
# @return [Boolean] true if the group repository is deleted, false otherwise
def delete_group_repository(group_id)
response = nexus.delete(nexus_url("service/local/repo_groups/#{sanitize_for_id(group_id)}"))
Expand All @@ -179,35 +179,37 @@ def delete_group_repository(group_id)

private

def create_hosted_repository_json(name, id, policy, provider)
def create_hosted_repository_json(name, id, policy, provider, param_overrides={})
params = {:provider => provider.nil? ? "maven2": provider}
params[:providerRole] = "org.sonatype.nexus.proxy.repository.Repository"
params[:exposed] = true
params[:browseable] = true
params[:indexable] = true
params[:repoType] = "hosted"
params[:repoPolicy] = policy.nil? ? "RELEASE" : ["RELEASE", "SNAPSHOT"].include?(policy) ? policy : "RELEASE"
params[:repoPolicy] = policy.nil? ? "RELEASE" : ["RELEASE", "SNAPSHOT"].include?(policy) ? policy : "RELEASE"
params[:name] = name
params[:id] = id.nil? ? sanitize_for_id(name) : sanitize_for_id(id)
params[:format] = "maven2"
params.merge!(param_overrides)
JSON.dump(:data => params)
end

def create_proxy_repository_json(name, url, id, policy, provider)
def create_proxy_repository_json(name, url, id, policy, provider, param_overrides={})
params = {:provider => provider.nil? ? "maven2" : provider}
params[:providerRole] = "org.sonatype.nexus.proxy.repository.Repository"
params[:exposed] = true
params[:browseable] = true
params[:indexable] = true
params[:repoType] = "proxy"
params[:repoPolicy] = policy.nil? ? "RELEASE" : ["RELEASE", "SNAPSHOT"].include?(policy) ? policy : "RELEASE"
params[:repoPolicy] = policy.nil? ? "RELEASE" : ["RELEASE", "SNAPSHOT"].include?(policy) ? policy : "RELEASE"
params[:checksumPolicy] = "WARN"
params[:writePolicy] = "READ_ONLY"
params[:downloadRemoteIndexes] = true
params[:autoBlockActive] = false
params[:name] = name
params[:id] = id.nil? ? sanitize_for_id(name) : sanitize_for_id(id)
params[:remoteStorage] = {:remoteStorageUrl => url.nil? ? "http://change-me.com/" : url}
params.merge!(param_overrides)
JSON.dump(:data => params)
end

Expand Down Expand Up @@ -235,11 +237,11 @@ def create_remove_from_group_repository_json(group_id, repository_to_remove_id)
repositories = group_repository_json["data"]["repositories"]

repositories.delete(repository_in_group?(group_id, repository_to_remove_id))

params = {:repositories => repositories}
params[:id] = group_repository_json["data"]["id"]
params[:name] = group_repository_json["data"]["name"]
JSON.dump(:data => params)
end
end
end
end