Skip to content

Commit c3a4498

Browse files
committed
return distinct events from drill_meta
1 parent 31d9896 commit c3a4498

File tree

1 file changed

+18
-6
lines changed

1 file changed

+18
-6
lines changed

bin/scripts/expire-data/delete_custom_events_regex.js

+18-6
Original file line numberDiff line numberDiff line change
@@ -50,14 +50,26 @@ Promise.all([pluginManager.dbConnection("countly"), pluginManager.dbConnection("
5050
}
5151
]).toArray();
5252
events = events.length ? events[0].list : [];
53-
var metaEvents = await drillDb.collection("drill_meta").find(
53+
const metaEvents = await drillDb.collection("drill_meta").aggregate([
5454
{
55-
'app_id': app._id + "",
56-
"type": "e",
57-
"e": {$regex: regex, $options: CASE_INSENSITIVE ? "i" : "", $nin: events}
55+
$match: {
56+
'app_id': app._id + "",
57+
"type": "e",
58+
"e": { $regex: regex, $options: CASE_INSENSITIVE ? "i" : "", $nin: events }
59+
}
5860
},
59-
{ _id: 0, e: 1}
60-
).toArray();
61+
{
62+
$group: {
63+
_id: "$e"
64+
}
65+
},
66+
{
67+
$project: {
68+
_id: 0,
69+
e: "$_id"
70+
}
71+
}
72+
]).toArray();
6173
events = events.concat(metaEvents.map(e => e.e));
6274
}
6375
catch (err) {

0 commit comments

Comments
 (0)