1
0
mirror of https://github.com/eternnoir/pyTelegramBotAPI.git synced 2023-08-10 21:12:57 +03:00

Merge pull request #18 from pevdh/master

Implemented #17 (with some small adjustments) and ForceReply
This commit is contained in:
FrankWang 2015-07-02 09:21:25 +08:00
commit 23574dee59
5 changed files with 87 additions and 13 deletions

View File

@ -114,6 +114,9 @@ tb.send_chat_action(chat_id, action_string)
# ReplyKeyboardMarkup. # ReplyKeyboardMarkup.
# Use ReplyKeyboardMarkup class. # Use ReplyKeyboardMarkup class.
# Thanks pevdh. # Thanks pevdh.
from telebot import types
markup = types.ReplyKeyboardMarkup() markup = types.ReplyKeyboardMarkup()
markup.add('a', 'v', 'd') markup.add('a', 'v', 'd')
tb.send_message(chat_id, message, None, None, markup) tb.send_message(chat_id, message, None, None, markup)
@ -161,5 +164,5 @@ def listener1(*messages):
- [x] sendVideo - [x] sendVideo
- [x] sendLocation - [x] sendLocation
- [x] sendChatAction - [x] sendChatAction
- [ ] getUserProfilePhotos - [x] getUserProfilePhotos
- [ ] getUpdat(contact and chat message not yet) - [ ] getUpdat(contact and chat message not yet)

View File

@ -44,13 +44,15 @@ class TeleBot:
def get_update(self): def get_update(self):
result = apihelper.get_updates(self.token, offset=(self.last_update_id + 1)) result = apihelper.get_updates(self.token, offset=(self.last_update_id + 1))
updates = result['result'] updates = result['result']
notify_updates = [] new_messages = []
for update in updates: for update in updates:
if update['update_id'] > self.last_update_id: if update['update_id'] > self.last_update_id:
self.last_update_id = update['update_id'] self.last_update_id = update['update_id']
msg = types.Message.de_json(json.dumps(update['message'])) msg = types.Message.de_json(json.dumps(update['message']))
notify_updates.append(msg) new_messages.append(msg)
self.__notify_update(notify_updates)
if len(new_messages) > 0:
self.__notify_update(new_messages)
def __notify_update(self, new_messages): def __notify_update(self, new_messages):
for listener in self.update_listener: for listener in self.update_listener:
@ -60,7 +62,7 @@ class TeleBot:
def polling(self, interval=3): def polling(self, interval=3):
""" """
Always get updates. Always get updates.
:param interval: iterval secs. :param interval: interval secs.
:return: :return:
""" """
self.interval = interval self.interval = interval
@ -91,10 +93,19 @@ class TeleBot:
def get_me(self): def get_me(self):
result = apihelper.get_me(self.token) result = apihelper.get_me(self.token)
if result['ok'] is not True: return types.User.de_json(json.dumps(result['result']))
raise Exception('getMe Error.' + json.dumps(result))
u = types.User.de_json(json.dumps(result['result'])) def get_user_profile_photos(self, user_id, offset=None, limit=None):
return u """
Retrieves the user profile photos of the person with 'user_id'
See https://core.telegram.org/bots/api#getuserprofilephotos
:param user_id:
:param offset:
:param limit:
:return:
"""
result = apihelper.get_user_profile_photos(self.token, user_id, offset, limit)
return types.UserProfilePhotos.de_json(json.dumps(result['result']))
def send_message(self, chat_id, text, disable_web_page_preview=None, reply_to_message_id=None, reply_markup=None): def send_message(self, chat_id, text, disable_web_page_preview=None, reply_to_message_id=None, reply_markup=None):
""" """
@ -199,3 +210,4 @@ class TeleBot:
:return: :return:
""" """
return apihelper.send_chat_action(self.token, chat_id, action) return apihelper.send_chat_action(self.token, chat_id, action)

View File

