'Ombi',
'enabled' => strpos('personal', $this->config['license']) !== false,
'image' => 'plugins/images/tabs/ombi.png',
'category' => 'Requests',
'settingsArray' => __FUNCTION__
];
if ($infoOnly) {
return $homepageInformation;
}
$homepageSettings = [
'debug' => true,
'settings' => [
'Enable' => [
$this->settingsOption('enable', 'homepageOmbiEnabled'),
$this->settingsOption('auth', 'homepageOmbiAuth'),
],
'Connection' => [
$this->settingsOption('url', 'ombiURL'),
$this->settingsOption('token', 'ombiToken'),
$this->settingsOption('username', 'ombiFallbackUser', ['label' => 'Ombi Fallback User', 'help' => 'Organizr will request an Ombi User Token based off of this user credentials']),
$this->settingsOption('password', 'ombiFallbackPassword', ['label' => 'Ombi Fallback Password',]),
$this->settingsOption('disable-cert-check', 'ombiDisableCertCheck'),
$this->settingsOption('use-custom-certificate', 'ombiUseCustomCertificate'),
],
'Misc Options' => [
$this->settingsOption('auth', 'homepageOmbiRequestAuth', ['label' => 'Minimum Group to Request']),
$this->settingsOption('select', 'ombiTvDefault', ['label' => 'TV Show Default Request', 'options' => $this->requestTvOptions()]),
$this->settingsOption('switch', 'ombiLimitUser', ['label' => 'Limit to User']),
$this->settingsOption('limit', 'ombiLimit'),
$this->settingsOption('refresh', 'ombiRefresh'),
$this->settingsOption('switch', 'ombiAlias', ['label' => 'Use Ombi Alias Names', 'help' => 'Use Ombi Alias Names instead of Usernames - If Alias is blank, Alias will fallback to Username']),
],
'Default Filter' => [
$this->settingsOption('switch', 'ombiDefaultFilterAvailable', ['label' => 'Show Available', 'help' => 'Show All Available Ombi Requests']),
$this->settingsOption('switch', 'ombiDefaultFilterUnavailable', ['label' => 'Show Unavailable', 'help' => 'Show All Unavailable Ombi Requests']),
$this->settingsOption('switch', 'ombiDefaultFilterApproved', ['label' => 'Show Approved', 'help' => 'Show All Approved Ombi Requests']),
$this->settingsOption('switch', 'ombiDefaultFilterUnapproved', ['label' => 'Show Unapproved', 'help' => 'Show All Unapproved Ombi Requests']),
$this->settingsOption('switch', 'ombiDefaultFilterDenied', ['label' => 'Show Denied', 'help' => 'Show All Denied Ombi Requests']),
],
'Test Connection' => [
$this->settingsOption('blank', null, ['label' => 'Please Save before Testing']),
$this->settingsOption('test', 'ombi'),
]
]
];
return array_merge($homepageInformation, $homepageSettings);
}
public function testConnectionOmbi()
{
if (empty($this->config['ombiURL'])) {
$this->setAPIResponse('error', 'Ombi URL is not defined', 422);
return false;
}
if (empty($this->config['ombiToken'])) {
$this->setAPIResponse('error', 'Ombi Token is not defined', 422);
return false;
}
$headers = array(
"Accept" => "application/json",
"Apikey" => $this->config['ombiToken'],
);
$url = $this->qualifyURL($this->config['ombiURL']);
try {
$options = $this->requestOptions($url, null, $this->config['ombiDisableCertCheck'], $this->config['ombiUseCustomCertificate']);
$test = Requests::get($url . "/api/v1/Settings/about", $headers, $options);
if ($test->success) {
$this->setAPIResponse('success', 'API Connection succeeded', 200);
return true;
} else {
$this->setResponse(401, $test->body);
return false;
}
} catch (Requests_Exception $e) {
$this->setLoggerChannel('Ombi')->error($e);
$this->setResponse(500, $e->getMessage());
return false;
}
}
public function ombiHomepagePermissions($key = null)
{
$permissions = [
'main' => [
'enabled' => [
'homepageOmbiEnabled'
],
'auth' => [
'homepageOmbiAuth'
],
'not_empty' => [
'ombiURL',
'ombiToken'
]
]
];
return $this->homepageCheckKeyPermissions($key, $permissions);
}
public function homepageOrderombi()
{
if ($this->homepageItemPermissions($this->ombiHomepagePermissions('main'))) {
return '
';
}
}
public function getOmbiRequests($type = "both", $limit = 50, $offset = 0)
{
if (!$this->homepageItemPermissions($this->ombiHomepagePermissions('main'), true)) {
return false;
}
$api['count'] = array(
'movie' => 0,
'tv' => 0,
'limit' => (integer)$limit,
'offset' => (integer)$offset
);
$headers = array(
"Accept" => "application/json",
"Apikey" => $this->config['ombiToken'],
);
$requests = array();
$url = $this->qualifyURL($this->config['ombiURL']);
try {
$options = $this->requestOptions($url, $this->config['ombiRefresh'], $this->config['ombiDisableCertCheck'], $this->config['ombiUseCustomCertificate']);
switch ($type) {
case 'movie':
$movie = Requests::get($url . "/api/v1/Request/movie", $headers, $options);
break;
case 'tv':
$tv = Requests::get($url . "/api/v1/Request/tv", $headers, $options);
break;
default:
$movie = Requests::get($url . "/api/v1/Request/movie", $headers, $options);
$tv = Requests::get($url . "/api/v1/Request/tv", $headers, $options);
break;
}
if ($movie->success || $tv->success) {
if (isset($movie)) {
$movie = json_decode($movie->body, true);
//$movie = array_reverse($movie);
foreach ($movie as $key => $value) {
$proceed = (($this->config['ombiLimitUser']) && strtolower($this->user['username']) == strtolower($value['requestedUser']['userName'])) || (strtolower($value['requestedUser']['userName']) == strtolower($this->config['ombiFallbackUser'])) || (!$this->config['ombiLimitUser']) || $this->qualifyRequest(1);
if ($proceed) {
$api['count']['movie']++;
$requests[] = array(
'id' => $value['theMovieDbId'],
'title' => $value['title'],
'overview' => $value['overview'],
'poster' => (isset($value['posterPath']) && $value['posterPath'] !== '') ? 'https://image.tmdb.org/t/p/w300/' . $value['posterPath'] : 'plugins/images/homepage/no-list.png',
'background' => (isset($value['background']) && $value['background'] !== '') ? 'https://image.tmdb.org/t/p/w1280/' . $value['background'] : '',
'approved' => $value['approved'],
'available' => $value['available'],
'denied' => $value['denied'],
'deniedReason' => $value['deniedReason'],
'user' => $value['requestedUser']['userName'],
'userAlias' => $value['requestedUser']['userAlias'],
'request_id' => $value['id'],
'request_date' => $value['requestedDate'],
'release_date' => $value['releaseDate'],
'type' => 'movie',
'icon' => 'mdi mdi-filmstrip',
'color' => 'palette-Deep-Purple-900 bg white',
);
}
}
}
if (isset($tv) && (is_array($tv) || is_object($tv))) {
$tv = json_decode($tv->body, true);
foreach ($tv as $key => $value) {
if (count($value['childRequests']) > 0) {
$proceed = (($this->config['ombiLimitUser']) && strtolower($this->user['username']) == strtolower($value['childRequests'][0]['requestedUser']['userName'])) || (!$this->config['ombiLimitUser']) || $this->qualifyRequest(1);
if ($proceed) {
$api['count']['tv']++;
$requests[] = array(
'id' => $value['tvDbId'],
'title' => $value['title'],
'overview' => $value['overview'],
'poster' => (isset($value['posterPath']) && $value['posterPath'] !== '') ? (str_starts_with($value['posterPath'], '/') ? 'https://image.tmdb.org/t/p/w300/' . $value['posterPath'] : $value['posterPath']) : 'plugins/images/homepage/no-list.png',
'background' => (isset($value['background']) && $value['background'] !== '') ? 'https://image.tmdb.org/t/p/w1280/' . $value['background'] : '',
'approved' => $value['childRequests'][0]['approved'],
'available' => $value['childRequests'][0]['available'],
'denied' => $value['childRequests'][0]['denied'],
'deniedReason' => $value['childRequests'][0]['deniedReason'],
'user' => $value['childRequests'][0]['requestedUser']['userName'],
'userAlias' => $value['childRequests'][0]['requestedUser']['userAlias'],
'request_id' => $value['id'],
'request_date' => $value['childRequests'][0]['requestedDate'],
'release_date' => $value['releaseDate'],
'type' => 'tv',
'icon' => 'mdi mdi-television',
'color' => 'grayish-blue-bg',
);
}
}
}
}
//sort here
usort($requests, function ($item1, $item2) {
if ($item1['request_date'] == $item2['request_date']) {
return 0;
}
return $item1['request_date'] > $item2['request_date'] ? -1 : 1;
});
}
} catch (Requests_Exception $e) {
$this->setLoggerChannel('Ombi')->error($e);
$this->setResponse(500, $e->getMessage());
return false;
};
$api['content'] = isset($requests) ? array_slice($requests, $offset, $limit) : false;
$this->setAPIResponse('success', null, 200, $api);
return $api;
}
public function addOmbiRequest($id, $type)
{
$id = ($id) ?? null;
$type = ($type) ?? null;
if (!$id) {
$this->setAPIResponse('error', 'Id was not supplied', 422);
return false;
}
if (!$type) {
$this->setAPIResponse('error', 'Type was not supplied', 422);
return false;
}
if (!$this->homepageItemPermissions($this->ombiHomepagePermissions('main'), true)) {
return false;
}
$url = $this->qualifyURL($this->config['ombiURL']);
switch ($type) {
case 'season':
case 'tv':
$type = 'tv';
$add = array(
'tvDbId' => $id,
'requestAll' => $this->ombiTVDefault('all'),
'latestSeason' => $this->ombiTVDefault('last'),
'firstSeason' => $this->ombiTVDefault('first')
);
break;
default:
$type = 'movie';
$add = array("theMovieDbId" => (int)$id);
break;
}
try {
$options = array('timeout' => 30);
if (isset($_COOKIE['Auth'])) {
$headers = array(
"Accept" => "application/json",
"Content-Type" => "application/json",
"Authorization" => "Bearer " . $_COOKIE['Auth']
);
} else {
$this->setAPIResponse('error', 'User does not have Auth Cookie', 500);
return false;
}
//https://api.themoviedb.org/3/movie/157336?api_key=83cf4ee97bb728eeaf9d4a54e64356a1
// Lets check if it exists inside Ombi first... but since I can't search with ID - i have to query title from id
$tmdbResponse = Requests::get('https://api.themoviedb.org/3/' . $type . '/' . $id . '?api_key=83cf4ee97bb728eeaf9d4a54e64356a1', [], $options);
if ($tmdbResponse->success) {
$details = json_decode($tmdbResponse->body, true);
if (count($details) > 0) {
switch ($type) {
case 'tv':
$title = $details['name'];
$idType = 'theTvDbId';
$tmdbResponseID = Requests::get('https://api.themoviedb.org/3/tv/' . $id . '/external_ids?api_key=83cf4ee97bb728eeaf9d4a54e64356a1', [], $options);
if ($tmdbResponseID->success) {
$detailsID = json_decode($tmdbResponseID->body, true);
if (count($detailsID) > 0) {
if (isset($detailsID['tvdb_id'])) {
$id = $detailsID['tvdb_id'];
$add['tvDbId'] = $id;
} else {
$this->setAPIResponse('error', 'Could not get TVDB Id', 422);
return false;
}
} else {
$this->setAPIResponse('error', 'Could not get TVDB Id', 422);
return false;
}
}
break;
case 'movie':
$title = $details['title'];
$idType = 'theMovieDbId';
break;
default:
$this->setAPIResponse('error', 'Ombi Type was not found', 422);
return false;
}
} else {
$this->setAPIResponse('error', 'No data returned from TMDB', 422);
return false;
}
} else {
$this->setAPIResponse('error', 'Could not contact TMDB', 422);
return false;
}
$options = $this->requestOptions($url, null, $this->config['ombiDisableCertCheck'], $this->config['ombiUseCustomCertificate']);
$searchResponse = Requests::get($url . '/api/v1/Search/' . $type . '/' . urlencode($title), $headers, $options);
if ($searchResponse->success) {
$details = json_decode($searchResponse->body, true);
if (count($details) > 0) {
foreach ($details as $k => $v) {
if ($v[$idType] == $id) {
if ($v['available']) {
$this->setAPIResponse('error', 'Request is already available', 409);
return false;
} elseif ($v['requested']) {
$this->setAPIResponse('error', 'Request is already requested', 409);
return false;
}
}
}
}
} else {
$this->setAPIResponse('error', 'Ombi Error Occurred', 500);
return false;
}
$response = Requests::post($url . "/api/v1/Request/" . $type, $headers, json_encode($add), $options);
if ($response->success) {
$this->setAPIResponse('success', 'Ombi Request submitted', 200);
return true;
} else {
$this->setAPIResponse('error', 'Ombi Error Occurred', 500);
return false;
}
} catch (Requests_Exception $e) {
$this->setLoggerChannel('Ombi')->error($e);
$this->setResponse(500, $e->getMessage());
return false;
}
}
public function actionOmbiRequest($id, $type, $action)
{
$id = ($id) ?? null;
$type = ($type) ?? null;
$action = ($action) ?? null;
if (!$id) {
$this->setAPIResponse('error', 'Id was not supplied', 422);
return false;
}
if (!$type) {
$this->setAPIResponse('error', 'Type was not supplied', 422);
return false;
}
if (!$action) {
$this->setAPIResponse('error', 'Action was not supplied', 422);
return false;
}
if (!$this->homepageItemPermissions($this->ombiHomepagePermissions('main'), true)) {
return false;
}
$url = $this->qualifyURL($this->config['ombiURL']);
$headers = array(
"Accept" => "application/json",
"Content-Type" => "application/json",
"Apikey" => $this->config['ombiToken']
);
$data = array(
'id' => $id,
);
switch ($type) {
case 'season':
case 'tv':
$type = 'tv';
break;
default:
$type = 'movie';
break;
}
try {
$options = $this->requestOptions($url, 60, $this->config['ombiDisableCertCheck'], $this->config['ombiUseCustomCertificate']);
switch ($action) {
case 'approve':
$response = Requests::post($url . "/api/v1/Request/" . $type . "/approve", $headers, json_encode($data), $options);
$message = 'Ombi Request has been approved';
break;
case 'available':
$response = Requests::post($url . "/api/v1/Request/" . $type . "/available", $headers, json_encode($data), $options);
$message = 'Ombi Request has been marked available';
break;
case 'unavailable':
$response = Requests::post($url . "/api/v1/Request/" . $type . "/unavailable", $headers, json_encode($data), $options);
$message = 'Ombi Request has been marked unavailable';
break;
case 'deny':
$response = Requests::put($url . "/api/v1/Request/" . $type . "/deny", $headers, json_encode($data), $options);
$message = 'Ombi Request has been denied';
break;
case 'delete':
$response = Requests::delete($url . "/api/v1/Request/" . $type . "/" . $id, $headers, $options);
$message = 'Ombi Request has been deleted';
break;
default:
return false;
}
if ($response->success) {
$this->setAPIResponse('success', $message, 200);
return true;
} else {
$this->setAPIResponse('error', 'Ombi Error Occurred', 500);
return false;
}
} catch (Requests_Exception $e) {
$this->setLoggerChannel('Ombi')->error($e);
$this->setResponse(500, $e->getMessage());
return false;
}
}
public function ombiTVDefault($type)
{
return $type == $this->config['ombiTvDefault'];
}
}