forked from sch/Slixfeed
b1a1955545
Fix ping functionality when activated as component (thank you Guus and MattJ). Add initial code for XEP-0060: Publish-Subscribe. Fix case-sensitivity with setting keys sent in-chat-command (Thank you mirux)
111 lines
4.2 KiB
Python
111 lines
4.2 KiB
Python
#!/usr/bin/env python3
|
|
# -*- coding: utf-8 -*-
|
|
|
|
"""
|
|
|
|
TODO
|
|
|
|
1) Send message to inviter that bot has joined to groupchat.
|
|
|
|
2) If groupchat requires captcha, send the consequent message.
|
|
|
|
3) If groupchat error is received, send that error message to inviter.
|
|
|
|
FIXME
|
|
|
|
1) Save name of groupchat instead of jid as name
|
|
|
|
"""
|
|
import logging
|
|
|
|
class XmppGroupchat:
|
|
|
|
# async def accept_muc_invite(self, message, ctr=None):
|
|
# # if isinstance(message, str):
|
|
# if not ctr:
|
|
# ctr = message["from"].bare
|
|
# jid = message['groupchat_invite']['jid']
|
|
# else:
|
|
# jid = message
|
|
def accept_invitation(self, message):
|
|
# operator muc_chat
|
|
inviter = message["from"].bare
|
|
jid = message['groupchat_invite']['jid']
|
|
self.join(self, inviter, jid)
|
|
|
|
|
|
def autojoin(self, bookmarks):
|
|
conferences = bookmarks["private"]["bookmarks"]["conferences"]
|
|
for conference in conferences:
|
|
if conference["jid"] and conference["autojoin"]:
|
|
if not conference["nick"]:
|
|
conference["nick"] = self.alias
|
|
logging.error('Alias (i.e. Nicknname) is missing for '
|
|
'bookmark {}'.format(conference['name']))
|
|
# jid_from = str(self.boundjid) if self.is_component else None
|
|
self.plugin['xep_0045'].join_muc(conference["jid"],
|
|
conference["nick"],
|
|
# pfrom=jid_from,
|
|
# If a room password is needed, use:
|
|
# password=the_room_password,
|
|
)
|
|
logging.info('Autojoin groupchat\n'
|
|
'Name : {}\n'
|
|
'JID : {}\n'
|
|
'Alias : {}\n'
|
|
.format(conference["name"],
|
|
conference["jid"],
|
|
conference["nick"]))
|
|
elif not conference["jid"]:
|
|
logging.error('JID is missing for bookmark {}'
|
|
.format(conference['name']))
|
|
|
|
|
|
def join(self, inviter, jid):
|
|
# token = await initdb(
|
|
# muc_jid,
|
|
# sqlite.get_setting_value,
|
|
# "token"
|
|
# )
|
|
# if token != "accepted":
|
|
# token = randrange(10000, 99999)
|
|
# await initdb(
|
|
# muc_jid,
|
|
# sqlite.update_setting_value,
|
|
# ["token", token]
|
|
# )
|
|
# self.send_message(
|
|
# mto=inviter,
|
|
# mfrom=self.boundjid.bare,
|
|
# mbody=(
|
|
# "Send activation token {} to groupchat xmpp:{}?join."
|
|
# ).format(token, muc_jid)
|
|
# )
|
|
logging.info('Joining groupchat\n'
|
|
'JID : {}\n'
|
|
'Inviter : {}\n'
|
|
.format(jid, inviter))
|
|
jid_from = str(self.boundjid) if self.is_component else None
|
|
self.plugin['xep_0045'].join_muc(jid,
|
|
self.alias,
|
|
pfrom=jid_from
|
|
# If a room password is needed, use:
|
|
# password=the_room_password,
|
|
)
|
|
|
|
|
|
def leave(self, jid):
|
|
message = ('This news bot will now leave this groupchat.\n'
|
|
'The JID of this news bot is xmpp:{}?message'
|
|
.format(self.boundjid.bare))
|
|
status_message = ('This bot has left the group. '
|
|
'It can be reached directly via {}'
|
|
.format(self.boundjid.bare))
|
|
self.send_message(mto=jid,
|
|
mfrom=self.boundjid,
|
|
mbody=message,
|
|
mtype='groupchat')
|
|
self.plugin['xep_0045'].leave_muc(jid,
|
|
self.alias,
|
|
status_message,
|
|
self.boundjid)
|