Coder Social home page Coder Social logo

teekeks / pytwitchapi Goto Github PK

View Code? Open in Web Editor NEW
232.0 9.0 35.0 1.94 MB

A Python 3.7 compatible implementation of the Twitch API, EventSub, PubSub and Chat

Home Page: https://pytwitchapi.dev

License: MIT License

Python 100.00%
twitchapi twitch-api twitch-tv webhook pubsub twitch-pubsub userauthenticator helix-api twitch-helix-webhooks twitch-helix

pytwitchapi's Introduction

Python Twitch API

PyPI verion Downloads Python version Twitch API version Documentation Status

This is a full implementation of the Twitch Helix API, PubSub, EventSub and Chat in python 3.7+.

Installation

Install using pip:

pip install twitchAPI

Documentation and Support

A full API documentation can be found on readthedocs.org.

For support please join the Twitch API discord server

Usage

Basic API calls

Setting up an Instance of the Twitch API and get your User ID:

from twitchAPI.twitch import Twitch
from twitchAPI.helper import first
import asyncio

async def twitch_example():
    # initialize the twitch instance, this will by default also create a app authentication for you
    twitch = await Twitch('app_id', 'app_secret')
    # call the API for the data of your twitch user
    # this returns a async generator that can be used to iterate over all results
    # but we are just interested in the first result
    # using the first helper makes this easy.
    user = await first(twitch.get_users(logins='your_twitch_user'))
    # print the ID of your user or do whatever else you want with it
    print(user.id)

# run this example
asyncio.run(twitch_example())

Authentication

The Twitch API knows 2 different authentications. App and User Authentication. Which one you need (or if one at all) depends on what calls you want to use.

It's always good to get at least App authentication even for calls where you don't need it since the rate limits are way better for authenticated calls.

Please read the docs for more details and examples on how to set and use Authentication!

App Authentication

App authentication is super simple, just do the following:

from twitchAPI.twitch import Twitch
twitch = await Twitch('my_app_id', 'my_app_secret')

User Authentication

To get a user auth token, the user has to explicitly click "Authorize" on the twitch website. You can use various online services to generate a token or use my build in Authenticator. For my Authenticator you have to add the following URL as a "OAuth Redirect URL": http://localhost:17563 You can set that here in your twitch dev dashboard.

from twitchAPI.twitch import Twitch
from twitchAPI.oauth import UserAuthenticator
from twitchAPI.type import AuthScope

twitch = await Twitch('my_app_id', 'my_app_secret')

target_scope = [AuthScope.BITS_READ]
auth = UserAuthenticator(twitch, target_scope, force_verify=False)
# this will open your default browser and prompt you with the twitch verification website
token, refresh_token = await auth.authenticate()
# add User authentication
await twitch.set_user_authentication(token, target_scope, refresh_token)

You can reuse this token and use the refresh_token to renew it:

from twitchAPI.oauth import refresh_access_token
new_token, new_refresh_token = await refresh_access_token('refresh_token', 'client_id', 'client_secret')

AuthToken refresh callback

Optionally you can set a callback for both user access token refresh and app access token refresh.

from twitchAPI.twitch import Twitch

async def user_refresh(token: str, refresh_token: str):
    print(f'my new user token is: {token}')

async def app_refresh(token: str):
    print(f'my new app token is: {token}')

twitch = await Twitch('my_app_id', 'my_app_secret')
twitch.app_auth_refresh_callback = app_refresh
twitch.user_auth_refresh_callback = user_refresh

EventSub

EventSub lets you listen for events that happen on Twitch.

The EventSub client runs in its own thread, calling the given callback function whenever an event happens.

There are multiple EventSub transports available, used for different use cases.

See here for more info about EventSub in general and the different Transports, including code examples: on readthedocs

PubSub

PubSub enables you to subscribe to a topic, for updates (e.g., when a user cheers in a channel).

A more detailed documentation can be found here on readthedocs

from twitchAPI.pubsub import PubSub
from twitchAPI.twitch import Twitch
from twitchAPI.helper import first
from twitchAPI.type import AuthScope
from twitchAPI.oauth import UserAuthenticator
import asyncio
from pprint import pprint
from uuid import UUID

