ubicloud/spec/lib/victoria_metrics/client_spec.rb

# frozen_string_literal: true

require "spec_helper"

RSpec.describe VictoriaMetrics::Client do
  let(:endpoint) { "http://localhost:8428" }
  let(:client) { described_class.new(endpoint: endpoint) }
  let(:cert) { "-----BEGIN CERTIFICATE-----\nMIIDCzCCAfOgAwIBAgIUasLyHvpgRtp3/8N9pRPE7f89Gi4wDQYJKoZIhvcNAQEL\nBQAwFTETMBEGA1UEAwwKTXkgVGVzdCBDQTAeFw0yNTA2MDIwOTE2MjFaFw0zNTA1\nMzEwOTE2MjFaMBUxEzARBgNVBAMMCk15IFRlc3QgQ0EwggEiMA0GCSqGSIb3DQEB\nAQUAA4IBDwAwggEKAoIBAQC0WFDSoccSl95/VL4U73JYAYgg1ar96Mo9VJn5H+Y0\nvyfKUI7DWrqZtiqYlCr01nN52FFHwEBgCIYr+aa5MmMHZfe0nbeDK4AbsZKJHr0Z\nBfJfqI9pRxVd9MyRcU2XTAeDWRK3k3sRj6webU2MFxUvF7xB2Wx2+rNhLZhB+d8t\nZSRpwFiX9rgMKYkycY1kV4ZurUT72ct/Q+dNCTTUOel/brMDQhdn02PYAUKgh2UB\nELeooXt1JPedjSH41ShV2yEBA1NyTctaVp3tWfiq+b4p0ZiV/ekoBtkDe5WtaNo1\nxgvRGH/rcOfTraZKokgqCVCG1Ka4DrkvSsaTlOe9XrQlAgMBAAGjUzBRMB0GA1Ud\nDgQWBBQUnKN3Du3ihaNNK3Q9+lztEI4pajAfBgNVHSMEGDAWgBQUnKN3Du3ihaNN\nK3Q9+lztEI4pajAPBgNVHRMBAf8EBTADAQH/MA0GCSqGSIb3DQEBCwUAA4IBAQAG\ndJijmtiYx2dCw50V3QhjyVyTvhFf1B9XUKGP2i0IPApULXqDGll47iIGo6i1yD7V\n7hjpV0BCtFlNH5nH2bZ0zyUi3XCLTqlnHM8+tI6ZUMWRq2lJAgILVHH/D/VUTUl6\nS+h6rGbtzNBCz2jmP3LiL2lmfcPivJpim5RPtAbApyt7fvHWD8aGQWZHpLYn+2v5\n1laUkm55cvWlsnC27PeNT00/3Eu96dqMiLHFJgKkUGFJMr+49X+BTaLcCUXCja+s\n4nXqhVt+iVVk1RtVS/b1C17DvxnV5g1NAFiZQOx5Gfsr5v8SafKCgR/4xm/kGfEz\nIkfEWqyeWXMj/JRB2yCy\n-----END CERTIFICATE-----" }

  describe "#initialize" do
    it "creates a client with the given endpoint" do
      expect(client.instance_variable_get(:@endpoint)).to eq(endpoint)
    end

    it "creates a client with SSL configuration" do
      client = described_class.new(endpoint: endpoint, ssl_ca_data: cert)

      excon_client = client.instance_variable_get(:@client)
      expect(excon_client).to be_a(Excon::Connection)
      expect(excon_client.data[:ssl_cert_store]).to be_a(OpenSSL::X509::Store)
    end

    it "creates a client without SSL configuration when ssl_ca_data is not provided" do
      client = described_class.new(endpoint: endpoint)

      excon_client = client.instance_variable_get(:@client)
      expect(excon_client).to be_a(Excon::Connection)
      expect(excon_client.data[:ssl_cert_store]).to be_nil
    end

    context "with authentication" do
      let(:username) { "user" }
      let(:password) { "pass" }
      let(:client) { described_class.new(endpoint: endpoint, username: username, password: password) }

      it "creates a client with authentication credentials" do
        expect(client.instance_variable_get(:@username)).to eq(username)
        expect(client.instance_variable_get(:@password)).to eq(password)
      end
    end
  end

  describe "#health" do
    context "when the service is healthy" do
      before do
        stub_request(:get, "#{endpoint}/health")
          .to_return(status: 200)
      end

      it "returns true" do
        expect(client.health).to be true
      end
    end

    context "when the service is unhealthy" do
      before do
        stub_request(:get, "#{endpoint}/health")
          .to_return(status: 500)
      end

      it "raises an error" do
        expect { client.health }.to raise_error(VictoriaMetrics::ClientError)
      end
    end
  end

  describe "#send_request" do
    context "with authentication" do
      let(:username) { "user" }
      let(:password) { "pass" }
      let(:client) { described_class.new(endpoint: endpoint, username: username, password: password) }

      before do
        stub_request(:get, "#{endpoint}/test")
          .with(headers: {"Authorization" => "Basic #{Base64.strict_encode64("#{username}:#{password}")}"})
          .to_return(status: 200)
      end

      it "includes authentication headers" do
        client.send(:send_request, "GET", "/test")
        expect(WebMock).to have_requested(:get, "#{endpoint}/test")
          .with(headers: {"Authorization" => "Basic #{Base64.strict_encode64("#{username}:#{password}")}"})
      end
    end

    context "with different response status codes" do
      it "handles 200 status code" do
        stub_request(:get, "#{endpoint}/test")
          .to_return(status: 200)
        response = client.send(:send_request, "GET", "/test")
        expect(response.status).to eq(200)
      end

      it "handles 204 status code" do
        stub_request(:get, "#{endpoint}/test")
          .to_return(status: 204)
        response = client.send(:send_request, "GET", "/test")
        expect(response.status).to eq(204)
      end

      it "handles 206 status code" do
        stub_request(:get, "#{endpoint}/test")
          .to_return(status: 206)
        response = client.send(:send_request, "GET", "/test")
        expect(response.status).to eq(206)
      end

      it "handles 404 status code" do
        stub_request(:get, "#{endpoint}/test")
          .to_return(status: 404)
        response = client.send(:send_request, "GET", "/test")
        expect(response.status).to eq(404)
      end

      it "raises error for 500 status code" do
        stub_request(:get, "#{endpoint}/test")
          .to_return(status: 500, body: "Internal Server Error")
        expect { client.send(:send_request, "GET", "/test") }.to raise_error(VictoriaMetrics::ClientError, "VictoriaMetrics Client error, method: GET, path: /test, status code: 500")
      end
    end
  end

  describe "#import_prometheus" do
    let(:samples) { "metric{label=\"value\"} 42.5" }
    let(:time) { Time.now }
    let(:timestamp_msec) { (time.to_f * 1000).to_i }
    let(:scrape) { instance_double(VictoriaMetrics::Client::Scrape, time: time, samples: samples) }

    before do
      allow(client).to receive(:gzip).with(samples).and_return("gzipped_data")
    end

    context "with no extra labels" do
      before do
        stub_request(:post, "#{endpoint}/api/v1/import/prometheus?timestamp=#{timestamp_msec}")
          .with(
            body: "gzipped_data",
            headers: {
              "Content-Encoding" => "gzip",
              "Content-Type" => "application/octet-stream"
            }
          )
          .to_return(status: 204)
      end

      it "sends a POST request with correct parameters" do
        expect { client.import_prometheus(scrape) }.not_to raise_error
      end
    end

    context "with extra labels" do
      let(:extra_labels) { {"env" => "production", "region" => "us-west"} }

      before do
        stub_request(:post, "#{endpoint}/api/v1/import/prometheus?timestamp=#{timestamp_msec}&extra_label=env%3Dproduction&extra_label=region%3Dus-west")
          .with(
            body: "gzipped_data",
            headers: {
              "Content-Encoding" => "gzip",
              "Content-Type" => "application/octet-stream"
            }
          )
          .to_return(status: 204)
      end

      it "sends a POST request with correct parameters and extra labels" do
        expect { client.import_prometheus(scrape, extra_labels) }.not_to raise_error
      end
    end

    context "when the server returns an error" do
      before do
        stub_request(:post, "#{endpoint}/api/v1/import/prometheus?timestamp=#{timestamp_msec}")
          .to_return(status: 500, body: "Server Error")
      end

      it "raises a ClientError" do
        expect { client.import_prometheus(scrape) }.to raise_error(VictoriaMetrics::ClientError)
      end
    end

    context "with authentication" do
      let(:username) { "user" }
      let(:password) { "pass" }
      let(:client) { described_class.new(endpoint: endpoint, username: username, password: password) }

      before do
        stub_request(:post, "#{endpoint}/api/v1/import/prometheus?timestamp=#{timestamp_msec}")
          .with(
            headers: {
              "Authorization" => "Basic #{Base64.strict_encode64("#{username}:#{password}")}",
              "Content-Encoding" => "gzip",
              "Content-Type" => "application/octet-stream"
            }
          )
          .to_return(status: 204)
      end

      it "includes authentication headers" do
        client.import_prometheus(scrape)
        expect(WebMock).to have_requested(:post, "#{endpoint}/api/v1/import/prometheus?timestamp=#{timestamp_msec}")
          .with(
            headers: {
              "Authorization" => "Basic #{Base64.strict_encode64("#{username}:#{password}")}",
              "Content-Encoding" => "gzip",
              "Content-Type" => "application/octet-stream"
            }
          )
      end
    end
  end

  describe "#query_range" do
    let(:query) { 'sum(rate(http_requests_total{job="api"}[5m]))' }
    let(:start_ts) { Time.now.to_i - 3600 } # 1 hour ago
    let(:end_ts) { Time.now.to_i }

    context "when the query is successful" do
      before do
        stub_request(:get, /#{endpoint}\/api\/v1\/query_range.*/)
          .to_return(
            status: 200,
            body: {
              "status" => "success",
              "data" => {
                "resultType" => "matrix",
                "result" => [
                  {
                    "metric" => {"job" => "api", "instance" => "server1"},
                    "values" => [
                      [1600000000, "10.5"],
                      [1600000015, "12.3"]
                    ]
                  },
                  {
                    "metric" => {"job" => "api", "instance" => "server2"},
                    "values" => [
                      [1600000000, "5.2"],
                      [1600000015, "6.1"]
                    ]
                  }
                ]
              }
            }.to_json
          )
      end

      it "returns formatted series data" do
        result = client.query_range(query: query, start_ts: start_ts, end_ts: end_ts)

        expect(result.length).to eq(2)
        expect(result[0]["labels"]).to eq({"job" => "api", "instance" => "server1"})
        expect(result[0]["values"]).to eq([[1600000000, "10.5"], [1600000015, "12.3"]])
        expect(result[1]["labels"]).to eq({"job" => "api", "instance" => "server2"})
        expect(result[1]["values"]).to eq([[1600000000, "5.2"], [1600000015, "6.1"]])
      end

      it "constructs the correct query parameters" do
        client.query_range(query: query, start_ts: start_ts, end_ts: end_ts)

        expected_step = client.send(:step_seconds, start_ts, end_ts)
        query_params = [
          ["query", query],
          ["start", start_ts.to_s],
          ["end", end_ts.to_s],
          ["step", expected_step.to_s]
        ]
        encoded_params = URI.encode_www_form(query_params)

        expect(WebMock).to have_requested(:get, "#{endpoint}/api/v1/query_range?#{encoded_params}")
      end
    end

    context "when the query returns no results" do
      before do
        stub_request(:get, /#{endpoint}\/api\/v1\/query_range.*/)
          .to_return(
            status: 200,
            body: {
              "status" => "success",
              "data" => {
                "resultType" => "matrix",
                "result" => []
              }
            }.to_json
          )
      end

      it "returns an empty array" do
        result = client.query_range(query: query, start_ts: start_ts, end_ts: end_ts)
        expect(result).to eq([])
      end
    end

    context "when the query returns an error" do
      before do
        stub_request(:get, /#{endpoint}\/api\/v1\/query_range.*/)
          .to_return(
            status: 200,
            body: {
              "status" => "error",
              "errorType" => "execution",
              "error" => "parse error: unexpected end of input"
            }.to_json
          )
      end

      it "returns an empty array" do
        result = client.query_range(query: query, start_ts: start_ts, end_ts: end_ts)
        expect(result).to eq([])
      end
    end

    context "when the query returns a different result type" do
      before do
        stub_request(:get, /#{endpoint}\/api\/v1\/query_range.*/)
          .to_return(
            status: 200,
            body: {
              "status" => "success",
              "data" => {
                "resultType" => "scalar",
                "result" => 42
              }
            }.to_json
          )
      end

      it "returns an empty array" do
        result = client.query_range(query: query, start_ts: start_ts, end_ts: end_ts)
        expect(result).to eq([])
      end
    end
  end

  describe "#gzip" do
    it "compresses the input string" do
      input = "test string"
      compressed = client.send(:gzip, input)

      # Verify it's gzipped by decompressing it
      io = StringIO.new(compressed)
      gz = Zlib::GzipReader.new(io)
      decompressed = gz.read

      expect(decompressed).to eq(input)
    end
  end

  describe "#scrape_initialize" do
    it "initializes a Scrape object with time and samples" do
      time = Time.now
      samples = "metric{label=\"value\"} 42.5"
      scrape = VictoriaMetrics::Client::Scrape.new(time: time, samples: samples)

      expect(scrape).to be_a(VictoriaMetrics::Client::Scrape)
      expect(scrape.time).to eq(time)
      expect(scrape.samples).to eq(samples)
    end
  end

  describe "#step_seconds" do
    it "calculates the step based on the time range" do
      # 1 hour difference
      start_time = 1600000000
      end_time = start_time + 3600
      expect(client.send(:step_seconds, start_time, end_time)).to eq(15)

      # 3 hours difference
      end_time = start_time + (3 * 3600)
      expect(client.send(:step_seconds, start_time, end_time)).to eq(30)

      # 5 hours difference
      end_time = start_time + (5 * 3600)
      expect(client.send(:step_seconds, start_time, end_time)).to eq(45)
    end

    it "handles edge cases" do
      # Exactly 2 hours
      start_time = 1600000000
      end_time = start_time + (2 * 3600)
      expect(client.send(:step_seconds, start_time, end_time)).to eq(15)

      # Less than 1 hour
      end_time = start_time + 1800 # 30 minutes
      expect(client.send(:step_seconds, start_time, end_time)).to eq(15)
    end
  end
end