mirror of
https://github.com/opf/openproject.git
synced 2026-06-14 03:30:14 +00:00
522 lines
16 KiB
Ruby
522 lines
16 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
#-- copyright
|
|
# OpenProject is an open source project management software.
|
|
# Copyright (C) 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"
|
|
|
|
RSpec.describe Repository::Subversion do
|
|
let(:instance) { build(:repository_subversion) }
|
|
let(:adapter) { instance.scm }
|
|
let(:config) { {} }
|
|
let(:enabled_scm) { %w[subversion] }
|
|
|
|
before do
|
|
allow(Setting).to receive(:enabled_scm).and_return(enabled_scm)
|
|
allow(instance).to receive(:scm).and_return(adapter)
|
|
allow(instance.class).to receive(:scm_config).and_return(config)
|
|
end
|
|
|
|
describe "when disabled" do
|
|
let(:enabled_scm) { [] }
|
|
|
|
it "does not allow creating a repository" do
|
|
expect { instance.save! }.to raise_error ActiveRecord::RecordInvalid
|
|
end
|
|
|
|
it "returns an error when trying to save" do
|
|
expect(instance.save).to be false
|
|
expect(instance.errors[:type]).to include I18n.t("activerecord.errors.models.repository.not_available")
|
|
end
|
|
end
|
|
|
|
describe "default Subversion" do
|
|
it "is not manageable" do
|
|
expect(instance.manageable?).to be false
|
|
end
|
|
|
|
it "has one available type" do
|
|
expect(instance.class.available_types).to eq [:existing]
|
|
end
|
|
|
|
context "with disabled types" do
|
|
let(:config) { { disabled_types: %i[existing managed] } }
|
|
|
|
it "does not have any types" do
|
|
expect(instance.class.available_types).to be_empty
|
|
end
|
|
end
|
|
|
|
context "with mixed disabled types" do
|
|
let(:config) { { disabled_types: ["existing", :managed] } }
|
|
|
|
it "does not have any types" do
|
|
expect(instance.class.available_types).to be_empty
|
|
end
|
|
end
|
|
|
|
context "with string disabled types",
|
|
with_config: { "scm" => { "subversion" => { "disabled_types" => %w[managed unknowntype] } } } do
|
|
before do
|
|
allow(instance.class).to receive(:scm_config).and_call_original
|
|
end
|
|
|
|
it "is no longer manageable" do
|
|
expect(instance.class.available_types).to eq([:existing])
|
|
expect(instance.class.disabled_types).to eq(%i[managed unknowntype])
|
|
expect(instance.manageable?).to be false
|
|
end
|
|
end
|
|
end
|
|
|
|
describe "managed Subversion" do
|
|
let(:managed_path) { "/tmp/managed_svn" }
|
|
|
|
it "is not manageable unless configured explicitly" do
|
|
expect(instance.manageable?).to be false
|
|
end
|
|
|
|
context "with managed config" do
|
|
let(:config) { { manages: managed_path } }
|
|
let(:project) { build(:project) }
|
|
|
|
it "is manageable" do
|
|
expect(instance.manageable?).to be true
|
|
expect(instance.class.available_types).to eq(%i[existing managed])
|
|
end
|
|
|
|
context "with disabled managed typed" do
|
|
let(:config) { { disabled_types: [:managed] } }
|
|
|
|
it "is no longer manageable" do
|
|
expect(instance.class.available_types).to eq([:existing])
|
|
expect(instance.manageable?).to be false
|
|
end
|
|
end
|
|
|
|
context "and associated project" do
|
|
before do
|
|
instance.project = project
|
|
end
|
|
|
|
it "outputs valid managed paths" do
|
|
path = File.join(managed_path, project.identifier)
|
|
expect(instance.managed_repository_path).to eq(path)
|
|
expect(instance.managed_repository_url).to eq("file://#{path}")
|
|
end
|
|
end
|
|
|
|
context "and associated project with parent" do
|
|
let(:parent) { build(:project) }
|
|
let(:project) { build(:project, parent:) }
|
|
|
|
before do
|
|
instance.project = project
|
|
end
|
|
|
|
it "outputs the correct hierarchy path" do
|
|
expect(instance.managed_repository_path)
|
|
.to eq(File.join(managed_path, project.identifier))
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
describe "URL validation" do
|
|
let(:checkout_root) { "/tmp/svn-checkouts" }
|
|
let(:managed_git_root) { "/tmp/managed-git" }
|
|
let(:managed_svn_root) { "/tmp/managed-svn" }
|
|
let(:config) { { manages: managed_svn_root } }
|
|
|
|
before do
|
|
allow(OpenProject::Configuration).to receive(:scm_local_checkout_path).and_return(checkout_root)
|
|
allow(Repository::Git).to receive(:managed_root).and_return(managed_git_root)
|
|
end
|
|
|
|
context "file URL points to OpenProject-managed directory" do
|
|
let(:instance) { build(:repository_subversion, url: "file://#{managed_git_root}/sample-project/.git") }
|
|
|
|
it "is invalid" do
|
|
expect(instance).not_to be_valid
|
|
expect(instance.errors.full_messages).to include("URL must not point to an OpenProject-managed repository directory.")
|
|
end
|
|
end
|
|
|
|
context "root_url points to OpenProject-managed directory" do
|
|
let(:instance) { build(:repository_subversion, url: "https://example.org/svn/repo") }
|
|
|
|
before do
|
|
instance.root_url = "file://#{checkout_root}/sample-project"
|
|
end
|
|
|
|
it "is invalid" do
|
|
expect(instance).not_to be_valid
|
|
expect(instance.errors.full_messages).to include("URL must not point to an OpenProject-managed repository directory.")
|
|
end
|
|
end
|
|
|
|
context "with non-managed file URL" do
|
|
let(:instance) { build(:repository_subversion, url: "file:///srv/svn/public") }
|
|
|
|
it "is valid" do
|
|
expect(instance).to be_valid
|
|
end
|
|
end
|
|
end
|
|
|
|
describe "with a remote repository" do
|
|
let(:instance) do
|
|
build(:repository_subversion,
|
|
url: "https://somewhere.example.org/svn/foo")
|
|
end
|
|
|
|
it_behaves_like "is not a countable repository" do
|
|
let(:repository) { instance }
|
|
end
|
|
end
|
|
|
|
describe "with an actual repository" do
|
|
with_subversion_repository do |repo_dir|
|
|
let(:url) { "file://#{repo_dir}" }
|
|
let(:instance) { create(:repository_subversion, url:, root_url: url) }
|
|
|
|
it "is available" do
|
|
expect(instance.scm).to be_available
|
|
end
|
|
|
|
it "fetches changesets from scratch" do
|
|
instance.fetch_changesets
|
|
instance.reload
|
|
|
|
expect(instance.changesets.count).to eq(14)
|
|
expect(instance.file_changes.count).to eq(34)
|
|
expect(instance.changesets.find_by(revision: "1").comments).to eq("Initial import.")
|
|
end
|
|
|
|
it "fetches changesets incremental" do
|
|
instance.fetch_changesets
|
|
|
|
# Remove changesets with revision > 5
|
|
instance.changesets.each { |c| c.destroy if c.revision.to_i > 5 }
|
|
instance.reload
|
|
expect(instance.changesets.count).to eq(5)
|
|
|
|
instance.fetch_changesets
|
|
expect(instance.changesets.count).to eq(14)
|
|
end
|
|
|
|
it "latests changesets" do
|
|
instance.fetch_changesets
|
|
|
|
# with limit
|
|
changesets = instance.latest_changesets("", nil, 2)
|
|
expect(changesets.size).to eq(2)
|
|
expect(instance.latest_changesets("", nil).to_a.slice(0, 2)).to eq(changesets)
|
|
|
|
# with path
|
|
changesets = instance.latest_changesets("subversion_test/folder", nil)
|
|
expect(changesets.map(&:revision)).to eq %w[10 9 7 6 5 2]
|
|
|
|
# with path and revision
|
|
changesets = instance.latest_changesets("subversion_test/folder", 8)
|
|
expect(changesets.map(&:revision)).to eq %w[7 6 5 2]
|
|
end
|
|
|
|
it "directories listing with square brackets in path" do
|
|
instance.fetch_changesets
|
|
instance.reload
|
|
|
|
entries = instance.entries("subversion_test/[folder_with_brackets]")
|
|
expect(entries).not_to be_nil
|
|
expect(entries.size).to eq(1)
|
|
expect(entries.first.name).to eq("README.txt")
|
|
end
|
|
|
|
context "with square brackets in base" do
|
|
let(:url) { "file://#{repo_dir}/subversion_test/[folder_with_brackets]" }
|
|
|
|
it "directories listing with square brackets in base" do
|
|
instance.fetch_changesets
|
|
instance.reload
|
|
|
|
expect(instance.changesets.count).to eq(1)
|
|
expect(instance.file_changes.count).to eq(2)
|
|
|
|
entries = instance.entries("")
|
|
expect(entries).not_to be_nil
|
|
expect(entries.size).to eq(1)
|
|
expect(entries.first.name).to eq("README.txt")
|
|
end
|
|
end
|
|
|
|
it "shows the identifier" do
|
|
instance.fetch_changesets
|
|
instance.reload
|
|
c = instance.changesets.find_by(revision: "1")
|
|
expect(c.revision).to eq(c.identifier)
|
|
end
|
|
|
|
it "finds changeset by empty name" do
|
|
instance.fetch_changesets
|
|
instance.reload
|
|
["", " ", nil].each do |r|
|
|
expect(instance.find_changeset_by_name(r)).to be_nil
|
|
end
|
|
end
|
|
|
|
it "identifiers nine digit" do
|
|
c = Changeset.new(repository: instance, committed_on: Time.now,
|
|
revision: "123456789", comments: "test")
|
|
expect(c.identifier).to eq(c.revision)
|
|
end
|
|
|
|
it "formats identifier" do
|
|
instance.fetch_changesets
|
|
instance.reload
|
|
c = instance.changesets.find_by(revision: "1")
|
|
expect(c.format_identifier).to eq(c.revision)
|
|
end
|
|
|
|
it "formats identifier nine digit" do
|
|
c = Changeset.new(repository: instance, committed_on: Time.now,
|
|
revision: "123456789", comments: "test")
|
|
expect(c.format_identifier).to eq(c.revision)
|
|
end
|
|
|
|
context "with windows-1252 encoding",
|
|
with_settings: { commit_logs_encoding: %w(windows-1252) } do
|
|
it "logs encoding ignore setting" do
|
|
s1 = +"\xC2\x80"
|
|
s2 = +"\xc3\x82\xc2\x80"
|
|
if s1.respond_to?(:force_encoding)
|
|
s1.force_encoding("ISO-8859-1")
|
|
s2.force_encoding("UTF-8")
|
|
expect(s1.encode("UTF-8")).to eq(s2)
|
|
end
|
|
c = Changeset.new(repository: instance,
|
|
comments: s2,
|
|
revision: "123",
|
|
committed_on: Time.now)
|
|
expect(c.save).to be true
|
|
expect(c.comments).to eq(s2)
|
|
end
|
|
end
|
|
|
|
it "loads previous and next changeset" do
|
|
instance.fetch_changesets
|
|
instance.reload
|
|
changeset2 = instance.find_changeset_by_name("2")
|
|
changeset3 = instance.find_changeset_by_name("3")
|
|
expect(changeset3.previous).to eq(changeset2)
|
|
expect(changeset2.next).to eq(changeset3)
|
|
end
|
|
|
|
it "returns nil for no previous or next changeset" do
|
|
instance.fetch_changesets
|
|
instance.reload
|
|
changeset = instance.find_changeset_by_name("1")
|
|
expect(changeset.previous).to be_nil
|
|
|
|
changeset = instance.find_changeset_by_name("14")
|
|
expect(changeset.next).to be_nil
|
|
end
|
|
|
|
context "with an admin browsing activity" do
|
|
let(:user) { create(:admin) }
|
|
let(:project) { create(:project) }
|
|
|
|
def find_events(user, options = {})
|
|
options[:scope] = ["changesets"]
|
|
fetcher = Activities::Fetcher.new(user, options)
|
|
fetcher.events(from: 30.days.ago, to: 1.day.from_now)
|
|
end
|
|
|
|
it "finds events" do
|
|
Changeset.create(repository: instance, committed_on: Time.now,
|
|
revision: "1", comments: "test")
|
|
event = find_events(user).first
|
|
expect(event.event_title).to include("1:")
|
|
expect(event.event_path).to match(/\?rev=1$/)
|
|
end
|
|
|
|
it "finds events with larger numbers" do
|
|
Changeset.create(repository: instance, committed_on: Time.now,
|
|
revision: "123456789", comments: "test")
|
|
event = find_events(user).first
|
|
expect(event.event_title).to include("123456789:")
|
|
expect(event.event_path).to match(/\?rev=123456789$/)
|
|
end
|
|
end
|
|
|
|
describe "#entries" do
|
|
let(:entries) { instance.entries }
|
|
|
|
it "lists 10 entries" do
|
|
expect(entries.size).to eq 10
|
|
end
|
|
|
|
describe "with limit: 5" do
|
|
let(:directories) { entries.select { |e| e.kind == "dir" } }
|
|
let(:files) { entries.select { |e| e.kind == "file" } }
|
|
|
|
let(:limited_entries) { instance.entries limit: 5 }
|
|
|
|
before do
|
|
expect(directories.size).to eq 3
|
|
end
|
|
|
|
it "lists 5 entries only, directories first" do
|
|
expected_entries = (directories + files.take(2)).map(&:path)
|
|
|
|
expect(limited_entries.map(&:path)).to eq expected_entries
|
|
end
|
|
|
|
it "indicates 5 omitted entries" do
|
|
expect(limited_entries.truncated).to eq 5
|
|
end
|
|
end
|
|
end
|
|
|
|
it_behaves_like "is a countable repository" do
|
|
let(:repository) { instance }
|
|
end
|
|
end
|
|
end
|
|
|
|
it_behaves_like "repository can be relocated", :subversion
|
|
|
|
describe "ciphering" do
|
|
context "with cipher key", with_config: { "database_cipher_key" => "secret" } do
|
|
it "password is encrypted" do
|
|
r = create(:repository_subversion, password: "foo")
|
|
expect(r.password)
|
|
.to eql("foo")
|
|
|
|
expect(r.read_attribute(:password))
|
|
.to match(/\Aaes-256-cbc:.+\Z/)
|
|
end
|
|
end
|
|
|
|
context "with blank cipher key", with_config: { "database_cipher_key" => "" } do
|
|
it "password is unencrypted" do
|
|
r = create(:repository_subversion, password: "foo")
|
|
expect(r.password)
|
|
.to eql("foo")
|
|
expect(r.read_attribute(:password))
|
|
.to eql("foo")
|
|
end
|
|
end
|
|
|
|
context "with cipher key nil", with_config: { "database_cipher_key" => nil } do
|
|
it "password is unencrypted" do
|
|
r = create(:repository_subversion, password: "foo")
|
|
|
|
expect(r.password)
|
|
.to eql("foo")
|
|
expect(r.read_attribute(:password))
|
|
.to eql("foo")
|
|
end
|
|
end
|
|
|
|
context "without a cipher key first but activating it later" do
|
|
before do
|
|
WithConfig.new(self).stub_key(:database_cipher_key, nil)
|
|
|
|
create(:repository_subversion, password: "clear")
|
|
|
|
WithConfig.new(self).stub_key(:database_cipher_key, "secret")
|
|
end
|
|
|
|
it "unciphered password is readable" do
|
|
expect(Repository.last.password)
|
|
.to eql("clear")
|
|
end
|
|
end
|
|
|
|
describe "#encrypt_all" do
|
|
context "with unencrypted passwords first but then with an encryption key" do
|
|
before do
|
|
Repository.delete_all
|
|
|
|
WithConfig.new(self).stub_key(:database_cipher_key, nil)
|
|
|
|
create(:repository_subversion, password: "foo")
|
|
create(:repository_subversion, password: "bar")
|
|
|
|
WithConfig.new(self).stub_key(:database_cipher_key, "secret")
|
|
end
|
|
|
|
it "encrypts formerly unencrypted passwords" do
|
|
expect(Repository.encrypt_all(:password))
|
|
.to be_truthy
|
|
|
|
bar = Repository.last
|
|
|
|
expect(bar.password)
|
|
.to eql("bar")
|
|
expect(bar.read_attribute(:password))
|
|
.to match(/\Aaes-256-cbc:.+\Z/)
|
|
|
|
foo = Repository.first
|
|
|
|
expect(foo.password)
|
|
.to eql("foo")
|
|
expect(foo.read_attribute(:password))
|
|
.to match(/\Aaes-256-cbc:.+\Z/)
|
|
end
|
|
end
|
|
end
|
|
|
|
describe "#decrypt_all", with_config: { "database_cipher_key" => "secret" } do
|
|
it "removes cyphering from all passwords" do
|
|
Repository.delete_all
|
|
|
|
foo = create(:repository_subversion, password: "foo")
|
|
bar = create(:repository_subversion, password: "bar")
|
|
|
|
expect(Repository.decrypt_all(:password))
|
|
.to be_truthy
|
|
|
|
bar.reload
|
|
|
|
expect(bar.password)
|
|
.to eql("bar")
|
|
expect(bar.read_attribute(:password))
|
|
.to eql("bar")
|
|
|
|
foo.reload
|
|
|
|
expect(foo.password)
|
|
.to eql("foo")
|
|
expect(foo.read_attribute(:password))
|
|
.to eql("foo")
|
|
end
|
|
end
|
|
end
|
|
end
|