-
-
Notifications
You must be signed in to change notification settings - Fork 24
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add glsl shader pack and SVP integration.
- Loading branch information
Showing
7 changed files
with
387 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -2,3 +2,4 @@ __pycache__ | |
| dist | ||
| build | ||
| plex_mpv_shim.egg-info | ||
| plex_mpv_shim/default_shader_pack/* | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,145 @@ | ||
| from .conf import settings | ||
| import urllib.request | ||
| import urllib.error | ||
| import logging | ||
| import sys | ||
|
|
||
| log = logging.getLogger('svp_integration') | ||
|
|
||
| def list_request(path): | ||
| try: | ||
| response = urllib.request.urlopen(settings.svp_url + "?" + path) | ||
| return response.read().decode('utf-8').replace('\r\n', '\n').split('\n') | ||
| except urllib.error.URLError as ex: | ||
| log.error("Could not reach SVP API server.", exc_info=1) | ||
| return None | ||
|
|
||
| def simple_request(path): | ||
| response_list = list_request(path) | ||
| if response_list is None: | ||
| return None | ||
| if len(response_list) != 1 or " = " not in response_list[0]: | ||
| return None | ||
| return response_list[0].split(" = ")[1] | ||
|
|
||
| def get_profiles(): | ||
| profile_ids = list_request("list=profiles") | ||
| profiles = {} | ||
| for profile_id in profile_ids: | ||
| profile_id = profile_id.replace("profiles.", "") | ||
| if profile_id == "P10000001_1001_1001_1001_100000000001": | ||
| profile_name = "Automatic" | ||
| else: | ||
| profile_name = simple_request("profiles.{0}.title".format(profile_id)) | ||
| profile_guid = "{" + profile_id[1:].replace("_", "-") + "}" | ||
| profiles[profile_guid] = profile_name | ||
| return profiles | ||
|
|
||
| def get_name_from_guid(profile_id): | ||
| profile_id = "P" + profile_id[1:-1].replace("-", "_") | ||
| if profile_id == "P10000001_1001_1001_1001_100000000001": | ||
| return "Automatic" | ||
| else: | ||
| return simple_request("profiles.{0}.title".format(profile_id)) | ||
|
|
||
| def get_last_profile(): | ||
| return simple_request("rt.playback.last_profile") | ||
|
|
||
| def is_svp_alive(): | ||
| try: | ||
| response = list_request("") | ||
| return response is not None | ||
| except Exception: | ||
| log.error("Could not reach SVP API server.", exc_info=1) | ||
| return False | ||
|
|
||
| def is_svp_enabled(): | ||
| return simple_request("rt.disabled") == "false" | ||
|
|
||
| def is_svp_active(): | ||
| response = simple_request("rt.playback.active") | ||
| if response is None: | ||
| return False | ||
| return response != "" | ||
|
|
||
| def set_active_profile(profile_id): | ||
| # As far as I know, there is no way to directly set the profile. | ||
| if not is_svp_active(): | ||
| return False | ||
| if profile_id == get_last_profile(): | ||
| return True | ||
| for i in range(len(list_request("list=profiles"))): | ||
| list_request("!profile_next") | ||
| if get_last_profile() == profile_id: | ||
| return True | ||
| return False | ||
|
|
||
| def set_disabled(disabled): | ||
| return simple_request("rt.disabled={0}".format("true" if disabled else "false")) == "true" | ||
|
|
||
| class SVPManager: | ||
| def __init__(self, menu, playerManager): | ||
| self.menu = menu | ||
|
|
||
| if settings.svp_enable: | ||
| socket = settings.svp_socket | ||
| if socket is None: | ||
| if sys.platform.startswith("win32") or sys.platform.startswith("cygwin"): | ||
| socket = "mpvpipe" | ||
| else: | ||
| socket = "/tmp/mpvsocket" | ||
|
|
||
| # This actually *adds* another ipc server. | ||
| playerManager._player.input_ipc_server = socket | ||
|
|
||
| if not is_svp_alive(): | ||
| log.error("SVP is not reachable. Please make sure you have the API enabled.") | ||
|
|
||
| def is_available(self): | ||
| if not settings.svp_enable: | ||
| return False | ||
| if not is_svp_alive(): | ||
| return False | ||
| return True | ||
|
|
||
| def menu_set_profile(self): | ||
| profile_id = self.menu.menu_list[self.menu.menu_selection][2] | ||
| if profile_id is None: | ||
| set_disabled(True) | ||
| else: | ||
| set_active_profile(profile_id) | ||
| # Need to re-render menu. | ||
| self.menu.menu_action("back") | ||
| self.menu_action() | ||
|
|
||
| def menu_set_enabled(self): | ||
| set_disabled(False) | ||
|
|
||
| # Need to re-render menu. | ||
| self.menu.menu_action("back") | ||
| self.menu_action() | ||
|
|
||
| def menu_action(self): | ||
| if is_svp_active(): | ||
| selected = 0 | ||
| active_profile = get_last_profile() | ||
| profile_option_list = [ | ||
| ("Disabled", self.menu_set_profile, None) | ||
| ] | ||
| for i, (profile_id, profile_name) in enumerate(get_profiles().items()): | ||
| profile_option_list.append( | ||
| (profile_name, self.menu_set_profile, profile_id) | ||
| ) | ||
| if profile_id == active_profile: | ||
| selected = i+1 | ||
| self.menu.put_menu("Select SVP Profile", profile_option_list, selected) | ||
| else: | ||
| if is_svp_enabled(): | ||
| self.menu.put_menu("SVP is Not Active", [ | ||
| ("Disable", self.menu_set_profile, None), | ||
| ("Retry", self.menu_set_enabled) | ||
| ], selected=1) | ||
| else: | ||
| self.menu.put_menu("SVP is Disabled", [ | ||
| ("Enable SVP", self.menu_set_enabled) | ||
| ]) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.