Files
upstream-rocketchat/apps/meteor/tests/unit/server/startup/initialData.tests.ts
upstream-mirror 30810eecd7
Some checks failed
Create issues from TODOs / todos (push) Failing after 3s
Close inactive issues / close-issues (push) Has been cancelled
Deploy GitHub Pages / deploy-preview (push) Has been cancelled
CI / ⚙️ Variables Setup (push) Has been cancelled
CI / ⚙️ Test Guard (push) Has been cancelled
CI / 🚀 Notify external services - draft (push) Has been cancelled
CI / 📦 Build Packages (push) Has been cancelled
CI / 📦 Meteor Build (coverage) (push) Has been cancelled
CI / 📦 Meteor Build (production) (push) Has been cancelled
CI / 🚢 Build Docker (amd64, [account-service presence-service omnichannel-transcript-service], ${{ (github.event_name != 'release' && github.ref != 'refs/heads/develop') && 'coverage' || 'production' }}) (push) Has been cancelled
CI / 🚢 Build Docker (amd64, [account-service presence-service omnichannel-transcript-service], fips) (push) Has been cancelled
CI / 🚢 Build Docker (amd64, [authorization-service queue-worker-service ddp-streamer-service], ${{ (github.event_name != 'release' && github.ref != 'refs/heads/develop') && 'coverage' || 'production' }}) (push) Has been cancelled
CI / 🚢 Build Docker (amd64, [authorization-service queue-worker-service ddp-streamer-service], fips) (push) Has been cancelled
CI / 🚢 Build Docker (amd64, [rocketchat], ${{ (github.event_name != 'release' && github.ref != 'refs/heads/develop') && 'coverage' || 'production' }}) (push) Has been cancelled
CI / 🚢 Build Docker (amd64, [rocketchat], coverage) (push) Has been cancelled
CI / 🚢 Build Docker (amd64, [rocketchat], fips) (push) Has been cancelled
CI / 🚢 Build Docker (arm64, [account-service presence-service omnichannel-transcript-service], ${{ (github.event_name != 'release' && github.ref != 'refs/heads/develop') && 'coverage' || 'production' }}) (push) Has been cancelled
CI / 🚢 Build Docker (arm64, [authorization-service queue-worker-service ddp-streamer-service], ${{ (github.event_name != 'release' && github.ref != 'refs/heads/develop') && 'coverage' || 'production' }}) (push) Has been cancelled
CI / 🚢 Build Docker (arm64, [rocketchat], ${{ (github.event_name != 'release' && github.ref != 'refs/heads/develop') && 'coverage' || 'production' }}) (push) Has been cancelled
CI / 🚢 Build Docker (arm64, [rocketchat], coverage) (push) Has been cancelled
CI / 🚢 Publish Docker Images (ghcr.io) (push) Has been cancelled
CI / 📦 Track Image Sizes (push) Has been cancelled
CI / 🔎 Code Check - Action Lint (push) Has been cancelled
CI / 🔎 Code Check (push) Has been cancelled
CI / 🔨 Test Storybook (push) Has been cancelled
CI / 🔨 Test Unit (push) Has been cancelled
CI / 🔨 Test API (CE) (push) Has been cancelled
CI / 🔨 Test API Livechat (CE) (push) Has been cancelled
CI / 🔨 Test UI (CE) (push) Has been cancelled
CI / 🔨 Test API (EE) (push) Has been cancelled
CI / 🔨 Test API Livechat (EE) (push) Has been cancelled
CI / 🔨 Test API Apps (deno-runtime - EE) (push) Has been cancelled
CI / 🔨 Test UI (EE) (push) Has been cancelled
CI / 🔨 Test API (FIPS) (push) Has been cancelled
CI / 🔨 Test API Livechat (FIPS) (push) Has been cancelled
CI / 🔨 Test UI (FIPS) (push) Has been cancelled
CI / 🔨 Test Federation Matrix (push) Has been cancelled
CI / 📊 Report Coverage (push) Has been cancelled
CI / ✅ Tests Done (push) Has been cancelled
CI / 🚀 Publish build assets (push) Has been cancelled
CI / 🚀 Publish Docker Images (DockerHub) (push) Has been cancelled
CI / 🚀 Notify external services (push) Has been cancelled
CI / Update Version Durability (push) Has been cancelled
Release / Release (push) Has been cancelled
Auto-close duplicate issues / auto-close-duplicates (push) Failing after 1s
Code scanning - action / CodeQL-Build (push) Failing after 2s
snapshot of https://github.com/RocketChat/Rocket.Chat.git (develop, 2026-09-16; blobs > 131072B omitted)
2026-09-16 01:21:02 +05:00

233 lines
7.7 KiB
TypeScript

import { expect } from 'chai';
import { beforeEach, it } from 'mocha';
import proxyquire from 'proxyquire';
import sinon from 'sinon';
const checkUsernameAvailability = sinon.stub();
const validateEmail = sinon.stub();
const addUserRolesAsync = sinon.stub();
const models = {
Settings: {},
Rooms: {},
Users: {
create: sinon.stub(),
findOneByEmailAddress: sinon.stub(),
},
Roles: {
countUsersInRole: sinon.stub(),
},
};
const setPasswordAsync = sinon.stub();
const settingsGet = sinon.stub();
const { insertAdminUserFromEnv } = proxyquire.noCallThru().load('../../../../server/startup/initialData.js', {
'meteor/accounts-base': {
Accounts: {
setPasswordAsync,
},
},
'meteor/meteor': {
Meteor: {
startup: sinon.stub(),
},
},
'../lib/media/file-upload': {},
'../lib/rooms/addUserToDefaultChannels': {},
'../lib/users/checkUsernameAvailability': {
checkUsernameAvailability,
},
'../settings': {
settings: { get: settingsGet },
},
'@rocket.chat/tools': {
validateEmail,
},
'../lib/roles/addUserRoles': {
addUserRolesAsync,
},
'@rocket.chat/models': models,
});
describe('insertAdminUserFromEnv', () => {
beforeEach(() => {
checkUsernameAvailability.reset();
validateEmail.reset();
addUserRolesAsync.reset();
models.Users.create.reset();
models.Users.findOneByEmailAddress.reset();
setPasswordAsync.reset();
settingsGet.reset();
process.env.ADMIN_PASS = 'pass';
models.Roles.countUsersInRole.reset();
});
it('should do nothing if process.env.ADMIN_PASS is empty', async () => {
process.env.ADMIN_PASS = '';
const result = await insertAdminUserFromEnv();
expect(result).to.be.undefined;
});
it('should do nothing if theres already an admin user', async () => {
models.Roles.countUsersInRole.resolves(1);
const result = await insertAdminUserFromEnv();
expect(models.Roles.countUsersInRole.called).to.be.true;
expect(validateEmail.called).to.be.false;
expect(result).to.be.undefined;
});
it('should try to validate an email when process.env.ADMIN_EMAIL is set', async () => {
process.env.ADMIN_EMAIL = 'email';
models.Roles.countUsersInRole.resolves(0);
validateEmail.returns(false);
models.Users.create.returns({ insertedId: 'newuserid' });
const result = await insertAdminUserFromEnv();
expect(models.Roles.countUsersInRole.called).to.be.true;
expect(validateEmail.called).to.be.true;
expect(validateEmail.calledWith('email')).to.be.true;
expect(models.Users.create.called).to.be.true;
expect(setPasswordAsync.called).to.be.true;
expect(result).to.be.undefined;
});
it('should override the admins name when process.env.ADMIN_NAME is set', async () => {
process.env.ADMIN_EMAIL = 'email';
process.env.ADMIN_NAME = 'name';
models.Roles.countUsersInRole.resolves(0);
validateEmail.returns(true);
validateEmail.returns(false);
models.Users.create.returns({ insertedId: 'newuserid' });
await insertAdminUserFromEnv();
expect(
models.Users.create.calledWith(
sinon.match({
name: 'name',
username: 'admin',
status: 'offline',
statusDefault: 'online',
utcOffset: 0,
active: true,
type: 'user',
}),
),
).to.be.true;
});
it('should ignore the admin email when another user already has it set', async () => {
process.env.ADMIN_EMAIL = 'email';
models.Roles.countUsersInRole.resolves(0);
validateEmail.returns(true);
models.Users.create.returns({ insertedId: 'newuserid' });
models.Users.findOneByEmailAddress.returns({ _id: 'someuser' });
await insertAdminUserFromEnv();
expect(models.Users.create.getCall(0).firstArg).to.not.to.have.property('email');
});
it('should add the email from env when its valid and no users are using it', async () => {
process.env.ADMIN_EMAIL = 'email';
models.Roles.countUsersInRole.resolves(0);
validateEmail.returns(true);
models.Users.create.returns({ insertedId: 'newuserid' });
models.Users.findOneByEmailAddress.returns(undefined);
await insertAdminUserFromEnv();
expect(models.Users.create.getCall(0).firstArg)
.to.have.property('emails')
.to.deep.equal([{ address: 'email', verified: false }]);
});
it('should mark the admin email as verified when process.env.ADMIN_EMAIL_VERIFIED is set to true', async () => {
process.env.ADMIN_EMAIL = 'email';
process.env.ADMIN_EMAIL_VERIFIED = 'true';
models.Roles.countUsersInRole.resolves(0);
validateEmail.returns(true);
models.Users.create.returns({ insertedId: 'newuserid' });
models.Users.findOneByEmailAddress.returns(undefined);
await insertAdminUserFromEnv();
expect(models.Users.create.getCall(0).firstArg)
.to.have.property('emails')
.to.deep.equal([{ address: 'email', verified: true }]);
});
it('should validate a username with setting UTF8_User_Names_Validation when process.env.ADMIN_USERNAME is set', async () => {
process.env.ADMIN_USERNAME = '1234';
models.Roles.countUsersInRole.resolves(0);
validateEmail.returns(true);
settingsGet.returns('[0-9]+');
models.Users.create.returns({ insertedId: 'newuserid' });
await insertAdminUserFromEnv();
expect(checkUsernameAvailability.called).to.be.true;
});
it('should override the username from admin if the env ADMIN_USERNAME is set, is valid and the username is available', async () => {
process.env.ADMIN_USERNAME = '1234';
models.Roles.countUsersInRole.resolves(0);
validateEmail.returns(true);
settingsGet.returns('[0-9]+');
checkUsernameAvailability.returns(true);
models.Users.create.returns({ insertedId: 'newuserid' });
await insertAdminUserFromEnv();
expect(models.Users.create.calledWith(sinon.match({ username: '1234' }))).to.be.true;
});
it('should ignore the username when it does not pass setting regexp validation', async () => {
process.env.ADMIN_USERNAME = '1234';
models.Roles.countUsersInRole.resolves(0);
validateEmail.returns(true);
settingsGet.returns('[A-Z]+');
checkUsernameAvailability.returns(true);
models.Users.create.returns({ insertedId: 'newuserid' });
await insertAdminUserFromEnv();
expect(models.Users.create.calledWith(sinon.match({ username: 'admin' }))).to.be.true;
});
it('should call addUserRolesAsync as the last step when all data is valid and all overrides are valid', async () => {
process.env.ADMIN_EMAIL = 'email';
process.env.ADMIN_NAME = 'name';
process.env.ADMIN_USERNAME = '1234';
process.env.ADMIN_EMAIL_VERIFIED = 'true';
models.Roles.countUsersInRole.resolves(0);
validateEmail.returns(true);
settingsGet.returns('[0-9]+');
checkUsernameAvailability.returns(true);
models.Users.create.returns({ insertedId: 'newuserid' });
models.Users.findOneByEmailAddress.returns(undefined);
await insertAdminUserFromEnv();
expect(addUserRolesAsync.called).to.be.true;
expect(setPasswordAsync.called).to.be.true;
expect(models.Users.create.calledWith(sinon.match({ name: 'name', username: '1234', emails: [{ address: 'email', verified: true }] })))
.to.be.true;
});
it('should use the default nameValidation regex when the regex on the setting is invalid', async () => {
process.env.ADMIN_NAME = 'name';
process.env.ADMIN_USERNAME = '$$$$$$';
models.Roles.countUsersInRole.resolves(0);
settingsGet.returns('[');
checkUsernameAvailability.returns(true);
models.Users.create.returns({ insertedId: 'newuserid' });
await insertAdminUserFromEnv();
expect(models.Users.create.calledWith(sinon.match({ username: 'admin' })));
});
it('should ignore the username when is not available', async () => {
process.env.ADMIN_USERNAME = '1234';
models.Roles.countUsersInRole.resolves(0);
checkUsernameAvailability.throws('some error');
models.Users.create.returns({ insertedId: 'newuserid' });
await insertAdminUserFromEnv();
expect(models.Users.create.calledWith(sinon.match({ username: 'admin' }))).to.be.true;
});
});