Skip to content

twitch.py 1.1: multiple changes version bump #580

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
flashcode merged 1 commit into from
Sep 25, 2025
Merged

twitch.py 1.1: multiple changes version bump #580

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
71 changes: 32 additions & 39 deletions python/twitch.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
# SPDX-FileCopyrightText: 2014-2024 mumixam <[email protected]>
# SPDX-FileCopyrightText: 2014-2025 mumixam <[email protected]>
#
# SPDX-License-Identifier: GPL-3.0-or-later
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 3 of the License, or
Expand Down Expand Up @@ -35,6 +34,10 @@
# plugins.var.python.twitch.token (default: "")
#
# # History:
# 2025-09-23,
# v1.1: changed hook_modifier from "irc_in_WHISPER" to "irc_in2_WHISPER" -mumixam
# changed hook_process_hashtable("url:") to hook_url -mumixam
# use rawstrings to keep invalid escapes from throwing warnings -zer0def
#
# 2024-06-29, mumixam + stacyharper
# v1.0: eval client_id and token expressions so that /secure can be used
Expand Down Expand Up @@ -69,7 +72,7 @@

SCRIPT_NAME = "twitch"
SCRIPT_AUTHOR = "mumixam"
SCRIPT_VERSION = "1.0.1"
SCRIPT_VERSION = "1.1"
SCRIPT_LICENSE = "GPL3"
SCRIPT_DESC = "twitch.tv Chat Integration"
OPTIONS={
Expand All @@ -89,6 +92,7 @@
import time
import string
import ast
import re

curlopt = {
"httpheader": "\n".join([
Expand Down Expand Up @@ -127,8 +131,7 @@ def twitch_main(data, buffer, args):
if not (server in OPTIONS['servers'].split() and type == 'channel'):
return weechat.WEECHAT_RC_OK
url = 'https://api.twitch.tv/helix/streams?user_login=' + username
weechat.hook_process_hashtable(
"url:" + url, curlopt, 7 * 1000, "stream_api", buffer)
weechat.hook_url(url, curlopt, 7 * 1000, "stream_api", buffer)
return weechat.WEECHAT_RC_OK


Expand All @@ -138,17 +141,15 @@ def makeutf8(data):
data=str(data,'utf8')
return data


def stream_api(data, command, rc, stdout, stderr):
def stream_api(data, url, options, output):
try:
jsonDict = json.loads(stdout.strip())
jsonDict = json.loads(output['output'].strip())
except Exception as e:
weechat.prnt(data, '%stwitch.py: error communicating with twitch api' % weechat.prefix('error'))
if OPTIONS['debug']:
weechat.prnt(data,'%stwitch.py: return code: %s' % (weechat.prefix('error'),rc))
weechat.prnt(data,'%stwitch.py: stdout: %s' % (weechat.prefix('error'),stdout))
weechat.prnt(data,'%stwitch.py: stderr: %s' % (weechat.prefix('error'),stderr))
weechat.prnt(data,'%stwitch.py: exception: %s' % (weechat.prefix('error'),e))
weechat.prnt(data,'%stwitch.py: response code: %s' % (weechat.prefix('error'),output['response_code']))
weechat.prnt(data,'%stwitch.py: headers: %s' % (weechat.prefix('error'),output['headers']))
weechat.prnt(data,'%stwitch.py: output: %s' % (weechat.prefix('error'),output['output']))
return weechat.WEECHAT_RC_OK
currentbuf = weechat.current_buffer()
title_fg = weechat.color(
Expand All @@ -168,7 +169,7 @@ def stream_api(data, command, rc, stdout, stderr):
if not 'data' in jsonDict.keys():
weechat.prnt(data, 'twitch.py: Error with twitch API (data key missing from json)')
if OPTIONS['debug']:
weechat.prnt(data, 'twitch.py: %s' % stdout.strip())
weechat.prnt(data, 'twitch.py: %s' % output['output'].strip())
return weechat.WEECHAT_RC_OK
if not jsonDict['data']:
line = "STREAM: %sOFFLINE%s %sCHECKED AT: (%s)" % (
Expand Down Expand Up @@ -232,23 +233,20 @@ def stream_api(data, command, rc, stdout, stderr):
weechat.buffer_set(data, "title", output)
if game_id is not None and not game_id in gameid_cache:
url = 'https://api.twitch.tv/helix/games?id=' + game_id
weechat.hook_process_hashtable(
"url:" + url, curlopt, 7 * 1000, "game_api", data)
weechat.hook_url(url, curlopt, 7 * 1000, "game_api", data)

return weechat.WEECHAT_RC_OK



def game_api(data, command, rc, stdout, stderr):
def game_api(data, url, options, output):
try:
jsonDict = json.loads(stdout.strip())
jsonDict = json.loads(output['output'].strip())
except Exception as e:
weechat.prnt(data, '%stwitch.py: error communicating with twitch api' % weechat.prefix('error'))
if OPTIONS['debug']:
weechat.prnt(data,'%stwitch.py: return code: %s' % (weechat.prefix('error'),rc))
weechat.prnt(data,'%stwitch.py: stdout: %s' % (weechat.prefix('error'),stdout))
weechat.prnt(data,'%stwitch.py: stderr: %s' % (weechat.prefix('error'),stderr))
weechat.prnt(data,'%stwitch.py: exception: %s' % (weechat.prefix('error'),e))
weechat.prnt(data,'%stwitch.py: response code: %s' % (weechat.prefix('error'),output['response_code']))
weechat.prnt(data,'%stwitch.py: headers: %s' % (weechat.prefix('error'),output['headers']))
weechat.prnt(data,'%stwitch.py: output: %s' % (weechat.prefix('error'),output['output']))
return weechat.WEECHAT_RC_OK

if 'data' in jsonDict.keys():
Expand All @@ -265,17 +263,15 @@ def game_api(data, command, rc, stdout, stderr):
return weechat.WEECHAT_RC_OK



def channel_api(data, command, rc, stdout, stderr):
def channel_api(data, url, options, output):
try:
jsonDict = json.loads(stdout.strip())
jsonDict = json.loads(output['output'].strip())
except Exception as e:
weechat.prnt(data, '%stwitch.py: error communicating with twitch api' % weechat.prefix('error'))
if OPTIONS['debug']:
weechat.prnt(data['buffer'],'%stwitch.py: return code: %s' % (weechat.prefix('error'),rc))
weechat.prnt(data['buffer'],'%stwitch.py: stdout: %s' % (weechat.prefix('error'),stdout))
weechat.prnt(data['buffer'],'%stwitch.py: stderr: %s' % (weechat.prefix('error'),stderr))
weechat.prnt(data['buffer'],'%stwitch.py: exception: %s' % (weechat.prefix('error'),e))
weechat.prnt(data,'%stwitch.py: response code: %s' % (weechat.prefix('error'),output['response_code']))
weechat.prnt(data,'%stwitch.py: headers: %s' % (weechat.prefix('error'),output['headers']))
weechat.prnt(data,'%stwitch.py: output: %s' % (weechat.prefix('error'),output['output']))
return weechat.WEECHAT_RC_OK
currentbuf = weechat.current_buffer()
pcolor = weechat.color('chat_prefix_network')
Expand All @@ -298,8 +294,7 @@ def channel_api(data, command, rc, stdout, stderr):
pcolor, pformat, dcolor, ncolor, name, dcolor, ccolor, ul, rul, followers)
weechat.prnt(data, makeutf8(output))
url = 'https://api.twitch.tv/helix/users/follows?from_id=' + uid
url_hook = weechat.hook_process_hashtable(
"url:" + url, curlopt, 7 * 1000, "channel_api", data)
url_hook = weechat.hook_url(url, curlopt, 7 * 1000, "channel_api", data)
return weechat.WEECHAT_RC_OK
if 'from_id' in command:
following = jsonDict['total']
Expand All @@ -325,8 +320,7 @@ def channel_api(data, command, rc, stdout, stderr):
pcolor, pformat, dcolor, ncolor, name, dcolor, ccolor, ul, rul, status)
weechat.prnt(data, makeutf8(output))
url = 'https://api.twitch.tv/helix/users/follows?to_id=' + uid
url_hook = weechat.hook_process_hashtable(
"url:" + url, curlopt, 7 * 1000, "channel_api", data)
url_hook = weechat.hook_url(url, curlopt, 7 * 1000, "channel_api", data)

else:
weechat.prnt(data, 'Error: No Such User')
Expand All @@ -353,15 +347,15 @@ def twitch_clearchat(data, modifier, modifier_data, string):
if user:
if 'ban-duration' in tags:
if 'ban-reason' in tags and tags['ban-reason']:
bn=tags['ban-reason'].replace('\s',' ')
bn=re.sub(r'\s',' ', tags['ban-reason'])
weechat.prnt(buffer,"%s--%s %s has been timed out for %s seconds %sReason%s: %s" %
(pcolor, ccolor, user, tags['ban-duration'], ul, rul, bn))
else:
weechat.prnt(buffer,"%s--%s %s has been timed out for %s seconds" %
(pcolor, ccolor, user, tags['ban-duration']))
elif 'ban-reason' in tags:
if tags['ban-reason']:
bn=tags['ban-reason'].replace('\s',' ')
bn=re.sub(r'\s', ' ', tags['ban-reason'])
weechat.prnt(buffer,"%s--%s %s has been banned %sReason%s: %s" %
(pcolor, ccolor, user, ul, rul,bn))
else:
Expand Down Expand Up @@ -458,7 +452,7 @@ def twitch_usernotice(data, modifier, server, string):
"irc", "%s.%s" % (server, mp['channel']))
if mp['tags']:
tags = dict([s.split('=',1) for s in mp['tags'].split(';')])
msg = tags['system-msg'].replace('\s',' ')
msg = re.sub(r'\\s', ' ', tags['system-msg'])
if mp['text']:
msg += ' [Comment] '+mp['text']
weechat.prnt(buffer, '%s--%s %s' % (pcolor, ccolor, msg))
Expand Down Expand Up @@ -522,8 +516,7 @@ def twitch_whois(data, modifier, server_name, string):
currentbuf = weechat.current_buffer()
url = 'https://api.twitch.tv/kraken/users?login=' + username
params='&api_version=5'
url_hook = weechat.hook_process_hashtable(
"url:" + url+params, curlopt, 7 * 1000, "channel_api", currentbuf)
url_hook = weechat.hook_url(url+params, curlopt, 7 * 1000, "channel_api", currentbuf)
return ""


Expand Down Expand Up @@ -682,7 +675,7 @@ def config_change(pointer, name, value):
weechat.hook_modifier("irc_in2_HOSTTARGET", "twitch_suppress", "")
weechat.hook_modifier("irc_in2_ROOMSTATE", "twitch_roomstate", "")
weechat.hook_modifier("irc_in2_USERNOTICE", "twitch_usernotice", "")
weechat.hook_modifier("irc_in_WHISPER", "twitch_whisper", "")
weechat.hook_modifier("irc_in2_WHISPER", "twitch_whisper", "")
weechat.hook_modifier("irc_out_PRIVMSG", "twitch_privmsg", "")
weechat.hook_modifier("irc_out_WHOIS", "twitch_whois", "")
weechat.hook_modifier("irc_in2_PRIVMSG", "twitch_in_privmsg", "")