summaryrefslogtreecommitdiff
path: root/src/server/api/streaming.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2021-04-18 23:25:55 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2021-04-18 23:25:55 +0900
commit631091940ba13f23dd705596a243c8c585f0d64e (patch)
tree571966ad2bf8dde14026b4d253c0bb2d597c580f /src/server/api/streaming.ts
parentMerge branch 'develop' (diff)
parent12.77.1 (diff)
downloadmisskey-631091940ba13f23dd705596a243c8c585f0d64e.tar.gz
misskey-631091940ba13f23dd705596a243c8c585f0d64e.tar.bz2
misskey-631091940ba13f23dd705596a243c8c585f0d64e.zip
Merge branch 'develop'
Diffstat (limited to 'src/server/api/streaming.ts')
-rw-r--r--src/server/api/streaming.ts18
1 files changed, 12 insertions, 6 deletions
diff --git a/src/server/api/streaming.ts b/src/server/api/streaming.ts
index 7224c23570..57e8c90860 100644
--- a/src/server/api/streaming.ts
+++ b/src/server/api/streaming.ts
@@ -35,10 +35,22 @@ module.exports = (server: http.Server) => {
const main = new MainStreamConnection(connection, ev, user, app);
+ const intervalId = user ? setInterval(() => {
+ Users.update(user.id, {
+ lastActiveDate: new Date(),
+ });
+ }, 1000 * 60 * 5) : null;
+ if (user) {
+ Users.update(user.id, {
+ lastActiveDate: new Date(),
+ });
+ }
+
connection.once('close', () => {
ev.removeAllListeners();
main.dispose();
redisClient.off('message', onRedisMessage);
+ if (intervalId) clearInterval(intervalId);
});
connection.on('message', async (data) => {
@@ -46,11 +58,5 @@ module.exports = (server: http.Server) => {
connection.send('pong');
}
});
-
- if (user) {
- Users.update(user.id, {
- lastActiveDate: new Date(),
- });
- }
});
};