emulator_service_impl.h

Go to the documentation of this file.

#pragma once
 
#include <functional>
#include <memory>
 
#include "util/grpc_win_compat.h"
 
#include <grpcpp/grpcpp.h>
 
#include "absl/status/statusor.h"
#include "app/emu/debug/step_controller.h"
#include "app/emu/debug/symbol_provider.h"
#include "app/service/screenshot_utils.h"
#include "protos/emulator_service.grpc.pb.h"
 
#include "app/emu/i_emulator.h"
 
namespace yaze {
class Rom;
namespace emu {
// Emulator forward decl no longer needed here if we include i_emulator.h
}
}  // namespace yaze
 
namespace yaze::net {
 
class EmulatorServiceImpl final : public agent::EmulatorService::Service {
 public:
  using RomGetter = std::function<Rom*()>;
  using RomLoader = std::function<bool(const std::string& path)>;
  // Returns a PNG capture for GetGameState(include_screenshot). It must run
  // the capture on the render thread; GetGameState is called on gRPC threads.
  using ScreenshotCapturer =
      std::function<absl::StatusOr<test::ScreenshotArtifact>()>;
 
  explicit EmulatorServiceImpl(emu::IEmulator* emulator,
                               RomGetter rom_getter = nullptr,
                               RomLoader rom_loader = nullptr);
 
  // Without a capturer, GetGameState omits the screenshot.
  void SetScreenshotCapturer(ScreenshotCapturer capturer) {
    screenshot_capturer_ = std::move(capturer);
  }
 
  // --- ROM Loading ---
  grpc::Status LoadRom(grpc::ServerContext* context,
                       const agent::LoadRomRequest* request,
                       agent::LoadRomResponse* response) override;
  grpc::Status GetLoadedRomPath(
      grpc::ServerContext* context, const agent::Empty* request,
      agent::LoadedRomPathResponse* response) override;
 
  // --- Core Lifecycle & Control ---
  grpc::Status ControlEmulator(grpc::ServerContext* context,
                               const agent::ControlRequest* request,
                               agent::CommandResponse* response) override;
 
  grpc::Status StepEmulator(grpc::ServerContext* context,
                            const agent::StepControlRequest* request,
                            agent::StepResponse* response) override;
 
  grpc::Status RunToBreakpoint(grpc::ServerContext* context,
                               const agent::Empty* request,
                               agent::BreakpointHitResponse* response) override;
 
  // --- Input & State ---
  grpc::Status PressButtons(grpc::ServerContext* context,
                            const agent::ButtonRequest* request,
                            agent::CommandResponse* response) override;
  grpc::Status ReleaseButtons(grpc::ServerContext* context,
                              const agent::ButtonRequest* request,
                              agent::CommandResponse* response) override;
  grpc::Status HoldButtons(grpc::ServerContext* context,
                           const agent::ButtonHoldRequest* request,
                           agent::CommandResponse* response) override;
  grpc::Status GetGameState(grpc::ServerContext* context,
                            const agent::GameStateRequest* request,
                            agent::GameStateResponse* response) override;
  grpc::Status ReadMemory(grpc::ServerContext* context,
                          const agent::MemoryRequest* request,
                          agent::MemoryResponse* response) override;
  grpc::Status WriteMemory(grpc::ServerContext* context,
                           const agent::MemoryWriteRequest* request,
                           agent::CommandResponse* response) override;
 
  // --- Debugging Management ---
  grpc::Status BreakpointControl(
      grpc::ServerContext* context,
      const agent::BreakpointControlRequest* request,
      agent::BreakpointControlResponse* response) override;
 
  grpc::Status WatchpointControl(
      grpc::ServerContext* context,
      const agent::WatchpointControlRequest* request,
      agent::WatchpointControlResponse* response) override;
 
  // --- Analysis & Symbols ---
  grpc::Status GetDisassembly(grpc::ServerContext* context,
                              const agent::DisassemblyRequest* request,
                              agent::DisassemblyResponse* response) override;
  grpc::Status GetExecutionTrace(grpc::ServerContext* context,
                                 const agent::TraceRequest* request,
                                 agent::TraceResponse* response) override;
  grpc::Status ResolveSymbol(grpc::ServerContext* context,
                             const agent::SymbolLookupRequest* request,
                             agent::SymbolLookupResponse* response) override;
  grpc::Status GetSymbolAt(grpc::ServerContext* context,
                           const agent::AddressRequest* request,
                           agent::SymbolLookupResponse* response) override;
  grpc::Status LoadSymbols(grpc::ServerContext* context,
                           const agent::SymbolFileRequest* request,
                           agent::CommandResponse* response) override;
 
  // --- Session & Experiments ---
  grpc::Status GetDebugStatus(grpc::ServerContext* context,
                              const agent::Empty* request,
                              agent::DebugStatusResponse* response) override;
  grpc::Status TestRun(grpc::ServerContext* context,
                       const agent::TestRunRequest* request,
                       agent::TestRunResponse* response) override;
 
  // --- Save State Management ---
  grpc::Status SaveState(grpc::ServerContext* context,
                         const agent::SaveStateRequest* request,
                         agent::SaveStateResponse* response) override;
  grpc::Status LoadState(grpc::ServerContext* context,
                         const agent::LoadStateRequest* request,
                         agent::LoadStateResponse* response) override;
  grpc::Status ListStates(grpc::ServerContext* context,
                          const agent::ListStatesRequest* request,
                          agent::ListStatesResponse* response) override;
 
 private:
  emu::IEmulator*
      emulator_;  // Non-owning pointer to the emulator interface interface
  RomGetter rom_getter_;
  RomLoader rom_loader_;
  ScreenshotCapturer screenshot_capturer_;
  emu::debug::SymbolProvider symbol_provider_;  // Symbol table for debugging
};
 
}  // namespace yaze::net