APP_ID = 'my_app_id'
APP_SECRET = 'my_app_secret'
USER_SCOPE = [AuthScope.WHISPERS_READ]
TARGET_CHANNEL = 'teekeks42'

async def callback_whisper(uuid: UUID, data: dict) -> None:
    print('got callback for UUID ' + str(uuid))
    pprint(data)


async def run_example():
    # setting up Authentication and getting your user id
    twitch = await Twitch(APP_ID, APP_SECRET)
    auth = UserAuthenticator(twitch, [AuthScope.WHISPERS_READ], force_verify=False)
    token, refresh_token = await auth.authenticate()
    # you can get your user auth token and user auth refresh token following the example in twitchAPI.oauth
    await twitch.set_user_authentication(token, [AuthScope.WHISPERS_READ], refresh_token)
    user = await first(twitch.get_users(logins=[TARGET_CHANNEL]))

    # starting up PubSub
    pubsub = PubSub(twitch)
    pubsub.start()
    # you can either start listening before or after you started pubsub.
    uuid = await pubsub.listen_whispers(user.id, callback_whisper)
    input('press ENTER to close...')
    # you do not need to unlisten to topics before stopping but you can listen and unlisten at any moment you want
    await pubsub.unlisten(uuid)
    pubsub.stop()
    await twitch.close()

asyncio.run(run_example())

Chat

A simple twitch chat bot. Chat bots can join channels, listen to chat and reply to messages, commands, subscriptions and many more.

A more detailed documentation can be found here on readthedocs

Example code for a simple bot

from twitchAPI.twitch import Twitch
from twitchAPI.oauth import UserAuthenticator
from twitchAPI.type import AuthScope, ChatEvent
from twitchAPI.chat import Chat, EventData, ChatMessage, ChatSub, ChatCommand
import asyncio

APP_ID = 'my_app_id'
APP_SECRET = 'my_app_secret'
USER_SCOPE = [AuthScope.CHAT_READ, AuthScope.CHAT_EDIT]
TARGET_CHANNEL = 'teekeks42'


# this will be called when the event READY is triggered, which will be on bot start
async def on_ready(ready_event: EventData):
    print('Bot is ready for work, joining channels')
    # join our target channel, if you want to join multiple, either call join for each individually
    # or even better pass a list of channels as the argument
    await ready_event.chat.join_room(TARGET_CHANNEL)
    # you can do other bot initialization things in here


# this will be called whenever a message in a channel was send by either the bot OR another user
async def on_message(msg: ChatMessage):
    print(f'in {msg.room.name}, {msg.user.name} said: {msg.text}')


# this will be called whenever someone subscribes to a channel
async def on_sub(sub: ChatSub):
    print(f'New subscription in {sub.room.name}:\\n'
          f'  Type: {sub.sub_plan}\\n'
          f'  Message: {sub.sub_message}')


# this will be called whenever the !reply command is issued
async def test_command(cmd: ChatCommand):
    if len(cmd.parameter) == 0:
        await cmd.reply('you did not tell me what to reply with')
    else:
        await cmd.reply(f'{cmd.user.name}: {cmd.parameter}')


# this is where we set up the bot
async def run():
    # set up twitch api instance and add user authentication with some scopes
    twitch = await Twitch(APP_ID, APP_SECRET)
    auth = UserAuthenticator(twitch, USER_SCOPE)
    token, refresh_token = await auth.authenticate()
    await twitch.set_user_authentication(token, USER_SCOPE, refresh_token)

    # create chat instance
    chat = await Chat(twitch)

    # register the handlers for the events you want

    # listen to when the bot is done starting up and ready to join channels
    chat.register_event(ChatEvent.READY, on_ready)
    # listen to chat messages
    chat.register_event(ChatEvent.MESSAGE, on_message)
    # listen to channel subscriptions
    chat.register_event(ChatEvent.SUB, on_sub)
    # there are more events, you can view them all in this documentation

    # you can directly register commands and their handlers, this will register the !reply command
    chat.register_command('reply', test_command)


    # we are done with our setup, lets start this bot up!
    chat.start()

    # lets run till we press enter in the console
    try:
        input('press ENTER to stop\n')
    finally:
        # now we can close the chat bot and the twitch api client
        chat.stop()
        await twitch.close()


