Ps2alerts\Api\Transformer\Profiles\OutfitProfileTransformer

Complexity

Total Complexity

23

Size/Duplication

Total Lines	241
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	13

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	1
A	transform()	0	15	1
A	includeFacilities()	0	17	3
B	getCaptureStats()	0	31	4
A	includeInvolvement()	0	5	1
B	includeMetrics()	0	24	2
A	includePlayers()	0	22	3
B	getOutfitPlayers()	0	33	3
B	getOutfitMembers()	0	38	5

<?php

namespace Ps2alerts\Api\Transformer\Profiles;

use League\Fractal\TransformerAbstract;
use Ps2alerts\Api\Contract\DatabaseAwareInterface;
use Ps2alerts\Api\Contract\DatabaseAwareTrait;
use Ps2alerts\Api\Contract\HttpClientAwareInterface;
use Ps2alerts\Api\Contract\HttpClientAwareTrait;
use Ps2alerts\Api\Contract\RedisAwareInterface;
use Ps2alerts\Api\Contract\RedisAwareTrait;
use Ps2alerts\Api\Repository\Metrics\MapRepository;
use Ps2alerts\Api\Repository\Metrics\OutfitRepository;
use Ps2alerts\Api\Repository\Metrics\OutfitTotalRepository;
use Ps2alerts\Api\Repository\Metrics\PlayerRepository;
use Ps2alerts\Api\Repository\Metrics\PlayerTotalRepository;
use Ps2alerts\Api\Transformer\Profiles\OutfitInvolvementTransformer;
use Ps2alerts\Api\Transformer\Profiles\OutfitPlayersTransformer;

