Sha256: c86312be94a741711dbe081cabc13a15e77fe60607e28ad24000d04cdee23b24
Contents?: true
Size: 1.84 KB
Versions: 6
Compression:
Stored size: 1.84 KB
Contents
# frozen_string_literal: true
require 'json'
require 'yaml'
require 'csv'
module KubernetesDeploy
class BindingsParser
def self.parse(string)
new(string).parse
end
def initialize(initial_string = nil)
@raw_bindings = Array(initial_string)
end
def add(string)
@raw_bindings << string
end
def parse
result = {}
@raw_bindings.each do |string|
bindings = parse_file(string) || parse_json(string) || parse_csv(string)
unless bindings
raise ArgumentError, "Failed to parse bindings."
end
result.deep_merge!(bindings)
end
result
end
private
def parse_file(string)
return unless string =~ /\A@/
begin
file_path = string.gsub(/\A@/, '')
case File.extname(file_path)
when '.json'
bindings = parse_json(File.read(file_path))
when '.yaml', '.yml'
bindings = YAML.safe_load(File.read(file_path), [], [], true, file_path)
else
raise ArgumentError, "Supplied file does not appear to be JSON or YAML"
end
bindings
rescue Errno::ENOENT
raise ArgumentError, "Supplied file does not exist: #{string}"
end
end
def parse_json(string)
bindings = JSON.parse(string)
unless bindings.is_a?(Hash)
raise ArgumentError, "Expected JSON data to be a hash."
end
bindings
rescue JSON::ParserError
nil
end
def parse_csv(string)
lines = CSV.parse(string)
bindings = {}
lines.each do |line|
line.each do |binding|
key, value = binding.split('=', 2)
if key.blank?
raise ArgumentError, "key is blank"
end
bindings[key] = value
end
end
bindings
rescue CSV::MalformedCSVError
nil
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems