sintonia/legacy/application/services/ThirdPartyService.php

<?php

/**
 * Class ServiceNotFoundException.
 */
class ServiceNotFoundException extends Exception
{
}

/**
 * Class ThirdPartyService generic superclass for third-party services.
 */
abstract class Application_Service_ThirdPartyService
{
    /**
     * @var string service name to store in ThirdPartyTrackReferences database
     */
    protected static $_SERVICE_NAME;

    /**
     * Create a ThirdPartyTrackReferences object for a track that's been uploaded
     * to an external service
     * TODO: should we have a database layer class to handle Propel operations?
     *
     * @param $fileId int local CcFiles identifier
     *
     * @return string the new ThirdPartyTrackReferences identifier
     *
     * @throws Exception
     * @throws PropelException
     */
    public function createTrackReference($fileId)
    {
        // First, check if the track already has an entry in the database
        // If the file ID given is null, create a new reference
        $ref = is_null($fileId) ? null : ThirdPartyTrackReferencesQuery::create()
            ->filterByDbService(static::$_SERVICE_NAME)
            ->findOneByDbFileId($fileId);
        if (is_null($ref)) {
            $ref = new ThirdPartyTrackReferences();
        }
        $ref->setDbService(static::$_SERVICE_NAME);
        $ref->setDbFileId($fileId);
        $ref->save();

        return $ref->getDbId();
    }

    /**
     * Remove a ThirdPartyTrackReferences row from the database.
     * This is necessary if the track was removed from the service
     * or the foreign id in our database is incorrect.
     *
     * @param $fileId int cc_files identifier
     *
     * @throws Exception
     * @throws PropelException
     */
    public function removeTrackReference($fileId)
    {
        $ref = ThirdPartyTrackReferencesQuery::create()
            ->filterByDbService(static::$_SERVICE_NAME)
            ->findOneByDbFileId($fileId);
        $ref->delete();
    }

    /**
     * Given a CcFiles identifier for a file that's been uploaded to a third-party service,
     * return the third-party identifier for the remote file.
     *
     * @param int $fileId the cc_files identifier
     *
     * @return string the service foreign identifier
     */
    public function getServiceId($fileId)
    {
        $ref = ThirdPartyTrackReferencesQuery::create()
            ->filterByDbService(static::$_SERVICE_NAME)
            ->findOneByDbFileId($fileId)  // There shouldn't be duplicates!
;

        return empty($ref) ? '' : $ref->getDbForeignId();
    }

    /**
     * Check if a reference exists for a given CcFiles identifier.
     *
     * @param int $fileId the cc_files identifier
     *
     * @return int 1 if the file has been published,
     *             0 if the file has yet to be published,
     *             or -1 if the file is in a pending state
     */
    public function referenceExists($fileId)
    {
        $ref = ThirdPartyTrackReferencesQuery::create()
            ->filterByDbService(static::$_SERVICE_NAME)
            ->findOneByDbFileId($fileId);
        if (!empty($ref)) {
            $task = CeleryTasksQuery::create()
                ->orderByDbDispatchTime(Criteria::DESC)
                ->findOneByDbTrackReference($ref->getDbId());

            return $task->getDbStatus() == CELERY_PENDING_STATUS ? -1
                : ($task->getDbStatus() == CELERY_FAILED_STATUS ? 0 : 1);
        }

        return 0;
    }
}