diff options
author | Santo Cariotti <santo@dcariotti.me> | 2025-04-17 22:28:08 +0200 |
---|---|---|
committer | Santo Cariotti <santo@dcariotti.me> | 2025-04-17 22:28:08 +0200 |
commit | 544977d54effa7804386aa40f30a87f5e2365efa (patch) | |
tree | aa6896cfa3db9c2e61b219f6995e25da64255f30 /pkg/ui/multiplayer/multiplayer.go | |
parent | 8255fbdd7d9d595e71545b7c6909114024527a34 (diff) |
Move internal/network package to pkg/p2p
Diffstat (limited to 'pkg/ui/multiplayer/multiplayer.go')
-rw-r--r-- | pkg/ui/multiplayer/multiplayer.go | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/pkg/ui/multiplayer/multiplayer.go b/pkg/ui/multiplayer/multiplayer.go index c9fc4b2..0e390eb 100644 --- a/pkg/ui/multiplayer/multiplayer.go +++ b/pkg/ui/multiplayer/multiplayer.go @@ -3,36 +3,36 @@ package multiplayer import ( "time" - "github.com/boozec/rahanna/internal/network" + "github.com/boozec/rahanna/pkg/p2p" "go.uber.org/zap" ) type GameNetwork struct { - server *network.TCPNetwork - me network.NetworkID - peer network.NetworkID + server *p2p.TCPNetwork + me p2p.NetworkID + peer p2p.NetworkID } // Wrapper to a `TCPNetwork` -func NewGameNetwork(localID string, address string, onHandshake network.NetworkHandshakeFunc, logger *zap.Logger) *GameNetwork { - opts := network.TCPNetworkOpts{ +func NewGameNetwork(localID string, address string, onHandshake p2p.NetworkHandshakeFunc, logger *zap.Logger) *GameNetwork { + opts := p2p.TCPNetworkOpts{ ListenAddr: address, HandshakeFn: onHandshake, RetryDelay: time.Second * 2, Logger: logger, } - server := network.NewTCPNetwork(network.NetworkID(localID), opts) + server := p2p.NewTCPNetwork(p2p.NetworkID(localID), opts) return &GameNetwork{ server: server, - me: network.NetworkID(localID), + me: p2p.NetworkID(localID), } } -func (n *GameNetwork) Peer() network.NetworkID { +func (n *GameNetwork) Peer() p2p.NetworkID { return n.peer } -func (n *GameNetwork) Me() network.NetworkID { +func (n *GameNetwork) Me() p2p.NetworkID { return n.me } @@ -40,11 +40,11 @@ func (n *GameNetwork) Send(payload []byte) error { return n.server.Send(n.peer, payload) } -func (n *GameNetwork) AddPeer(remoteID network.NetworkID, addr string) { +func (n *GameNetwork) AddPeer(remoteID p2p.NetworkID, addr string) { n.peer = remoteID n.server.AddPeer(remoteID, addr) } -func (n *GameNetwork) AddReceiveFunction(f network.NetworkMessageReceiveFunc) { +func (n *GameNetwork) AddReceiveFunction(f p2p.NetworkMessageReceiveFunc) { n.server.OnReceiveFn = f } |