Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Appearance settings

Commit dc2e406

Browse filesBrowse files
committed
fix: use event service
1 parent c7c7f78 commit dc2e406
Copy full SHA for dc2e406

File tree

Expand file treeCollapse file tree

1 file changed

+2
-16
lines changed
Filter options
Expand file treeCollapse file tree

1 file changed

+2
-16
lines changed

‎src/backend/src/routers/signup.js

Copy file name to clipboardExpand all lines: src/backend/src/routers/signup.js
+2-16Lines changed: 2 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -84,17 +84,6 @@ module.exports = eggspress(['/signup'], {
8484

8585

8686
// send event
87-
async function emitAsync(eventName, data) {
88-
const listeners = process.listeners(eventName);
89-
90-
if (listeners.length === 0) {
91-
return data;
92-
}
93-
94-
await Promise.all(listeners.map(listener => listener(data)));
95-
return data;
96-
}
97-
9887
let event = {
9988
allow: true,
10089
ip: req.headers?.['x-forwarded-for'] ||
@@ -103,11 +92,8 @@ module.exports = eggspress(['/signup'], {
10392
body: req.body,
10493
};
10594

106-
const MAX_WAIT = 5 * 1000;
107-
await Promise.race([
108-
emitAsync('puter.signup', event),
109-
new Promise(resolve => setTimeout(() => resolve(), MAX_WAIT)),
110-
])
95+
const svc_event = Context.get('services').get('event');
96+
await svc_event.emit('puter.signup', event)
11197

11298
if ( ! event.allow ) {
11399
return res.status(400).send(event.error ?? 'You are not allowed to sign up.');

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.