# lets run our setup
asyncio.run(run())

pytwitchapi's People

Contributors

asishm avatar aw-was-here avatar braastos avatar d7415 avatar dependabot[bot] avatar duskofdawn avatar gitagogaming avatar iprodigy avatar jc-chung avatar joostlek avatar latent-logic avatar lynara avatar meduris avatar moralrecordings avatar parmenashp avatar rubrodapa avatar stolenvw avatar teekeks avatar tempystral avatar

Stargazers

 avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar

Watchers

 avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar

pytwitchapi's Issues

add a authenticate_app flag to __init__ of Twitch

Since the Twitch API currently does not have any call that is not requiring at elast a app token, add a flag to init for automatic authentication.

This will save one line of code that will be required in almost all circumstances of using the library.

asyncio.CanceldError in oauth.__run()

When the Auth Flow is used, i regularly get an asyncio.CanceldError.
In your oauth.py you catch an CancelledError, but you dont catch the asyncio.CanceldError.

OSError: [Errno 99] error while attempting to bind on address ('::1', 17563, 0, 0): cannot assign requested address

I was trying to run the example WebSocket code and it crashes on this:

Exception in thread Thread-1:
Traceback (most recent call last):
  File "/usr/lib/python3.7/threading.py", line 926, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.7/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "/usr/local/lib/python3.7/dist-packages/twitchAPI/oauth.py", line 103, in __run
    self.__loop.run_until_complete(site.start())
  File "/usr/lib/python3.7/asyncio/base_events.py", line 579, in run_until_complete
    return future.result()
  File "/usr/local/lib/python3.7/dist-packages/aiohttp/web_runner.py", line 104, in start
    reuse_port=self._reuse_port)
  File "/usr/lib/python3.7/asyncio/base_events.py", line 1374, in create_server
    % (sa, err.strerror.lower())) from None
OSError: [Errno 99] error while attempting to bind on address ('::1', 17563, 0, 0): cannot assign requested address

The example I used can be found here

get_clips is not usable without clip_id

Hi,

I am trying to get the list of clips of a streamer, from a game. I have the broadcaster ID and the game ID but no clip id (that's what i am looking for)

Reading the twitch api on https://dev.twitch.tv/docs/api/reference#get-clips i should be using "get_clips".
i read the sentence : "For a query to be valid, id (one or more), broadcaster_id, or game_id must be specified. You may specify only one of these parameters." just before the optional query parameter.

The python TwitchAPI doesn't let me go without the clip_id. When i try the call :
test = twitch.get_clips(broadcaster_id=streamer.get('to_id'),game_id=Game.get('id'),first=100,started_at=timeStart)

i get the error :
TypeError: get_clips() missing 1 required positional argument: 'clip_id'

Is it a difference between the python Twitch API and the Twitch API or should i do this differently ?

auth.authenticate() - Task was destroyed but it is pending

Hello

While using the example code detailed in the chapter "User Authentication" of https://pypi.org/project/twitchAPI/

I get an error in the end of the program, that uses "token, refresh_token = auth.authenticate()"

The twitch page opens, i am redirected on http://localhost:17563/?code=(...), and the execution continues, until the program stops and then :

Task was destroyed but it is pending!
task: <Task pending name='Task-7' coro=<IocpProactor.accept..accept_coro() running at f:\dev\python\install\lib\asyncio\windows_events.py:566> wait_for=<_OverlappedFuture cancelled>>
Task was destroyed but it is pending!
task: <Task pending name='Task-5' coro=<IocpProactor.accept..accept_coro() running at f:\dev\python\install\lib\asyncio\windows_events.py:566> wait_for=<_OverlappedFuture cancelled>>
Exception ignored in: <function _ProactorBasePipeTransport.del at 0x00000169C487BD30>
Traceback (most recent call last):
File "f:\dev\python\install\lib\asyncio\proactor_events.py", line 116, in del
File "f:\dev\python\install\lib\asyncio\proactor_events.py", line 108, in close
File "f:\dev\python\install\lib\asyncio\base_events.py", line 746, in call_soon
File "f:\dev\python\install\lib\asyncio\base_events.py", line 510, in _check_closed
RuntimeError: Event loop is closed
Task was destroyed but it is pending!
task: <Task pending name='Task-8' coro=<RequestHandler.start() running at F:\Dev\Python\Projects\myProject\lib\site-packages\aiohttp\web_protocol.py:398> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x00000169C4DA1A90>()]>>

