Update command sending from server API to use new daemon code

Author: DaneEveritt

app/Http/Controllers/Api/Client/Servers/CommandController.php

@@ -7,25 +7,25 @@
 use Psr\Http\Message\ResponseInterface;
 use GuzzleHttp\Exception\ClientException;
 use GuzzleHttp\Exception\RequestException;
+use Pterodactyl\Repositories\Wings\DaemonCommandRepository;
 use Pterodactyl\Http\Controllers\Api\Client\ClientApiController;
 use Pterodactyl\Http\Requests\Api\Client\Servers\SendCommandRequest;
 use Pterodactyl\Exceptions\Http\Connection\DaemonConnectionException;
-use Pterodactyl\Contracts\Repository\Daemon\CommandRepositoryInterface;
 use Symfony\Component\HttpKernel\Exception\PreconditionFailedHttpException;
 
 class CommandController extends ClientApiController
 {
     /**
-     * @var \Pterodactyl\Contracts\Repository\Daemon\CommandRepositoryInterface
+     * @var \Pterodactyl\Repositories\Wings\DaemonCommandRepository
      */
     private $repository;
 
     /**
      * CommandController constructor.
      *
-     * @param \Pterodactyl\Contracts\Repository\Daemon\CommandRepositoryInterface $repository
+     * @param \Pterodactyl\Repositories\Wings\DaemonCommandRepository $repository
      */
-    public function __construct(CommandRepositoryInterface $repository)
+    public function __construct(DaemonCommandRepository $repository)
     {
         parent::__construct();
 
@@ -43,12 +43,9 @@ public function __construct(CommandRepositoryInterface $repository)
     public function index(SendCommandRequest $request): Response
     {
         $server = $request->getModel(Server::class);
-        $token = $request->attributes->get('server_token');
 
         try {
-            $this->repository->setServer($server)
-                ->setToken($token)
-                ->send($request->input('command'));
+            $this->repository->setServer($server)->send($request->input('command'));
         } catch (RequestException $exception) {
             if ($exception instanceof ClientException) {
                 if ($exception->getResponse() instanceof ResponseInterface && $exception->getResponse()->getStatusCode() === 412) {

app/Repositories/Wings/DaemonCommandRepository.php

@@ -2,6 +2,27 @@
 
 namespace Pterodactyl\Repositories\Wings;
 
+use Webmozart\Assert\Assert;
+use Pterodactyl\Models\Server;
+use Psr\Http\Message\ResponseInterface;
+
 class DaemonCommandRepository extends DaemonRepository
 {
+    /**
+     * Sends a command or multiple commands to a running server instance.
+     *
+     * @param string|string[] $command
+     * @return \Psr\Http\Message\ResponseInterface
+     */
+    public function send($command): ResponseInterface
+    {
+        Assert::isInstanceOf(Server::class, $this->server);
+
+        return $this->getHttpClient()->post(
+            sprintf('/api/servers/%s/commands', $this->server->uuid),
+            [
+                'json' => ['commands' => is_array($command) ? $command : [$command]],
+            ]
+        );
+    }
 }