class OutfitProfileTransformer extends TransformerAbstract implements
    DatabaseAwareInterface,
    HttpClientAwareInterface,
    RedisAwareInterface
{
    use DatabaseAwareTrait;
    use HttpClientAwareTrait;
    use RedisAwareTrait;

    /**
     * List of available includes to this resource
     *
     * @var array
     */
    protected $availableIncludes = [
        'facilities',
        'involvement',
        'metrics',
        'players'
    ];

    protected $mapRepo;
    protected $outfitRepo;
    protected $outfitTotalRepo;
    protected $playerRepo;
    protected $playerTotalRepo;

    public function __construct(
        MapRepository         $mapRepo,
        OutfitRepository      $outfitRepo,
        OutfitTotalRepository $outfitTotalRepo,
        PlayerRepository      $playerRepo,
        PlayerTotalRepository $playerTotalRepo
    ) {
        $this->mapRepo         = $mapRepo;
        $this->outfitRepo      = $outfitRepo;
        $this->outfitTotalRepo = $outfitTotalRepo;
        $this->playerRepo      = $playerRepo;
        $this->playerTotalRepo = $playerTotalRepo;
    }

    /**
     * The transform method required by Fractal to parse the data and return proper typing and fields.
     *
     * @param  array $data Data to transform
     *
     * @return array
     */
    public function transform($data)
    {
        return [
            'id'        => (string) $data['outfitID'], // Bigint
            'name'      => (string) $data['outfitName'],
            'tag'       => (string) $data['outfitTag'],
            'faction'   => (int) $data['outfitFaction'],
            'kills'     => (int) $data['outfitKills'],
            'deaths'    => (int) $data['outfitDeaths'],
            'teamkills' => (int) $data['outfitTKs'],
            'suicides'  => (int) $data['outfitSuicides'],
            'server'    => (int) $data['outfitServer'],
            'captures'  => (int) $data['outfitCaptures']
        ];
    }

    public function includeFacilities($data)
    {
        $redis = $this->getRedisDriver();
        $key = "ps2alerts:api:profiles:outfit:captures:{$data['outfitID']}";

        if ($redis->exists($key)) {
            $bases = json_decode($redis->get($key), true);
        } else {
            $bases = $this->getCaptureStats($data);

            if (count($bases) > 0) {
                $redis->setEx($key, 3600, json_encode($bases));
            }
        }

        return $this->collection($bases, new OutfitCaptureTransformer);

new \Ps2alerts\Api\Transformer\Profiles\OutfitCaptureTransformer() is of type object<Ps2alerts\Api\Transformer\Profiles\OutfitCaptureTransformer>, but the function expects a callable.

    }

    public function getCaptureStats($data)
    {
        // For some reason, auraSQL or my abstraction code won't handle this. Time to do it manually.

        $pdo = $this->getDatabaseDriver();

        $statement = $pdo->prepare("SELECT defence, facilityID FROM ws_map WHERE outfitCaptured = ?");
        $statement->bindValue(1, $data['outfitID']);
        $statement->execute();

        $bases = [];

        while ($row = $statement->fetch(\PDO::FETCH_OBJ)) {
            if (empty($bases[$row->facilityID])) {
                $bases[$row->facilityID] = [
                    'facility' => $row->facilityID,
                    'captures' => 0,
                    'defences' => 0
                ];
            }

            if ($row->defence === '1') {
                $bases[$row->facilityID]['defences']++;

            } else {
                $bases[$row->facilityID]['captures']++;
            }
        }

        return $bases;
    }

    public function includeInvolvement($data)
    {
        $data = $this->outfitRepo->readAllByIdWithArchive($data['outfitID'], 'outfitID');
        return $this->collection($data, new OutfitInvolvementTransformer);

new \Ps2alerts\Api\Transformer\Profiles\OutfitInvolvementTransformer() is of type object<Ps2alerts\Api\Transformer\Profiles\OutfitInvolvementTransformer>, but the function expects a callable.

    }

    public function includeMetrics($data)
    {
        $metrics = [
            'kills'     => 0,
            'deaths'    => 0,
            'teamkills' => 0,
            'suicides'  => 0,
            'headshots' => 0
        ];

        $alerts = $this->outfitRepo->readAllByIdWithArchive($data['outfitID'], 'outfitID');
        $count = count($alerts);
        $metrics['involvement'] = $count;

        // Calculate metrics
        for ($i = 0; $i < $count; $i++) {
            $metrics['kills']     = $metrics['kills'] + $alerts[$i]['outfitKills'];
            $metrics['deaths']    = $metrics['deaths'] + $alerts[$i]['outfitDeaths'];
            $metrics['teamkills'] = $metrics['teamkills'] + $alerts[$i]['outfitTKs'];
            $metrics['suicides']  = $metrics['suicides'] + $alerts[$i]['outfitSuicides'];
        }

        return $this->item($metrics, new OutfitMetricsTransformer);

new \Ps2alerts\Api\Transformer\Profiles\OutfitMetricsTransformer() is of type object<Ps2alerts\Api\Transformer\Profiles\OutfitMetricsTransformer>, but the function expects a callable.

    }

    public function includePlayers($data)
    {
        $chars = $this->getOutfitMembers($data, 0);

        // If we've hit the upper census limit
        if (count($chars) == 5000) {
            $chars = array_merge($chars, $this->getOutfitMembers($data, 5000));
        }

        $count = count($chars);

        if ($count == 0) {
            return null;
        }

        $players = $this->getOutfitPlayers($data, $chars);

        return $this->collection(
            $players,
            new OutfitPlayersTransformer

new \Ps2alerts\Api\Transformer\Profiles\OutfitPlayersTransformer() is of type object<Ps2alerts\Api\Transformer\Profiles\OutfitPlayersTransformer>, but the function expects a callable.

        );
    }

    public function getOutfitPlayers($data, $chars)
    {
        $redis = $this->getRedisDriver();
        $key = "ps2alerts:api:profiles:outfit:players:{$data['outfitID']}";

        // If we have this cached already
        if (! empty($redis->exists($key))) {
            return json_decode($redis->get($key), true);
        }

        $count = count($chars);
        $whereIn = '';

        // Get all members out of the database
        for ($i = 0; $i < $count; $i++) {
            $whereIn .= "'{$chars[$i]}',";
        }

        // Trim trailing comma
        $whereIn = rtrim($whereIn, ',');

        $query = $this->playerTotalRepo->newQuery();

        $query->cols(['playerID, playerName, playerKills, playerDeaths, playerTeamKills, playerSuicides, headshots']);
        $query->where("playerID IN ({$whereIn})");

        $players = $this->playerTotalRepo->fireStatementAndReturn($query);

        // Cache results in redis
        $redis->setEx($key, 3600, json_encode($players));

        return $players;
    }

    public function getOutfitMembers($data, $offset)
    {
        $client = $this->getHttpClientDriver();
        $redis = $this->getRedisDriver();

        $key = "ps2alerts:api:profiles:outfit:census:members:{$data['outfitID']}:{$offset}";

        // If we have this cached already
        if (! empty($redis->exists($key))) {
            return json_decode($redis->get($key));
        }

        $namespace = 'ps2:v2';

        if ($data['outfitServer'] >= 2000) {
            $namespace = 'ps2ps4eu';
        } elseif ($data['outfitServer'] >= 1000) {
            $namespace = 'ps2ps4us';
        }

        $response = $client->get(
            "https://census.daybreakgames.com/s:planetside2alertstats/get/{$namespace}/outfit_member?outfit_id={$data['outfitID']}&c:limit=5000&c:start={$offset}"
        );

        $body = json_decode($response->getBody()->getContents(), true);

        $count = count($body['outfit_member_list']);
        $chars = [];

        for ($i = 0; $i < $count; $i++) {
            $chars[] = $body['outfit_member_list'][$i]['character_id'];
        }

        // Cache results in redis
        $redis->setEx($key, 3600, json_encode($chars));

        return $chars;
    }
}