@@ -8,12 +8,8 @@ const firestore = require("../utils/firestore");
8
8
const { fetchWallet, createWallet } = require ( "../models/wallets" ) ;
9
9
const { updateUserStatus } = require ( "../models/userStatus" ) ;
10
10
const { arraysHaveCommonItem, chunks } = require ( "../utils/array" ) ;
11
- const {
12
- ALLOWED_FILTER_PARAMS ,
13
- FIRESTORE_IN_CLAUSE_SIZE ,
14
- USERS_PATCH_HANDLER_SUCCESS_MESSAGES ,
15
- USERS_PATCH_HANDLER_ERROR_MESSAGES ,
16
- } = require ( "../constants/users" ) ;
11
+ const { archiveUsers } = require ( "../services/users" ) ;
12
+ const { ALLOWED_FILTER_PARAMS , FIRESTORE_IN_CLAUSE_SIZE } = require ( "../constants/users" ) ;
17
13
const { DOCUMENT_WRITE_SIZE } = require ( "../constants/constants" ) ;
18
14
const { userState } = require ( "../constants/userStatus" ) ;
19
15
const { BATCH_SIZE_IN_CLAUSE } = require ( "../constants/firebase" ) ;
@@ -31,46 +27,6 @@ const { formatUsername } = require("../utils/username");
31
27
const { logType } = require ( "../constants/logs" ) ;
32
28
const { addLog } = require ( "../services/logService" ) ;
33
29
34
- const archiveUsers = async ( usersData ) => {
35
- const batch = firestore . batch ( ) ;
36
- const usersBatch = [ ] ;
37
- const summary = {
38
- totalUsersArchived : 0 ,
39
- totalOperationsFailed : 0 ,
40
- updatedUserDetails : [ ] ,
41
- failedUserDetails : [ ] ,
42
- } ;
43
-
44
- usersData . forEach ( ( user ) => {
45
- const { id, first_name : firstName , last_name : lastName } = user ;
46
- const updatedUserData = {
47
- ...user ,
48
- roles : {
49
- ...user . roles ,
50
- archived : true ,
51
- } ,
52
- updated_at : Date . now ( ) ,
53
- } ;
54
- batch . update ( userModel . doc ( id ) , updatedUserData ) ;
55
- usersBatch . push ( { id, firstName, lastName } ) ;
56
- } ) ;
57
-
58
- try {
59
- await batch . commit ( ) ;
60
- summary . totalUsersArchived += usersData . length ;
61
- summary . updatedUserDetails = [ ...usersBatch ] ;
62
- return {
63
- message : USERS_PATCH_HANDLER_SUCCESS_MESSAGES . ARCHIVE_USERS . SUCCESSFULLY_COMPLETED_BATCH_UPDATES ,
64
- ...summary ,
65
- } ;
66
- } catch ( err ) {
67
- logger . error ( "Firebase batch Operation Failed!" ) ;
68
- summary . totalOperationsFailed += usersData . length ;
69
- summary . failedUserDetails = [ ...usersBatch ] ;
70
- return { message : USERS_PATCH_HANDLER_ERROR_MESSAGES . ARCHIVE_USERS . BATCH_DATA_UPDATED_FAILED , ...summary } ;
71
- }
72
- } ;
73
-
74
30
/**
75
31
* Adds or updates the user data
76
32
*
@@ -1088,7 +1044,6 @@ const fetchUsersNotInDiscordServer = async () => {
1088
1044
} ;
1089
1045
1090
1046
module . exports = {
1091
- archiveUsers,
1092
1047
addOrUpdate,
1093
1048
fetchPaginatedUsers,
1094
1049
fetchUser,
0 commit comments