48 lines
1.0 KiB
Go
48 lines
1.0 KiB
Go
|
package reach
|
||
|
|
|
||
|
|
import (
|
||
|
|
"sync"
|
||
|
|
|
||
|
|
"forge.cadoles.com/Pyxis/golang-socketio"
|
||
|
|
"github.com/pkg/errors"
|
||
|
|
)
|
||
|
|
|
||
|
|
const (
|
||
|
|
eventGetTimeSyncStatus = "get time sync status"
|
||
|
|
eventTimeSyncResults = "time sync status"
|
||
|
|
)
|
||
|
|
|
||
|
|
type timeSyncStatus struct {
|
||
|
|
Status bool `json:"status"`
|
||
|
|
}
|
||
|
|
|
||
|
|
// TimeSyncStatus returns the ReachRS module time sync status
|
||
|
|
func (c *Client) TimeSyncStatus() (bool, error) {
|
||
|
|
|
||
|
|
var err error
|
||
|
|
var synced bool
|
||
|
|
var wg sync.WaitGroup
|
||
|
|
|
||
|
|
wg.Add(1)
|
||
|
|
|
||
|
|
err = c.conn.On(eventTimeSyncResults, func(h *gosocketio.Channel, st *timeSyncStatus) {
|
||
|
|
synced = st.Status
|
||
|
|
c.conn.Off(eventTimeSyncResults)
|
||
|
|
wg.Done()
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
return false, errors.Wrapf(err, "error while binding to '%s' event", eventTimeSyncResults)
|
||
|
|
}
|
||
|
|
|
||
|
|
c.logf("sending '%s' event", eventGetTimeSyncStatus)
|
||
|
|
if err = c.conn.Emit(eventGetTimeSyncStatus, nil); err != nil {
|
||
|
|
return false, errors.Wrapf(err, "error while emitting '%s' event", eventGetTimeSyncStatus)
|
||
|
|
}
|
||
|
|
c.logf("'%s' event sent", eventGetTimeSyncStatus)
|
||
|
|
|
||
|
|
wg.Wait()
|
||
|
|
|
||
|
|
return synced, err
|
||
|
|
|
||
|
|
}
|