Skip to content

Commit eef9703

Browse files
authored
fix(domaincache): ZMS-266: domaincache add updates where necessary (#866)
1 parent d0bd732 commit eef9703

File tree

1 file changed

+27
-0
lines changed

1 file changed

+27
-0
lines changed

lib/api/addresses.js

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1075,6 +1075,15 @@ module.exports = (db, server, userHandler, settingsHandler) => {
10751075
}
10761076
}
10771077

1078+
try {
1079+
const domain = addressData.address.split('@')[1];
1080+
if (domain && !domain.includes('*')) {
1081+
await db.users.collection('domaincache').insertOne({ domain });
1082+
}
1083+
} catch {
1084+
// ignore
1085+
}
1086+
10781087
if (Object.keys(updates).length) {
10791088
try {
10801089
await db.users.collection('addresses').updateOne(
@@ -2041,6 +2050,15 @@ module.exports = (db, server, userHandler, settingsHandler) => {
20412050
$set: updates
20422051
}
20432052
);
2053+
2054+
try {
2055+
const domain = addressData.address.split('@')[1];
2056+
if (domain && !domain.includes('*')) {
2057+
await db.users.collection('domaincache').insertOne({ domain });
2058+
}
2059+
} catch {
2060+
// ignore
2061+
}
20442062
} catch (err) {
20452063
if (err.code === 11000) {
20462064
res.status(400);
@@ -2641,6 +2659,15 @@ module.exports = (db, server, userHandler, settingsHandler) => {
26412659
log.error('RenameDomain', 'ALIASERR old=%s new=%s error=%s', oldDomain, newDomain, err.message);
26422660
}
26432661

2662+
try {
2663+
const domain = newDomain;
2664+
if (domain && !domain.includes('*')) {
2665+
await db.users.collection('domaincache').insertOne({ domain });
2666+
}
2667+
} catch {
2668+
// ignore
2669+
}
2670+
26442671
await publish(db.redis, {
26452672
ev: ADDRESS_DOMAIN_RENAMED,
26462673
previous: oldDomain,

0 commit comments

Comments
 (0)