-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #141 from SpineEventEngine/multitenancy-support
Multitenancy support
- Loading branch information
Showing
36 changed files
with
1,114 additions
and
610 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,144 @@ | ||
| /* | ||
| * Copyright 2020, TeamDev. All rights reserved. | ||
| * | ||
| * Redistribution and use in source and/or binary forms, with or without | ||
| * modification, must retain the above copyright notice and the following | ||
| * disclaimer. | ||
| * | ||
| * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | ||
| * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | ||
| * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | ||
| * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | ||
| * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | ||
| * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | ||
| * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | ||
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | ||
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | ||
| * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | ||
| */ | ||
|
|
||
| import {TenantId} from "../proto/spine/core/tenant_id_pb"; | ||
| import {EmailAddress} from "../proto/spine/net/email_address_pb"; | ||
| import {InternetDomain} from "../proto/spine/net/internet_domain_pb"; | ||
| import {isProtobufMessage, Type} from "./typed-message"; | ||
|
|
||
| /** | ||
| * A factory of `TenantId` instances. | ||
| * | ||
| * Exposes methods that are "shortcuts" for the convenient creation of `TenantId` message | ||
| * instances. | ||
| */ | ||
| export class TenantIds { | ||
|
|
||
| /** | ||
| * Constructs a `TenantId` which represents an internet domain. | ||
| * | ||
| * @param {!string} domainName the domain name as a plain string | ||
| * @return {TenantId} a new `TenantId` instance | ||
| */ | ||
| static internetDomain(domainName) { | ||
| if (!domainName) { | ||
| throw new Error('Expected a non-empty internet domain name.'); | ||
| } | ||
| const domain = new InternetDomain(); | ||
| domain.setValue(domainName); | ||
| const result = new TenantId(); | ||
| result.setDomain(domain); | ||
| return result; | ||
| } | ||
|
|
||
| /** | ||
| * Constructs a `TenantId` which represents an email address. | ||
| * | ||
| * @param {!string} address the email address as a plain string | ||
| * @return {TenantId} a new `TenantId` instance | ||
| */ | ||
| static emailAddress(address) { | ||
| if (!address) { | ||
| throw new Error('Expected a non-empty email address value.'); | ||
| } | ||
| const emailAddress = new EmailAddress(); | ||
| emailAddress.setValue(address); | ||
| const result = new TenantId(); | ||
| result.setEmail(emailAddress); | ||
| return result; | ||
| } | ||
|
|
||
| /** | ||
| * Constructs a `TenantId` which is a plain string value. | ||
| * | ||
| * @param {!string} tenantIdValue the tenant ID | ||
| * @return {TenantId} a new `TenantId` instance | ||
| */ | ||
| static plainString(tenantIdValue) { | ||
| if (!tenantIdValue) { | ||
| throw new Error('Expected a valid tenant ID value.'); | ||
| } | ||
| const result = new TenantId(); | ||
| result.setValue(tenantIdValue); | ||
| return result; | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * The current tenant provider. | ||
| * | ||
| * This object is passed to the `ActorRequestFactory` and is used during creation of all | ||
| * client-side requests. | ||
| * | ||
| * The current tenant ID can be switched dynamically with the help of the `update` method. | ||
| * | ||
| * If it is necessary to update the current ID to a "no tenant" value (to work in a single-tenant | ||
| * environment), pass the default tenant ID to the `update` method as follows: | ||
| * `tenantProvider.update(new TenantId())`. | ||
| */ | ||
| export class TenantProvider { | ||
|
|
||
| /** | ||
| * Creates a new `TenantProvider` configured with the passed tenant ID. | ||
| * | ||
| * The argument may be omitted but until the `_tenantId` is assigned some non-default value, the | ||
| * application is considered single-tenant. | ||
| * | ||
| * @param {?TenantId} tenantId the ID of the currently active tenant | ||
| */ | ||
| constructor(tenantId) { | ||
| if (tenantId) { | ||
| TenantProvider._checkIsValidTenantId(tenantId); | ||
| this._tenantId = tenantId; | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * @param {!TenantId} tenantId the ID of the currently active tenant | ||
| */ | ||
| update(tenantId) { | ||
| TenantProvider._checkIsValidTenantId(tenantId); | ||
| this._tenantId = tenantId; | ||
| } | ||
|
|
||
| /** | ||
| * Returns the currently active tenant ID. | ||
| * | ||
| * @return {TenantId} | ||
| */ | ||
| tenantId() { | ||
| return this._tenantId; | ||
| } | ||
|
|
||
| /** | ||
| * Checks that the passed object represents a `TenantId` message. | ||
| * | ||
| * @param {!object} tenantId the object to check | ||
| * @private | ||
| */ | ||
| static _checkIsValidTenantId(tenantId) { | ||
| if (!tenantId | ||
| || !isProtobufMessage(tenantId) | ||
| || Type.forMessage(tenantId).url().value() !== 'type.spine.io/spine.core.TenantId') { | ||
| throw new Error(`Expected a valid instance of the 'TenantId' message.` | ||
| + `The '${tenantId}' was passed instead.`); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,82 @@ | ||
| /* | ||
| * Copyright 2020, TeamDev. All rights reserved. | ||
| * | ||
| * Redistribution and use in source and/or binary forms, with or without | ||
| * modification, must retain the above copyright notice and the following | ||
| * disclaimer. | ||
| * | ||
| * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | ||
| * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | ||
| * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | ||
| * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | ||
| * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | ||
| * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | ||
| * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | ||
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | ||
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | ||
| * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | ||
| */ | ||
|
|
||
| import assert from 'assert'; | ||
| import {TenantIds} from "../../main/client/tenant"; | ||
|
|
||
| describe('TenantIds', function () { | ||
|
|
||
| it('create a tenant ID which represents an internet domain', done => { | ||
| const internetDomain = "en.wikipedia.org"; | ||
| const tenantId = TenantIds.internetDomain(internetDomain); | ||
| assert.equal(tenantId.getDomain(), internetDomain); | ||
| done(); | ||
| }); | ||
|
|
||
| it('throws an `Error` when the passed internet domain name is not defined', () => { | ||
| assert.throws( | ||
| () => TenantIds.internetDomain(undefined) | ||
| ); | ||
| }); | ||
|
|
||
| it('throws an `Error` when the passed internet domain name is empty', () => { | ||
| assert.throws( | ||
| () => TenantIds.internetDomain('') | ||
| ); | ||
| }); | ||
|
|
||
| it('create a tenant ID which represents an email address', done => { | ||
| const emailAddress = "user@test.com"; | ||
| const tenantId = TenantIds.emailAddress(emailAddress); | ||
| assert.equal(tenantId.getEmail(), emailAddress); | ||
| done(); | ||
| }); | ||
|
|
||
| it('throws an `Error` when the passed email address value is not defined', () => { | ||
| assert.throws( | ||
| () => TenantIds.emailAddress(undefined) | ||
| ); | ||
| }); | ||
|
|
||
| it('throws an `Error` when the passed email address value is empty', () => { | ||
| assert.throws( | ||
| () => TenantIds.emailAddress('') | ||
| ); | ||
| }); | ||
|
|
||
| it('create a plain string tenant ID', done => { | ||
| const tenantIdValue = "some-tenant-ID"; | ||
| const tenantId = TenantIds.plainString(tenantIdValue); | ||
| assert.equal(tenantId.getValue(), tenantIdValue); | ||
| done(); | ||
| }); | ||
|
|
||
| it('throws an `Error` when the passed string is not defined', () => { | ||
| assert.throws( | ||
| () => TenantIds.plainString(undefined) | ||
| ); | ||
| }); | ||
|
|
||
| it('throws an `Error` when the passed string is empty', () => { | ||
| assert.throws( | ||
| () => TenantIds.plainString('') | ||
| ); | ||
| }); | ||
| }); |
Oops, something went wrong.