eprothro/cassie

module Cassie::Statements::Logging
  class DeserializeEvent < ActiveSupport::Notifications::Event

    def count
      payload[:count]
    end

    def message
      {
        event: "cassie.deserialize",
        duration: duration.round(1),
        count: count
      }.extend(Inspector)
    end

    module Inspector
      def inspect
        color("(#{fetch(:duration).round(1)}ms) #{fetch(:count)} #{'result'.pluralize(fetch(:count))} deserialized from Cassandra rows")
      end

      def to_s
        inspect
      end

      protected

      def color(message)
        "\e[1m\e[34m#{message}\e[0m\e[22m"
      end
    end
  end
end