chore: reformat code
This commit is contained in:
parent
3c926a8bff
commit
3180c1b540
@ -71,7 +71,7 @@ func (r *Recorder) onSwitchRecord(_ mqtt.Client, message mqtt.Message) {
|
|||||||
r.muEnabled.Lock()
|
r.muEnabled.Lock()
|
||||||
defer r.muEnabled.Unlock()
|
defer r.muEnabled.Unlock()
|
||||||
|
|
||||||
if ! r.enabled && msg.GetEnabled() {
|
if !r.enabled && msg.GetEnabled() {
|
||||||
r.recordSet = r.idGenerator.Next()
|
r.recordSet = r.idGenerator.Next()
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -110,9 +110,9 @@ func (r *Recorder) onFrame(_ mqtt.Client, message mqtt.Message) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
record := events.RecordMessage{
|
record := events.RecordMessage{
|
||||||
Frame: &msg,
|
Frame: &msg,
|
||||||
Steering: steering,
|
Steering: steering,
|
||||||
RecordSet: r.recordSet,
|
RecordSet: r.recordSet,
|
||||||
}
|
}
|
||||||
|
|
||||||
payload, err := proto.Marshal(&record)
|
payload, err := proto.Marshal(&record)
|
||||||
@ -157,7 +157,6 @@ var registerCallBacks = func(r *Recorder) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
type IdGenerator interface {
|
type IdGenerator interface {
|
||||||
Next() string
|
Next() string
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user