init
This commit is contained in:
commit
75ed0bd64f
|
|
@ -0,0 +1 @@
|
|||
__pycache__/
|
||||
|
|
@ -0,0 +1,18 @@
|
|||
from src import ModuleManager, utils
|
||||
|
||||
URL = "https://envs.sh"
|
||||
|
||||
class Module(ModuleManager.BaseModule):
|
||||
def on_load(self):
|
||||
self.exports.add("shorturl-s-envssh", self._shorturl)
|
||||
def _shorturl(self, url):
|
||||
if len(url) < 18:
|
||||
return None
|
||||
|
||||
page = utils.http.request(URL, method="POST",
|
||||
post_data={"shorten": url})
|
||||
|
||||
if page and page.data:
|
||||
return page.decode("utf8").rstrip("\n")
|
||||
return None
|
||||
|
||||
|
|
@ -0,0 +1,213 @@
|
|||
import emoji
|
||||
import json
|
||||
import random
|
||||
from mastodon import Mastodon
|
||||
from src import ModuleManager, utils
|
||||
|
||||
CHANNEL = "#tilderadio"
|
||||
NOTIFY_CHANNELS = [CHANNEL, "#meta", "#team", "#club"]
|
||||
LISTEN_URL = "https://tilderadio.org/listen"
|
||||
SCHEDULE_URL = "https://tilderadio.org/schedule/"
|
||||
SOURCE_URL = "https://tildegit.org/tilderadio/radiobot"
|
||||
RADIO_API_BASE = "https://radio.tildeverse.org/api"
|
||||
TOOT_CREDS_FILE = "/home/ben/.bitbot/tilderadio-toot.json"
|
||||
SLOGANS = [
|
||||
"The soundtrack in your cat's head",
|
||||
"Your cat says she likes us better",
|
||||
"radio for the people",
|
||||
"radio by bots, for bots",
|
||||
"On the Internet, no one knows you're a weakly superhuman AGI with a really good speech synth module.",
|
||||
"We found your cat",
|
||||
"cats.",
|
||||
"a hacker's excuse for radio",
|
||||
"0::1 is where the heart is",
|
||||
"now with the longest slogan in human history",
|
||||
"reticulating splines",
|
||||
"Hold the shift",
|
||||
"a very serious place for very serious happenings",
|
||||
"sorry, this extension is invalid",
|
||||
"This is the radio you were looking for",
|
||||
"Not The Illuminati, We Promise",
|
||||
"the radio is coming from INSIDE the house",
|
||||
"Dont Sue Us!",
|
||||
"it's radio minus radio",
|
||||
"where your passwords are stored in plain text",
|
||||
"Like radio. Only better.",
|
||||
"tomasino 0wnz y0u!",
|
||||
"that escalated quickly",
|
||||
"music for your brain meats",
|
||||
"003 Days Since Last Workplace Accident",
|
||||
"*heavy breathing*",
|
||||
"Dizzy? We stop the world from spinning",
|
||||
"Where Disney Princesses Go Slumming",
|
||||
'any slogan but "eat the poop or die"',
|
||||
"that's not what she said!",
|
||||
"not product placement, we promise! (tildestore.com)",
|
||||
]
|
||||
|
||||
|
||||
class Module(ModuleManager.BaseModule):
|
||||
now_playing = ""
|
||||
dj = ""
|
||||
song = ""
|
||||
listeners = 0
|
||||
mastodon = None
|
||||
is_online = False
|
||||
|
||||
def save_nowplaying(self, jsontxt):
|
||||
if jsontxt == "":
|
||||
data = utils.http.request(RADIO_API_BASE + "/nowplaying/1").json()
|
||||
else:
|
||||
data = json.loads(jsontxt)
|
||||
|
||||
self.is_online = data["live"]["is_live"]
|
||||
self.dj = data["live"]["streamer_name"]
|
||||
self.song = data["now_playing"]["song"]["text"]
|
||||
self.listeners = data["listeners"]["current"]
|
||||
|
||||
def format_nowplaying(self):
|
||||
ret = ""
|
||||
if self.is_online:
|
||||
ret = f"({self.dj}) "
|
||||
ret += f"now playing: {self.song} ~~ {self.listeners} listeners"
|
||||
return ret
|
||||
|
||||
def on_load(self):
|
||||
self.save_nowplaying("")
|
||||
|
||||
with open(TOOT_CREDS_FILE, "r") as f:
|
||||
creds = json.load(f)
|
||||
self.mastodon = Mastodon(
|
||||
client_id=creds["client_id"],
|
||||
client_secret=creds["client_secret"],
|
||||
access_token=creds["access_token"],
|
||||
api_base_url=creds["base_url"],
|
||||
)
|
||||
|
||||
@utils.hook("api.get.slogan", authenticated=False)
|
||||
def httpslogan(self, event):
|
||||
return random.choice(SLOGANS)
|
||||
|
||||
@utils.hook("api.post.radio")
|
||||
def hook(self, event):
|
||||
previous_dj = self.dj
|
||||
self.save_nowplaying(event["data"])
|
||||
|
||||
# new dj online!
|
||||
if self.dj != "" and self.dj != previous_dj:
|
||||
newdj_message = f"{self.dj} is now online playing {self.song}! tune in here now: {LISTEN_URL}"
|
||||
|
||||
self.mastodon.toot(newdj_message)
|
||||
|
||||
# TODO: send dm notifications
|
||||
# TODO: send email notifications
|
||||
|
||||
if "tilde" in self.bot.servers:
|
||||
server = self.bot.servers["tilde"]
|
||||
for channel_name in NOTIFY_CHANNELS:
|
||||
if channel_name in server.channels:
|
||||
channel = server.channels[channel_name]
|
||||
|
||||
self.events.on("send.stdout").call(
|
||||
target=channel,
|
||||
module_name="Tilderadio",
|
||||
server=server,
|
||||
message=newdj_message,
|
||||
)
|
||||
|
||||
# post new songs while streaming
|
||||
if self.is_online:
|
||||
if "tilde" in self.bot.servers:
|
||||
server = self.bot.servers["tilde"]
|
||||
if CHANNEL in server.channels:
|
||||
channel = server.channels[CHANNEL]
|
||||
|
||||
self.events.on("send.stdout").call(
|
||||
target=channel,
|
||||
module_name="Tilderadio",
|
||||
server=server,
|
||||
message=now_playing,
|
||||
)
|
||||
|
||||
@utils.hook("received.command.np", alias_of="nowplaying")
|
||||
@utils.hook("received.command.nowplaying")
|
||||
@utils.kwarg("help", "show the current song on tilderadio")
|
||||
def nowplaying(self, event):
|
||||
event["stdout"].write(self.format_nowplaying())
|
||||
|
||||
@utils.hook("received.command.schedule")
|
||||
@utils.kwarg("help", "show a link to the tilderadio schedule")
|
||||
def schedule(self, event):
|
||||
event["stdout"].write(f"you can find the schedule here: {SCHEDULE_URL}")
|
||||
|
||||
@utils.hook("received.command.un", alias_of="upnext")
|
||||
@utils.hook("received.command.upnext")
|
||||
@utils.kwarg("help", "show who's up next to stream")
|
||||
def upnext(self, event):
|
||||
js = utils.http.request(RADIO_API_BASE + "/station/1/schedule?rows=1").json()
|
||||
if len(js) < 1:
|
||||
event["stdout"].write("nothing scheduled")
|
||||
else:
|
||||
data = js[0]
|
||||
start = utils.datetime.parse.iso8601(data["start"])
|
||||
now = utils.datetime.utcnow()
|
||||
total_secs = (start - now).total_seconds()
|
||||
event["stdout"].write(
|
||||
"dj {} is up next at {} UTC in {}!".format(
|
||||
data["name"],
|
||||
utils.datetime.format.datetime_human(start),
|
||||
utils.datetime.format.to_pretty_time(total_secs),
|
||||
)
|
||||
)
|
||||
|
||||
@utils.hook("received.command.subscribe")
|
||||
@utils.kwarg("help", "sign up to get a direct message when a new dj goes online")
|
||||
def subscribe(self, event):
|
||||
# TODO: save subscribe to db
|
||||
event["stdout"].write("i'll send you a message when a dj goes online")
|
||||
|
||||
@utils.hook("received.command.unsubscribe")
|
||||
@utils.kwarg("help", "unsubscribe from dj announcements")
|
||||
def unsubscribe(self, event):
|
||||
# TODO: remove sender from subscribers
|
||||
event["stdout"].write("ok, i'll no longer send you dj announcements")
|
||||
|
||||
@utils.hook("received.command.emailsubscribe")
|
||||
@utils.kwarg("help", "sign up to get an email when a dj goes online")
|
||||
@utils.spec("!<email>string")
|
||||
def email_subscribe(self, event):
|
||||
# TODO: add email subscription if not already there
|
||||
email = event["spec"][0]
|
||||
event["stdout"].write(
|
||||
f"ok, i'll send an email to you at {email} when a dj goes online"
|
||||
)
|
||||
|
||||
@utils.hook("received.command.emailunsubscribe")
|
||||
@utils.kwarg("help", "stop sending email notifications")
|
||||
def email_unsubscribe(self, event):
|
||||
# TODO: remove email subscription if there
|
||||
event["stdout"].write("ok i'll stop sending you emails")
|
||||
|
||||
@utils.hook("received.command.dj")
|
||||
@utils.kwarg("help", "check if someone is currently streaming")
|
||||
def showdj(self, event):
|
||||
if self.dj == "":
|
||||
message = "no one is currently on the air"
|
||||
else:
|
||||
message = f"dj {self.dj} is now streaming!"
|
||||
event["stdout"].write(message)
|
||||
|
||||
@utils.hook("received.command.slogan")
|
||||
@utils.kwarg("help", "get a random tilderadio slogan")
|
||||
def slogan(self, event):
|
||||
event["stdout"].write(random.choice(SLOGANS))
|
||||
|
||||
@utils.hook("received.command.toot")
|
||||
@utils.kwarg("help", "send a toot from the tilderadio mastodon account")
|
||||
@utils.spec("!<status>string")
|
||||
def toot(self, event):
|
||||
status = event["spec"][0]
|
||||
if len(status) > 8:
|
||||
status = emoji.emojize(status, use_aliases=True)
|
||||
uri = self.mastodon.toot(status)["uri"]
|
||||
event["stdout"].write(f"tooted!: {uri}")
|
||||
|
|
@ -0,0 +1,18 @@
|
|||
from src import ModuleManager, utils
|
||||
|
||||
URL = "https://ttm.sh"
|
||||
|
||||
class Module(ModuleManager.BaseModule):
|
||||
def on_load(self):
|
||||
self.exports.add("shorturl-s-ttmsh", self._shorturl)
|
||||
def _shorturl(self, url):
|
||||
if len(url) < 18:
|
||||
return None
|
||||
|
||||
page = utils.http.request(URL, method="POST",
|
||||
post_data={"shorten": url})
|
||||
|
||||
if page and page.data:
|
||||
return page.decode("utf8").rstrip("\n")
|
||||
return None
|
||||
|
||||
Loading…
Reference in New Issue