心跳维护

repositories/online_repostiroy.go

@@ -63,8 +63,7 @@ func (repo *onlineRepository) Is(ctx context.Context, userId string) (bool, erro
 
 // Heartbeat implements OnlineRepository.
 func (repo *onlineRepository) Heartbeat(ctx context.Context, o *models.Online) error {
-	repo.rdb.Expire(ctx, fmt.Sprintf("clients.%s.%s", o.ServerId, o.UserId), repo.HeartbeatWait)
-	panic("unimplemented")
+	return repo.rdb.Expire(ctx, fmt.Sprintf("clients.%s.%s", o.ServerId, o.UserId), repo.HeartbeatWait).Err()
 }
 
 // Offline implements OnlineRepository.