mirror of
https://github.com/giongto35/cloud-game.git
synced 2026-07-23 18:17:32 +00:00
196930281b
In the current version of the application, we have strictly hardcoded the captured runtime application (FFI Libretro frontend) as well as the streaming transport (WebRTC). This commit makes it possible to choose these components at runtime. In this commit, we no longer manage initially connected users separately from the rooms, and instead, we treat all users as abstract app sessions, rather than hardcoded WebRTC connections. These sessions may contain all the transport specifics, such as WebRTC and so on. Rooms, instead of having the hardcoded emulator app and WebRTC media encoders, now have these components decoupled. In theory, it is possible to add new transports (e.g., WebTransport) and streaming apps (e.g., wrapped into an ffmpeg desktop app).
118 lines
3.1 KiB
Go
118 lines
3.1 KiB
Go
package coordinator
|
|
|
|
import (
|
|
"fmt"
|
|
"sync/atomic"
|
|
|
|
"github.com/giongto35/cloud-game/v3/pkg/api"
|
|
"github.com/giongto35/cloud-game/v3/pkg/com"
|
|
"github.com/giongto35/cloud-game/v3/pkg/logger"
|
|
)
|
|
|
|
type Worker struct {
|
|
Connection
|
|
RegionalClient
|
|
slotted
|
|
|
|
Addr string
|
|
PingServer string
|
|
Port string
|
|
RoomId string // room reference
|
|
Tag string
|
|
Zone string
|
|
|
|
log *logger.Logger
|
|
}
|
|
|
|
type RegionalClient interface {
|
|
In(region string) bool
|
|
}
|
|
|
|
type HasUserRegistry interface {
|
|
Find(com.Uid) (*User, bool)
|
|
}
|
|
|
|
func NewWorker(sock *com.Connection, handshake api.ConnectionRequest[com.Uid], log *logger.Logger) *Worker {
|
|
conn := com.NewConnection[api.PT, api.In[com.Uid], api.Out, *api.Out](sock, handshake.Id, log)
|
|
return &Worker{
|
|
Connection: conn,
|
|
Addr: handshake.Addr,
|
|
PingServer: handshake.PingURL,
|
|
Port: handshake.Port,
|
|
Tag: handshake.Tag,
|
|
Zone: handshake.Zone,
|
|
log: log.Extend(log.With().
|
|
Str(logger.ClientField, logger.MarkNone).
|
|
Str(logger.DirectionField, logger.MarkNone).
|
|
Str("cid", conn.Id().Short())),
|
|
}
|
|
}
|
|
|
|
func (w *Worker) HandleRequests(users HasUserRegistry) chan struct{} {
|
|
return w.ProcessPackets(func(p api.In[com.Uid]) error {
|
|
payload := p.GetPayload()
|
|
switch p.GetType() {
|
|
case api.RegisterRoom:
|
|
rq := api.Unwrap[api.RegisterRoomRequest](payload)
|
|
if rq == nil {
|
|
return api.ErrMalformed
|
|
}
|
|
w.log.Info().Msgf("set room [%v] = %v", w.Id(), *rq)
|
|
w.HandleRegisterRoom(*rq)
|
|
case api.CloseRoom:
|
|
rq := api.Unwrap[api.CloseRoomRequest](payload)
|
|
if rq == nil {
|
|
return api.ErrMalformed
|
|
}
|
|
w.HandleCloseRoom(*rq)
|
|
case api.IceCandidate:
|
|
rq := api.Unwrap[api.WebrtcIceCandidateRequest[com.Uid]](payload)
|
|
if rq == nil {
|
|
return api.ErrMalformed
|
|
}
|
|
err := w.HandleIceCandidate(*rq, users)
|
|
if err != nil {
|
|
w.log.Error().Err(err).Send()
|
|
return api.ErrMalformed
|
|
}
|
|
default:
|
|
w.log.Warn().Msgf("Unknown packet: %+v", p)
|
|
}
|
|
return nil
|
|
})
|
|
}
|
|
|
|
// In say whether some worker from this region (zone).
|
|
// Empty region always returns true.
|
|
func (w *Worker) In(region string) bool { return region == "" || region == w.Zone }
|
|
|
|
// slotted used for tracking user slots and the availability.
|
|
type slotted int32
|
|
|
|
// HasSlot checks if the current worker has a free slot to start a new game.
|
|
// Workers support only one game at a time, so it returns true in case if
|
|
// there are no players in the room (worker).
|
|
func (s *slotted) HasSlot() bool { return atomic.LoadInt32((*int32)(s)) == 0 }
|
|
|
|
// Reserve increments user counter of the worker.
|
|
func (s *slotted) Reserve() { atomic.AddInt32((*int32)(s), 1) }
|
|
|
|
// UnReserve decrements user counter of the worker.
|
|
func (s *slotted) UnReserve() {
|
|
if atomic.AddInt32((*int32)(s), -1) < 0 {
|
|
atomic.StoreInt32((*int32)(s), 0)
|
|
}
|
|
}
|
|
|
|
func (s *slotted) FreeSlots() { atomic.StoreInt32((*int32)(s), 0) }
|
|
|
|
func (w *Worker) Disconnect() {
|
|
w.Connection.Disconnect()
|
|
w.RoomId = ""
|
|
w.FreeSlots()
|
|
}
|
|
|
|
func (w *Worker) PrintInfo() string {
|
|
return fmt.Sprintf("id: %v, addr: %v, port: %v, zone: %v, ping addr: %v, tag: %v",
|
|
w.Id(), w.Addr, w.Port, w.Zone, w.PingServer, w.Tag)
|
|
}
|