It seems the asyncio event stop is not handled properly. Am i doing something wrong or is there something missing in the sample code provided ?

Small errors in documentation

In the imports of the code snippet for user authentication you import twitch.types instead of twitchAPI.types.
In that same snippet the variable twitch passed to the UserAuthenticator is not yet defined.

twitch.py wrong URL in channel point subroutines

Hi,

I found a bug inside of twitch.py.

The subroutines:

  • delete_custom_reward
  • get_custom_reward
  • get_custom_reward_redemption
  • update_redemption_status
    are missing the TWITCH_API_BASE_URL inside the call of the build_url function.

At the moment they are defined as:
url = build_url('channel_poi......
but should look like:
url = build_url(TWITCH_API_BASE_URL + 'channel_poi......

Could you please fix that?

regards
Thomas

Use hookable log

Currently, twitchAPI just uses the default logger, for better customization options it should use its own loggers.

Non-dynamic Redirect URI

Hello,

I am currently trying to get the ouath section of this work. In order for this to work you must have a redirect URI for your site that is set inside the settings for your twitch site as you mention here: https://pytwitchapi.readthedocs.io/en/latest/modules/twitchAPI.oauth.html?highlight=redirect#requirements
However, I did not see a way for you to change the redirect URI, which means that the only valid redirect uri is 'localhost:17563' as seen here under the UserAuthenticator class: https://github.com/Teekeks/pyTwitchAPI/blob/master/twitchAPI/oauth.py

Did I miss something in the documentation? Or was there a way of directly changing the uri in the UserAuthenticator class?

Twitch doesn't register webhook subscription

I want to subscribe to stream changes and I use slightly modded of webhook_example.py:

twitch = Twitch(APP_ID, APP_SECRET)
twitch.authenticate_app([])

hook = TwitchWebHook("https://nikitacartes.xyz:8100/", APP_ID, 8101)
hook.authenticate(twitch.get_app_token())
hook.start()

success, uuid_stream = hook.subscribe_stream_changed(USER_ID, callback_stream_changed)

print(f'was subscription successfull?: {success}')
print(twitch.get_webhook_subscriptions())

But get_webhook_subscriptions says, what i have 0 subscription.

was subscription successfull?: True
{'total': 0, 'data': [], 'pagination': {}}

For proxy from 8100 port to Plain 8101 I use maproxy, if this is important.

import tornado.ioloop
import maproxy.proxyserver

ssl_certs = {"certfile":  "nikitacartes.xyz/fullchain.pem", "keyfile": "nikitacartes.xyz/privkey.pem"}

server = maproxy.proxyserver.ProxyServer("0.0.0.0", 8101, client_ssl_options=ssl_certs)
server.listen(8100)
tornado.ioloop.IOLoop.instance().start()

Datetime.datetime not accepted "as is" as parameter in get_clips (for started_at)

Hi again !

Still working on get_clips to try to get the list of clips of some streamers.

I used the temporary workaround you provide me to not use "clip_id"

test = twitch.get_clips(streamer.get('to_id'), Game.get('id'), [], first=100, started_at=timeStart)
I get an answer from twitch (no exception in the code) that is :
{'error': 'Bad Request', 'status': 400, 'message': 'parsing time "2020-10-26T19:30:50.688906" as "2006-01-02T15:04:05Z07:00": cannot parse "" as "Z07:00"'}

I tried using a timeStart generated by the two codes :
timeStart = datetime.datetime(datetime.date.today().year, datetime.date.today().month, datetime.date.today().day)
timeStart = datetime.datetime.now()

Meaning my timeStart is coded : 2020-10-26 19:30:50.688906

Should the get_clips function "transform" the datetime.datetime given by adding something in the end before sending it to twitch? Or is there something i missed ? Or is the "Z07:00" something that i can provide ?

I tried playing with tznames from datetime but i can't find a way to make this work...

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    ๐Ÿ–– Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. ๐Ÿ“Š๐Ÿ“ˆ๐ŸŽ‰

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google โค๏ธ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.