78 lines
2.7 KiB
Python
78 lines
2.7 KiB
Python
import requests
|
|
from celery import shared_task
|
|
from django.conf import settings
|
|
from mhackspace.feeds.helper import import_feeds
|
|
|
|
|
|
@shared_task
|
|
def update_homepage_feeds():
|
|
return import_feeds()
|
|
|
|
matrix_url = "https://matrix.org/_matrix/client/r0"
|
|
matrix_login_url = matrix_url + "/login"
|
|
matrix_join_room_alias_url = matrix_url + "/join/{room}?access_token={access_token}"
|
|
matrix_join_room_id_url = matrix_url + "rooms/%21{room}/join?access_token={access_token}"
|
|
matrix_send_msg_url = matrix_url + "/rooms/%21{room}/send/m.room.message?access_token={access_token}"
|
|
|
|
@shared_task
|
|
def matrix_message(message):
|
|
#login
|
|
details = {
|
|
"type":"m.login.password",
|
|
"user":settings.MATRIX_USER,
|
|
"password":settings.MATRIX_PASSWORD}
|
|
r0 = requests.post(matrix_login_url, json = details)
|
|
access_token = r0.json().get('access_token')
|
|
|
|
#join room by id
|
|
url_params = {
|
|
'room': settings.MATRIX_ROOM,
|
|
'access_token': access_token}
|
|
url = matrix_join_room_id_url.format(**url_params)
|
|
r1 = requests.post(url)
|
|
|
|
#send message
|
|
url_params = {
|
|
"room": settings.MATRIX_ROOM,
|
|
"access_token": access_token}
|
|
url = matrix_send_msg_url.format(**url_params)
|
|
details = {
|
|
"msgtype":"m.text",
|
|
"body":message}
|
|
r2 = requests.post(url, json = details)
|
|
return True
|
|
|
|
# url = "https://matrix.org/_matrix/client/r0/join/{room_alias}?access_token={access_token}".format(
|
|
# **{'access_token': access_token,
|
|
# 'room_alias': '#maidstone-hackspace:matrix.org'})
|
|
# response = requests.post(url)
|
|
|
|
|
|
# return import_feeds()
|
|
# url = "https://matrix.org/_matrix/client/r0/rooms/%21{room}:matrix.org/join?access_token={access_token}".format(
|
|
# **{'room': 'fmCpNwqgIiuwATlcdw',
|
|
# 'access_token': access_token})
|
|
# r = requests.get(url)
|
|
# fmCpNwqgIiuwATlcdw:matrix.org
|
|
|
|
|
|
#join room by id
|
|
# url = "https://matrix.org/_matrix/client/r0/rooms/%21{room}/join?access_token={access_token}".format(
|
|
# **{'room': 'fmCpNwqgIiuwATlcdw:matrix.org',
|
|
# 'access_token': access_token})
|
|
# response = requests.post(url)
|
|
|
|
|
|
# url = "https://matrix.org/_matrix/client/r0/rooms/%21{room}/send/m.room.message?access_token={access_token}".format(
|
|
# **{'room': 'fmCpNwqgIiuwATlcdw:matrix.org',
|
|
# 'access_token': access_token})
|
|
# details = {"msgtype":"m.text", "body":"poke from python"} #{"type":"m.login.password", "user":"oly", "password":""}
|
|
# r = requests.post(url, json = details)
|
|
# return r.json()
|
|
|
|
|
|
# url = "https://matrix.org/_matrix/client/r0/rooms/%21{room}/join?access_token={access_token}".format(
|
|
# **{'room': 'fmCpNwqgIiuwATlcdw:matrix.org',
|
|
# 'access_token': access_token})
|
|
# response = requests.post(url)
|