FileTransfer.php

Go to the documentation of this file.

<?php
 
namespace PlanetTeamSpeak\TeamSpeak3Framework\Adapter;
 
use PlanetTeamSpeak\TeamSpeak3Framework\Exception\FileTransferException;
use PlanetTeamSpeak\TeamSpeak3Framework\Exception\TransportException;
use PlanetTeamSpeak\TeamSpeak3Framework\Helper\Profiler;
use PlanetTeamSpeak\TeamSpeak3Framework\Helper\Signal;
use PlanetTeamSpeak\TeamSpeak3Framework\Helper\StringHelper;
use PlanetTeamSpeak\TeamSpeak3Framework\Transport\Transport;

class FileTransfer extends Adapter
{
    public function syn(): void
    {
        $this->initTransport($this->options);
        $this->transport->setAdapter($this);
 
        Profiler::init(spl_object_hash($this));
 
        Signal::getInstance()->emit("filetransferConnected", $this);
    }

    public function __destruct()
    {
        if ($this->getTransport() instanceof Transport && $this->getTransport()->isConnected()) {
            $this->getTransport()->disconnect();
        }
    }

    protected function init(string $ftkey): void
    {
        if (strlen($ftkey) != 32 && strlen($ftkey) != 16) {
            throw new FileTransferException("invalid file transfer key format");
        }
 
        $this->getProfiler()->start();
        $this->getTransport()->send($ftkey);
 
        Signal::getInstance()->emit("filetransferHandshake", $this);
    }

    public function upload(string $ftkey, int $seek, string $data): void
    {
        $this->init($ftkey);
 
        $size = strlen($data);
        $pack = 4096;
 
        Signal::getInstance()->emit("filetransferUploadStarted", $ftkey, $seek, $size);
 
        for (; $seek < $size;) {
            $rest = $size - $seek;
            $pack = min($rest, $pack);
            $buff = substr($data, $seek, $pack);
            $seek = $seek + $pack;
 
            $this->getTransport()->send($buff);
 
            Signal::getInstance()->emit("filetransferUploadProgress", $ftkey, $seek, $size);
        }
 
        $this->getProfiler()->stop();
 
        Signal::getInstance()->emit("filetransferUploadFinished", $ftkey, $seek, $size);
    }

    public function download(string $ftkey, int $size, bool $passthru = false)
    {
        $this->init($ftkey);
 
        if ($passthru) {
            $this->passthru($size);
            return;
        }
 
        $buff = new StringHelper("");
        $pack = 4096;
 
        Signal::getInstance()->emit("filetransferDownloadStarted", $ftkey, count($buff), $size);
 
        for ($seek = 0; $seek < $size;) {
            $rest = $size - $seek;
            $pack = min($rest, $pack);
            $data = $this->getTransport()->read(min($rest, $pack));
            $seek = $seek + $pack;
 
            $buff->append($data);
 
            Signal::getInstance()->emit("filetransferDownloadProgress", $ftkey, count($buff), $size);
        }
 
        $this->getProfiler()->stop();
 
        Signal::getInstance()->emit("filetransferDownloadFinished", $ftkey, count($buff), $size);
 
        if (strlen($buff) != $size) {
            throw new FileTransferException("incomplete file download (" . count($buff) . " of " . $size . " bytes)");
        }
 
        return $buff;
    }

    protected function passthru(int $size): void
    {
        $buff_size = fpassthru($this->getTransport()->getStream());
 
        if ($buff_size != $size) {
            throw new FileTransferException("incomplete file download (" . $buff_size . " of " . $size . " bytes)");
        }
    }
}