mirror of
https://github.com/rgrgogu/new_starr.git
synced 2026-09-27 00:12:54 +08:00
make default_group as utility and added more things
Signed-off-by: Kenneth Obsequio <k80308392@gmail.com>
This commit is contained in:
@@ -24,6 +24,7 @@ const { getFieldValues } = require('../../utils/fieldValues.util');
|
||||
const { excludeAttributes: usersExclude, jsonbSchemas: usersSchemas } = require('../../models/users/users.attributes');
|
||||
const { excludeAttributes: groupExclude, jsonbSchemas: groupSchemas, computedAttributes: groupComputed } = require('../../models/users/user_groups.attributes');
|
||||
const logActivity = require('../../utils/logActivity.util');
|
||||
const { dropDefaultGroupMembership, reconcileDefaultGroup } = require('../../utils/defaultGroup.util');
|
||||
|
||||
// ─── Helper — generate a unique group code ────────────────────────────────────
|
||||
/**
|
||||
@@ -416,6 +417,8 @@ exports.addUserToGroup = async (req, res) => {
|
||||
{ ignoreDuplicates: true }
|
||||
);
|
||||
|
||||
await dropDefaultGroupMembership(user_ids, group_id, { updatedBy: req.user.user_id });
|
||||
|
||||
logActivity(req.user.user_id, 'add_user_to_group', { entityType: 'group', entityId: Number(group_id), details: { user_ids } });
|
||||
return R.success(res, 'Users added to group.');
|
||||
} catch (err) {
|
||||
@@ -447,6 +450,8 @@ exports.removeUserFromGroup = async (req, res) => {
|
||||
);
|
||||
await mdl_UserGroupMembers.destroy({ where: { user_id: user_ids, group_id } });
|
||||
|
||||
await reconcileDefaultGroup(user_ids, { createdBy: req.user.user_id });
|
||||
|
||||
logActivity(req.user.user_id, 'remove_user_from_group', { entityType: 'group', entityId: Number(group_id), details: { user_ids } });
|
||||
return R.success(res, 'Users removed from group.');
|
||||
} catch (err) {
|
||||
|
||||
@@ -39,6 +39,7 @@ const mdl_Users = require('../models/users/users.mdl');
|
||||
const mdl_UserSessions = require('../models/users/user_sessions.mdl');
|
||||
const { checkAccountStatus } = require('../services/accountStatus.service');
|
||||
const { mdl_UserGroups, mdl_UserGroupMembers } = require('../models/users/user_groups.mdl')
|
||||
const { NOGRP_CODE, getDefaultGroupId, enrollDefaultGroup } = require('../utils/defaultGroup.util');
|
||||
const { generateTokens, verifyRefreshToken, hashToken, shouldRotateRefreshToken } = require('../utils/token.util');
|
||||
const { generateState, generateNonce, generatePKCE, buildAuthUrl, exchangeCode, verifyIdToken } = require('../utils/google_oidc.util');
|
||||
const { generateOTP, getOTPExpiry, isOTPExpired } = require('../utils/otp.util');
|
||||
@@ -135,8 +136,7 @@ exports.register = async (req, res) => {
|
||||
}
|
||||
|
||||
// ── Resolve enroll target (explicit group or NOGRP fallback) ──────────────
|
||||
const enrollGroup = group
|
||||
?? await mdl_UserGroups.findOne({ where: { group_code: 'NOGRP', is_active: true } });
|
||||
const enrollGroupId = group?.group_id ?? await getDefaultGroupId();
|
||||
|
||||
// ── Create user ───────────────────────────────────────────────────────────
|
||||
const hashed = await bcrypt.hash(password, 12);
|
||||
@@ -160,9 +160,9 @@ exports.register = async (req, res) => {
|
||||
}, { transaction });
|
||||
|
||||
// ── Enroll into group ─────────────────────────────────────────────────────
|
||||
if (enrollGroup) {
|
||||
if (enrollGroupId) {
|
||||
await mdl_UserGroupMembers.create({
|
||||
group_id: enrollGroup.group_id,
|
||||
group_id: enrollGroupId,
|
||||
user_id: user.user_id,
|
||||
createdBy: null,
|
||||
}, { transaction });
|
||||
@@ -255,7 +255,7 @@ exports.verifyOTP = async (req, res) => {
|
||||
updatedAt: now,
|
||||
},
|
||||
];
|
||||
if (grp?.group_code === 'NOGRP') {
|
||||
if (grp?.group_code === NOGRP_CODE) {
|
||||
notifications.push({
|
||||
user_id: user.user_id,
|
||||
...NOTIFICATION_REGISTRY.nogrp_welcome.build(),
|
||||
@@ -465,14 +465,7 @@ exports.googleCallback = async (req, res) => {
|
||||
},
|
||||
}, { transaction: t });
|
||||
|
||||
const noGrp = await mdl_UserGroups.findOne({ where: { group_code: 'NOGRP', is_active: true }, transaction: t });
|
||||
if (noGrp) {
|
||||
await mdl_UserGroupMembers.create({
|
||||
group_id: noGrp.group_id,
|
||||
user_id: user.user_id,
|
||||
createdBy: null,
|
||||
}, { transaction: t });
|
||||
}
|
||||
await enrollDefaultGroup(user.user_id, { transaction: t });
|
||||
|
||||
await t.commit();
|
||||
|
||||
|
||||
Reference in New Issue
Block a user