mirror of
https://github.com/n8n-io/n8n.git
synced 2025-01-11 12:57:29 -08:00
perf(core): Make user controller tests faster (no-changelog) (#7819)
Before: `17.949 s` After: `3.886 s` Followup to: https://github.com/n8n-io/n8n/pull/7797#discussion_r1404148034
This commit is contained in:
parent
83086af247
commit
75a5807c72
|
@ -66,3 +66,6 @@ export function affixRoleToSaveCredential(role: Role) {
|
||||||
export async function getAllCredentials() {
|
export async function getAllCredentials() {
|
||||||
return Container.get(CredentialsRepository).find();
|
return Container.get(CredentialsRepository).find();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export const getCredentialById = async (id: string) =>
|
||||||
|
Container.get(CredentialsRepository).findOneBy({ id });
|
||||||
|
|
|
@ -117,3 +117,6 @@ export async function createWorkflowWithTrigger(
|
||||||
export async function getAllWorkflows() {
|
export async function getAllWorkflows() {
|
||||||
return Container.get(WorkflowRepository).find();
|
return Container.get(WorkflowRepository).find();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export const getWorkflowById = async (id: string) =>
|
||||||
|
Container.get(WorkflowRepository).findOneBy({ id });
|
||||||
|
|
15
packages/cli/test/integration/shared/utils/users.ts
Normal file
15
packages/cli/test/integration/shared/utils/users.ts
Normal file
|
@ -0,0 +1,15 @@
|
||||||
|
import type { PublicUser } from '@/Interfaces';
|
||||||
|
|
||||||
|
export const validateUser = (user: PublicUser) => {
|
||||||
|
expect(typeof user.id).toBe('string');
|
||||||
|
expect(user.email).toBeDefined();
|
||||||
|
expect(user.firstName).toBeDefined();
|
||||||
|
expect(user.lastName).toBeDefined();
|
||||||
|
expect(typeof user.isOwner).toBe('boolean');
|
||||||
|
expect(user.isPending).toBe(false);
|
||||||
|
expect(user.signInType).toBe('email');
|
||||||
|
expect(user.settings).toBe(null);
|
||||||
|
expect(user.personalizationAnswers).toBeNull();
|
||||||
|
expect(user.password).toBeUndefined();
|
||||||
|
expect(user.globalRole).toBeDefined();
|
||||||
|
};
|
|
@ -1,124 +1,64 @@
|
||||||
import type { SuperAgentTest } from 'supertest';
|
|
||||||
|
|
||||||
import { CredentialsEntity } from '@db/entities/CredentialsEntity';
|
|
||||||
import type { Role } from '@db/entities/Role';
|
|
||||||
import type { User } from '@db/entities/User';
|
|
||||||
import { WorkflowEntity } from '@db/entities/WorkflowEntity';
|
|
||||||
|
|
||||||
import Container from 'typedi';
|
import Container from 'typedi';
|
||||||
import { UserRepository } from '@db/repositories/user.repository';
|
import { UserRepository } from '@db/repositories/user.repository';
|
||||||
import { WorkflowRepository } from '@db/repositories/workflow.repository';
|
|
||||||
import { CredentialsRepository } from '@db/repositories/credentials.repository';
|
import { UsersController } from '@/controllers/users.controller';
|
||||||
import { SharedCredentialsRepository } from '@db/repositories/sharedCredentials.repository';
|
import { SharedCredentialsRepository } from '@db/repositories/sharedCredentials.repository';
|
||||||
import { SharedWorkflowRepository } from '@db/repositories/sharedWorkflow.repository';
|
import { SharedWorkflowRepository } from '@db/repositories/sharedWorkflow.repository';
|
||||||
|
|
||||||
import { mockInstance } from '../shared/mocking';
|
import { getCredentialById, saveCredential } from './shared/db/credentials';
|
||||||
|
import { getCredentialOwnerRole, getWorkflowOwnerRole } from './shared/db/roles';
|
||||||
|
import { createAdmin, createMember, createOwner, getUserById } from './shared/db/users';
|
||||||
|
import { createWorkflow, getWorkflowById } from './shared/db/workflows';
|
||||||
import { SUCCESS_RESPONSE_BODY } from './shared/constants';
|
import { SUCCESS_RESPONSE_BODY } from './shared/constants';
|
||||||
import { randomCredentialPayload, randomName } from './shared/random';
|
import { validateUser } from './shared/utils/users';
|
||||||
import * as testDb from './shared/testDb';
|
import { randomName } from './shared/random';
|
||||||
import * as utils from './shared/utils/';
|
import * as utils from './shared/utils/';
|
||||||
import { saveCredential } from './shared/db/credentials';
|
import * as testDb from './shared/testDb';
|
||||||
import { getAllRoles } from './shared/db/roles';
|
|
||||||
import { createAdmin, createMember, createOwner, createUser, getUserById } from './shared/db/users';
|
|
||||||
import { createWorkflow } from './shared/db/workflows';
|
|
||||||
import type { PublicUser } from '@/Interfaces';
|
|
||||||
import { InternalHooks } from '@/InternalHooks';
|
|
||||||
import { UsersController } from '@/controllers/users.controller';
|
|
||||||
import { ExternalHooks } from '@/ExternalHooks';
|
|
||||||
import { Logger } from '@/Logger';
|
|
||||||
import { ActiveWorkflowRunner } from '@/ActiveWorkflowRunner';
|
|
||||||
|
|
||||||
const { any } = expect;
|
import type { SuperAgentTest } from 'supertest';
|
||||||
|
import type { Role } from '@db/entities/Role';
|
||||||
let credentialOwnerRole: Role;
|
import type { User } from '@db/entities/User';
|
||||||
let globalMemberRole: Role;
|
|
||||||
let workflowOwnerRole: Role;
|
|
||||||
|
|
||||||
let owner: User;
|
|
||||||
let admin: User;
|
|
||||||
let otherAdmin: User;
|
|
||||||
let member: User;
|
|
||||||
let otherMember: User;
|
|
||||||
|
|
||||||
let authOwnerAgent: SuperAgentTest;
|
|
||||||
let authAdminAgent: SuperAgentTest;
|
|
||||||
let authMemberAgent: SuperAgentTest;
|
|
||||||
let authlessAgent: SuperAgentTest;
|
|
||||||
|
|
||||||
let usersCount: number;
|
|
||||||
|
|
||||||
mockInstance(InternalHooks);
|
|
||||||
mockInstance(ExternalHooks);
|
|
||||||
mockInstance(Logger);
|
|
||||||
mockInstance(ActiveWorkflowRunner);
|
|
||||||
|
|
||||||
const testServer = utils.setupTestServer({ endpointGroups: ['users'] });
|
const testServer = utils.setupTestServer({ endpointGroups: ['users'] });
|
||||||
|
|
||||||
beforeAll(async () => {
|
describe('GET /users', () => {
|
||||||
const [_, fetchedGlobalMemberRole, fetchedWorkflowOwnerRole, fetchedCredentialOwnerRole] =
|
let owner: User;
|
||||||
await getAllRoles();
|
let member: User;
|
||||||
|
let ownerAgent: SuperAgentTest;
|
||||||
|
|
||||||
credentialOwnerRole = fetchedCredentialOwnerRole;
|
beforeAll(async () => {
|
||||||
globalMemberRole = fetchedGlobalMemberRole;
|
await testDb.truncate(['User']);
|
||||||
workflowOwnerRole = fetchedWorkflowOwnerRole;
|
|
||||||
|
|
||||||
usersCount = [owner, admin, otherAdmin, member, otherMember].length;
|
|
||||||
});
|
|
||||||
|
|
||||||
beforeEach(async () => {
|
|
||||||
jest.resetAllMocks();
|
|
||||||
await testDb.truncate(['User', 'SharedCredentials', 'SharedWorkflow', 'Workflow', 'Credentials']);
|
|
||||||
owner = await createOwner();
|
owner = await createOwner();
|
||||||
member = await createMember();
|
member = await createMember();
|
||||||
otherMember = await createMember();
|
await createMember();
|
||||||
admin = await createAdmin();
|
|
||||||
otherAdmin = await createAdmin();
|
|
||||||
authOwnerAgent = testServer.authAgentFor(owner);
|
|
||||||
authAdminAgent = testServer.authAgentFor(admin);
|
|
||||||
authMemberAgent = testServer.authAgentFor(member);
|
|
||||||
authlessAgent = testServer.authlessAgent;
|
|
||||||
});
|
|
||||||
|
|
||||||
const validatePublicUser = (user: PublicUser) => {
|
ownerAgent = testServer.authAgentFor(owner);
|
||||||
expect(typeof user.id).toBe('string');
|
|
||||||
expect(user.email).toBeDefined();
|
|
||||||
expect(user.firstName).toBeDefined();
|
|
||||||
expect(user.lastName).toBeDefined();
|
|
||||||
expect(typeof user.isOwner).toBe('boolean');
|
|
||||||
expect(user.isPending).toBe(false);
|
|
||||||
expect(user.signInType).toBe('email');
|
|
||||||
expect(user.settings).toBe(null);
|
|
||||||
expect(user.personalizationAnswers).toBeNull();
|
|
||||||
expect(user.password).toBeUndefined();
|
|
||||||
expect(user.globalRole).toBeDefined();
|
|
||||||
};
|
|
||||||
|
|
||||||
describe('GET /users', () => {
|
|
||||||
test('should return all users', async () => {
|
|
||||||
const response = await authOwnerAgent.get('/users').expect(200);
|
|
||||||
|
|
||||||
expect(response.body.data).toHaveLength(usersCount);
|
|
||||||
|
|
||||||
response.body.data.forEach(validatePublicUser);
|
|
||||||
});
|
});
|
||||||
|
|
||||||
|
test('should return all users', async () => {
|
||||||
|
const response = await ownerAgent.get('/users').expect(200);
|
||||||
|
|
||||||
|
expect(response.body.data).toHaveLength(3);
|
||||||
|
|
||||||
|
response.body.data.forEach(validateUser);
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('list query options', () => {
|
||||||
describe('filter', () => {
|
describe('filter', () => {
|
||||||
test('should filter users by field: email', async () => {
|
test('should filter users by field: email', async () => {
|
||||||
const secondMember = await createMember();
|
const response = await ownerAgent
|
||||||
|
|
||||||
const response = await authOwnerAgent
|
|
||||||
.get('/users')
|
.get('/users')
|
||||||
.query(`filter={ "email": "${secondMember.email}" }`)
|
.query(`filter={ "email": "${member.email}" }`)
|
||||||
.expect(200);
|
.expect(200);
|
||||||
|
|
||||||
expect(response.body.data).toHaveLength(1);
|
expect(response.body.data).toHaveLength(1);
|
||||||
|
|
||||||
const [user] = response.body.data;
|
const [user] = response.body.data;
|
||||||
|
|
||||||
expect(user.email).toBe(secondMember.email);
|
expect(user.email).toBe(member.email);
|
||||||
|
|
||||||
const _response = await testServer
|
const _response = await ownerAgent
|
||||||
.authAgentFor(owner)
|
|
||||||
.get('/users')
|
.get('/users')
|
||||||
.query('filter={ "email": "non@existing.com" }')
|
.query('filter={ "email": "non@existing.com" }')
|
||||||
.expect(200);
|
.expect(200);
|
||||||
|
@ -127,21 +67,18 @@ describe('GET /users', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should filter users by field: firstName', async () => {
|
test('should filter users by field: firstName', async () => {
|
||||||
const secondMember = await createMember();
|
const response = await ownerAgent
|
||||||
|
|
||||||
const response = await authOwnerAgent
|
|
||||||
.get('/users')
|
.get('/users')
|
||||||
.query(`filter={ "firstName": "${secondMember.firstName}" }`)
|
.query(`filter={ "firstName": "${member.firstName}" }`)
|
||||||
.expect(200);
|
.expect(200);
|
||||||
|
|
||||||
expect(response.body.data).toHaveLength(1);
|
expect(response.body.data).toHaveLength(1);
|
||||||
|
|
||||||
const [user] = response.body.data;
|
const [user] = response.body.data;
|
||||||
|
|
||||||
expect(user.email).toBe(secondMember.email);
|
expect(user.email).toBe(member.email);
|
||||||
|
|
||||||
const _response = await testServer
|
const _response = await ownerAgent
|
||||||
.authAgentFor(owner)
|
|
||||||
.get('/users')
|
.get('/users')
|
||||||
.query('filter={ "firstName": "Non-Existing" }')
|
.query('filter={ "firstName": "Non-Existing" }')
|
||||||
.expect(200);
|
.expect(200);
|
||||||
|
@ -150,20 +87,18 @@ describe('GET /users', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should filter users by field: lastName', async () => {
|
test('should filter users by field: lastName', async () => {
|
||||||
const secondMember = await createMember();
|
const response = await ownerAgent
|
||||||
|
|
||||||
const response = await authOwnerAgent
|
|
||||||
.get('/users')
|
.get('/users')
|
||||||
.query(`filter={ "lastName": "${secondMember.lastName}" }`)
|
.query(`filter={ "lastName": "${member.lastName}" }`)
|
||||||
.expect(200);
|
.expect(200);
|
||||||
|
|
||||||
expect(response.body.data).toHaveLength(1);
|
expect(response.body.data).toHaveLength(1);
|
||||||
|
|
||||||
const [user] = response.body.data;
|
const [user] = response.body.data;
|
||||||
|
|
||||||
expect(user.email).toBe(secondMember.email);
|
expect(user.email).toBe(member.email);
|
||||||
|
|
||||||
const _response = await authOwnerAgent
|
const _response = await ownerAgent
|
||||||
.get('/users')
|
.get('/users')
|
||||||
.query('filter={ "lastName": "Non-Existing" }')
|
.query('filter={ "lastName": "Non-Existing" }')
|
||||||
.expect(200);
|
.expect(200);
|
||||||
|
@ -172,7 +107,7 @@ describe('GET /users', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should filter users by computed field: isOwner', async () => {
|
test('should filter users by computed field: isOwner', async () => {
|
||||||
const response = await authOwnerAgent
|
const response = await ownerAgent
|
||||||
.get('/users')
|
.get('/users')
|
||||||
.query('filter={ "isOwner": true }')
|
.query('filter={ "isOwner": true }')
|
||||||
.expect(200);
|
.expect(200);
|
||||||
|
@ -183,13 +118,12 @@ describe('GET /users', () => {
|
||||||
|
|
||||||
expect(user.isOwner).toBe(true);
|
expect(user.isOwner).toBe(true);
|
||||||
|
|
||||||
const _response = await testServer
|
const _response = await ownerAgent
|
||||||
.authAgentFor(owner)
|
|
||||||
.get('/users')
|
.get('/users')
|
||||||
.query('filter={ "isOwner": false }')
|
.query('filter={ "isOwner": false }')
|
||||||
.expect(200);
|
.expect(200);
|
||||||
|
|
||||||
expect(_response.body.data).toHaveLength(usersCount - 1);
|
expect(_response.body.data).toHaveLength(2);
|
||||||
|
|
||||||
const [_user] = _response.body.data;
|
const [_user] = _response.body.data;
|
||||||
|
|
||||||
|
@ -199,205 +133,227 @@ describe('GET /users', () => {
|
||||||
|
|
||||||
describe('select', () => {
|
describe('select', () => {
|
||||||
test('should select user field: id', async () => {
|
test('should select user field: id', async () => {
|
||||||
const response = await authOwnerAgent.get('/users').query('select=["id"]').expect(200);
|
const response = await ownerAgent.get('/users').query('select=["id"]').expect(200);
|
||||||
|
|
||||||
expect(response.body).toEqual({
|
expect(response.body).toEqual({
|
||||||
data: new Array(usersCount).fill({ id: any(String) }),
|
data: [
|
||||||
|
{ id: expect.any(String) },
|
||||||
|
{ id: expect.any(String) },
|
||||||
|
{ id: expect.any(String) },
|
||||||
|
],
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should select user field: email', async () => {
|
test('should select user field: email', async () => {
|
||||||
const response = await authOwnerAgent.get('/users').query('select=["email"]').expect(200);
|
const response = await ownerAgent.get('/users').query('select=["email"]').expect(200);
|
||||||
|
|
||||||
expect(response.body).toEqual({
|
expect(response.body).toEqual({
|
||||||
data: new Array(usersCount).fill({ email: any(String) }),
|
data: [
|
||||||
|
{ email: expect.any(String) },
|
||||||
|
{ email: expect.any(String) },
|
||||||
|
{ email: expect.any(String) },
|
||||||
|
],
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should select user field: firstName', async () => {
|
test('should select user field: firstName', async () => {
|
||||||
const response = await authOwnerAgent.get('/users').query('select=["firstName"]').expect(200);
|
const response = await ownerAgent.get('/users').query('select=["firstName"]').expect(200);
|
||||||
|
|
||||||
expect(response.body).toEqual({
|
expect(response.body).toEqual({
|
||||||
data: new Array(usersCount).fill({ firstName: any(String) }),
|
data: [
|
||||||
|
{ firstName: expect.any(String) },
|
||||||
|
{ firstName: expect.any(String) },
|
||||||
|
{ firstName: expect.any(String) },
|
||||||
|
],
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should select user field: lastName', async () => {
|
test('should select user field: lastName', async () => {
|
||||||
const response = await authOwnerAgent.get('/users').query('select=["lastName"]').expect(200);
|
const response = await ownerAgent.get('/users').query('select=["lastName"]').expect(200);
|
||||||
|
|
||||||
expect(response.body).toEqual({
|
expect(response.body).toEqual({
|
||||||
data: new Array(usersCount).fill({ lastName: any(String) }),
|
data: [
|
||||||
|
{ lastName: expect.any(String) },
|
||||||
|
{ lastName: expect.any(String) },
|
||||||
|
{ lastName: expect.any(String) },
|
||||||
|
],
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('take', () => {
|
describe('take', () => {
|
||||||
test('should return n users or less, without skip', async () => {
|
test('should return n users or less, without skip', async () => {
|
||||||
const response = await authOwnerAgent.get('/users').query('take=2').expect(200);
|
const response = await ownerAgent.get('/users').query('take=2').expect(200);
|
||||||
|
|
||||||
expect(response.body.data).toHaveLength(2);
|
expect(response.body.data).toHaveLength(2);
|
||||||
|
|
||||||
response.body.data.forEach(validatePublicUser);
|
response.body.data.forEach(validateUser);
|
||||||
|
|
||||||
const _response = await authOwnerAgent.get('/users').query('take=1').expect(200);
|
const _response = await ownerAgent.get('/users').query('take=1').expect(200);
|
||||||
|
|
||||||
expect(_response.body.data).toHaveLength(1);
|
expect(_response.body.data).toHaveLength(1);
|
||||||
|
|
||||||
_response.body.data.forEach(validatePublicUser);
|
_response.body.data.forEach(validateUser);
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should return n users or less, with skip', async () => {
|
test('should return n users or less, with skip', async () => {
|
||||||
const response = await authOwnerAgent.get('/users').query('take=1&skip=1').expect(200);
|
const response = await ownerAgent.get('/users').query('take=1&skip=1').expect(200);
|
||||||
|
|
||||||
expect(response.body.data).toHaveLength(1);
|
expect(response.body.data).toHaveLength(1);
|
||||||
|
|
||||||
response.body.data.forEach(validatePublicUser);
|
response.body.data.forEach(validateUser);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('combinations', () => {
|
describe('auxiliary fields', () => {
|
||||||
|
/**
|
||||||
|
* Some list query options require auxiliary fields:
|
||||||
|
*
|
||||||
|
* - `isOwner` requires `globalRole`
|
||||||
|
* - `select` with `take` requires `id` (for pagination)
|
||||||
|
*/
|
||||||
test('should support options that require auxiliary fields', async () => {
|
test('should support options that require auxiliary fields', async () => {
|
||||||
// isOwner requires globalRole
|
const response = await ownerAgent
|
||||||
// id-less select with take requires id
|
|
||||||
|
|
||||||
const response = await authOwnerAgent
|
|
||||||
.get('/users')
|
.get('/users')
|
||||||
.query('filter={ "isOwner": true }&select=["firstName"]&take=10')
|
.query('filter={ "isOwner": true }&select=["firstName"]&take=1')
|
||||||
.expect(200);
|
.expect(200);
|
||||||
|
|
||||||
expect(response.body).toEqual({ data: [{ firstName: any(String) }] });
|
expect(response.body).toEqual({ data: [{ firstName: expect.any(String) }] });
|
||||||
|
});
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('DELETE /users/:id', () => {
|
describe('DELETE /users/:id', () => {
|
||||||
test('should delete the user', async () => {
|
let owner: User;
|
||||||
const newWorkflow = new WorkflowEntity();
|
let member: User;
|
||||||
|
let ownerAgent: SuperAgentTest;
|
||||||
|
let workflowOwnerRole: Role;
|
||||||
|
let credentialOwnerRole: Role;
|
||||||
|
|
||||||
Object.assign(newWorkflow, {
|
beforeAll(async () => {
|
||||||
name: randomName(),
|
await testDb.truncate(['User']);
|
||||||
active: false,
|
|
||||||
connections: {},
|
owner = await createOwner();
|
||||||
nodes: [],
|
member = await createMember();
|
||||||
|
ownerAgent = testServer.authAgentFor(owner);
|
||||||
|
|
||||||
|
workflowOwnerRole = await getWorkflowOwnerRole();
|
||||||
|
credentialOwnerRole = await getCredentialOwnerRole();
|
||||||
});
|
});
|
||||||
|
|
||||||
const savedWorkflow = await Container.get(WorkflowRepository).save(newWorkflow);
|
test('should delete user and their resources', async () => {
|
||||||
|
const savedWorkflow = await createWorkflow({ name: randomName() }, member);
|
||||||
|
|
||||||
await Container.get(SharedWorkflowRepository).save({
|
const savedCredential = await saveCredential(
|
||||||
role: workflowOwnerRole,
|
{ name: randomName(), type: '', data: {}, nodesAccess: [] },
|
||||||
user: member,
|
{ user: member, role: credentialOwnerRole },
|
||||||
workflow: savedWorkflow,
|
);
|
||||||
});
|
|
||||||
|
|
||||||
const newCredential = new CredentialsEntity();
|
const response = await ownerAgent.delete(`/users/${member.id}`);
|
||||||
|
|
||||||
Object.assign(newCredential, {
|
|
||||||
name: randomName(),
|
|
||||||
data: '',
|
|
||||||
type: '',
|
|
||||||
nodesAccess: [],
|
|
||||||
});
|
|
||||||
|
|
||||||
const savedCredential = await Container.get(CredentialsRepository).save(newCredential);
|
|
||||||
|
|
||||||
await Container.get(SharedCredentialsRepository).save({
|
|
||||||
role: credentialOwnerRole,
|
|
||||||
user: member,
|
|
||||||
credentials: savedCredential,
|
|
||||||
});
|
|
||||||
|
|
||||||
const response = await authOwnerAgent.delete(`/users/${member.id}`);
|
|
||||||
|
|
||||||
expect(response.statusCode).toBe(200);
|
expect(response.statusCode).toBe(200);
|
||||||
expect(response.body).toEqual(SUCCESS_RESPONSE_BODY);
|
expect(response.body).toEqual(SUCCESS_RESPONSE_BODY);
|
||||||
|
|
||||||
const user = await Container.get(UserRepository).findOneBy({ id: member.id });
|
const user = await Container.get(UserRepository).findOneBy({ id: member.id });
|
||||||
expect(user).toBeNull(); // deleted
|
|
||||||
|
|
||||||
const sharedWorkflow = await Container.get(SharedWorkflowRepository).findOne({
|
const sharedWorkflow = await Container.get(SharedWorkflowRepository).findOne({
|
||||||
relations: ['user'],
|
relations: ['user'],
|
||||||
where: { userId: member.id, roleId: workflowOwnerRole.id },
|
where: { userId: member.id, roleId: workflowOwnerRole.id },
|
||||||
});
|
});
|
||||||
expect(sharedWorkflow).toBeNull(); // deleted
|
|
||||||
|
|
||||||
const sharedCredential = await Container.get(SharedCredentialsRepository).findOne({
|
const sharedCredential = await Container.get(SharedCredentialsRepository).findOne({
|
||||||
relations: ['user'],
|
relations: ['user'],
|
||||||
where: { userId: member.id, roleId: credentialOwnerRole.id },
|
where: { userId: member.id, roleId: credentialOwnerRole.id },
|
||||||
});
|
});
|
||||||
expect(sharedCredential).toBeNull(); // deleted
|
|
||||||
|
|
||||||
const workflow = await Container.get(WorkflowRepository).findOneBy({ id: savedWorkflow.id });
|
const workflow = await getWorkflowById(savedWorkflow.id);
|
||||||
expect(workflow).toBeNull(); // deleted
|
|
||||||
|
|
||||||
// TODO: Include active workflow and check whether webhook has been removed
|
const credential = await getCredentialById(savedCredential.id);
|
||||||
|
|
||||||
const credential = await Container.get(CredentialsRepository).findOneBy({
|
// @TODO: Include active workflow and check whether webhook has been removed
|
||||||
id: savedCredential.id,
|
|
||||||
});
|
expect(user).toBeNull();
|
||||||
expect(credential).toBeNull(); // deleted
|
expect(sharedWorkflow).toBeNull();
|
||||||
|
expect(sharedCredential).toBeNull();
|
||||||
|
expect(workflow).toBeNull();
|
||||||
|
expect(credential).toBeNull();
|
||||||
|
|
||||||
|
// restore
|
||||||
|
|
||||||
|
member = await createMember();
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to delete self', async () => {
|
test('should delete user and transfer their resources', async () => {
|
||||||
const response = await authOwnerAgent.delete(`/users/${owner.id}`);
|
const [savedWorkflow, savedCredential] = await Promise.all([
|
||||||
|
await createWorkflow({ name: randomName() }, member),
|
||||||
expect(response.statusCode).toBe(400);
|
await saveCredential(
|
||||||
|
{ name: randomName(), type: '', data: {}, nodesAccess: [] },
|
||||||
const user = await Container.get(UserRepository).findOneBy({ id: owner.id });
|
{
|
||||||
expect(user).toBeDefined();
|
user: member,
|
||||||
});
|
|
||||||
|
|
||||||
test('should fail if user to delete is transferee', async () => {
|
|
||||||
const { id: idToDelete } = await createUser({ globalRole: globalMemberRole });
|
|
||||||
|
|
||||||
const response = await authOwnerAgent.delete(`/users/${idToDelete}`).query({
|
|
||||||
transferId: idToDelete,
|
|
||||||
});
|
|
||||||
|
|
||||||
expect(response.statusCode).toBe(400);
|
|
||||||
|
|
||||||
const user = await Container.get(UserRepository).findOneBy({ id: idToDelete });
|
|
||||||
expect(user).toBeDefined();
|
|
||||||
});
|
|
||||||
|
|
||||||
test('with transferId should perform transfer', async () => {
|
|
||||||
const userToDelete = await createUser({ globalRole: globalMemberRole });
|
|
||||||
|
|
||||||
const savedWorkflow = await createWorkflow(undefined, userToDelete);
|
|
||||||
|
|
||||||
const savedCredential = await saveCredential(randomCredentialPayload(), {
|
|
||||||
user: userToDelete,
|
|
||||||
role: credentialOwnerRole,
|
role: credentialOwnerRole,
|
||||||
});
|
},
|
||||||
|
),
|
||||||
|
]);
|
||||||
|
|
||||||
const response = await authOwnerAgent.delete(`/users/${userToDelete.id}`).query({
|
const response = await ownerAgent.delete(`/users/${member.id}`).query({
|
||||||
transferId: owner.id,
|
transferId: owner.id,
|
||||||
});
|
});
|
||||||
|
|
||||||
expect(response.statusCode).toBe(200);
|
expect(response.statusCode).toBe(200);
|
||||||
|
|
||||||
const sharedWorkflow = await Container.get(SharedWorkflowRepository).findOneOrFail({
|
const [user, sharedWorkflow, sharedCredential] = await Promise.all([
|
||||||
|
await Container.get(UserRepository).findOneBy({ id: member.id }),
|
||||||
|
await Container.get(SharedWorkflowRepository).findOneOrFail({
|
||||||
relations: ['workflow'],
|
relations: ['workflow'],
|
||||||
where: { userId: owner.id },
|
where: { userId: owner.id },
|
||||||
});
|
}),
|
||||||
|
await Container.get(SharedCredentialsRepository).findOneOrFail({
|
||||||
expect(sharedWorkflow.workflow).toBeDefined();
|
|
||||||
expect(sharedWorkflow.workflow.id).toBe(savedWorkflow.id);
|
|
||||||
|
|
||||||
const sharedCredential = await Container.get(SharedCredentialsRepository).findOneOrFail({
|
|
||||||
relations: ['credentials'],
|
relations: ['credentials'],
|
||||||
where: { userId: owner.id },
|
where: { userId: owner.id },
|
||||||
|
}),
|
||||||
|
]);
|
||||||
|
|
||||||
|
expect(user).toBeNull();
|
||||||
|
expect(sharedWorkflow.workflow.id).toBe(savedWorkflow.id);
|
||||||
|
expect(sharedCredential.credentials.id).toBe(savedCredential.id);
|
||||||
});
|
});
|
||||||
|
|
||||||
expect(sharedCredential.credentials).toBeDefined();
|
test('should fail to delete self', async () => {
|
||||||
expect(sharedCredential.credentials.id).toBe(savedCredential.id);
|
const response = await ownerAgent.delete(`/users/${owner.id}`);
|
||||||
|
|
||||||
const deletedUser = await Container.get(UserRepository).findOneBy({ id: userToDelete.id });
|
expect(response.statusCode).toBe(400);
|
||||||
|
|
||||||
expect(deletedUser).toBeNull();
|
const user = await getUserById(owner.id);
|
||||||
|
|
||||||
|
expect(user).toBeDefined();
|
||||||
|
});
|
||||||
|
|
||||||
|
test('should fail to delete if user to delete is transferee', async () => {
|
||||||
|
const response = await ownerAgent.delete(`/users/${member.id}`).query({
|
||||||
|
transferId: member.id,
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(response.statusCode).toBe(400);
|
||||||
|
|
||||||
|
const user = await Container.get(UserRepository).findOneBy({ id: member.id });
|
||||||
|
|
||||||
|
expect(user).toBeDefined();
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('PATCH /users/:id/role', () => {
|
describe('PATCH /users/:id/role', () => {
|
||||||
|
let owner: User;
|
||||||
|
let admin: User;
|
||||||
|
let otherAdmin: User;
|
||||||
|
let member: User;
|
||||||
|
let otherMember: User;
|
||||||
|
|
||||||
|
let ownerAgent: SuperAgentTest;
|
||||||
|
let adminAgent: SuperAgentTest;
|
||||||
|
let memberAgent: SuperAgentTest;
|
||||||
|
let authlessAgent: SuperAgentTest;
|
||||||
|
|
||||||
const {
|
const {
|
||||||
NO_MEMBER,
|
NO_MEMBER,
|
||||||
MISSING_NEW_ROLE_KEY,
|
MISSING_NEW_ROLE_KEY,
|
||||||
|
@ -408,6 +364,23 @@ describe('PATCH /users/:id/role', () => {
|
||||||
NO_OWNER_ON_OWNER,
|
NO_OWNER_ON_OWNER,
|
||||||
} = UsersController.ERROR_MESSAGES.CHANGE_ROLE;
|
} = UsersController.ERROR_MESSAGES.CHANGE_ROLE;
|
||||||
|
|
||||||
|
beforeAll(async () => {
|
||||||
|
await testDb.truncate(['User']);
|
||||||
|
|
||||||
|
[owner, admin, otherAdmin, member, otherMember] = await Promise.all([
|
||||||
|
await createOwner(),
|
||||||
|
await createAdmin(),
|
||||||
|
await createAdmin(),
|
||||||
|
await createMember(),
|
||||||
|
await createMember(),
|
||||||
|
]);
|
||||||
|
|
||||||
|
ownerAgent = testServer.authAgentFor(owner);
|
||||||
|
adminAgent = testServer.authAgentFor(admin);
|
||||||
|
memberAgent = testServer.authAgentFor(member);
|
||||||
|
authlessAgent = testServer.authlessAgent;
|
||||||
|
});
|
||||||
|
|
||||||
describe('unauthenticated user', () => {
|
describe('unauthenticated user', () => {
|
||||||
test('should receive 401', async () => {
|
test('should receive 401', async () => {
|
||||||
const response = await authlessAgent.patch(`/users/${member.id}/role`).send({
|
const response = await authlessAgent.patch(`/users/${member.id}/role`).send({
|
||||||
|
@ -420,7 +393,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
|
|
||||||
describe('member', () => {
|
describe('member', () => {
|
||||||
test('should fail to demote owner to member', async () => {
|
test('should fail to demote owner to member', async () => {
|
||||||
const response = await authMemberAgent.patch(`/users/${owner.id}/role`).send({
|
const response = await memberAgent.patch(`/users/${owner.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'member' },
|
newRole: { scope: 'global', name: 'member' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -429,7 +402,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to demote owner to admin', async () => {
|
test('should fail to demote owner to admin', async () => {
|
||||||
const response = await authMemberAgent.patch(`/users/${owner.id}/role`).send({
|
const response = await memberAgent.patch(`/users/${owner.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'admin' },
|
newRole: { scope: 'global', name: 'admin' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -438,7 +411,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to demote admin to member', async () => {
|
test('should fail to demote admin to member', async () => {
|
||||||
const response = await authMemberAgent.patch(`/users/${admin.id}/role`).send({
|
const response = await memberAgent.patch(`/users/${admin.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'member' },
|
newRole: { scope: 'global', name: 'member' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -447,7 +420,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to promote other member to owner', async () => {
|
test('should fail to promote other member to owner', async () => {
|
||||||
const response = await authMemberAgent.patch(`/users/${otherMember.id}/role`).send({
|
const response = await memberAgent.patch(`/users/${otherMember.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'owner' },
|
newRole: { scope: 'global', name: 'owner' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -456,7 +429,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to promote other member to admin', async () => {
|
test('should fail to promote other member to admin', async () => {
|
||||||
const response = await authMemberAgent.patch(`/users/${otherMember.id}/role`).send({
|
const response = await memberAgent.patch(`/users/${otherMember.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'admin' },
|
newRole: { scope: 'global', name: 'admin' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -465,7 +438,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to promote self to admin', async () => {
|
test('should fail to promote self to admin', async () => {
|
||||||
const response = await authMemberAgent.patch(`/users/${member.id}/role`).send({
|
const response = await memberAgent.patch(`/users/${member.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'admin' },
|
newRole: { scope: 'global', name: 'admin' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -474,7 +447,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to promote self to owner', async () => {
|
test('should fail to promote self to owner', async () => {
|
||||||
const response = await authMemberAgent.patch(`/users/${member.id}/role`).send({
|
const response = await memberAgent.patch(`/users/${member.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'owner' },
|
newRole: { scope: 'global', name: 'owner' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -485,12 +458,12 @@ describe('PATCH /users/:id/role', () => {
|
||||||
|
|
||||||
describe('admin', () => {
|
describe('admin', () => {
|
||||||
test('should receive 400 on invalid payload', async () => {
|
test('should receive 400 on invalid payload', async () => {
|
||||||
const response = await authAdminAgent.patch(`/users/${member.id}/role`).send({});
|
const response = await adminAgent.patch(`/users/${member.id}/role`).send({});
|
||||||
|
|
||||||
expect(response.statusCode).toBe(400);
|
expect(response.statusCode).toBe(400);
|
||||||
expect(response.body.message).toBe(MISSING_NEW_ROLE_KEY);
|
expect(response.body.message).toBe(MISSING_NEW_ROLE_KEY);
|
||||||
|
|
||||||
const _response = await authAdminAgent.patch(`/users/${member.id}/role`).send({
|
const _response = await adminAgent.patch(`/users/${member.id}/role`).send({
|
||||||
newRole: {},
|
newRole: {},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -499,7 +472,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should receive 404 on unknown target user', async () => {
|
test('should receive 404 on unknown target user', async () => {
|
||||||
const response = await authAdminAgent
|
const response = await adminAgent
|
||||||
.patch('/users/c2317ff3-7a9f-4fd4-ad2b-7331f6359260/role')
|
.patch('/users/c2317ff3-7a9f-4fd4-ad2b-7331f6359260/role')
|
||||||
.send({
|
.send({
|
||||||
newRole: { scope: 'global', name: 'member' },
|
newRole: { scope: 'global', name: 'member' },
|
||||||
|
@ -510,7 +483,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to demote owner to admin', async () => {
|
test('should fail to demote owner to admin', async () => {
|
||||||
const response = await authAdminAgent.patch(`/users/${owner.id}/role`).send({
|
const response = await adminAgent.patch(`/users/${owner.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'admin' },
|
newRole: { scope: 'global', name: 'admin' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -519,7 +492,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to demote owner to member', async () => {
|
test('should fail to demote owner to member', async () => {
|
||||||
const response = await authAdminAgent.patch(`/users/${owner.id}/role`).send({
|
const response = await adminAgent.patch(`/users/${owner.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'member' },
|
newRole: { scope: 'global', name: 'member' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -528,7 +501,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to promote member to owner', async () => {
|
test('should fail to promote member to owner', async () => {
|
||||||
const response = await authAdminAgent.patch(`/users/${member.id}/role`).send({
|
const response = await adminAgent.patch(`/users/${member.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'owner' },
|
newRole: { scope: 'global', name: 'owner' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -537,7 +510,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to promote admin to owner', async () => {
|
test('should fail to promote admin to owner', async () => {
|
||||||
const response = await authAdminAgent.patch(`/users/${member.id}/role`).send({
|
const response = await adminAgent.patch(`/users/${member.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'owner' },
|
newRole: { scope: 'global', name: 'owner' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -546,7 +519,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should be able to demote admin to member', async () => {
|
test('should be able to demote admin to member', async () => {
|
||||||
const response = await authAdminAgent.patch(`/users/${otherAdmin.id}/role`).send({
|
const response = await adminAgent.patch(`/users/${otherAdmin.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'member' },
|
newRole: { scope: 'global', name: 'member' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -557,10 +530,15 @@ describe('PATCH /users/:id/role', () => {
|
||||||
|
|
||||||
expect(user.globalRole.scope).toBe('global');
|
expect(user.globalRole.scope).toBe('global');
|
||||||
expect(user.globalRole.name).toBe('member');
|
expect(user.globalRole.name).toBe('member');
|
||||||
|
|
||||||
|
// restore other admin
|
||||||
|
|
||||||
|
otherAdmin = await createAdmin();
|
||||||
|
adminAgent = testServer.authAgentFor(otherAdmin);
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should be able to demote self to member', async () => {
|
test('should be able to demote self to member', async () => {
|
||||||
const response = await authAdminAgent.patch(`/users/${admin.id}/role`).send({
|
const response = await adminAgent.patch(`/users/${admin.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'member' },
|
newRole: { scope: 'global', name: 'member' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -571,10 +549,15 @@ describe('PATCH /users/:id/role', () => {
|
||||||
|
|
||||||
expect(user.globalRole.scope).toBe('global');
|
expect(user.globalRole.scope).toBe('global');
|
||||||
expect(user.globalRole.name).toBe('member');
|
expect(user.globalRole.name).toBe('member');
|
||||||
|
|
||||||
|
// restore admin
|
||||||
|
|
||||||
|
admin = await createAdmin();
|
||||||
|
adminAgent = testServer.authAgentFor(admin);
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should be able to promote member to admin', async () => {
|
test('should be able to promote member to admin', async () => {
|
||||||
const response = await authAdminAgent.patch(`/users/${member.id}/role`).send({
|
const response = await adminAgent.patch(`/users/${member.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'admin' },
|
newRole: { scope: 'global', name: 'admin' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -585,12 +568,17 @@ describe('PATCH /users/:id/role', () => {
|
||||||
|
|
||||||
expect(user.globalRole.scope).toBe('global');
|
expect(user.globalRole.scope).toBe('global');
|
||||||
expect(user.globalRole.name).toBe('admin');
|
expect(user.globalRole.name).toBe('admin');
|
||||||
|
|
||||||
|
// restore member
|
||||||
|
|
||||||
|
member = await createMember();
|
||||||
|
memberAgent = testServer.authAgentFor(member);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('owner', () => {
|
describe('owner', () => {
|
||||||
test('should be able to promote member to admin', async () => {
|
test('should be able to promote member to admin', async () => {
|
||||||
const response = await authOwnerAgent.patch(`/users/${member.id}/role`).send({
|
const response = await ownerAgent.patch(`/users/${member.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'admin' },
|
newRole: { scope: 'global', name: 'admin' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -601,10 +589,15 @@ describe('PATCH /users/:id/role', () => {
|
||||||
|
|
||||||
expect(user.globalRole.scope).toBe('global');
|
expect(user.globalRole.scope).toBe('global');
|
||||||
expect(user.globalRole.name).toBe('admin');
|
expect(user.globalRole.name).toBe('admin');
|
||||||
|
|
||||||
|
// restore member
|
||||||
|
|
||||||
|
member = await createMember();
|
||||||
|
memberAgent = testServer.authAgentFor(member);
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should be able to demote admin to member', async () => {
|
test('should be able to demote admin to member', async () => {
|
||||||
const response = await authOwnerAgent.patch(`/users/${admin.id}/role`).send({
|
const response = await ownerAgent.patch(`/users/${admin.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'member' },
|
newRole: { scope: 'global', name: 'member' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -615,10 +608,15 @@ describe('PATCH /users/:id/role', () => {
|
||||||
|
|
||||||
expect(user.globalRole.scope).toBe('global');
|
expect(user.globalRole.scope).toBe('global');
|
||||||
expect(user.globalRole.name).toBe('member');
|
expect(user.globalRole.name).toBe('member');
|
||||||
|
|
||||||
|
// restore admin
|
||||||
|
|
||||||
|
admin = await createAdmin();
|
||||||
|
adminAgent = testServer.authAgentFor(admin);
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to demote self to admin', async () => {
|
test('should fail to demote self to admin', async () => {
|
||||||
const response = await authOwnerAgent.patch(`/users/${owner.id}/role`).send({
|
const response = await ownerAgent.patch(`/users/${owner.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'admin' },
|
newRole: { scope: 'global', name: 'admin' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -627,7 +625,7 @@ describe('PATCH /users/:id/role', () => {
|
||||||
});
|
});
|
||||||
|
|
||||||
test('should fail to demote self to member', async () => {
|
test('should fail to demote self to member', async () => {
|
||||||
const response = await authOwnerAgent.patch(`/users/${owner.id}/role`).send({
|
const response = await ownerAgent.patch(`/users/${owner.id}/role`).send({
|
||||||
newRole: { scope: 'global', name: 'member' },
|
newRole: { scope: 'global', name: 'member' },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue