mirror of
https://github.com/outline/outline.git
synced 2026-06-13 11:25:03 +03:00
Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| ecc32aa1df |
@@ -171,6 +171,10 @@
|
||||
"description": "smtp.example.com (optional)",
|
||||
"required": false
|
||||
},
|
||||
"SMTP_SERVICE": {
|
||||
"description": "Well-known SMTP service name for nodemailer (optional, e.g. 'gmail', 'SES')",
|
||||
"required": false
|
||||
},
|
||||
"SMTP_PORT": {
|
||||
"description": "1234 (optional)",
|
||||
"required": false
|
||||
|
||||
@@ -3,7 +3,7 @@ import { Hook, PluginManager } from "@server/utils/PluginManager";
|
||||
import config from "../plugin.json";
|
||||
import router from "./auth/email";
|
||||
|
||||
const enabled = !!env.SMTP_HOST || env.isDevelopment;
|
||||
const enabled = !!(env.SMTP_HOST || env.SMTP_SERVICE) || env.isDevelopment;
|
||||
|
||||
if (enabled) {
|
||||
PluginManager.add({
|
||||
|
||||
@@ -33,7 +33,7 @@ export class Mailer {
|
||||
transporter: Transporter | undefined;
|
||||
|
||||
constructor() {
|
||||
if (env.SMTP_HOST) {
|
||||
if (env.SMTP_HOST || env.SMTP_SERVICE) {
|
||||
this.transporter = nodemailer.createTransport(this.getOptions());
|
||||
}
|
||||
if (useTestEmailService) {
|
||||
@@ -203,6 +203,7 @@ export class Mailer {
|
||||
host: env.SMTP_HOST,
|
||||
port: env.SMTP_PORT,
|
||||
secure: env.SMTP_SECURE ?? env.isProduction,
|
||||
service: env.SMTP_SERVICE,
|
||||
auth: env.SMTP_USERNAME
|
||||
? {
|
||||
user: env.SMTP_USERNAME,
|
||||
|
||||
+7
-1
@@ -294,7 +294,7 @@ export class Environment {
|
||||
public SMTP_HOST = environment.SMTP_HOST;
|
||||
|
||||
@Public
|
||||
public EMAIL_ENABLED = !!this.SMTP_HOST || this.isDevelopment;
|
||||
public EMAIL_ENABLED = !!(this.SMTP_HOST || this.SMTP_SERVICE) || this.isDevelopment;
|
||||
|
||||
/**
|
||||
* Optional hostname of the client, used for identifying to the server
|
||||
@@ -302,6 +302,12 @@ export class Environment {
|
||||
*/
|
||||
public SMTP_NAME = environment.SMTP_NAME;
|
||||
|
||||
/**
|
||||
* The service name of a well-known SMTP service for nodemailer.
|
||||
* See https://community.nodemailer.com/2-0-0-beta/setup-smtp/well-known-services/
|
||||
*/
|
||||
public SMTP_SERVICE = environment.SMTP_SERVICE;
|
||||
|
||||
/**
|
||||
* The port of your SMTP server.
|
||||
*/
|
||||
|
||||
@@ -190,7 +190,7 @@ class Team extends ParanoidModel<
|
||||
* @return {boolean} Whether to show email login options
|
||||
*/
|
||||
get emailSigninEnabled(): boolean {
|
||||
return this.guestSignin && (!!env.SMTP_HOST || env.isDevelopment);
|
||||
return this.guestSignin && (!!(env.SMTP_HOST || env.SMTP_SERVICE) || env.isDevelopment);
|
||||
}
|
||||
|
||||
get url() {
|
||||
|
||||
@@ -1,17 +1,3 @@
|
||||
import Router from "koa-router";
|
||||
import { UserRole } from "@shared/types";
|
||||
import teamCreator from "@server/commands/teamCreator";
|
||||
import teamDestroyer from "@server/commands/teamDestroyer";
|
||||
import teamUpdater from "@server/commands/teamUpdater";
|
||||
import ConfirmTeamDeleteEmail from "@server/emails/templates/ConfirmTeamDeleteEmail";
|
||||
import env from "@server/env";
|
||||
import { ValidationError } from "@server/errors";
|
||||
import auth from "@server/middlewares/authentication";
|
||||
import { rateLimiter } from "@server/middlewares/rateLimiter";
|
||||
import { transaction } from "@server/middlewares/transaction";
|
||||
import validate from "@server/middlewares/validate";
|
||||
import { Event, Team, TeamDomain, User } from "@server/models";
|
||||
import { authorize } from "@server/policies";
|
||||
import { presentTeam, presentPolicies } from "@server/presenters";
|
||||
import { APIContext } from "@server/types";
|
||||
import { RateLimiterStrategy } from "@server/utils/RateLimiter";
|
||||
@@ -19,177 +5,4 @@ import { safeEqual } from "@server/utils/crypto";
|
||||
import * as T from "./schema";
|
||||
|
||||
const router = new Router();
|
||||
const emailEnabled = !!(env.SMTP_HOST || env.isDevelopment);
|
||||
|
||||
const handleTeamUpdate = async (ctx: APIContext<T.TeamsUpdateSchemaReq>) => {
|
||||
const { transaction } = ctx.state;
|
||||
const { user } = ctx.state.auth;
|
||||
const team = await Team.findByPk(user.teamId, {
|
||||
include: [{ model: TeamDomain, separate: true }],
|
||||
lock: transaction.LOCK.UPDATE,
|
||||
transaction,
|
||||
});
|
||||
authorize(user, "update", team);
|
||||
|
||||
const updatedTeam = await teamUpdater({
|
||||
params: ctx.input.body,
|
||||
user,
|
||||
team,
|
||||
ip: ctx.request.ip,
|
||||
transaction,
|
||||
});
|
||||
|
||||
ctx.body = {
|
||||
data: presentTeam(updatedTeam),
|
||||
policies: presentPolicies(user, [updatedTeam]),
|
||||
};
|
||||
};
|
||||
|
||||
router.post(
|
||||
"team.update",
|
||||
rateLimiter(RateLimiterStrategy.TenPerMinute),
|
||||
auth(),
|
||||
validate(T.TeamsUpdateSchema),
|
||||
transaction(),
|
||||
handleTeamUpdate
|
||||
);
|
||||
|
||||
router.post(
|
||||
"teams.update",
|
||||
rateLimiter(RateLimiterStrategy.TenPerMinute),
|
||||
auth(),
|
||||
validate(T.TeamsUpdateSchema),
|
||||
transaction(),
|
||||
handleTeamUpdate
|
||||
);
|
||||
|
||||
router.post(
|
||||
"teams.requestDelete",
|
||||
rateLimiter(RateLimiterStrategy.FivePerHour),
|
||||
auth(),
|
||||
async (ctx: APIContext) => {
|
||||
if (!emailEnabled) {
|
||||
throw ValidationError("Email support is not setup for this instance");
|
||||
}
|
||||
|
||||
const { user } = ctx.state.auth;
|
||||
const { team } = user;
|
||||
authorize(user, "delete", team);
|
||||
|
||||
await new ConfirmTeamDeleteEmail({
|
||||
to: user.email,
|
||||
deleteConfirmationCode: team.getDeleteConfirmationCode(user),
|
||||
}).schedule();
|
||||
|
||||
ctx.body = {
|
||||
success: true,
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"teams.delete",
|
||||
rateLimiter(RateLimiterStrategy.TenPerHour),
|
||||
auth(),
|
||||
validate(T.TeamsDeleteSchema),
|
||||
transaction(),
|
||||
async (ctx: APIContext<T.TeamsDeleteSchemaReq>) => {
|
||||
const { auth, transaction } = ctx.state;
|
||||
const { code } = ctx.input.body;
|
||||
const { user } = auth;
|
||||
const { team } = user;
|
||||
|
||||
authorize(user, "delete", team);
|
||||
|
||||
if (emailEnabled) {
|
||||
const deleteConfirmationCode = team.getDeleteConfirmationCode(user);
|
||||
|
||||
if (!safeEqual(code, deleteConfirmationCode)) {
|
||||
throw ValidationError("The confirmation code was incorrect");
|
||||
}
|
||||
}
|
||||
|
||||
await teamDestroyer({
|
||||
team,
|
||||
user,
|
||||
transaction,
|
||||
ip: ctx.request.ip,
|
||||
});
|
||||
|
||||
ctx.body = {
|
||||
success: true,
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"teams.create",
|
||||
rateLimiter(RateLimiterStrategy.FivePerHour),
|
||||
auth(),
|
||||
transaction(),
|
||||
async (ctx: APIContext) => {
|
||||
const { transaction } = ctx.state;
|
||||
const { user } = ctx.state.auth;
|
||||
const { name } = ctx.request.body;
|
||||
|
||||
const existingTeam = await Team.scope(
|
||||
"withAuthenticationProviders"
|
||||
).findByPk(user.teamId, {
|
||||
rejectOnEmpty: true,
|
||||
transaction,
|
||||
});
|
||||
|
||||
authorize(user, "createTeam", existingTeam);
|
||||
|
||||
const authenticationProviders = existingTeam.authenticationProviders.map(
|
||||
(provider) => ({
|
||||
name: provider.name,
|
||||
providerId: provider.providerId,
|
||||
})
|
||||
);
|
||||
|
||||
const team = await teamCreator({
|
||||
name,
|
||||
subdomain: name,
|
||||
authenticationProviders,
|
||||
ip: ctx.ip,
|
||||
transaction,
|
||||
});
|
||||
|
||||
const newUser = await User.create(
|
||||
{
|
||||
teamId: team.id,
|
||||
name: user.name,
|
||||
email: user.email,
|
||||
role: UserRole.Admin,
|
||||
},
|
||||
{ transaction }
|
||||
);
|
||||
|
||||
await Event.create(
|
||||
{
|
||||
name: "users.create",
|
||||
actorId: user.id,
|
||||
userId: newUser.id,
|
||||
teamId: newUser.teamId,
|
||||
data: {
|
||||
name: newUser.name,
|
||||
},
|
||||
ip: ctx.ip,
|
||||
},
|
||||
{ transaction }
|
||||
);
|
||||
|
||||
ctx.body = {
|
||||
success: true,
|
||||
data: {
|
||||
team: presentTeam(team),
|
||||
transferUrl: `${
|
||||
team.url
|
||||
}/auth/redirect?token=${newUser?.getTransferToken()}`,
|
||||
},
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
export default router;
|
||||
const emailEnabled = !!(env.SMTP_HOST || env.SMTP_SERVICE || env.isDevelopment);
|
||||
|
||||
@@ -1,740 +1,4 @@
|
||||
import Router from "koa-router";
|
||||
import { Op, Sequelize, WhereOptions } from "sequelize";
|
||||
import { UserPreference, UserRole } from "@shared/types";
|
||||
import { UserRoleHelper } from "@shared/utils/UserRoleHelper";
|
||||
import { settingsPath } from "@shared/utils/routeHelpers";
|
||||
import { UserValidation } from "@shared/validations";
|
||||
import userDestroyer from "@server/commands/userDestroyer";
|
||||
import userInviter from "@server/commands/userInviter";
|
||||
import userSuspender from "@server/commands/userSuspender";
|
||||
import userUnsuspender from "@server/commands/userUnsuspender";
|
||||
import ConfirmUpdateEmail from "@server/emails/templates/ConfirmUpdateEmail";
|
||||
import ConfirmUserDeleteEmail from "@server/emails/templates/ConfirmUserDeleteEmail";
|
||||
import InviteEmail from "@server/emails/templates/InviteEmail";
|
||||
import env from "@server/env";
|
||||
import { ValidationError } from "@server/errors";
|
||||
import logger from "@server/logging/Logger";
|
||||
import auth from "@server/middlewares/authentication";
|
||||
import { rateLimiter } from "@server/middlewares/rateLimiter";
|
||||
import { transaction } from "@server/middlewares/transaction";
|
||||
import validate from "@server/middlewares/validate";
|
||||
import { Event, User, Team } from "@server/models";
|
||||
import { UserFlag } from "@server/models/User";
|
||||
import { can, authorize } from "@server/policies";
|
||||
import { presentUser, presentPolicies } from "@server/presenters";
|
||||
import { APIContext } from "@server/types";
|
||||
import { RateLimiterStrategy } from "@server/utils/RateLimiter";
|
||||
import { safeEqual } from "@server/utils/crypto";
|
||||
import { getDetailsForEmailUpdateToken } from "@server/utils/jwt";
|
||||
import pagination from "../middlewares/pagination";
|
||||
import * as T from "./schema";
|
||||
|
||||
const router = new Router();
|
||||
const emailEnabled = !!(env.SMTP_HOST || env.isDevelopment);
|
||||
|
||||
router.post(
|
||||
"users.list",
|
||||
auth(),
|
||||
pagination(),
|
||||
validate(T.UsersListSchema),
|
||||
async (ctx: APIContext<T.UsersListReq>) => {
|
||||
const { sort, direction, query, role, filter, ids, emails } =
|
||||
ctx.input.body;
|
||||
|
||||
const actor = ctx.state.auth.user;
|
||||
let where: WhereOptions<User> = {
|
||||
teamId: actor.teamId,
|
||||
};
|
||||
|
||||
// Filter out suspended users if we're not an admin
|
||||
if (!actor.isAdmin) {
|
||||
where = {
|
||||
...where,
|
||||
suspendedAt: {
|
||||
[Op.eq]: null,
|
||||
},
|
||||
};
|
||||
}
|
||||
|
||||
switch (filter) {
|
||||
case "invited": {
|
||||
where = { ...where, lastActiveAt: null };
|
||||
break;
|
||||
}
|
||||
|
||||
case "viewers": {
|
||||
where = { ...where, role: UserRole.Viewer };
|
||||
break;
|
||||
}
|
||||
|
||||
case "admins": {
|
||||
where = { ...where, role: UserRole.Admin };
|
||||
break;
|
||||
}
|
||||
|
||||
case "members": {
|
||||
where = { ...where, role: UserRole.Member };
|
||||
break;
|
||||
}
|
||||
|
||||
case "suspended": {
|
||||
if (actor.isAdmin) {
|
||||
where = {
|
||||
...where,
|
||||
suspendedAt: {
|
||||
[Op.ne]: null,
|
||||
},
|
||||
};
|
||||
}
|
||||
break;
|
||||
}
|
||||
|
||||
case "active": {
|
||||
where = {
|
||||
...where,
|
||||
lastActiveAt: {
|
||||
[Op.ne]: null,
|
||||
},
|
||||
suspendedAt: {
|
||||
[Op.is]: null,
|
||||
},
|
||||
};
|
||||
break;
|
||||
}
|
||||
|
||||
case "all": {
|
||||
break;
|
||||
}
|
||||
|
||||
default: {
|
||||
where = {
|
||||
...where,
|
||||
suspendedAt: {
|
||||
[Op.is]: null,
|
||||
},
|
||||
};
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (role) {
|
||||
where = {
|
||||
...where,
|
||||
role,
|
||||
};
|
||||
}
|
||||
|
||||
if (query) {
|
||||
where = {
|
||||
...where,
|
||||
[Op.and]: {
|
||||
[Op.or]: [
|
||||
Sequelize.literal(
|
||||
`unaccent(LOWER(email)) like unaccent(LOWER(:query))`
|
||||
),
|
||||
Sequelize.literal(
|
||||
`unaccent(LOWER(name)) like unaccent(LOWER(:query))`
|
||||
),
|
||||
],
|
||||
},
|
||||
};
|
||||
}
|
||||
|
||||
if (ids) {
|
||||
where = {
|
||||
...where,
|
||||
id: ids,
|
||||
};
|
||||
}
|
||||
|
||||
if (emails) {
|
||||
where = {
|
||||
...where,
|
||||
email: emails,
|
||||
};
|
||||
}
|
||||
|
||||
const replacements = { query: `%${query}%` };
|
||||
|
||||
const [users, total] = await Promise.all([
|
||||
User.findAll({
|
||||
where,
|
||||
replacements,
|
||||
order: [[sort, direction]],
|
||||
offset: ctx.state.pagination.offset,
|
||||
limit: ctx.state.pagination.limit,
|
||||
}),
|
||||
User.count({
|
||||
where,
|
||||
// @ts-expect-error Types are incorrect for count
|
||||
replacements,
|
||||
}),
|
||||
]);
|
||||
|
||||
ctx.body = {
|
||||
pagination: { ...ctx.state.pagination, total },
|
||||
data: users.map((user) =>
|
||||
presentUser(user, {
|
||||
includeEmail: !!can(actor, "readEmail", user),
|
||||
includeDetails: !!can(actor, "readDetails", user),
|
||||
})
|
||||
),
|
||||
policies: presentPolicies(actor, users),
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.info",
|
||||
auth(),
|
||||
validate(T.UsersInfoSchema),
|
||||
async (ctx: APIContext<T.UsersInfoReq>) => {
|
||||
const { id } = ctx.input.body;
|
||||
const actor = ctx.state.auth.user;
|
||||
const user = id ? await User.findByPk(id) : actor;
|
||||
authorize(actor, "read", user);
|
||||
const includeDetails = !!can(actor, "readDetails", user);
|
||||
|
||||
ctx.body = {
|
||||
data: presentUser(user, {
|
||||
includeDetails,
|
||||
}),
|
||||
policies: presentPolicies(actor, [user]),
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.updateEmail",
|
||||
rateLimiter(RateLimiterStrategy.TenPerHour),
|
||||
auth(),
|
||||
validate(T.UsersUpdateEmailSchema),
|
||||
async (ctx: APIContext<T.UsersUpdateEmailReq>) => {
|
||||
if (!emailEnabled) {
|
||||
throw ValidationError("Email support is not setup for this instance");
|
||||
}
|
||||
|
||||
const { user: actor } = ctx.state.auth;
|
||||
const { id } = ctx.input.body;
|
||||
const { team } = actor;
|
||||
const user = id ? await User.findByPk(id) : actor;
|
||||
const email = ctx.input.body.email.trim().toLowerCase();
|
||||
|
||||
authorize(actor, "update", user);
|
||||
|
||||
// Check if email domain is allowed
|
||||
if (!(await team.isDomainAllowed(email))) {
|
||||
throw ValidationError("The domain is not allowed for this workspace");
|
||||
}
|
||||
|
||||
// Check if email already exists in workspace
|
||||
if (await User.findByEmail(ctx, email)) {
|
||||
throw ValidationError("User with email already exists");
|
||||
}
|
||||
|
||||
await new ConfirmUpdateEmail({
|
||||
to: email,
|
||||
previous: user.email,
|
||||
code: user.getEmailUpdateToken(email),
|
||||
teamUrl: team.url,
|
||||
}).schedule();
|
||||
|
||||
ctx.body = {
|
||||
success: true,
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.get(
|
||||
"users.updateEmail",
|
||||
rateLimiter(RateLimiterStrategy.TenPerHour),
|
||||
auth(),
|
||||
transaction(),
|
||||
validate(T.UsersUpdateEmailConfirmSchema),
|
||||
async (ctx: APIContext<T.UsersUpdateEmailConfirmReq>) => {
|
||||
if (!emailEnabled) {
|
||||
throw ValidationError("Email support is not setup for this instance");
|
||||
}
|
||||
|
||||
const { transaction } = ctx.state;
|
||||
const { code, follow } = ctx.input.query;
|
||||
|
||||
// The link in the email does not include the follow query param, this
|
||||
// is to help prevent anti-virus, and email clients from pre-fetching the link
|
||||
// and spending the token before the user clicks on it. Instead we redirect
|
||||
// to the same URL with the follow query param added from the client side.
|
||||
if (!follow) {
|
||||
return ctx.redirectOnClient(ctx.request.href + "&follow=true");
|
||||
}
|
||||
let user: User;
|
||||
let email: string;
|
||||
|
||||
try {
|
||||
const res = await getDetailsForEmailUpdateToken(code as string, {
|
||||
transaction,
|
||||
lock: transaction.LOCK.UPDATE,
|
||||
});
|
||||
user = res.user;
|
||||
email = res.email;
|
||||
} catch (err) {
|
||||
ctx.redirect(`/?notice=expired-token`);
|
||||
return;
|
||||
}
|
||||
|
||||
const { user: actor } = ctx.state.auth;
|
||||
authorize(actor, "update", user);
|
||||
|
||||
// Check if email domain is allowed
|
||||
if (!(await actor.team.isDomainAllowed(email))) {
|
||||
throw ValidationError("The domain is not allowed for this workspace");
|
||||
}
|
||||
|
||||
// Check if email already exists in workspace
|
||||
if (await User.findByEmail(ctx, email)) {
|
||||
throw ValidationError("User with email already exists");
|
||||
}
|
||||
|
||||
user.email = email;
|
||||
await Event.createFromContext(ctx, {
|
||||
name: "users.update",
|
||||
userId: user.id,
|
||||
changes: user.changeset,
|
||||
});
|
||||
await user.save({ transaction });
|
||||
|
||||
ctx.redirect(settingsPath());
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.update",
|
||||
auth(),
|
||||
validate(T.UsersUpdateSchema),
|
||||
transaction(),
|
||||
async (ctx: APIContext<T.UsersUpdateReq>) => {
|
||||
const { auth, transaction } = ctx.state;
|
||||
const actor = auth.user;
|
||||
const { id, name, avatarUrl, language, preferences, timezone } =
|
||||
ctx.input.body;
|
||||
|
||||
let user: User | null = actor;
|
||||
if (id) {
|
||||
user = await User.findByPk(id, {
|
||||
rejectOnEmpty: true,
|
||||
transaction,
|
||||
lock: transaction.LOCK.UPDATE,
|
||||
});
|
||||
}
|
||||
authorize(actor, "update", user);
|
||||
const includeDetails = !!can(actor, "readDetails", user);
|
||||
|
||||
if (name) {
|
||||
user.name = name;
|
||||
}
|
||||
if (avatarUrl !== undefined) {
|
||||
user.avatarUrl = avatarUrl;
|
||||
}
|
||||
if (language) {
|
||||
user.language = language;
|
||||
}
|
||||
if (preferences) {
|
||||
for (const key of Object.keys(preferences) as Array<UserPreference>) {
|
||||
user.setPreference(key, preferences[key] as boolean);
|
||||
}
|
||||
}
|
||||
if (timezone) {
|
||||
user.timezone = timezone;
|
||||
}
|
||||
|
||||
await Event.createFromContext(ctx, {
|
||||
name: "users.update",
|
||||
userId: user.id,
|
||||
changes: user.changeset,
|
||||
});
|
||||
await user.save({ transaction });
|
||||
|
||||
ctx.body = {
|
||||
data: presentUser(user, {
|
||||
includeDetails,
|
||||
}),
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
// Admin specific
|
||||
|
||||
/**
|
||||
* Promote a user to an admin.
|
||||
*
|
||||
* @deprecated Use `users.update_role` instead.
|
||||
*/
|
||||
router.post(
|
||||
"users.promote",
|
||||
auth({ role: UserRole.Admin }),
|
||||
validate(T.UsersPromoteSchema),
|
||||
transaction(),
|
||||
(ctx: APIContext<T.UsersPromoteReq>) => {
|
||||
const forward = ctx as unknown as APIContext<T.UsersChangeRoleReq>;
|
||||
forward.input = {
|
||||
body: {
|
||||
id: ctx.input.body.id,
|
||||
role: UserRole.Admin,
|
||||
},
|
||||
};
|
||||
|
||||
return updateRole(forward);
|
||||
}
|
||||
);
|
||||
|
||||
/**
|
||||
* Demote a user to another role.
|
||||
*
|
||||
* @deprecated Use `users.update_role` instead.
|
||||
*/
|
||||
router.post(
|
||||
"users.demote",
|
||||
auth({ role: UserRole.Admin }),
|
||||
validate(T.UsersDemoteSchema),
|
||||
transaction(),
|
||||
(ctx: APIContext<T.UsersDemoteReq>) => {
|
||||
const forward = ctx as unknown as APIContext<T.UsersChangeRoleReq>;
|
||||
forward.input = {
|
||||
body: {
|
||||
id: ctx.input.body.id,
|
||||
role: ctx.input.body.to,
|
||||
},
|
||||
};
|
||||
|
||||
return updateRole(forward);
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.update_role",
|
||||
auth({ role: UserRole.Admin }),
|
||||
validate(T.UsersChangeRoleSchema),
|
||||
transaction(),
|
||||
updateRole
|
||||
);
|
||||
|
||||
async function updateRole(ctx: APIContext<T.UsersChangeRoleReq>) {
|
||||
const { transaction } = ctx.state;
|
||||
const userId = ctx.input.body.id;
|
||||
const role = ctx.input.body.role;
|
||||
const actor = ctx.state.auth.user;
|
||||
|
||||
const user = await User.findByPk(userId, {
|
||||
rejectOnEmpty: true,
|
||||
transaction,
|
||||
lock: transaction.LOCK.UPDATE,
|
||||
});
|
||||
await Team.findByPk(user.teamId, {
|
||||
transaction,
|
||||
lock: transaction.LOCK.UPDATE,
|
||||
});
|
||||
|
||||
let name;
|
||||
|
||||
if (user.role === role) {
|
||||
throw ValidationError("User is already in that role");
|
||||
}
|
||||
if (user.id === actor.id) {
|
||||
throw ValidationError("You cannot change your own role");
|
||||
}
|
||||
|
||||
if (UserRoleHelper.canDemote(user, role)) {
|
||||
name = "users.demote";
|
||||
authorize(actor, "demote", user);
|
||||
}
|
||||
if (UserRoleHelper.canPromote(user, role)) {
|
||||
name = "users.promote";
|
||||
authorize(actor, "promote", user);
|
||||
}
|
||||
|
||||
await user.update({ role }, { transaction });
|
||||
|
||||
await Event.createFromContext(ctx, {
|
||||
name,
|
||||
userId,
|
||||
data: {
|
||||
name: user.name,
|
||||
role,
|
||||
},
|
||||
});
|
||||
|
||||
const includeDetails = !!can(actor, "readDetails", user);
|
||||
|
||||
ctx.body = {
|
||||
data: presentUser(user, {
|
||||
includeDetails,
|
||||
}),
|
||||
policies: presentPolicies(actor, [user]),
|
||||
};
|
||||
}
|
||||
|
||||
router.post(
|
||||
"users.suspend",
|
||||
auth(),
|
||||
validate(T.UsersSuspendSchema),
|
||||
transaction(),
|
||||
async (ctx: APIContext<T.UsersSuspendReq>) => {
|
||||
const { transaction } = ctx.state;
|
||||
const userId = ctx.input.body.id;
|
||||
const actor = ctx.state.auth.user;
|
||||
const user = await User.findByPk(userId, {
|
||||
rejectOnEmpty: true,
|
||||
transaction,
|
||||
lock: transaction.LOCK.UPDATE,
|
||||
});
|
||||
authorize(actor, "suspend", user);
|
||||
|
||||
await userSuspender({
|
||||
user,
|
||||
actorId: actor.id,
|
||||
ip: ctx.request.ip,
|
||||
transaction,
|
||||
});
|
||||
const includeDetails = !!can(actor, "readDetails", user);
|
||||
|
||||
ctx.body = {
|
||||
data: presentUser(user, {
|
||||
includeDetails,
|
||||
}),
|
||||
policies: presentPolicies(actor, [user]),
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.activate",
|
||||
auth(),
|
||||
validate(T.UsersActivateSchema),
|
||||
transaction(),
|
||||
async (ctx: APIContext<T.UsersActivateReq>) => {
|
||||
const { transaction } = ctx.state;
|
||||
const userId = ctx.input.body.id;
|
||||
const actor = ctx.state.auth.user;
|
||||
const user = await User.findByPk(userId, {
|
||||
rejectOnEmpty: true,
|
||||
transaction,
|
||||
lock: transaction.LOCK.UPDATE,
|
||||
});
|
||||
authorize(actor, "activate", user);
|
||||
|
||||
await userUnsuspender({
|
||||
user,
|
||||
actorId: actor.id,
|
||||
transaction,
|
||||
ip: ctx.request.ip,
|
||||
});
|
||||
const includeDetails = !!can(actor, "readDetails", user);
|
||||
|
||||
ctx.body = {
|
||||
data: presentUser(user, {
|
||||
includeDetails,
|
||||
}),
|
||||
policies: presentPolicies(actor, [user]),
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.invite",
|
||||
rateLimiter(RateLimiterStrategy.TenPerHour),
|
||||
auth(),
|
||||
validate(T.UsersInviteSchema),
|
||||
async (ctx: APIContext<T.UsersInviteReq>) => {
|
||||
const { invites } = ctx.input.body;
|
||||
const actor = ctx.state.auth.user;
|
||||
|
||||
if (invites.length > UserValidation.maxInvitesPerRequest) {
|
||||
throw ValidationError(
|
||||
`You can only invite up to ${UserValidation.maxInvitesPerRequest} users at a time`
|
||||
);
|
||||
}
|
||||
|
||||
const { user } = ctx.state.auth;
|
||||
const team = await Team.findByPk(user.teamId);
|
||||
authorize(user, "inviteUser", team);
|
||||
|
||||
const response = await userInviter({
|
||||
user,
|
||||
invites,
|
||||
ip: ctx.request.ip,
|
||||
});
|
||||
|
||||
ctx.body = {
|
||||
data: {
|
||||
sent: response.sent,
|
||||
users: response.users.map((user) =>
|
||||
presentUser(user, { includeEmail: !!can(actor, "readEmail", user) })
|
||||
),
|
||||
},
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.resendInvite",
|
||||
auth(),
|
||||
validate(T.UsersResendInviteSchema),
|
||||
transaction(),
|
||||
async (ctx: APIContext<T.UsersResendInviteReq>) => {
|
||||
const { id } = ctx.input.body;
|
||||
const { auth, transaction } = ctx.state;
|
||||
const actor = auth.user;
|
||||
|
||||
const user = await User.findByPk(id, {
|
||||
lock: transaction.LOCK.UPDATE,
|
||||
transaction,
|
||||
});
|
||||
authorize(actor, "resendInvite", user);
|
||||
|
||||
if (user.getFlag(UserFlag.InviteSent) > 2) {
|
||||
throw ValidationError("This invite has been sent too many times");
|
||||
}
|
||||
|
||||
await new InviteEmail({
|
||||
to: user.email,
|
||||
name: user.name,
|
||||
actorName: actor.name,
|
||||
actorEmail: actor.email,
|
||||
teamName: actor.team.name,
|
||||
teamUrl: actor.team.url,
|
||||
}).schedule();
|
||||
|
||||
user.incrementFlag(UserFlag.InviteSent);
|
||||
await user.save({ transaction });
|
||||
|
||||
if (env.isDevelopment) {
|
||||
logger.info(
|
||||
"email",
|
||||
`Sign in immediately: ${
|
||||
env.URL
|
||||
}/auth/email.callback?token=${user.getEmailSigninToken()}`
|
||||
);
|
||||
}
|
||||
|
||||
ctx.body = {
|
||||
success: true,
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.requestDelete",
|
||||
rateLimiter(RateLimiterStrategy.FivePerHour),
|
||||
auth(),
|
||||
async (ctx: APIContext) => {
|
||||
if (!emailEnabled) {
|
||||
throw ValidationError("Email support is not setup for this instance");
|
||||
}
|
||||
|
||||
const { user } = ctx.state.auth;
|
||||
authorize(user, "delete", user);
|
||||
|
||||
await new ConfirmUserDeleteEmail({
|
||||
to: user.email,
|
||||
deleteConfirmationCode: user.deleteConfirmationCode,
|
||||
teamName: user.team.name,
|
||||
teamUrl: user.team.url,
|
||||
}).schedule();
|
||||
|
||||
ctx.body = {
|
||||
success: true,
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.delete",
|
||||
rateLimiter(RateLimiterStrategy.TenPerHour),
|
||||
auth(),
|
||||
validate(T.UsersDeleteSchema),
|
||||
transaction(),
|
||||
async (ctx: APIContext<T.UsersDeleteSchemaReq>) => {
|
||||
const { transaction } = ctx.state;
|
||||
const { id, code } = ctx.input.body;
|
||||
const actor = ctx.state.auth.user;
|
||||
let user: User;
|
||||
|
||||
if (id) {
|
||||
user = await User.findByPk(id, {
|
||||
rejectOnEmpty: true,
|
||||
transaction,
|
||||
lock: transaction.LOCK.UPDATE,
|
||||
});
|
||||
} else {
|
||||
user = actor;
|
||||
}
|
||||
authorize(actor, "delete", user);
|
||||
|
||||
// If we're attempting to delete our own account then a confirmation code
|
||||
// is required. This acts as CSRF protection.
|
||||
if ((!id || id === actor.id) && emailEnabled) {
|
||||
const deleteConfirmationCode = user.deleteConfirmationCode;
|
||||
|
||||
if (!safeEqual(code, deleteConfirmationCode)) {
|
||||
throw ValidationError("The confirmation code was incorrect");
|
||||
}
|
||||
}
|
||||
|
||||
await userDestroyer(ctx, {
|
||||
user,
|
||||
});
|
||||
|
||||
ctx.body = {
|
||||
success: true,
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.notificationsSubscribe",
|
||||
auth(),
|
||||
validate(T.UsersNotificationsSubscribeSchema),
|
||||
transaction(),
|
||||
async (ctx: APIContext<T.UsersNotificationsSubscribeReq>) => {
|
||||
const { eventType } = ctx.input.body;
|
||||
const { transaction } = ctx.state;
|
||||
const { user } = ctx.state.auth;
|
||||
user.setNotificationEventType(eventType, true);
|
||||
|
||||
await Event.createFromContext(ctx, {
|
||||
name: "users.update",
|
||||
userId: user.id,
|
||||
changes: user.changeset,
|
||||
});
|
||||
await user.save({ transaction });
|
||||
|
||||
ctx.body = {
|
||||
data: presentUser(user, { includeDetails: true }),
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
router.post(
|
||||
"users.notificationsUnsubscribe",
|
||||
auth(),
|
||||
validate(T.UsersNotificationsUnsubscribeSchema),
|
||||
transaction(),
|
||||
async (ctx: APIContext<T.UsersNotificationsUnsubscribeReq>) => {
|
||||
const { eventType } = ctx.input.body;
|
||||
const { transaction } = ctx.state;
|
||||
const { user } = ctx.state.auth;
|
||||
user.setNotificationEventType(eventType, false);
|
||||
|
||||
await Event.createFromContext(ctx, {
|
||||
name: "users.update",
|
||||
userId: user.id,
|
||||
changes: user.changeset,
|
||||
});
|
||||
await user.save({ transaction });
|
||||
|
||||
ctx.body = {
|
||||
data: presentUser(user, { includeDetails: true }),
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
export default router;
|
||||
const emailEnabled = !!(env.SMTP_HOST || env.SMTP_SERVICE || env.isDevelopment);
|
||||
|
||||
Reference in New Issue
Block a user