lib/gdk/services/siphon_producer_main_db.rb

# frozen_string_literal: true

require 'pathname'

module GDK
  module Services
    class SiphonProducerMainDb < Base
      def name
        'siphon-producer-main-db'
      end

      def command
        'siphon/cmd/cmd --config siphon/config.yml'
      end

      def ready_message
        "Siphon is listening on main DB for data from: #{config.siphon.tables.join(', ')}"
      end

      def validate!
        return unless config.siphon.enabled?
        return if config.clickhouse.enabled? && config.nats.enabled?

        raise GDK::ConfigSettings::UnsupportedConfiguration, <<~MSG.strip
          Running Siphon without ClickHouse and NATS is not possible.
          Enable ClickHouse and NATS in your GDK or disable Siphon to continue.
        MSG
      end

      def enabled?
        return false unless config.clickhouse.enabled? && config.nats.enabled?

        config.siphon.enabled?
      end
    end
  end
end