Plexpy script, kill a plex stream

kill_a_stream.py

"""
This is a simple script showing how you can used plexpys notifications system to kill a stream

Possible plexpyargs: -tk {transcode_key} -u {username} -td {transcode_decision} -t 20:20 -ln Secret_tash

Instructions:

    1. Save the script somewhere on your computer as kill_a_stream.py.

    2. Edit the variables at the top of the script:
        The host, port, token, and ssl, can be the same as in the PlexPy settings
        Edit the list of blocked_users, separated by a comma.

    3. PlexPy > Settings > Notification Agents > Scripts > Bell icon:
        [X] Notify on playback start
        [X] Notify on playback resume

    4. PlexPy > Settings > Notification Agents > Scripts > Gear icon:
        Enter the "Script folder" where you save the script from step 1.
        Playback Start: kill_a_stream.py
        Playback Resume: kill_a_stream.py
        Save

    5. PlexPy > Settings > Notifications > Script > Script Arguments:
        -tk {transcode_key} -u {username} -td {transcode_decision}

    Any time one of the blocked_users starts a transcoded session, the script will stop the stream.

    You can also supply a -t 20:30 and the script will only kill a stream after 20:30 or disallow transcode from a library with -ln

"""


import argparse
import requests
from uuid import getnode
import platform
from datetime import datetime


### Edit me ###
host = '10.0.0.97'
port = 32400
token = '<token>'
ssl = '' # s or ''
kill_time = ''  # time for date in 20:00 format
blocked_users = 'Hellowlol'  # 'username1, username2'
blocked_librarys = '' # 'PG-18, adult'
### stop ###


def tcomp(kill_time):
    zz = False
    if kill_time:
        tk = kill_time.split(':')
        h = int(tk[0])
        m = int(tk[1])
        zz = datetime(2009, 12, 2, h, m).time()
    return zz

def fetch(path, t='GET'):
    url = 'http%s://%s:%s/' % (ssl, host, port)

    headers = {'X-Plex-Token': token,
               'Accept': 'application/json',
               'X-Plex-Provides': 'controller',
               'X-Plex-Platform': platform.uname()[0],
               'X-Plex-Platform-Version': platform.uname()[2],
               'X-Plex-Product': 'Plexpy script',
               'X-Plex-Version': '0.9.5',
               'X-Plex-Device': platform.platform(),
               'X-Plex-Client-Identifier': str(hex(getnode()))
            }

    try:
        if t == 'GET':
            r = requests.get(url + path, headers=headers, verify=False)
        elif t == 'POST':
            r = requests.post(url + path, headers=headers, verify=False)
        elif t == 'DELETE':
            r = requests.delete(url + path, headers=headers, verify=False)

        if r and len(r.content):  # incase it dont return anything
            return r.json()
        else:
            return r.content

    except Exception as e:
        print e


def kill_transcode(transcode_key):
    print fetch('video/:/transcode/universal/stop?session=' + transcode_key)


def now():
    return datetime.now().time()

if __name__ == '__main__':
    parser = argparse.ArgumentParser()

    parser.add_argument('-tk', '--transcode_key', action='store', default='',
                        help='Transcode key of the the current stream to kill')

    parser.add_argument('-u', '--user', action='store', default=None,
                        help='username of the person watching a stream')

    parser.add_argument('-td', '--transcode_decision', action='store', default=None,
                        help='transcode decision')

    parser.add_argument('-ln', '--library_name', action='store', default=blocked_librarys,
                        help='What library was this played from')

    parser.add_argument('-t', '--time', action='store', default=kill_time,
                        help='Kill only streams if clock is above t')

    p = parser.parse_args()

    if p.user in [bu.strip() for bu in blocked_users.split(',')] and p.transcode_decision.lower() == 'transcode' and not p.time:
        kill_transcode(p.transcode_key)

    # You can also kill any transcodes based on time by passing the -t parameter or editing the kill_tme
    elif p.time and now() > tcomp(p.time) and p.transcode_decision.lower() == 'transcode' and p.user in [bu.strip() for bu in blocked_users.split(',')]:
        kill_transcode(p.transcode_key)

    elif p.library_name in [bln.strip() for bln in blocked_librarys.split(',')] and p.user in [bu.strip() for bu in blocked_users.split(',')] and p.transcode_decision.lower() == 'transcode':
        kill_transcode(p.transcode_key)

I have separate VMs hosting Plex Media Server and PlexPy, when the stream is getting killed - which server is killing the stream? is it PlexPy or is it Plex Media Server? Just curious which machine requires all pre-requisite modules to be installed.

Am currently getting the following error (shown in PlexPy logs) -

PlexPy Notifiers :: Script error:
Traceback (most recent call last):
File "/opt/plexpy/PlexPy_Scripts/Kill_A_Stream.py", line 26, in
import requests
ImportError: No module named requests

However, running it in CLI I do not get the error when attempting to run python /opt/plexpy/PlexPy_Scripts/Kill_A_Stream.py.

I can also confirm the necessary modules are installed, any helps or a more simple guide would be much appreciated. Or even a sample configuration someone has setup.

Currently running both Plex Media Server and PlexPy on Ubuntu Server 16.04.

Thanks.

@seanvree I've created an on demand script using Hellowlol's kill_transcode function, here.

Here is another for killing when playback is paused or to be ran on demand.

Sorry for not responding before. I don't get notified when some adds a comment to this gist. I'll respond when I have access to a computer

@seanvree This script isnt in development anymore. I cant remember why i added it i think it was a request on reddit. (I have loads of fun with it)
@rembomy Check for both transcode and copy in https://gist.github.com/Hellowlol/ee47b6534410b1880e19#file-kill_a_stream-py-L120
Fx if p.user in [bu.strip() for bu in blocked_users.split(',')] and p.transcode_decision.lower() in ['copy', 'transcode'] and not p.time:

@mescon I know is a really long time since you asked but in answering out of posterinty. The -t variable is intended if you want to block a user after a set amount of time. Say you dont want the kid use plex on the ipad after 2200

Hello friend, I am new to the plexpy script for a long time ago I am trying to make a script that allows me to have multiple users and some 2 to 3 transcodes, I want to close their transcodes if they are more than 2 and let them use only 1, it is possible???

@neuroryuu .. that functionality is built into the plex server. If you access server settings under Network there is:

Remote streams allowed per user  xxx
Maximum number of simultaneous streams each user is allowed when not on the local network.

Hi, first off all, thank you so much for this script :D after i updated plex to Version 1.7.5.4035. the script doesn't kill streams anymore. Can anyone comfirm this, or is it just me.