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

Function MarkActivityAsUploaded

pkg/telemetry/telemetry.go:453–466  ·  view source on GitHub ↗
(ctx context.Context, activityArr []*ActivityType)

Source from the content-addressed store, hash-verified

451}
452
453func MarkActivityAsUploaded(ctx context.Context, activityArr []*ActivityType) error {
454 dayStr := daystr.GetCurDayStr()
455 txErr := wstore.WithTx(ctx, func(tx *wstore.TxWrap) error {
456 query := `UPDATE db_activity SET uploaded = 1 WHERE day = ?`
457 for _, activity := range activityArr {
458 if activity.Day == dayStr {
459 continue
460 }
461 tx.Exec(query, activity.Day)
462 }
463 return nil
464 })
465 return txErr
466}

Callers 1

sendTelemetryFunction · 0.92

Calls 2

GetCurDayStrFunction · 0.92
WithTxFunction · 0.92

Tested by

no test coverage detected