github/plexpy
1
0
Fork 0
mirror of https://github.com/Tautulli/Tautulli.git synced 2025-08-19 21:03:21 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add LunaSea notification agent

Browse source
This commit is contained in:
JonnyWong16 2021-09-19 20:22:29 -07:00
commit 830ef460af
No known key found for this signature in database
GPG key ID: B1F1F9807184697A
1 changed files with 76 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

78
plexpy/notifiers.py
View file

@ -30,6 +30,7 @@ from paho.mqtt.publish import single
import os
import re
import requests
from requests.auth import HTTPBasicAuth
import smtplib
import subprocess
import sys
@ -104,7 +105,8 @@ AGENT_IDS = {'growl': 0,
'mqtt': 23,
'zapier': 24,
'webhook': 25,
'plexmobileapp': 26
'plexmobileapp': 26,
'lunasea': 27
}
DEFAULT_CUSTOM_CONDITIONS = [{'parameter': '', 'operator': '', 'value': ''}]
@ -177,6 +179,12 @@ def available_notification_agents():
'class': XBMC,
'action_types': ('all',)
},
{'label': 'LunaSea',
'name': 'lunasea',
'id': AGENT_IDS['lunasea'],
'class': LUNASEA,
'action_types': ('all',)
},
{'label': 'MQTT',
'name': 'mqtt',
'id': AGENT_IDS['mqtt'],
@ -705,7 +713,7 @@ class PrettyMetadata(object):
}
def get_poster_url(self):
poster_url = self.parameters['poster_url']
poster_url = self.parameters.get('poster_url')
if not poster_url:
if self.media_type in ('artist', 'album', 'track'):
poster_url = common.ONLINE_COVER_THUMB
@ -1919,6 +1927,72 @@ class JOIN(Notifier):
return config_option
class LUNASEA(Notifier):
"""
LunaSea Notifications
"""
NAME = 'LunaSea'
_DEFAULT_CONFIG = {'hook': '',
'profile': '',
'incl_subject': 1
}
def agent_notify(self, subject='', body='', action='', **kwargs):
if self.config['incl_subject']:
text = subject + '\r\n' + body
else:
text = body
if self.config['profile']:
auth = HTTPBasicAuth(self.config['profile'], '')
else:
auth = None
pretty_metadata = PrettyMetadata(kwargs['parameters'])
payload = {
'action': action,
'data': {
'message': text,
'user': pretty_metadata.parameters.get('user'),
'user_id': pretty_metadata.parameters.get('user_id'),
'player': pretty_metadata.parameters.get('player'),
'title': pretty_metadata.get_title(),
'poster_url': pretty_metadata.get_poster_url(),
'session_id': pretty_metadata.parameters.get('session_id'),
'user_streams': pretty_metadata.parameters.get('user_streams'),
'remote_access_reason': pretty_metadata.parameters.get('remote_access_reason'),
'update_version': pretty_metadata.parameters.get('update_version'),
'tautulli_update_version': pretty_metadata.parameters.get('tautulli_update_version')
}
}
return self.make_request(self.config['hook'], json=payload, auth=auth)
def _return_config_options(self):
config_option = [{'label': 'LunaSea Webhook URL',
'value': self.config['hook'],
'name': 'lunasea_hook',
'description': 'Your LunaSea device-based or user-based webhook URL.',
'input_type': 'token'
},
{'label': 'LunaSea Profile',
'value': self.config['profile'],
'name': 'lunasea_profile',
'description': 'Your LunaSea profile name. Leave blank for the default profile.',
'input_type': 'text'
},
{'label': 'Include Subject Line',
'value': self.config['incl_subject'],
'name': 'lunasea_incl_subject',
'description': 'Include the subject line with the notifications.',
'input_type': 'checkbox'
}
]
return config_option
class MQTT(Notifier):
"""
MQTT notifications