@ -49,6 +49,18 @@ def get_updates(token, offset=None):
req = requests.get(request_url) req = requests.get(request_url)
return check_result(method_url, req) return check_result(method_url, req)
def get_user_profile_photos(token, user_id, offset=None, limit=None):
api_url = telebot.API_URL
method_url = r'getUserProfilePhotos'
request_url = api_url + 'bot' + token + '/' + method_url
payload = {'user_id': user_id}
if offset:
payload['offset'] = offset
if limit:
payload['limit'] = limit
req = requests.get(request_url, params=payload)
return check_result(method_url, req)
def forward_message(token, chat_id, from_chat_id, message_id): def forward_message(token, chat_id, from_chat_id, message_id):
api_url = telebot.API_URL api_url = telebot.API_URL
@ -135,9 +147,8 @@ def check_result(func_name, result):
def convert_markup(markup): def convert_markup(markup):
if isinstance(markup, types.ReplyKeyboardMarkup): if isinstance(markup, types.Jsonable):
return markup.to_json() return markup.to_json()
else:
return markup return markup

View File

@ -22,6 +22,19 @@ ForceReply
import json import json
class Jsonable:
"""
Subclasses of this class are guaranteed to be able to be converted to JSON format.
All subclasses of this class must override to_json.
"""
def to_json(self):
"""
Returns a JSON string representation of this class.
This function must be overridden by subclasses.
:return: a JSON formatted string.
"""
raise NotImplementedError
class User: class User:
@classmethod @classmethod
@ -256,12 +269,41 @@ class Location:
class UserProfilePhotos: class UserProfilePhotos:
@classmethod
def de_json(cls, json_string):
obj = json.loads(json_string)
total_count = obj['total_count']
photos = [[PhotoSize.de_json(json.dumps(y)) for y in x] for x in obj['photos']]
return UserProfilePhotos(total_count, photos)
def __init__(self, total_count, photos): def __init__(self, total_count, photos):
self.total_count = total_count self.total_count = total_count
self.photos = photos self.photos = photos
class ReplyKeyboardMarkup: class ForceReply(Jsonable):
def __init__(self, selective=None):
self.selective = selective
def to_json(self):
json_dict = {'force_reply': True}
if self.selective:
json_dict['selective'] = True
return json.dumps(json_dict)
class ReplyKeyboardHide(Jsonable):
def __init__(self, selective=None):
self.selective = selective
def to_json(self):
json_dict = {'hide_keyboard': True}
if self.selective:
json_dict['selective'] = True
return json.dumps(json_dict)
class ReplyKeyboardMarkup(Jsonable):
def __init__(self, resize_keyboard=None, one_time_keyboard=None, selective=None, row_width=3): def __init__(self, resize_keyboard=None, one_time_keyboard=None, selective=None, row_width=3):
self.resize_keyboard = resize_keyboard self.resize_keyboard = resize_keyboard
self.one_time_keyboard = one_time_keyboard self.one_time_keyboard = one_time_keyboard

View File

@ -81,3 +81,9 @@ def test_json_Message_Location():
msg = types.Message.de_json(json_string) msg = types.Message.de_json(json_string)
assert msg.location.latitude == 26.090577 assert msg.location.latitude == 26.090577
assert msg.content_type == 'location' assert msg.content_type == 'location'
def test_json_UserProfilePhotos():
json_string = r'{"total_count":1,"photos":[[{"file_id":"AgADAgADqacxG6wpRwABvEB6fpeIcKS4HAIkAATZH_SpyZjzIwdVAAIC","file_size":6150,"width":160,"height":160},{"file_id":"AgADAgADqacxG6wpRwABvEB6fpeIcKS4HAIkAATOiTNi_YoJMghVAAIC","file_size":13363,"width":320,"height":320},{"file_id":"AgADAgADqacxG6wpRwABvEB6fpeIcKS4HAIkAAQW4DyFv0-lhglVAAIC","file_size":28347,"width":640,"height":640},{"file_id":"AgADAgADqacxG6wpRwABvEB6fpeIcKS4HAIkAAT50RvJCg0GQApVAAIC","file_size":33953,"width":800,"height":800}]]}'
upp = types.UserProfilePhotos.de_json(json_string)
assert upp.photos[0][0].width == 160
assert upp.photos[0][-1].height == 800