package types import ( "context" "errors" "time" "tailscale.com/tailcfg" "tailscale.com/util/ctxkey" ) const ( SelfUpdateIdentifier = "self-update" DatabasePostgres = "postgres" DatabaseSqlite = "sqlite3" ) var ErrCannotParsePrefix = errors.New("cannot parse prefix") type StateUpdateType int func (su StateUpdateType) String() string { switch su { case StateFullUpdate: return "StateFullUpdate" case StatePeerChanged: return "StatePeerChanged" case StatePeerChangedPatch: return "StatePeerChangedPatch" case StatePeerRemoved: return "StatePeerRemoved" case StateSelfUpdate: return "StateSelfUpdate" case StateDERPUpdated: return "StateDERPUpdated" } return "unknown state update type" } const ( StateFullUpdate StateUpdateType = iota // StatePeerChanged is used for updates that needs // to be calculated with all peers and all policy rules. // This would typically be things that include tags, routes // and similar. StatePeerChanged StatePeerChangedPatch StatePeerRemoved // StateSelfUpdate is used to indicate that the node // has changed in control, and the client needs to be // informed. // The updated node is inside the ChangeNodes field // which should have a length of one. StateSelfUpdate StateDERPUpdated ) // StateUpdate is an internal message containing information about // a state change that has happened to the network. // If type is StateFullUpdate, all fields are ignored. type StateUpdate struct { // The type of update Type StateUpdateType // ChangeNodes must be set when Type is StatePeerAdded // and StatePeerChanged and contains the full node // object for added nodes. ChangeNodes []NodeID // ChangePatches must be set when Type is StatePeerChangedPatch // and contains a populated PeerChange object. ChangePatches []*tailcfg.PeerChange // Removed must be set when Type is StatePeerRemoved and // contain a list of the nodes that has been removed from // the network. Removed []NodeID // DERPMap must be set when Type is StateDERPUpdated and // contain the new DERP Map. DERPMap *tailcfg.DERPMap // Additional message for tracking origin or what being // updated, useful for ambiguous updates like StatePeerChanged. Message string } // Empty reports if there are any updates in the StateUpdate. func (su *StateUpdate) Empty() bool { switch su.Type { case StatePeerChanged: return len(su.ChangeNodes) == 0 case StatePeerChangedPatch: return len(su.ChangePatches) == 0 case StatePeerRemoved: return len(su.Removed) == 0 } return false } func StateUpdateExpire(nodeID NodeID, expiry time.Time) StateUpdate { return StateUpdate{ Type: StatePeerChangedPatch, ChangePatches: []*tailcfg.PeerChange{ { NodeID: nodeID.NodeID(), KeyExpiry: &expiry, }, }, } } var ( NotifyOriginKey = ctxkey.New("notify.origin", "") NotifyHostnameKey = ctxkey.New("notify.hostname", "") ) func NotifyCtx(ctx context.Context, origin, hostname string) context.Context { ctx2, _ := context.WithTimeout(ctx, 3*time.Second) ctx2 = NotifyOriginKey.WithValue(ctx2, origin) ctx2 = NotifyHostnameKey.WithValue(ctx2, hostname) return ctx2 }