class Sysdig::Mock

Attributes

account_id[R]
logger[R]
url[R]

Public Class Methods

data() click to toggle source
# File lib/sysdig/mock.rb, line 8
def self.data
  @@data ||= Hash.new { |h,url|
    h[url] = {
      :alerts => {},
      :alert_notifications => {},
      :user_notifications => {
        "email" => {
          "enabled"    => false,
          "recipients" => []
        },
        "sns" => {
          "enabled" => false,
          "topics"  => []
        },
        "pagerDuty" => {
          "enabled"     => false,
          "integrated"  => false,
          "resolveOnOk" => false,
          "connectUrl"  => "https://connect.pagerduty.com/connect?vendor=x&callback=https://app.sysdigcloud.com/api/pagerDuty/callback/y/z"
        }
      }
    }
  }
end
new(options={}) click to toggle source
# File lib/sysdig/mock.rb, line 35
def initialize(options={})
  @url     = options[:url]    || "https://langley.engineyard.com"
  @logger  = options[:logger] || Logger.new(nil)

  username, password, token = *options.values_at(:username, :password, :token)

  @account_id = (username && password) ? Digest::SHA256.hexdigest("#{username}:#{password}") : token
end
reset!() click to toggle source
Calls superclass method
# File lib/sysdig/mock.rb, line 2
def self.reset!
  super

  @id = 0
end

Public Instance Methods

create_alert_notification(alert, state: "ACTIVE", resolved: false) click to toggle source
# File lib/sysdig/mock.rb, line 80
def create_alert_notification(alert, state: "ACTIVE", resolved: false)
  alert_notification_id = self.serial_id
  alert_data = self.data[:alerts].fetch(alert.identity)

  alert_notification = self.data[:alert_notifications][alert_notification_id] = {
    "id"        => alert_notification_id,
    "timestamp" => (Time.now.to_i - rand(60..300)) * 1_000_000,
    "timespan"  => alert_data["timespan"].to_i,
    "filter"    => alert_data["filter"],
    "condition" => alert_data["condition"],
    "state"     => state.upcase,
    "resolved"  => resolved,
    "alert"     => alert.identity.to_s,
    "entities"  => [
      "filter" => alert_data["filter"],
      "target" => {}, # @fixme the hell
      "metricValues" => {}, # @fixme breakdown of condition
    ]
  }

  self.alert_notifications.new(alert_notification)
end
data() click to toggle source
# File lib/sysdig/mock.rb, line 71
def data
  self.class.data[self.account_id]
end
response(options={}) click to toggle source
# File lib/sysdig/mock.rb, line 48
def response(options={})
  status  = options[:status] || 200
  body    = options[:body]
  headers = {
    "Content-Type" => "application/json; charset=utf-8",
  }.merge(options[:headers] || {})

  logger.debug "MOCKED RESPONSE: #{status}"
  logger.debug('response') { headers.map { |k, v| "#{k}: #{v.inspect}" }.join("\n") }
  logger.debug caller[0]
  logger.debug('response.body') { body }

  Sysdig::Response.new(
    :status  => status,
    :headers => headers,
    :body    => body,
    :request => {
      :method  => :mocked,
      :url     => caller[1],
    }
  ).raise!
end
serial_id() click to toggle source
# File lib/sysdig/mock.rb, line 75
def serial_id
  @id ||= 0
  @id += 1
end
url_for(*pieces) click to toggle source
# File lib/sysdig/mock.rb, line 44
def url_for(*pieces)
  File.join(self.url, *pieces)
end