github/directus
1
0
Fork 0
mirror of https://github.com/directus/directus.git synced 2026-01-23 02:18:00 -05:00
Code Issues Packages Projects Releases Wiki Activity

Run invite in transaction, rollback on error

Browse Source 
Fixes #4569
This commit is contained in:
rijkvanzanten
2021-04-08 17:33:04 -04:00
parent 48f2653406
commit 706b07bb02
1 changed files with 16 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
api/src/services/users.ts
View File

@@ -87,16 +87,24 @@ export class UsersService extends ItemsService {
throw new InvalidPayloadException(`Url "${url}" can't be used to invite users.`);
}
for (const email of emails) {
await this.service.create({ email, role, status: 'invited' });
await this.knex.transaction(async (trx) => {
const service = new ItemsService('directus_users', {
schema: this.schema,
accountability: this.accountability,
knex: trx,
});
const payload = { email, scope: 'invite' };
const token = jwt.sign(payload, env.SECRET as string, { expiresIn: '7d' });
const inviteURL = url ?? env.PUBLIC_URL + '/admin/accept-invite';
const acceptURL = inviteURL + '?token=' + token;
for (const email of emails) {
await service.create({ email, role, status: 'invited' });
await sendInviteMail(email, acceptURL);
}
const payload = { email, scope: 'invite' };
const token = jwt.sign(payload, env.SECRET as string, { expiresIn: '7d' });
const inviteURL = url ?? env.PUBLIC_URL + '/admin/accept-invite';
const acceptURL = inviteURL + '?token=' + token;
await sendInviteMail(email, acceptURL);
}
});
}
async acceptInvite(token: string, password: string) {