<?php

declare( strict_types = 1 );

namespace Wikibase\Repo\FederatedProperties;

use Deserializers\Deserializer;
use MWTimestamp;
use Wikibase\DataModel\Entity\EntityId;
use Wikibase\Lib\FederatedProperties\FederatedPropertyId;
use Wikibase\Lib\Store\EntityRevision;
use Wikibase\Lib\Store\EntityRevisionLookup;
use Wikibase\Lib\Store\LookupConstants;
use Wikibase\Lib\Store\RevisionedUnresolvedRedirectException;
use Wikimedia\Assert\Assert;

/** @license GPL-2.0-or-later */
class ApiEntityRevisionLookup implements EntityRevisionLookup {

	/** @var ApiEntityLookup */
	private $apiEntityLookup;

	/** @var Deserializer */
	private $entityDeserializer;

	public function __construct(
		ApiEntityLookup $apiEntityLookup,
		Deserializer $entityDeserializer
	) {
		$this->apiEntityLookup = $apiEntityLookup;
		$this->entityDeserializer = $entityDeserializer;
	}

	public function getEntityRevision(
		EntityId $entityId,
		$revisionId = 0,
		$mode = LookupConstants::LATEST_FROM_REPLICA
	) {
		Assert::parameterType( FederatedPropertyId::class, $entityId, '$entityId' );
		Assert::parameter( $revisionId === 0, '$revisionId', 'must be 0 (latest)' );
		/** @var FederatedPropertyId $entityId */
		'@phan-var FederatedPropertyId $entityId';

		$this->apiEntityLookup->fetchEntities( [ $entityId ] );
		$data = $this->apiEntityLookup->getResultPartForId( $entityId );
		if ( isset( $data['missing'] ) ) {
			return null;
		}

		$revisionId = $data['lastrevid'];
		$modified = MWTimestamp::convert( TS_MW, $data['modified'] );
		if ( $data['id'] !== $entityId->getRemoteIdSerialization() ) {
			throw new RevisionedUnresolvedRedirectException(
				$entityId,
				$data['id'], // TODO parse?
				$revisionId,
				$modified
			);
		}

		$entity = $this->entityDeserializer->deserialize( $data );
		return new EntityRevision( $entity, $revisionId, $modified );
	}

	public function getLatestRevisionId( EntityId $entityId, $mode = LookupConstants::LATEST_FROM_REPLICA ) {
		// TODO: Implement getLatestRevisionId() method.
	}

}