pubsub

type A struct {
	// MsgInfo happens when a peer introduces it's exposed state machines.
	MsgInfo       *MsgInfo
	MsgUpdates    *MsgUpdates
	MsgBye        *MsgBye
	MsgReqInfo    *MsgReqInfo
	MsgReqUpdates *MsgReqUpdates
	MsgGossip     *MsgGossip
	// Msgs is a list of PubSub messages.
	Msgs []*pubsub.Message
	// Length is a general length used for logging
	Length int `log:"length"`
	// Msg is a raw msg.
	Msg []byte
	// PeerId is a peer ID
	Peer    string `log:"peer"`
	PeerId  string
	PeerIds []string
	// MachId is a state machine ID
	MachId string `log:"mach_id"`
	// MTime is machine time
	MTime am.Time `log:"mtime"`
	// HTime is human time
	HTime time.Time
	// Addrs is a list of addresses.
	Addrs []multiaddr.Multiaddr `log:"addrs"`
	// NetMachs is a return channel for a list of [rpc.NetworkMachine]. It has to
	// be buffered or the mutation will fail.
	NetMachs    chan<- []*rpc.NetworkMachine
	ListFilters *ListFilters
	MachClocks  MachClocks
	MsgType     string `log:"msg_type"`
	PeersGossip PeerGossips
}

type Gossips map[int]uint64

type Info struct {
	Id     string
	Schema am.Schema
	States am.S
	MTime  am.Time
	Tags   []string
	Parent string
}

type ListFilters struct {
	IdExact   string
	IdPartial string
	IdRegexp  *regexp.Regexp
	Parent    string
	PeerId    string
	// Level to traverse towards the tree root.
	DepthLevel  int
	ChildrenMax int
	ChildrenMin int
}

type MachClocks map[int]am.Time

type MachInfo map[int]*Info

type Msg struct {
	Type MsgType
}

type MsgBye struct {
	Msg
	Machs map[int]MsgByeMach
}

type MsgByeMach struct {
	PeerBye bool
	Id      string
	MTime   am.Time
}

type MsgGossip struct {
	Msg
	// Number of workers from each peer
	PeerGossips PeerGossips
}

type MsgInfo struct {
	Msg
	// peer ID => mach idx => schema
	PeerInfo PeerInfo
	// Number of workers from each peer
	PeerGossips PeerGossips
}

type MsgReqInfo struct {
	Msg
	PeerIds []string
}

type MsgReqUpdates struct {
	Msg
	// TODO list specific mach indexes
	PeerIds []string
}

type MsgType string

type MsgUpdates struct {
	Msg
	PeerClocks PeerClocks
}

type PeerClocks map[string]MachClocks

type PeerGossips map[string]Gossips

type PeerInfo map[string]MachInfo

type Topic struct {
	*am.ExceptionHandler

	// T represents the PubSub topic used for communication.
	T *ps.Topic
	// Mach is a state machine for this PubSub.
	Mach        *am.Machine
	MachMetrics atomic.Pointer[am.Machine]
	HostToPeer  map[string]string
	// ListenAddrs contains the list of multiaddresses that this topic listens on.
	// None will allocate one automatically.
	ListenAddrs []ma.Multiaddr
	// Addrs is a list of addresses for this peer.
	Addrs atomic.Pointer[[]ma.Multiaddr]
	// Name indicates the name of the channel or topic instance,
	// typically associated with a given process.
	Name string
	// ConnAddrs contains a list of addresses for initial
	// connections to discovery nodes in the network.
	ConnAddrs []ma.Multiaddr
	// List of exposed state machines, index => mach_id, indexes are used on the
	// channel. Indexes should NOT change, as they are used for addressing. `nil`
	// value means empty.
	ExposedMachs []*am.Machine
	// Debounce for clock broadcasts (separate per each exposed state machine).
	Debounce   time.Time
	LogEnabled bool
	// HeartbeatFreq broadcasts changed clocks of exposed machines.
	HeartbeatFreq time.Duration
	// Maximum msgs per minute sent to the network. Does not include MsgInfo,
	// which are debounced.
	MaxMsgsPerWin int
	// DbgNetMachs exposes local network machines via to am-dbg
	DbgNetMachs        bool
	ConnectionsToReady int
	// all amounts and delayes are multiplied by this factor
	Multiplayer        int
	SendInfoDebounceMs int
	// Max allowed queue length to send MsgInfo to newly joned peers, as well as
	// received msgs.
	MaxQueueLen uint16
	// Number of gossips to send in SendGossipsState
	GossipAmount int

	// Use this hardcoded schema instead of exchanging real ones. Limits all the
	// workers to this one.
	// TODO catalog of named schemas, exchange unknown ones
	TestSchema am.Schema
	TestStates am.S
	// contains filtered or unexported fields
}

type TopicOpts struct {
	// Parent is a parent state machine for a new Topic state machine. See
	// [am.Opts].
	Parent am.Api
}

type Tracer struct {
	*am.TracerNoOp
	// contains filtered or unexported fields
}