sonos.php

<?php
include_once 'overcast.php';

class Sonos
{
  private $sessionId;

  function getSessionId($params)
  {
    error_log("SOAP getSessionId");

    $username = $params->username;
    $password = $params->password;

    $token = login($username, $password);
    if ($token) {
      $response = new StdClass();
      $response->getSessionIdResult = $token;
      return $response;
    } else {
      return new SoapFault("Client.LoginInvalid", "Overcast login failed");
    }
  }

  function credentials($params)
  {
    if (isset($params->sessionId)) {
      $this->sessionId = $params->sessionId;
    }
  }

  function getLastUpdate()
  {
    $start = microtime(true);

    $lastUpdate = getAccountLastUpdate($this->sessionId);

    $response = new StdClass();
    $response->getLastUpdateResult = new StdClass();
    $response->getLastUpdateResult->favorites = $lastUpdate;
    $response->getLastUpdateResult->catalog = $lastUpdate;
    $response->getLastUpdateResult->pollInterval = 300;

    $duration = microtime(true) - $start;
    error_log("SOAP getLastUpdate " . round($duration * 1000) . "ms");

    return $response;
  }

  function getMetadata($params)
  {
    $start = microtime(true);

    $count = $params->count;
    $id = $params->id;
    $index = $params->index;

    $total = 0;
    $mediaCollection = array();
    $mediaMetadata = array();

    if ($id == "root") {
      $total = 2;

      $media = new StdClass();
      $media->id = "active";
      $media->itemType = "container";
      $media->displayType = "";
      $media->title = "All Active Episodes";
      $media->canPlay = true;
      $media->canAddToFavorites = false;
      $media->containsFavorite = true;
      $mediaCollection[] = $media;

      $media = new StdClass();
      $media->id = "podcasts";
      $media->itemType = "container";
      $media->displayType = "";
      $media->title = "Podcasts";
      $media->canAddToFavorites = false;
      $mediaCollection[] = $media;
    } elseif ($id == "active") {
      $episodeIDs = fetchAccount($this->sessionId)->episodeIDs;
      $total = count($episodeIDs);

      foreach (array_slice($episodeIDs, $index, $count) as $episodeID) {
        $mediaMetadata[] = $this->findEpisodeMediaMetadata($episodeID, true);

        if (microtime(true) - $start > 1) {
          break;
        }
      }
    } elseif ($id == "podcasts") {
      $podcastIDs = fetchAccount($this->sessionId)->podcastIDs;
      $total = count($podcastIDs);

      foreach (array_slice($podcastIDs, $index, $count) as $podcastID) {
        $mediaCollection[] = $this->findPodcastMediaMetadata($podcastID);

        if (microtime(true) - $start > 1) {
          break;
        }
      }
    } else {
      $podcast = fetchPodcast($id);
      $activeEpisodeIDs = fetchAccount($this->sessionId)->episodeIDs;
      $total = count($podcast->episodeIDs);

      foreach (
        array_slice($podcast->episodeIDs, $index, $count)
        as $episodeID
      ) {
        $mediaMetadata[] = $this->findEpisodeMediaMetadata(
          $episodeID,
          in_array($episodeID, $activeEpisodeIDs)
        );

        if (microtime(true) - $start > 1) {
          break;
        }
      }
    }

    $response = new StdClass();
    $response->getMetadataResult = new StdClass();
    $response->getMetadataResult->index = $index;
    $response->getMetadataResult->total = $total;
    $response->getMetadataResult->count =
      count($mediaCollection) + count($mediaMetadata);
    $response->getMetadataResult->mediaCollection = $mediaCollection;
    $response->getMetadataResult->mediaMetadata = $mediaMetadata;

    $duration = microtime(true) - $start;
    error_log("SOAP getMetadata " . round($duration * 1000) . "ms");

    return $response;
  }

  function getMediaMetadata($params)
  {
    $start = microtime(true);

    $id = $params->id;

    $response = new StdClass();

    $activeEpisodeIDs = fetchAccount($this->sessionId)->episodeIDs;
    $response->getMediaMetadataResult = $this->findEpisodeMediaMetadata(
      $id,
      in_array($id, $activeEpisodeIDs)
    );

    $duration = microtime(true) - $start;
    error_log("SOAP getMediaMetadata " . round($duration * 1000) . "ms");

    return $response;
  }

  function getMediaURI($params)
  {
    $start = microtime(true);

    $id = $params->id;

    $episode = fetchEpisode($id);
    if (is_null($episode)) {
      return new SoapFault("Client.ItemNotFound", "Episode not found.");
    }

    $response = new StdClass();
    $response->getMediaURIResult = followRedirects($episode->url);

    $progress = fetchEpisodeProgress($this->sessionId, $id);
    if ($progress) {
      $response->positionInformation = new StdClass();
      $response->positionInformation->id = $id;
      $response->positionInformation->index = 0;
      $response->positionInformation->offsetMillis = $progress->position * 1000;
    }

    $duration = microtime(true) - $start;
    error_log("SOAP getMediaURI " . round($duration * 1000) . "ms");

    return $response;
  }

