kanbanworkflowstimelinescrumrubyroadmapproject-planningproject-managementopenprojectangularissue-trackerifcgantt-chartganttbug-trackerboardsbcf
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
111 lines
3.4 KiB
111 lines
3.4 KiB
#-- copyright
|
|
# OpenProject is an open source project management software.
|
|
# Copyright (C) 2012-2021 the OpenProject GmbH
|
|
#
|
|
# This program is free software; you can redistribute it and/or
|
|
# modify it under the terms of the GNU General Public License version 3.
|
|
#
|
|
# OpenProject is a fork of ChiliProject, which is a fork of Redmine. The copyright follows:
|
|
# Copyright (C) 2006-2013 Jean-Philippe Lang
|
|
# Copyright (C) 2010-2013 the ChiliProject Team
|
|
#
|
|
# This program is free software; you can redistribute it and/or
|
|
# modify it under the terms of the GNU General Public License
|
|
# as published by the Free Software Foundation; either version 2
|
|
# of the License, or (at your option) any later version.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with this program; if not, write to the Free Software
|
|
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
#
|
|
# See COPYRIGHT and LICENSE files for more details.
|
|
#++
|
|
|
|
require 'spec_helper'
|
|
|
|
describe ::BaseServices::BaseCallable, type: :model do
|
|
let(:test_service) do
|
|
Class.new(::BaseServices::BaseCallable) do
|
|
def perform(*)
|
|
state.test = 'foo'
|
|
ServiceResult.new(success: true, result: 'something')
|
|
end
|
|
|
|
def rollback
|
|
state.test = 'rolled back!'
|
|
end
|
|
end
|
|
end
|
|
|
|
let(:test_service2) do
|
|
Class.new(::BaseServices::BaseCallable) do
|
|
def perform(*)
|
|
state.test2 = 'foo'
|
|
ServiceResult.new(success: true, result: 'something')
|
|
end
|
|
|
|
def rollback
|
|
state.test = 'Roll back other value'
|
|
state.test2 = nil
|
|
end
|
|
end
|
|
end
|
|
|
|
let(:instance) { test_service.new }
|
|
subject { instance.call }
|
|
|
|
describe 'state' do
|
|
let(:result_state) { subject.state }
|
|
|
|
it 'is returned from the call', :aggregate_failures do
|
|
expect(result_state).to be_kind_of(::Shared::ServiceState)
|
|
expect(result_state.test).to eq 'foo'
|
|
expect(subject).to be_kind_of ::ServiceResult
|
|
|
|
expect(result_state.service_chain.count).to eq(1)
|
|
expect(result_state.service_chain).to include(test_service)
|
|
|
|
# Roll back
|
|
expect(instance).to receive(:rollback).once.and_call_original
|
|
result_state.rollback!
|
|
# Second call does not go through
|
|
result_state.rollback!
|
|
|
|
expect(result_state.test).to eq 'rolled back!'
|
|
end
|
|
|
|
describe 'with state already passed into the service' do
|
|
let(:instance) { test_service.new.with_state(bar: 'some value') }
|
|
|
|
it 'keeps that value', :aggregate_failures do
|
|
expect(result_state).to be_kind_of(::Shared::ServiceState)
|
|
expect(result_state.test).to eq 'foo'
|
|
expect(result_state.bar).to eq 'some value'
|
|
end
|
|
end
|
|
end
|
|
|
|
describe 'rolling back two services' do
|
|
it 'rolls back in that order' do
|
|
# Execute first service
|
|
result = test_service.new.call
|
|
state = result.state
|
|
|
|
# Execute second service
|
|
test_service2
|
|
.new
|
|
.with_state(state)
|
|
.call
|
|
|
|
expect(state.service_chain.map(&:class)).to eq [test_service, test_service2]
|
|
state.rollback!
|
|
expect(state.test2).to eq nil
|
|
expect(state.test).to eq 'rolled back!'
|
|
end
|
|
end
|
|
end
|
|
|