Contents

# frozen_string_literal: true

require 'ld-eventsource'

module Killbill
  module KPM
    class KPMClient < KillBillClient::Model::Resource
      KILLBILL_KPM_PREFIX = '/plugins/killbill-kpm'
      KILLBILL_OSGI_LOGGER_PREFIX = '/plugins/killbill-osgi-logger'

      class << self
        def get_available_plugins(kb_version_maybe_snapshot, latest, options)
          # Mostly useful for Kill Bill developers: get the latest version before the current snapshot
          # (we rarely deploy SNAPSHOT jars)
          captures = kb_version_maybe_snapshot.scan(/0.(\d+)(\.)?(\d+)?(-SNAPSHOT)?/)
          # [["20", ".", "1", "-SNAPSHOT"]]
          kb_version = if !captures.nil? && !captures.first.nil? && !captures.first[3].nil?
                         if captures.first[2].to_i.positive?
                           "0.#{captures.first[0]}.#{captures.first[2].to_i - 1}"
                         else
                           "0.#{captures.first[0].to_i - 1}.0"
                         end
                       else
                         kb_version_maybe_snapshot
                       end

          path = "#{KILLBILL_KPM_PREFIX}/plugins"
          response = KillBillClient::API.get path, { kbVersion: kb_version, latest: latest }, options
          JSON.parse(response.body)
        end

        def stream_osgi_logs(writer, host, last_event_id_ref)
          url = host
          url = "http://#{url}" unless url.starts_with?('http:')
          SSE::Client.new(url + KILLBILL_OSGI_LOGGER_PREFIX, last_event_id: last_event_id_ref.get, logger: Rails.logger) do |client|
            client.on_event do |event|
              writer.write(event.data, id: event.id)
              last_event_id_ref.set(event.id)
            end
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
killbill-kpm-ui-3.0.3	lib/kpm/client.rb
killbill-kpm-ui-3.0.2	lib/kpm/client.rb
killbill-kpm-ui-2.1.1	lib/kpm/client.rb
killbill-kpm-ui-3.0.1	lib/kpm/client.rb