Use correct column name for activity update

element-hq · Nov 13, 2023 · 5036c6d · 5036c6d
1 parent 86cbd35
commit 5036c6d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/database/puppet.go b/database/puppet.go
@@ -185,14 +185,14 @@ func (p *Puppet) UpdateActivityTs(activityTs int64) {
 	}
 	p.log.Debugfln("Updating activity time for %s to %d", p.SignalID, activityTs)
 	p.LastActivityTs = activityTs
-	_, err := p.db.Exec("UPDATE puppet SET last_activity_ts=$1 WHERE username=$2", p.LastActivityTs, p.SignalID)
+	_, err := p.db.Exec("UPDATE puppet SET last_activity_ts=$1 WHERE uuid=$2", p.LastActivityTs, p.SignalID)
 	if err != nil {
 		p.log.Warnfln("Failed to update last_activity_ts for %s: %v", p.SignalID, err)
 	}
 
 	if p.FirstActivityTs == 0 {
 		p.FirstActivityTs = activityTs
-		_, err = p.db.Exec("UPDATE puppet SET first_activity_ts=$1 WHERE username=$2 AND first_activity_ts is NULL", p.FirstActivityTs, p.SignalID)
+		_, err = p.db.Exec("UPDATE puppet SET first_activity_ts=$1 WHERE uuid=$2 AND first_activity_ts is NULL", p.FirstActivityTs, p.SignalID)
 		if err != nil {
 			p.log.Warnfln("Failed to update first_activity_ts %s: %v", p.SignalID, err)
 		}