2023-06-13 23:50:32 +02:00
|
|
|
package domain
|
|
|
|
|
|
|
|
import "time"
|
|
|
|
|
|
|
|
type PeerStatus struct {
|
|
|
|
PeerId PeerIdentifier `gorm:"primaryKey;column:identifier"`
|
|
|
|
UpdatedAt time.Time `gorm:"column:updated_at"`
|
|
|
|
|
|
|
|
IsPingable bool `gorm:"column:pingable"`
|
|
|
|
LastPing *time.Time `gorm:"column:last_ping"`
|
|
|
|
|
|
|
|
BytesReceived uint64 `gorm:"column:received"`
|
|
|
|
BytesTransmitted uint64 `gorm:"column:transmitted"`
|
|
|
|
|
|
|
|
LastHandshake *time.Time `gorm:"column:last_handshake"`
|
|
|
|
Endpoint string `gorm:"column:endpoint"`
|
|
|
|
LastSessionStart *time.Time `gorm:"column:last_session_start"`
|
|
|
|
}
|
|
|
|
|
2023-07-18 16:05:06 +02:00
|
|
|
func (s PeerStatus) IsConnected() bool {
|
|
|
|
oldestHandshakeTime := time.Now().Add(-2 * time.Minute) // if a handshake is older than 2 minutes, the peer is no longer connected
|
|
|
|
|
|
|
|
handshakeValid := false
|
|
|
|
if s.LastHandshake != nil {
|
|
|
|
handshakeValid = !s.LastHandshake.Before(oldestHandshakeTime)
|
|
|
|
}
|
|
|
|
|
|
|
|
return s.IsPingable || handshakeValid
|
|
|
|
}
|
|
|
|
|
2023-06-13 23:50:32 +02:00
|
|
|
type InterfaceStatus struct {
|
|
|
|
InterfaceId InterfaceIdentifier `gorm:"primaryKey;column:identifier"`
|
|
|
|
UpdatedAt time.Time `gorm:"column:updated_at"`
|
|
|
|
|
|
|
|
BytesReceived uint64 `gorm:"column:received"`
|
|
|
|
BytesTransmitted uint64 `gorm:"column:transmitted"`
|
|
|
|
}
|