self::READING, MangaReadingStatus::PLAN_TO_READ => self::PLAN_TO_READ, MangaReadingStatus::ON_HOLD => self::ON_HOLD, MangaReadingStatus::DROPPED => self::DROPPED, MangaReadingStatus::COMPLETED => self::COMPLETED ]; /** * The base url for api requests * @var string */ protected $base_url = "https://hummingbird.me/"; protected function _manga_api_call($type, $url, $json=null) { $token = $this->container->get('auth') ->get_auth_token(); // Set the token cookie, with the authentication token // from the auth class. $cookieJar = $this->cookieJar; $cookie_data = new SetCookie([ 'Name' => 'token', 'Value' => $token, 'Domain' => 'hummingbird.me' ]); $cookieJar->setCookie($cookie_data); $config = [ 'cookies' => $cookieJar ]; if ( ! is_null($json)) { $config['json'] = $json; } $result = $this->client->request(strtoupper($type), $url, $config); return [ 'statusCode' => $result->getStatusCode(), 'body' => $result->getBody() ]; } /** * Add a manga to the list * * @param array $data */ public function add($data) { $object = [ 'manga_library_entry' => [ 'status' => $data['status'], 'manga_id' => $data['id'] ] ]; return $this->_manga_api_call('post', 'manga_library_entries', $object); } /** * Update the selected manga * * @param array $data * @return array */ public function update($data) { $id = $data['id']; return $this->_manga_api_call( 'put', "manga_library_entries/{$id}", ['manga_library_entry' => $data] ); } /** * Delete a manga entry * * @param array $data * @return array */ public function delete($data) { $id = $data['id']; return $this->_manga_api_call('delete', "manga_library_entries/{$id}"); } /** * Search for manga by name * * @param string $name * @return array */ public function search($name) { $logger = $this->container->getLogger('default'); $config = [ 'query' => [ 'scope' => 'manga', 'depth' => 'full', 'query' => $name ] ]; $response = $this->get('search.json', $config); if ($response->getStatusCode() != 200) { $logger->warning("Non 200 response for search api call"); $logger->warning($response->getBody()); throw new RuntimeException($response->getEffectiveUrl()); } return Json::decode($response->getBody(), TRUE); } /** * Get the full set of anime lists * * @return array */ public function get_all_lists() { $data = $this->_get_list_from_api(); foreach ($data as &$val) { $this->sort_by_name($val, 'manga'); } return $data; } /** * Get a category out of the full list * * @param string $status * @return array */ public function get_list($status) { $data = $this->_get_list_from_api($status); $this->sort_by_name($data, 'manga'); return $data; } /** * Retrieve the list from the hummingbird api * * @param string $status * @return array */ protected function _get_list_from_api($status = "All") { $config = [ 'query' => [ 'user_id' => $this->config->get('hummingbird_username') ], 'allow_redirects' => FALSE ]; $response = $this->get('manga_library_entries', $config); $data = $this->_check_cache($response); $output = $this->map_by_status($data); return (array_key_exists($status, $output)) ? $output[$status] : $output; } /** * Check the status of the cache and return the appropriate response * * @param \GuzzleHttp\Message\Response $response * @codeCoverageIgnore * @return array */ private function _check_cache($response) { // Bail out early if there isn't any manga data $api_data = Json::decode($response->getBody(), TRUE); if ( ! array_key_exists('manga', $api_data)) { return []; } $cache_file = _dir($this->config->get('data_cache_path'), 'manga.json'); $transformed_cache_file = _dir( $this->config->get('data_cache_path'), 'manga-transformed.json' ); $cached_data = file_exists($cache_file) ? Json::decodeFile($cache_file) : []; if ($cached_data === $api_data && file_exists($transformed_cache_file)) { return Json::decodeFile($transformed_cache_file); } else { Json::encodeFile($cache_file, $api_data); $zippered_data = $this->zipper_lists($api_data); $transformer = new Transformer\MangaListTransformer(); $transformed_data = $transformer->transform_collection($zippered_data); Json::encodeFile($transformed_cache_file, $transformed_data); return $transformed_data; } } /** * Map transformed anime data to be organized by reading status * * @param array $data * @return array */ private function map_by_status($data) { $output = [ self::READING => [], self::PLAN_TO_READ => [], self::ON_HOLD => [], self::DROPPED => [], self::COMPLETED => [], ]; foreach ($data as &$entry) { $entry['manga']['image'] = $this->get_cached_image( $entry['manga']['image'], $entry['manga']['slug'], 'manga' ); $key = $this->const_map[$entry['reading_status']]; $output[$key][] = $entry; } return $output; } /** * Combine the two manga lists into one * @param array $raw_data * @return array */ private function zipper_lists($raw_data) { return (new Transformer\MangaListsZipper($raw_data))->transform(); } } // End of MangaModel.php