# frozen_string_literal: true

module Analytics
  module CycleAnalytics
    class ValueStream < ApplicationRecord
      MAX_VALUE_STREAMS_PER_NAMESPACE = 50

      self.table_name = :analytics_cycle_analytics_group_value_streams

      include Analytics::CycleAnalytics::Parentable

      has_many :stages, -> { ordered },
        class_name: 'Analytics::CycleAnalytics::Stage',
        foreign_key: :group_value_stream_id,
        index_errors: true,
        inverse_of: :value_stream

      validates :name, presence: true
      validates :name, length: { minimum: 3, maximum: 100, allow_nil: false }, uniqueness: { scope: :group_id }
      validate :max_value_streams_count, on: :create

      accepts_nested_attributes_for :stages, allow_destroy: true

      scope :preload_associated_models, -> {
        includes(:namespace, stages: [:namespace, :end_event_label, :start_event_label])
      }
      scope :order_by_name_asc, -> { order(arel_table[:name].lower.asc) }

      after_save :ensure_aggregation_record_presence

      def custom?
        persisted? || name != Analytics::CycleAnalytics::Stages::BaseService::DEFAULT_VALUE_STREAM_NAME
      end

      def self.build_default_value_stream(namespace)
        new(name: Analytics::CycleAnalytics::Stages::BaseService::DEFAULT_VALUE_STREAM_NAME, namespace: namespace)
      end

      def project
        return unless namespace.is_a?(::Namespaces::ProjectNamespace)

        namespace.project
      end

      def to_global_id
        return super if persisted?

        # Returns default name as id for built in value stream at FOSS level
        name
      end

      private

      def max_value_streams_count
        return unless namespace
        return unless namespace.value_streams.count >= MAX_VALUE_STREAMS_PER_NAMESPACE

        errors.add(:namespace, _('Maximum number of value streams per namespace exceeded'))
      end

      def ensure_aggregation_record_presence
        Analytics::CycleAnalytics::Aggregation.safe_create_for_namespace(namespace)
      end
    end
  end
end
Analytics::CycleAnalytics::ValueStream.prepend_mod_with('Analytics::CycleAnalytics::ValueStream')