extension.php

<?php

class StarToPocketExtension extends Minz_Extension {

	public function init() {
		$this->registerTranslates();

		// New, watching for star activity
		$this->registerHook('entries_favorite', [$this, 'handleStar']);
		$this->registerController('starToPocket');
		$this->registerViews();
	}

	public function handleConfigureAction() {
		$this->registerTranslates();
		
		if (Minz_Request::isPost()) {
			$keyboard_shortcut = Minz_Request::param('keyboard_shortcut', '');
			FreshRSS_Context::$user_conf->pocket_keyboard_shortcut = $keyboard_shortcut;
			FreshRSS_Context::$user_conf->save();
		}
	}

	/**
	 * if isStarred, send each starredEntry to 
	 * addAction in the controller.
	 */
	public function handleStar(array $starredEntries, bool $isStarred): void {
		$this->registerTranslates();
		foreach ($starredEntries as $entry) {
			if ($isStarred){
				$this->addAction($entry);
			}
		}
	}

	public function addAction($id)
	{
		// $this->view->_layout(false);

		$entry_dao = FreshRSS_Factory::createEntryDao();
		$entry = $entry_dao->searchById($id);

		if ($entry === null) {
			echo json_encode(array('status' => 404));
			return;
		}

		$post_data = array(
			'consumer_key' => FreshRSS_Context::$user_conf->pocket_consumer_key,
			'access_token' => FreshRSS_Context::$user_conf->pocket_access_token,
			'url' => $entry->link(),
			'title' => $entry->title(),
			'time' => time()
		);

		$result = $this->curlPostRequest('https://getpocket.com/v3/add', $post_data);
		$result['response'] = array('title' => $entry->title());

		// This was causing error messages to appear when starring
		// echo json_encode($result);
	}

	private function curlPostRequest($url, $post_data)
	{
		$headers = array(
			'Content-Type: application/json; charset=UTF-8',
			'X-Accept: application/json'
		);

		$curl = curl_init();
		curl_setopt($curl, CURLOPT_URL, $url);
		curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
		curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
		curl_setopt($curl, CURLOPT_HEADER, true);
		curl_setopt($curl, CURLOPT_POST, true);
		curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($post_data));

		$response = curl_exec($curl);

		$header_size = curl_getinfo($curl, CURLINFO_HEADER_SIZE);
		$response_header = substr($response, 0, $header_size);
		$response_body = substr($response, $header_size);
		$response_headers = $this->httpHeaderToArray($response_header);

		return array(
			'response' => json_decode($response_body),
			'status' => curl_getinfo($curl, CURLINFO_HTTP_CODE),
			'errorCode' => isset($response_headers['x-error-code']) ? intval($response_headers['x-error-code']) : 0
		);
	}

	private function httpHeaderToArray($header)
	{
		$headers = array();
		$headers_parts = explode("\r\n", $header);

		foreach ($headers_parts as $header_part) {
			// skip empty header parts
			if (strlen($header_part) <= 0) {
				continue;
			}

			// Filter the beginning of the header which is the basic HTTP status code
			if (strpos($header_part, ':')) {
				$header_name = substr($header_part, 0, strpos($header_part, ':'));
				$header_value = substr($header_part, strpos($header_part, ':') + 1);
				$headers[$header_name] = trim($header_value);
			}
		}

		return $headers;
	}
}