Sha256: 7db57653ad79a527ff318b58bc972a1ec0939cd14afafb7f0b7602c74353728a
Contents?: true
Size: 1.23 KB
Versions: 22
Compression:
Stored size: 1.23 KB
Contents
class KuberKit::ArtifactsSync::ArtifactsUpdater
ResolverNotFoundError = Class.new(KuberKit::NotFoundError)
include KuberKit::Import[
"artifacts_sync.git_artifact_resolver",
"artifacts_sync.null_artifact_resolver",
"ui"
]
def use_resolver(artifact_resolver, artifact_class:)
@@resolvers ||= {}
if !artifact_resolver.is_a?(KuberKit::ArtifactsSync::AbstractArtifactResolver)
raise ArgumentError.new("should be an instance of KuberKit::ArtifactsSync::AbstractArtifactResolver, got: #{artifact_resolver.inspect}")
end
@@resolvers[artifact_class] = artifact_resolver
end
def update(shell, artifacts)
add_default_resolvers
artifacts.each do |artifact|
resolver = @@resolvers[artifact.class]
ui.print_debug "ArtifactUpdater", "Updating artifact #{artifact.name.to_s.green}"
raise ResolverNotFoundError, "Can't find resolver for artifact #{artifact}" if resolver.nil?
resolver.resolve(shell, artifact)
end
end
def add_default_resolvers
use_resolver(git_artifact_resolver, artifact_class: KuberKit::Core::Artifacts::Git)
use_resolver(null_artifact_resolver, artifact_class: KuberKit::Core::Artifacts::Local)
end
def reset!
@@resolvers = {}
end
end
Version data entries
22 entries across 22 versions & 1 rubygems