Skip to content

Commit 20cebdd

Browse files
committed
fix clearcache issue doing signup
1 parent 573c9b1 commit 20cebdd

2 files changed

Lines changed: 38 additions & 5 deletions

File tree

OpenFlow/src/DBHelper.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,9 @@ export class DBHelper {
5454
keys = await this.memoryCache.keys();
5555
}
5656
for (var i = 0; i < keys.length; i++) {
57-
this.memoryCache.del(keys[i]);
57+
if (keys[i] && !keys[i].startsWith("requesttoken")) {
58+
this.memoryCache.del(keys[i]);
59+
}
5860
}
5961
if (Config.log_cache) Logger.instanse.debug("clearCache called with reason: " + reason);
6062
}

OpenFlow/src/LoginProvider.ts

Lines changed: 35 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -424,15 +424,46 @@ export class LoginProvider {
424424
try {
425425
const key = req.query.key;
426426
var exists = await DBHelper.FindRequestTokenID(key, span);
427-
if (NoderedUtil.IsNullUndefinded(exists)) return res.status(500).send({ message: "Illegal key" });
428-
res.status(200).send(Object.assign(exists, { message: "ok" }));
427+
if (NoderedUtil.IsNullUndefinded(exists)) {
428+
res.status(200).send({ message: "Illegal key" });
429+
return;
430+
// return res.status(500).send({ message: "Illegal key" });
431+
}
432+
429433
if (!NoderedUtil.IsNullEmpty(exists.jwt)) {
430-
await DBHelper.RemoveRequestTokenID(key, span);
434+
if (Config.validate_user_form != "") {
435+
try {
436+
var tuser = await await Crypt.verityToken(exists.jwt);
437+
var user = await DBHelper.FindById(tuser._id, exists.jwt, span);
438+
if (user.validated == true) {
439+
await DBHelper.RemoveRequestTokenID(key, span);
440+
res.status(200).send(Object.assign(exists, { message: "ok" }));
441+
442+
} else {
443+
res.status(200).send({ message: "ok" });
444+
}
445+
} catch (error) {
446+
Logger.instanse.error(error.message ? error.message : error);
447+
}
448+
} else {
449+
res.status(200).send(Object.assign(exists, { message: "ok" }));
450+
await DBHelper.RemoveRequestTokenID(key, span);
451+
}
452+
} else {
453+
res.status(200).send(Object.assign(exists, { message: "ok" }));
431454
}
432455
} catch (error) {
456+
Logger.instanse.error(error.message ? error.message : error);
433457
span?.recordException(error);
434-
return res.status(500).send({ message: error.message ? error.message : error });
458+
try {
459+
res.status(500).send({ message: error.message ? error.message : error });
460+
} catch (error) {
461+
}
435462
} finally {
463+
try {
464+
res.end();
465+
} catch (error) {
466+
}
436467
Logger.otel.endSpan(span);
437468
}
438469
});

0 commit comments

Comments
 (0)