Stats\Models\StatsModel

Complexity

Total Complexity

8

Size/Duplication

Total Lines	116
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

95.12%

Importance

Changes	9
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	getItems()	0	61	6
B	save()	0	24	2

<?php

namespace Stats\Models;

use Joomla\Database\Query\LimitableInterface;
use Joomla\Model\AbstractDatabaseModel;

/**
 * Statistics database model
 *
 * @since  1.0
 */
class StatsModel extends AbstractDatabaseModel
{
	/**
	 * The query batch size
	 *
	 * @var    integer
	 * @since  1.0
	 */
	private $batchSize = 25000;

	/**
	 * Loads the statistics data from the database.
	 *
	 * @param   string  $column  A single column to filter on
	 *
	 * @return  \Generator  A Generator containing the response data
	 *
	 * @since   1.0
	 * @throws  \InvalidArgumentException
	 */
	public function getItems(string $column = '') : \Generator
	{
		$db = $this->getDb();

		// To keep from running out of memory, we need to know how many records are in the database to be able to loop correctly
		$totalRecords = $db->setQuery(
			$db->getQuery(true)
				->select('COUNT(unique_id)')
				->from('#__jstats')
		)->loadResult();

		// Validate the requested column is actually in the table
		if ($column !== '')
		{
			$columnList = $db->getTableColumns('#__jstats');

			// The column should exist in the table and be part of the API
			if (!in_array($column, array_keys($columnList)) && !in_array($column, ['unique_id', 'modified']))
			{
				throw new \InvalidArgumentException('An invalid data source was requested.', 404);
			}

			$query = $db->getQuery(true)
				->select($column);
		}
		else
		{
			$query = $db->getQuery(true)
				->select(['php_version', 'db_type', 'db_version', 'cms_version', 'server_os']);
		}

		$query->from('#__jstats')
			->group('unique_id');

		$limitable = $query instanceof LimitableInterface;

		// We can't have this as a single array, we run out of memory... This is gonna get interesting...
		for ($offset = 0; $offset < $totalRecords; $offset + $this->batchSize)
		{
			if ($limitable)
			{
				$query->setLimit($this->batchSize, $offset);

				$db->setQuery($query);
			}
			else
			{
				$db->setQuery($query, $offset, $this->batchSize);
			}

			yield $db->loadAssocList();

			$offset += $this->batchSize;
		}

		// Disconnect the DB to free some memory
		$db->disconnect();

		// And unset some variables
		unset($db, $query, $offset, $totalRecords);
	}

	/**
	 * Saves the given data.
	 *
	 * @param   \stdClass  $data  Data object to save.
	 *
	 * @return  void
	 *
	 * @since   1.0
	 */
	public function save(\stdClass $data)
	{
		$db = $this->getDb();

		// Set the modified date of the record
		$data->modified = (new \DateTime('now', new \DateTimeZone('UTC')))->format($db->getDateFormat());

		// Check if a row exists for this unique ID and update the existing record if so
		$recordExists = $db->setQuery(
			$db->getQuery(true)
				->select('unique_id')
				->from('#__jstats')
				->where('unique_id = ' . $db->quote($data->unique_id))
		)->loadResult();

		if ($recordExists)
		{
			$db->updateObject('#__jstats', $data, ['unique_id']);
		}
		else
		{
			$db->insertObject('#__jstats', $data, ['unique_id']);

array('unique_id') is of type array<integer,string,{"0":"string"}>, but the function expects a string|null.

		}
	}
}