MCPcopy Index your code
hub / github.com/wavetermdev/waveterm / beforeSendActivityUpdate

Function beforeSendActivityUpdate

cmd/server/main-server.go:290–303  ·  view source on GitHub ↗
(ctx context.Context)

Source from the content-addressed store, hash-verified

288}
289
290func beforeSendActivityUpdate(ctx context.Context) {
291 activity := wshrpc.ActivityUpdate{}
292 activity.NumTabs, _ = wstore.DBGetCount[*waveobj.Tab](ctx)
293 activity.NumBlocks, _ = wstore.DBGetCount[*waveobj.Block](ctx)
294 activity.Blocks, _ = wstore.DBGetBlockViewCounts(ctx)
295 activity.NumWindows, _ = wstore.DBGetCount[*waveobj.Window](ctx)
296 activity.NumSSHConn = conncontroller.GetNumSSHHasConnected()
297 activity.NumWSLConn = wslconn.GetNumWSLHasConnected()
298 activity.NumWSNamed, activity.NumWS, _ = wstore.DBGetWSCounts(ctx)
299 err := telemetry.UpdateActivity(ctx, activity)
300 if err != nil {
301 log.Printf("error updating before activity: %v\n", err)
302 }
303}
304
305func startupActivityUpdate(firstLaunch bool) {
306 defer func() {

Callers 1

sendTelemetryWrapperFunction · 0.85

Calls 5

DBGetBlockViewCountsFunction · 0.92
GetNumSSHHasConnectedFunction · 0.92
GetNumWSLHasConnectedFunction · 0.92
DBGetWSCountsFunction · 0.92
UpdateActivityFunction · 0.92

Tested by

no test coverage detected