Contents

require 'spec_helper'

describe Influxer::Metrics do
  before do
    allow_any_instance_of(Influxer::Client).to receive(:query) do |_, sql|    
      sql
    end
  end

  let(:dummy) do
    Class.new(Influxer::Metrics) do
      set_series 'dummy'
      default_scope -> { time(:hour) }
    end
  end

  let(:doomy) do
    Class.new(dummy) do
      scope :by_user, -> (id) { where(user: id) if id.present? }
      scope :hourly, -> { where(by: :hour).time(nil) }
      scope :daily, -> { where(by: :day).time(nil) }

      fanout :by, :user, :account, delimeter: "."
    end
  end

  let(:dappy) do
    Class.new(doomy) do
      fanout :user, delimeter: "_"
    end
  end

  describe "fanouts" do
    it "should work with one fanout" do
      expect(doomy.by_user(1).to_sql).to eq "select * from \"dummy.user.1\" group by time(1h)"
    end

    it "should work with several fanouts" do
      expect(dappy.by_user(1).hourly.to_sql).to eq "select * from \"dummy_by_hour_user_1\""
    end

    it "should work with regexp fanouts" do
      expect(dappy.where(dummy_id: 100).by_user(/[1-3]/).daily.to_sql).to eq "select * from merge(/^dummy_by_day_user_[1-3]$/) where (dummy_id=100)"
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
influxer-0.2.2	spec/metrics/fanout_spec.rb
influxer-0.2.0	spec/metrics/fanout_spec.rb
influxer-0.1.2	spec/metrics/fanout_spec.rb
influxer-0.1.1	spec/metrics/fanout_spec.rb
influxer-0.1.0	spec/metrics/fanout_spec.rb