Contents

module Actions
  module SccManager
    class Sync < Actions::EntryAction
      def plan(scc_account)
        ::Foreman::Logging.logger('foreman_scc_manager')
                          .info("Initiating 'sync' for SccAccount '#{scc_account.name}'.")
        action_subject(scc_account)
        sequence do
          sync_repo_action = plan_action(::Actions::SccManager::SyncRepositories, scc_account)
          sync_prod_action = plan_action(::Actions::SccManager::SyncProducts, scc_account)
          plan_self(repo_status: sync_repo_action.output[:status], prod_status: sync_prod_action.output[:status])
        end
      end

      def finalize
        scc_account = SccAccount.find(input[:scc_account][:id])
        if input[:repo_status] == 'SUCCESS' && input[:prod_status] == 'SUCCESS'
          scc_account.update! synced: DateTime.current
        else
          raise 'Updating failed'
        end
      end

      def rescue_strategy
        Dynflow::Action::Rescue::Fail
      end

      def humanized_name
        _('Sync SUSE subscriptions')
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
foreman_scc_manager-1.3.1	app/lib/actions/scc_manager/sync.rb
foreman_scc_manager-1.3.0	app/lib/actions/scc_manager/sync.rb