  function getExtendedMetadata($params)
  {
    $start = microtime(true);

    $id = $params->id;

    $response = new StdClass();
    $response->getExtendedMetadataResult = new StdClass();

    if ($id == "root") {
    } elseif ($id == "active") {
    } elseif ($id == "podcasts") {
    } elseif (substr($id, 0, 1) == '+') {
      $activeEpisodeIDs = fetchAccount($this->sessionId)->episodeIDs;
      $response->getExtendedMetadataResult->mediaMetadata = $this->findEpisodeMediaMetadata(
        $id,
        in_array($id, $activeEpisodeIDs)
      );
    } else {
      $response->getExtendedMetadataResult->mediaCollection = $this->findPodcastMediaMetadata(
        $id
      );
    }

    $duration = microtime(true) - $start;
    error_log("SOAP getExtendedMetadata " . round($duration * 1000) . "ms");

    return $response;
  }

  function createItem($params)
  {
    $start = microtime(true);

    $id = $params->favorite;

    $response = new StdClass();
    $response->createItemResult = $id;

    addEpisode($this->sessionId, $id);

    $duration = microtime(true) - $start;
    error_log("SOAP createItem " . round($duration * 1000) . "ms");

    return $response;
  }

  function deleteItem($params)
  {
    $start = microtime(true);

    $id = $params->favorite;

    $response = new StdClass();

    deleteEpisode($this->sessionId, $id);

    $duration = microtime(true) - $start;
    error_log("SOAP createItem " . round($duration * 1000) . "ms");

    return $response;
  }

  function setPlayedSeconds($params)
  {
    $start = microtime(true);

    $id = $params->id;
    $offsetMillis = $params->offsetMillis;

    if ($offsetMillis) {
      updateEpisodeProgress($this->sessionId, $id, $offsetMillis / 1000);
    }

    $response = new StdClass();
    $response->setPlayedSecondsResult = new StdClass();

    $duration = microtime(true) - $start;
    error_log("SOAP setPlayedSeconds " . round($duration * 1000) . "ms");

    return $response;
  }

  function reportPlaySeconds($params)
  {
    $start = microtime(true);

    $id = $params->id;
    $offsetMillis = $params->offsetMillis;

    if ($offsetMillis) {
      updateEpisodeProgress($this->sessionId, $id, $offsetMillis / 1000);
    }

    $response = new StdClass();
    $response->reportPlaySecondsResult = new StdClass();
    $response->reportPlaySecondsResult->interval = 10;

    $duration = microtime(true) - $start;
    error_log("SOAP reportPlaySeconds " . round($duration * 1000) . "ms");

    return $response;
  }

  function reportPlayStatus($params)
  {
    $start = microtime(true);

    $id = $params->id;
    $offsetMillis = $params->offsetMillis;

    if ($offsetMillis) {
      updateEpisodeProgress($this->sessionId, $id, $offsetMillis / 1000);
    }

    $response = new StdClass();
    $response->reportPlayStatusResult = new StdClass();

    $duration = microtime(true) - $start;
    error_log("SOAP reportPlayStatus " . round($duration * 1000) . "ms");

    return $response;
  }

  function findPodcastMediaMetadata($id)
  {
    $media = new StdClass();
    $podcast = fetchPodcast($id);

    if (is_null($podcast)) {
      $media->id = $id;
      $media->itemType = "album";
      $media->displayType = "";
      $media->title = "Podcast not found";
      $media->canPlay = false;
      $media->canAddToFavorites = false;
      $media->containsFavorite = false;
    } else {
      $media->id = $podcast->id;
      $media->itemType = "album";
      $media->displayType = "";
      $media->title = $podcast->title;
      $media->albumArtURI = $podcast->imageURL;
      $media->canPlay = true;
      $media->canAddToFavorites = false;
      $media->containsFavorite = false;
    }

    return $media;
  }

  function findEpisodeMediaMetadata($id, $favorite)
  {
    $media = new StdClass();
    $episode = fetchEpisode($id);

    if (is_null($episode)) {
      $media->id = $id;
      $media->itemType = "track";
      $media->title = "Episode not found";
      $media->mimeType = "audio/mp3";
      $media->displayType = "";
      $media->summary = "";
      $media->trackMetadata = new StdClass();
      $media->trackMetadata->canPlay = false;
    } else {
      $media->id = $episode->id;
      $media->isFavorite = $favorite;
      $media->displayType = "";
      $media->mimeType = $episode->mimeType;
      $media->itemType = "track";
      $media->title = $episode->title;
      $media->summary = "";
      $media->trackMetadata = new StdClass();
      $media->trackMetadata->canPlay = true;
      $media->trackMetadata->canAddToFavorites = true;
      $media->trackMetadata->albumArtURI = $episode->imageURL;
      $media->trackMetadata->albumId = $episode->podcastId;
      $media->trackMetadata->album = $episode->podcastTitle;

      if (isset($episode->number)) {
        $media->trackMetadata->trackNumber = $episode->number;
      }

      if (isset($episode->duration)) {
        $media->trackMetadata->canResume = true;
        $media->trackMetadata->duration = $episode->duration;
      }
    }

    return $media;
  }
}
?>