90 lines
2.4 KiB
TypeScript
90 lines
2.4 KiB
TypeScript
import has from "lodash/has";
|
|
import { Transaction } from "sequelize";
|
|
import { TeamPreference } from "@shared/types";
|
|
import env from "@server/env";
|
|
import { Event, Team, TeamDomain, User } from "@server/models";
|
|
|
|
type Props = {
|
|
params: Partial<Omit<Team, "allowedDomains">> & { allowedDomains?: string[] };
|
|
ip?: string;
|
|
user: User;
|
|
team: Team;
|
|
transaction: Transaction;
|
|
};
|
|
|
|
const teamUpdater = async ({ params, user, team, ip, transaction }: Props) => {
|
|
const { allowedDomains, preferences, subdomain, ...attributes } = params;
|
|
team.setAttributes(attributes);
|
|
|
|
if (subdomain !== undefined && env.isCloudHosted) {
|
|
team.subdomain = subdomain === "" ? null : subdomain;
|
|
}
|
|
|
|
if (allowedDomains !== undefined) {
|
|
const existingAllowedDomains = await TeamDomain.findAll({
|
|
where: { teamId: team.id },
|
|
transaction,
|
|
});
|
|
|
|
// Only keep existing domains if they are still in the list of allowed domains
|
|
const newAllowedDomains = team.allowedDomains.filter((existingTeamDomain) =>
|
|
allowedDomains.includes(existingTeamDomain.name)
|
|
);
|
|
|
|
// Add new domains
|
|
const existingDomains = team.allowedDomains.map((x) => x.name);
|
|
const newDomains = allowedDomains.filter(
|
|
(newDomain) => newDomain !== "" && !existingDomains.includes(newDomain)
|
|
);
|
|
await Promise.all(
|
|
newDomains.map(async (newDomain) => {
|
|
newAllowedDomains.push(
|
|
await TeamDomain.create(
|
|
{
|
|
name: newDomain,
|
|
teamId: team.id,
|
|
createdById: user.id,
|
|
},
|
|
{ transaction }
|
|
)
|
|
);
|
|
})
|
|
);
|
|
|
|
// Destroy the existing TeamDomains that were removed
|
|
const deletedDomains = existingAllowedDomains.filter(
|
|
(x) => !allowedDomains.includes(x.name)
|
|
);
|
|
await Promise.all(deletedDomains.map((x) => x.destroy({ transaction })));
|
|
team.allowedDomains = newAllowedDomains;
|
|
}
|
|
|
|
if (preferences) {
|
|
for (const value of Object.values(TeamPreference)) {
|
|
if (has(preferences, value)) {
|
|
team.setPreference(value, preferences[value]);
|
|
}
|
|
}
|
|
}
|
|
|
|
const changes = team.changeset;
|
|
if (Object.keys(changes.attributes).length) {
|
|
await Event.create(
|
|
{
|
|
name: "teams.update",
|
|
actorId: user.id,
|
|
teamId: user.teamId,
|
|
ip,
|
|
changes,
|
|
},
|
|
{
|
|
transaction,
|
|
}
|
|
);
|
|
}
|
|
|
|
return team.save({ transaction });
|
|
};
|
|
|
|
export default teamUpdater;
|