github/overleaf
1
0
Fork 0
mirror of https://github.com/overleaf/overleaf.git synced 2024-11-29 07:13:39 -05:00
Code Issues Projects Releases Packages Wiki Activity

add transport type to metrics

Browse source
This commit is contained in:
Brian Gough 2021-05-10 10:16:50 +01:00
parent a3009d2ef2
commit 9622b341b7
2 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
services/real-time/app/js/Router.js
View file

@ -153,7 +153,7 @@ module.exports = Router = {
client.publicId = 'P.' + base64id.generateId() client.publicId = 'P.' + base64id.generateId()
client.emit('connectionAccepted', null, client.publicId) client.emit('connectionAccepted', null, client.publicId)
metrics.inc('socket-io.connection') metrics.inc('socket-io.connection', 1, { status: client.transport })
metrics.gauge('socket-io.clients', io.sockets.clients().length) metrics.gauge('socket-io.clients', io.sockets.clients().length)
logger.log({ session, client_id: client.id }, 'client connected') logger.log({ session, client_id: client.id }, 'client connected')
@ -211,7 +211,7 @@ module.exports = Router = {
}) })
client.on('disconnect', function () { client.on('disconnect', function () {
metrics.inc('socket-io.disconnect') metrics.inc('socket-io.disconnect', 1, { status: client.transport })
metrics.gauge('socket-io.clients', io.sockets.clients().length) metrics.gauge('socket-io.clients', io.sockets.clients().length)
WebsocketController.leaveProject(io, client, function (err) { WebsocketController.leaveProject(io, client, function (err) {

14
services/real-time/app/js/WebsocketController.js
View file

@ -36,7 +36,7 @@ module.exports = WebsocketController = {
{ user_id, project_id, client_id: client.id }, { user_id, project_id, client_id: client.id },
'user joining project' 'user joining project'
) )
metrics.inc('editor.join-project') metrics.inc('editor.join-project', 1, { status: client.transport })
WebApiManager.joinProject(project_id, user, function ( WebApiManager.joinProject(project_id, user, function (
error, error,
project, project,
@ -114,7 +114,7 @@ module.exports = WebsocketController = {
return callback() return callback()
} // client did not join project } // client did not join project
metrics.inc('editor.leave-project') metrics.inc('editor.leave-project', 1, { status: client.transport })
logger.log( logger.log(
{ project_id, user_id, client_id: client.id }, { project_id, user_id, client_id: client.id },
'client leaving project' 'client leaving project'
@ -167,7 +167,7 @@ module.exports = WebsocketController = {
} }
const joinLeaveEpoch = ++client.joinLeaveEpoch const joinLeaveEpoch = ++client.joinLeaveEpoch
metrics.inc('editor.join-doc') metrics.inc('editor.join-doc', 1, { status: client.transport })
const { project_id, user_id, is_restricted_user } = client.ol_context const { project_id, user_id, is_restricted_user } = client.ol_context
if (!project_id) { if (!project_id) {
return callback(new NotJoinedError()) return callback(new NotJoinedError())
@ -319,7 +319,7 @@ module.exports = WebsocketController = {
leaveDoc(client, doc_id, callback) { leaveDoc(client, doc_id, callback) {
// client may have disconnected, but we have to cleanup internal state. // client may have disconnected, but we have to cleanup internal state.
client.joinLeaveEpoch++ client.joinLeaveEpoch++
metrics.inc('editor.leave-doc') metrics.inc('editor.leave-doc', 1, { status: client.transport })
const { project_id, user_id } = client.ol_context const { project_id, user_id } = client.ol_context
logger.log( logger.log(
{ user_id, project_id, doc_id, client_id: client.id }, { user_id, project_id, doc_id, client_id: client.id },
@ -338,7 +338,9 @@ module.exports = WebsocketController = {
return callback() return callback()
} }
metrics.inc('editor.update-client-position', 0.1) metrics.inc('editor.update-client-position', 0.1, {
status: client.transport
})
const { const {
project_id, project_id,
first_name, first_name,
@ -475,7 +477,7 @@ module.exports = WebsocketController = {
} }
update.meta.source = client.publicId update.meta.source = client.publicId
update.meta.user_id = user_id update.meta.user_id = user_id
metrics.inc('editor.doc-update', 0.3) metrics.inc('editor.doc-update', 0.3, { status: client.transport })
logger.log( logger.log(
{ {