Add Reset with 0 key

pkg/api/api.go

@@ -81,6 +81,7 @@ const (
 	RecordGame       PT = 110
 	GetWorkerList    PT = 111
 	ErrNoFreeSlots   PT = 112
+	ResetGame        PT = 113
 	RegisterRoom     PT = 201
 	CloseRoom        PT = 202
 	IceCandidate        = WebrtcIce
@@ -120,6 +121,8 @@ func (p PT) String() string {
 		return "GetWorkerList"
 	case ErrNoFreeSlots:
 		return "NoFreeSlots"
+	case ResetGame:
+		return "ResetGame"
 	case RegisterRoom:
 		return "RegisterRoom"
 	case CloseRoom:

pkg/api/worker.go

@@ -12,7 +12,11 @@ type (
 	LoadGameRequest[T Id] struct {
 		StatefulRoom[T]
 	}
-	LoadGameResponse      string
+	LoadGameResponse       string
+	ResetGameRequest[T Id] struct {
+		StatefulRoom[T]
+	}
+	ResetGameResponse     string
 	SaveGameRequest[T Id] struct {
 		StatefulRoom[T]
 	}

pkg/coordinator/user.go

@@ -83,6 +83,12 @@ func (u *User) HandleRequests(info HasServerInfo, conf config.CoordinatorConfig)
 				return api.ErrMalformed
 			}
 			u.HandleChangePlayer(*rq)
+		case api.ResetGame:
+			rq := api.Unwrap[api.ResetGameRequest[com.Uid]](payload)
+			if rq == nil {
+				return api.ErrMalformed
+			}
+			u.HandleResetGame(*rq)
 		case api.RecordGame:
 			if !conf.Recording.Enabled {
 				return api.ErrForbidden

pkg/coordinator/userhandlers.go

@@ -50,6 +50,13 @@ func (u *User) HandleQuitGame(rq api.GameQuitRequest[com.Uid]) {
 	}
 }
 
+func (u *User) HandleResetGame(rq api.ResetGameRequest[com.Uid]) {
+	if rq.Room.Rid != u.w.RoomId {
+		return
+	}
+	u.w.ResetGame(u.Id())
+}
+
 func (u *User) HandleSaveGame() error {
 	resp, err := u.w.SaveGame(u.Id())
 	if err != nil {

pkg/coordinator/workerapi.go

@@ -48,6 +48,10 @@ func (w *Worker) ChangePlayer(id com.Uid, index int) (*api.ChangePlayerResponse,
 		w.Send(api.ChangePlayer, api.ChangePlayerRequest[com.Uid]{StatefulRoom: StateRoom(id, w.RoomId), Index: index}))
 }
 
+func (w *Worker) ResetGame(id com.Uid) {
+	w.Notify(api.ResetGame, api.ResetGameRequest[com.Uid]{StatefulRoom: StateRoom(id, w.RoomId)})
+}
+
 func (w *Worker) RecordGame(id com.Uid, rec bool, recUser string) (*api.RecordGameResponse, error) {
 	return api.UnwrapChecked[api.RecordGameResponse](
 		w.Send(api.RecordGame, api.RecordGameRequest[com.Uid]{StatefulRoom: StateRoom(id, w.RoomId), Active: rec, User: recUser}))

pkg/worker/caged/libretro/frontend.go

@@ -47,6 +47,7 @@ type Emulator interface {
 	Input(player int, device byte, data []byte)
 	// Scale returns set video scale factor
 	Scale() float64
+	Reset()
 }
 
 type Frontend struct {
@@ -307,6 +308,7 @@ func (f *Frontend) HashPath() string              { return f.storage.GetSavePath
 func (f *Frontend) IsPortrait() bool              { return f.nano.IsPortrait() }
 func (f *Frontend) KbMouseSupport() bool          { return f.nano.KbMouseSupport() }
 func (f *Frontend) PixFormat() uint32             { return f.nano.Video.PixFmt.C }
+func (f *Frontend) Reset()                        { f.mu.Lock(); defer f.mu.Unlock(); f.nano.Reset() }
 func (f *Frontend) RestoreGameState() error       { return f.Load() }
 func (f *Frontend) Rotation() uint                { return f.nano.Rot }
 func (f *Frontend) SRAMPath() string              { return f.storage.GetSRAMPath() }

pkg/worker/caged/libretro/nanoarch/nanoarch.c

@@ -90,6 +90,10 @@ void bridge_retro_unload_game(void *f) {
     ((void (*)(void)) f)();
 }
 
+void bridge_retro_reset(void *f) {
+    ((void (*)(void)) f)();
+}
+
 void bridge_retro_run(void *f) {
     ((void (*)(void)) f)();
 }

pkg/worker/caged/libretro/nanoarch/nanoarch.go

@@ -230,6 +230,7 @@ func (n *Nanoarch) CoreLoad(meta Metadata) {
 	retroSetInputState = loadFunction(coreLib, "retro_set_input_state")
 	retroSetAudioSample = loadFunction(coreLib, "retro_set_audio_sample")
 	retroSetAudioSampleBatch = loadFunction(coreLib, "retro_set_audio_sample_batch")
+	retroReset = loadFunction(coreLib, "retro_reset")
 	retroRun = loadFunction(coreLib, "retro_run")
 	retroLoadGame = loadFunction(coreLib, "retro_load_game")
 	retroUnloadGame = loadFunction(coreLib, "retro_unload_game")
@@ -396,6 +397,10 @@ func (n *Nanoarch) Shutdown() {
 	C.free(unsafe.Pointer(n.cSystemDirectory))
 }
 
+func (n *Nanoarch) Reset() {
+	C.bridge_retro_reset(retroReset)
+}
+
 func (n *Nanoarch) Run() {
 	if n.LibCo {
 		C.same_thread(retroRun)
@@ -595,6 +600,7 @@ var (
 	coreLib                      unsafe.Pointer
 	retroInit                    unsafe.Pointer
 	retroLoadGame                unsafe.Pointer
+	retroReset                   unsafe.Pointer
 	retroRun                     unsafe.Pointer
 	retroSetAudioSample          unsafe.Pointer
 	retroSetAudioSampleBatch     unsafe.Pointer

pkg/worker/caged/libretro/nanoarch/nanoarch.h

@@ -15,6 +15,7 @@ void bridge_retro_deinit(void *f);
 void bridge_retro_get_system_av_info(void *f, struct retro_system_av_info *si);
 void bridge_retro_get_system_info(void *f, struct retro_system_info *si);
 void bridge_retro_init(void *f);
+void bridge_retro_reset(void *f);
 void bridge_retro_run(void *f);
 void bridge_retro_set_audio_sample(void *f, void *callback);
 void bridge_retro_set_audio_sample_batch(void *f, void *callback);

pkg/worker/coordinator.go

@@ -126,6 +126,12 @@ func (c *coordinator) HandleRequests(w *Worker) chan struct{} {
 			} else {
 				out = c.HandleChangePlayer(*dat, w)
 			}
+		case api.ResetGame:
+			dat := api.Unwrap[api.ResetGameRequest[com.Uid]](x.Payload)
+			if dat == nil {
+				return api.ErrMalformed
+			}
+			c.HandleResetGame(*dat, w)
 		case api.RecordGame:
 			if dat := api.Unwrap[api.RecordGameRequest[com.Uid]](x.Payload); dat == nil {
 				err, out = api.ErrMalformed, api.EmptyPacket

pkg/worker/coordinatorhandlers.go

@@ -234,6 +234,14 @@ func (c *coordinator) HandleQuitGame(rq api.GameQuitRequest[com.Uid], w *Worker)
 	}
 }
 
+func (c *coordinator) HandleResetGame(rq api.ResetGameRequest[com.Uid], w *Worker) api.Out {
+	if r := w.router.FindRoom(rq.Rid); r != nil {
+		room.WithEmulator(r.App()).Reset()
+		return api.OkPacket
+	}
+	return api.ErrPacket
+}
+
 func (c *coordinator) HandleSaveGame(rq api.SaveGameRequest[com.Uid], w *Worker) api.Out {
 	r := w.router.FindRoom(rq.Rid)
 	if r == nil {

web/js/api.js

@@ -15,6 +15,7 @@ const endpoints = {
     GAME_RECORDING: 110,
     GET_WORKER_LIST: 111,
     GAME_ERROR_NO_FREE_SLOTS: 112,
+    GAME_RESET: 113,
 
     APP_VIDEO_CHANGE: 150,
 }
@@ -319,6 +320,7 @@ export const api = {
             }
         },
         load: () => packet(endpoints.GAME_LOAD),
+        reset: (roomId) => packet(endpoints.GAME_RESET, {room_id: roomId}),
         save: () => packet(endpoints.GAME_SAVE),
         setPlayerIndex: (i) => packet(endpoints.GAME_SET_PLAYER_INDEX, i),
         start: (game, roomId, record, recordUser, player) => packet(endpoints.GAME_START, {

web/js/app.js

@@ -437,6 +437,9 @@ const app = {
                         room.reset();
                         window.location = window.location.pathname;
                         break;
+                    case KEY.RESET:
+                        api.game.reset(room.id)
+                        break;
                     case KEY.STATS:
                         stats.toggle();
                         break;

web/js/input/keyboard.js

@@ -45,7 +45,8 @@ const defaultMap = Object.freeze({
     KeyH: KEY.HELP,
     Backslash: KEY.STATS,
     Digit9: KEY.SETTINGS,
-    KeyT: KEY.DTOGGLE
+    KeyT: KEY.DTOGGLE,
+    Digit0: KEY.RESET,
 });
 
 let keyMap = {};

web/js/input/keys.js

@@ -29,4 +29,5 @@ export const KEY = {
     L3: 'l3',
     R3: 'r3',
     REC: 'rec',
+    RESET: 'reset',
 }