Contents

# encoding: utf-8
require "logstash/namespace"
require "base64"

module LogStash module Util class CloudSettingId
  attr_reader :original, :decoded, :label, :elasticsearch_host, :kibana_host

  def initialize(value)
    return if value.nil?

    unless value.is_a?(String)
      raise ArgumentError.new("Cloud Id must be String. Received: #{value.class}")
    end
    @original = value
    @label, sep, last = value.partition(":")
    if last.empty?
      @decoded = Base64.urlsafe_decode64(@label) rescue ""
      @label = ""
    else
      @decoded = Base64.urlsafe_decode64(last) rescue ""
    end
    unless @decoded.count("$") == 2
      raise ArgumentError.new("Cloud Id does not decode. Received: \"#{@original}\".")
    end
    parts = @decoded.split("$")
    if parts.any?(&:empty?)
      raise ArgumentError.new("Cloud Id, after decoding, is invalid. Format: '<part1>$<part2>$<part3>'. Received: \"#{@decoded}\".")
    end
    cloud_host, es_server, kb_server = parts
    @elasticsearch_host = sprintf("%s.%s:443", es_server, cloud_host)
    @kibana_host  = sprintf("%s.%s:443", kb_server, cloud_host)
  end

  def to_s
    @original.to_s
  end

  def inspect
    to_s
  end
end end end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
logstash-core-6.0.0.rc1-java	lib/logstash/util/cloud_setting_id.rb
logstash-core-6.0.0.beta2-java	lib/logstash/util/cloud_setting_id.rb