aboutsummaryrefslogtreecommitdiff
path: root/tests/load/driver.cxx
diff options
context:
space:
mode:
authorKaren Arutyunov <karen@codesynthesis.com>2018-09-05 21:23:41 +0300
committerKaren Arutyunov <karen@codesynthesis.com>2018-09-08 17:44:57 +0300
commit70c1cdfd8f34472761fe5ec97f0713990c1b4f5b (patch)
treef2e631c10563bcc0cde07e4359c11b800a188d86 /tests/load/driver.cxx
parent3be834183ae36c321e4b560dce9a63cee846e63d (diff)
Add multi-tenancy support
Diffstat (limited to 'tests/load/driver.cxx')
-rw-r--r--tests/load/driver.cxx104
1 files changed, 64 insertions, 40 deletions
diff --git a/tests/load/driver.cxx b/tests/load/driver.cxx
index b387b9b..a36653c 100644
--- a/tests/load/driver.cxx
+++ b/tests/load/driver.cxx
@@ -35,7 +35,7 @@ check_location (shared_ptr<package>& p)
{
if (p->internal ())
return p->location && *p->location ==
- path (p->id.name.string () + "-" + p->version.string () + ".tar.gz");
+ path (p->name.string () + "-" + p->version.string () + ".tar.gz");
else
return !p->location;
}
@@ -63,12 +63,14 @@ namespace bpkg
static void
test_pkg_repos (const cstrings& loader_args,
const dir_path& loadtab_dir,
- odb::pgsql::database&);
+ odb::pgsql::database&,
+ const string& tenant);
static void
test_git_repos (const cstrings& loader_args,
const dir_path& loadtab_dir,
- odb::pgsql::database&);
+ odb::pgsql::database&,
+ const string& tenant);
int
main (int argc, char* argv[])
@@ -98,8 +100,9 @@ main (int argc, char* argv[])
return 1;
}
- // Parse the database options.
+ // Parse the tenant and database options.
//
+ string tenant;
string user;
string password;
string name ("brep_package");
@@ -109,7 +112,9 @@ main (int argc, char* argv[])
for (++i; i < argc - 1; ++i)
{
string n (argv[i]);
- if (n == "--db-user" || n == "-u")
+ if (n == "--tenant")
+ tenant = argv[++i];
+ else if (n == "--db-user" || n == "-u")
user = argv[++i];
else if (n == "--db-password")
password = argv[++i];
@@ -157,12 +162,12 @@ main (int argc, char* argv[])
{
case repository_type::pkg:
{
- test_pkg_repos (loader_args, loadtab_dir, db);
+ test_pkg_repos (loader_args, loadtab_dir, db, tenant);
break;
}
case repository_type::git:
{
- test_git_repos (loader_args, loadtab_dir, db);
+ test_git_repos (loader_args, loadtab_dir, db, tenant);
break;
}
default:
@@ -192,7 +197,8 @@ dep (const char* n, optional<dependency_constraint> c)
static void
test_git_repos (const cstrings& loader_args,
const dir_path& loadtab_dir,
- odb::pgsql::database& db)
+ odb::pgsql::database& db,
+ const string& tenant)
{
path loadtab (loadtab_dir / "git-loadtab");
@@ -212,13 +218,17 @@ test_git_repos (const cstrings& loader_args,
session s;
transaction t (db.begin ());
- assert (db.query<repository> ().size () == 1);
- assert (db.query<package> ().size () == 1);
+ assert (db.query<repository> (
+ query<repository>::id.tenant == tenant).size () == 1);
+
+ assert (db.query<package> (
+ query<package>::id.tenant == tenant).size () == 1);
// Verify 'foo' repository.
//
shared_ptr<repository> r (
- db.load<repository> ("git:example.com/foo#master"));
+ db.load<repository> (repository_id (tenant,
+ "git:example.com/foo#master")));
assert (r->location.string () == "https://git.example.com/foo.git#master");
assert (r->summary && *r->summary == "foo project repository");
@@ -229,7 +239,7 @@ test_git_repos (const cstrings& loader_args,
//
shared_ptr<package> p (
db.load<package> (
- package_id (package_name ("libfoo"), version ("1.0"))));
+ package_id (tenant, package_name ("libfoo"), version ("1.0"))));
assert (p->fragment &&
*p->fragment == "0f50af28d1cfb0c22f5b88e2bf674ab732e058d9");
@@ -249,7 +259,8 @@ test_git_repos (const cstrings& loader_args,
static void
test_pkg_repos (const cstrings& loader_args,
const dir_path& loadtab_dir,
- odb::pgsql::database& db)
+ odb::pgsql::database& db,
+ const string& tenant)
{
path p (loadtab_dir / dir_path ("1/stable") / packages);
timestamp srt (file_mtime (p));
@@ -273,23 +284,30 @@ test_pkg_repos (const cstrings& loader_args,
session s;
transaction t (db.begin ());
- assert (db.query<repository> ().size () == 7);
- assert (db.query<package> ().size () == 18);
+ assert (db.query<repository> (
+ query<repository>::id.tenant == tenant).size () == 7);
+
+ assert (db.query<package> (
+ query<package>::id.tenant == tenant).size () == 18);
shared_ptr<repository> sr (
- db.load<repository> ("pkg:dev.cppget.org/stable"));
+ db.load<repository> (repository_id (tenant,
+ "pkg:dev.cppget.org/stable")));
shared_ptr<repository> mr (
- db.load<repository> ("pkg:dev.cppget.org/math"));
+ db.load<repository> (repository_id (tenant,
+ "pkg:dev.cppget.org/math")));
shared_ptr<repository> cr (
- db.load<repository> ("pkg:dev.cppget.org/misc"));
+ db.load<repository> (repository_id (tenant, "pkg:dev.cppget.org/misc")));
shared_ptr<repository> tr (
- db.load<repository> ("pkg:dev.cppget.org/testing"));
+ db.load<repository> (repository_id (tenant,
+ "pkg:dev.cppget.org/testing")));
shared_ptr<repository> gr (
- db.load<repository> ("pkg:dev.cppget.org/staging"));
+ db.load<repository> (repository_id (tenant,
+ "pkg:dev.cppget.org/staging")));
// Verify 'stable' repository.
//
@@ -326,7 +344,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> fpvxy (
db.load<package> (
- package_id (package_name ("libfoo"), version ("+0-X.Y"))));
+ package_id (tenant, package_name ("libfoo"), version ("+0-X.Y"))));
assert (fpvxy->project == package_name ("libfoo"));
assert (fpvxy->summary == "The Foo Library");
@@ -359,7 +377,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> fpv1 (
db.load<package> (
- package_id (package_name ("libfoo"), version ("1.0"))));
+ package_id (tenant, package_name ("libfoo"), version ("1.0"))));
assert (fpv1->summary == "The Foo Library");
assert (fpv1->tags.empty ());
@@ -393,7 +411,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> fpv2 (
db.load<package> (
- package_id (package_name ("libfoo"), version ("1.2.2"))));
+ package_id (tenant, package_name ("libfoo"), version ("1.2.2"))));
assert (fpv2->summary == "The Foo library");
assert (fpv2->tags == strings ({"c++", "foo"}));
@@ -435,7 +453,9 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> fpv2a (
db.load<package> (
- package_id (package_name ("libfoo"), version ("1.2.2-alpha.1"))));
+ package_id (tenant,
+ package_name ("libfoo"),
+ version ("1.2.2-alpha.1"))));
assert (fpv2a->summary == "The Foo library");
assert (fpv2a->tags == strings ({"c++", "foo"}));
@@ -495,7 +515,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> fpv3 (
db.load<package> (
- package_id (package_name ("libfoo"), version ("1.2.3+4"))));
+ package_id (tenant, package_name ("libfoo"), version ("1.2.3+4"))));
assert (fpv3->summary == "The Foo library");
assert (fpv3->tags == strings ({"c++", "foo"}));
@@ -531,7 +551,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> fpv4 (
db.load<package> (
- package_id (package_name ("libfoo"), version ("1.2.4"))));
+ package_id (tenant, package_name ("libfoo"), version ("1.2.4"))));
assert (fpv4->summary == "The Foo Library");
assert (fpv4->tags == strings ({"c++", "foo"}));
@@ -597,7 +617,9 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> xpv (
db.load<package> (
- package_id (package_name ("libstudxml"), version ("1.0.0+1"))));
+ package_id (tenant,
+ package_name ("libstudxml"),
+ version ("1.0.0+1"))));
assert (xpv->summary == "Modern C++ XML API");
assert (xpv->tags == strings ({"c++", "xml", "parser", "serializer",
@@ -646,7 +668,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> fpv5 (
db.load<package> (
- package_id (package_name ("libfoo"), version ("1.2.4+1"))));
+ package_id (tenant, package_name ("libfoo"), version ("1.2.4+1"))));
assert (fpv5->summary == "The Foo Math Library");
assert (fpv5->tags == strings ({"c++", "foo", "math"}));
@@ -761,7 +783,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> epv (
db.load<package> (
- package_id (package_name ("libexp"), version ("+2-1.2+1"))));
+ package_id (tenant, package_name ("libexp"), version ("+2-1.2+1"))));
assert (epv->project == "mathLab");
assert (epv->summary == "The exponent");
@@ -812,7 +834,9 @@ test_pkg_repos (const cstrings& loader_args,
// libpq-0
//
shared_ptr<package> qpv (
- db.load<package> (package_id (package_name ("libpq"), version ("0"))));
+ db.load<package> (package_id (tenant,
+ package_name ("libpq"),
+ version ("0"))));
assert (qpv->summary == "PostgreSQL C API client library");
@@ -849,7 +873,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> bpv (
db.load<package> (
- package_id (package_name ("libbar"), version ("2.4.0+3"))));
+ package_id (tenant, package_name ("libbar"), version ("2.4.0+3"))));
assert (check_external (*bpv));
assert (bpv->other_repositories.size () == 1);
@@ -862,7 +886,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> fpv0 (
db.load<package> (
- package_id (package_name ("libfoo"), version ("0.1"))));
+ package_id (tenant, package_name ("libfoo"), version ("0.1"))));
assert (check_external (*fpv0));
assert (fpv0->other_repositories.size () == 1);
@@ -873,7 +897,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> fpv6 (
db.load<package> (
- package_id (package_name ("libfoo"), version ("1.2.4+2"))));
+ package_id (tenant, package_name ("libfoo"), version ("1.2.4+2"))));
assert (check_external (*fpv6));
assert (fpv6->other_repositories.size () == 1);
@@ -913,7 +937,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> mpv0 (
db.load<package> (
- package_id (package_name ("libmisc"), version ("2.4.0"))));
+ package_id (tenant, package_name ("libmisc"), version ("2.4.0"))));
assert (check_external (*mpv0));
assert (mpv0->other_repositories.size () == 1);
@@ -924,7 +948,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> mpv1 (
db.load<package> (
- package_id (package_name ("libmisc"), version ("2.3.0+1"))));
+ package_id (tenant, package_name ("libmisc"), version ("2.3.0+1"))));
assert (check_external (*mpv1));
assert (mpv1->other_repositories.size () == 1);
@@ -963,7 +987,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> tpv (
db.load<package> (
- package_id (package_name ("libexpat"), version ("5.1"))));
+ package_id (tenant, package_name ("libexpat"), version ("5.1"))));
assert (check_external (*tpv));
assert (tpv->other_repositories.size () == 1);
@@ -976,7 +1000,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> gpv (
db.load<package> (
- package_id (package_name ("libgenx"), version ("1.0"))));
+ package_id (tenant, package_name ("libgenx"), version ("1.0"))));
assert (check_external (*gpv));
assert (gpv->other_repositories.size () == 1);
@@ -989,7 +1013,7 @@ test_pkg_repos (const cstrings& loader_args,
//
shared_ptr<package> mpv2 (
db.load<package> (
- package_id (package_name ("libmisc"), version ("1.0"))));
+ package_id (tenant, package_name ("libmisc"), version ("1.0"))));
assert (check_external (*mpv2));
assert (mpv2->other_repositories.size () == 1);
@@ -1019,7 +1043,7 @@ test_pkg_repos (const cstrings& loader_args,
shared_ptr<package> bpv (
db.load<package> (
- package_id (package_name ("libbar"), version ("2.4.0+3"))));
+ package_id (tenant, package_name ("libbar"), version ("2.4.0+3"))));
assert (bpv->summary == "test");
@@ -1040,7 +1064,7 @@ test_pkg_repos (const cstrings& loader_args,
shared_ptr<package> bpv (
db.find<package> (
- package_id (package_name ("libbar"), version ("2.4.0+3"))));
+ package_id (tenant, package_name ("libbar"), version ("2.4.0+3"))));
// External package summary is not saved.
//