scinote-web/app/services/repositories/multiple_share_update_service.rb

# frozen_string_literal: true

module Repositories
  class MultipleShareUpdateService
    extend Service
    include Canaid::Helpers::PermissionsHelper

    attr_reader :repository, :user, :warnings, :errors

    def initialize(repository_id:,
                   user_id:,
                   team_id:,
                   team_ids_for_share: [],
                   team_ids_for_unshare: [],
                   team_ids_for_update: [],
                   shared_with_all: nil,
                   shared_permissions_level: nil)
      @repository = Repository.find_by_id repository_id
      @user = User.find_by_id user_id
      @team = Team.find_by_id team_id
      @team_ids_for_share = team_ids_for_share
      @team_ids_for_unshare = team_ids_for_unshare
      @team_ids_for_update = team_ids_for_update
      @errors = {}
      @warnings = []
      @shared_with_all = shared_with_all
      @shared_permission_level = shared_permissions_level
    end

    def call
      return self unless valid?

      if !@shared_with_all.nil? && !@shared_permission_level.nil?
        @repository.shared = @shared_with_all
        @repository.permission_level = @shared_permission_level

        if @repository.changed?
          change_type = @repository.changes.key?('shared') ? 'share' : 'update_permission_level'
          log_activity_share_all(change_type, @repository) if @repository.save
        end
      end

      @team_ids_for_share.each do |share|
        team_repository = TeamRepository.new(repository: @repository,
                                             team_id: share[:id],
                                             permission_level: share[:permission_level])

        if team_repository.save
          log_activity(:share_inventory, team_repository)
        else
          warnings << I18n.t('repositories.multiple_share_service.unable_to_share',
                             repository: @repository.name, team: share[:id])
        end
      end

      @team_ids_for_unshare.each do |team_id|
        team_repository = TeamRepository.where(repository: @repository, team_id: team_id).first

        if team_repository
          log_activity(:unshare_inventory, team_repository)
          team_repository.destroy
        else
          warnings << I18n.t('repositories.multiple_share_service.unable_to_unshare',
                             repository: @repository.name, team: team_id)
        end
      end

      @team_ids_for_update.each do |update|
        team_repository = TeamRepository.where(repository: @repository, team_id: update[:id]).first
        team_repository.permission_level = update[:permission_level] if team_repository

        if team_repository&.save
          log_activity(:update_share_inventory, team_repository)
        else
          warnings << I18n.t('repositories.multiple_share_service.unable_to_update',
                             repository: @repository.name, team: update[:id])
        end
      end

      self
    end

    def succeed?
      @errors.none?
    end

    private

    def valid?
      unless @user && @repository
        @errors[:invalid_arguments] =
          { 'repository': @repository,
            'user': @user,
            'team': @team }
          .map do |key, value|
            "Can't find #{key.capitalize}" if value.nil?
          end.compact
        return false
      end

      if can_manage_repository?(@user, @repository)
        true
      else
        @errors[:user_without_permissions] =
          ['You are not allowed to share this repository']
        false
      end
    end

    def log_activity(type_of, team_repository)
      Activities::CreateActivityService
        .call(activity_type: type_of,
              owner: @user,
              subject: team_repository.repository,
              team: @team,
              message_items: { repository: team_repository.repository.id,
                               team: team_repository.team.id,
                               permission_level:
                                 Extends::SHARED_INVENTORIES_PL_MAPPINGS[team_repository.permission_level.to_sym] })
    end

    def log_activity_share_all(change_type, repository)
      type = if change_type == 'share'
               @repository.shared ? :share_inventory_with_all : :unshare_inventory_with_all
             else
               :update_share_with_all_permission_level
             end

      Activities::CreateActivityService
        .call(activity_type: type,
              owner: @user,
              subject: repository,
              team: @team,
              message_items: { repository: repository.id,
                               team: @team.id,
                               permission_level:
                                 Extends::SHARED_INVENTORIES_PL_MAPPINGS[repository.permission_level.to_sym] })
    end
  end
end