Add tate command
All checks were successful
Build and Publish college-bot-v2 / build_and_publish (push) Successful in 17s
All checks were successful
Build and Publish college-bot-v2 / build_and_publish (push) Successful in 17s
This commit is contained in:
parent
19bd4030d0
commit
f48b8e3ca0
GPG key ID:
0FA334385D0B689F
1 changed files with 127 additions and 78 deletions
|
|
@ -1019,91 +1019,140 @@ class Ollama(commands.Cog):
|
|||
break
|
||||
await msg.edit(embed=embed)
|
||||
|
||||
@commands.command()
|
||||
@commands.guild_only()
|
||||
async def trump(self, ctx: commands.Context):
|
||||
async with ctx.channel.typing():
|
||||
thread_id = self.history.create_thread(
|
||||
ctx.author,
|
||||
async def generate_truth(self, ctx: commands.Context, entity: str, limit: int = None):
|
||||
if entity == "trump":
|
||||
system = (
|
||||
"You are the former united states president, Donald Trump, convicted of 34 felonies."
|
||||
" You have been posting approximately 50 times a day on your platform 'Truth Social' spreading your"
|
||||
" words of truth to the american people in order to make america great again. After reading through all"
|
||||
" of your previous truth posts, you should generate another one, ready to be posted, "
|
||||
"under 4000 characters. Write only the content to be posted, do not include any pleasantries."
|
||||
" Write using the style of a twitter or facebook post. Do not repeat a previous post."
|
||||
" words of truth to the american people in order to make america great again."
|
||||
)
|
||||
async with httpx.AsyncClient() as client:
|
||||
r = CONFIG["truth"].get("api", "https://bots.nexy7574.co.uk/jimmy/v2")
|
||||
username = CONFIG["truth"].get("username", "1")
|
||||
password = CONFIG["truth"].get("password", "2")
|
||||
response = await client.get(
|
||||
r + "/api/truths/all",
|
||||
timeout=60,
|
||||
auth=(username, password),
|
||||
)
|
||||
response.raise_for_status()
|
||||
truths: list[dict] = response.json()
|
||||
truths: list[TruthPayload] = list(map(lambda t: TruthPayload.model_validate(t), truths))
|
||||
for truth in truths:
|
||||
if truth.author == "trump":
|
||||
await asyncio.to_thread(
|
||||
functools.partial(
|
||||
self.history.add_message,
|
||||
thread_id,
|
||||
"assistant",
|
||||
truth.content,
|
||||
save=False
|
||||
)
|
||||
)
|
||||
self.history.add_message(thread_id, "user", "Generate a new truth post.")
|
||||
elif entity == "tate":
|
||||
system = (
|
||||
"You are the 'Top G' Andrew Tate. Andrew Tate is a former professional kickboxer who turned to the "
|
||||
"world of influencing. His personality is one of arrogance and self-aggrandizement, "
|
||||
"often referred to as \"King of Toxic Masculinity\" by critics due to his controversial views on "
|
||||
"gender roles, relationships, and other topics. He has been involved in several controversies related "
|
||||
"to his content online including promoting extremist ideologies and misogynistic views. "
|
||||
"Despite this, he still has a large following and is known for being an entrepreneur who built multiple"
|
||||
" successful businesses such as Trinity Kickboxing Academy, Hustlers University, "
|
||||
"and Romania's Real Estate Empire. "
|
||||
"You post advice regarding masculinity and success, often in a controversial manner, on Truth Social. "
|
||||
)
|
||||
else:
|
||||
raise ValueError("Invalid entity; must be one of trump/tate")
|
||||
system += (
|
||||
"\n\nAfter reading through all"
|
||||
" of your previous truth posts, you should generate another one, ready to be posted, "
|
||||
"under 4000 characters. Write only the content to be posted, do not include any pleasantries."
|
||||
" Write using the style of a twitter or facebook post. Do not repeat a previous post."
|
||||
)
|
||||
thread_id = self.history.create_thread(
|
||||
ctx.author,
|
||||
system
|
||||
)
|
||||
async with httpx.AsyncClient() as client:
|
||||
r = CONFIG["truth"].get("api", "https://bots.nexy7574.co.uk/jimmy/v2")
|
||||
username = CONFIG["truth"].get("username", "1")
|
||||
password = CONFIG["truth"].get("password", "2")
|
||||
response = await client.get(
|
||||
r + "/api/truths/all",
|
||||
timeout=60,
|
||||
auth=(username, password),
|
||||
)
|
||||
response.raise_for_status()
|
||||
truths = response.json()
|
||||
truths: list[TruthPayload] = list(map(lambda t: TruthPayload.model_validate(t), truths))
|
||||
|
||||
tried = set()
|
||||
for _ in range(10):
|
||||
server = self.next_server(tried)
|
||||
if await self.check_server(CONFIG["ollama"][server]["base_url"]):
|
||||
break
|
||||
tried.add(server)
|
||||
else:
|
||||
return await ctx.reply("All servers are offline. Please try again later.", delete_after=300)
|
||||
if entity:
|
||||
truths = list(filter(lambda t: t.author == entity, truths))
|
||||
if limit:
|
||||
truths.sort(key=lambda t: t.timestamp, reverse=True) # newest first
|
||||
|
||||
client = OllamaClient(CONFIG["ollama"][server]["base_url"])
|
||||
async with self.servers[server]:
|
||||
if not await client.has_model_named("llama2-uncensored", "7b-chat"):
|
||||
with client.download_model("llama2-uncensored", "7b-chat") as handler:
|
||||
await handler.flatten()
|
||||
|
||||
embed = discord.Embed(
|
||||
title="New Truth!",
|
||||
description="",
|
||||
colour=0x6559FF
|
||||
)
|
||||
msg = await ctx.reply(embed=embed)
|
||||
last_edit = time.time()
|
||||
messages = self.history.get_history(thread_id)
|
||||
with client.new_chat("llama2-uncensored:7b-chat", messages) as handler:
|
||||
async for ln in handler:
|
||||
embed.description += ln["message"]["content"]
|
||||
if len(embed.description) >= 4000:
|
||||
break
|
||||
if (time.time() - last_edit) >= 2.5:
|
||||
await msg.edit(embed=embed)
|
||||
last_edit = time.time()
|
||||
|
||||
for truth in truths:
|
||||
if truth.content == embed.description:
|
||||
embed.add_field(
|
||||
name="Repeated truth :(",
|
||||
value="This truth was already truthed. Shit AI."
|
||||
)
|
||||
break
|
||||
embed.set_footer(
|
||||
text="Finished generating truth based off of {:,} messages, using server {!r} | {!s}".format(
|
||||
len(messages) - 2,
|
||||
server,
|
||||
thread_id
|
||||
for truth in truths:
|
||||
await asyncio.to_thread(
|
||||
functools.partial(
|
||||
self.history.add_message,
|
||||
thread_id,
|
||||
"assistant",
|
||||
truth.content,
|
||||
save=False
|
||||
)
|
||||
)
|
||||
await msg.edit(embed=embed)
|
||||
self.history.add_message(thread_id, "user", "Generate a new truth post.")
|
||||
|
||||
tried = set()
|
||||
for _ in range(10):
|
||||
server = self.next_server(tried)
|
||||
if await self.check_server(CONFIG["ollama"][server]["base_url"]):
|
||||
break
|
||||
tried.add(server)
|
||||
else:
|
||||
return await ctx.reply("All servers are offline. Please try again later.", delete_after=300)
|
||||
|
||||
client = OllamaClient(CONFIG["ollama"][server]["base_url"])
|
||||
async with self.servers[server]:
|
||||
if not await client.has_model_named("llama2-uncensored", "7b-chat"):
|
||||
with client.download_model("llama2-uncensored", "7b-chat") as handler:
|
||||
await handler.flatten()
|
||||
|
||||
embed = discord.Embed(
|
||||
title="New Truth!",
|
||||
description="",
|
||||
colour=0x6559FF
|
||||
)
|
||||
msg = await ctx.reply(embed=embed)
|
||||
last_edit = time.time()
|
||||
messages = self.history.get_history(thread_id)
|
||||
with client.new_chat("llama2-uncensored:7b-chat", messages) as handler:
|
||||
async for ln in handler:
|
||||
embed.description += ln["message"]["content"]
|
||||
if len(embed.description) >= 4000:
|
||||
break
|
||||
if (time.time() - last_edit) >= 2.5:
|
||||
await msg.edit(embed=embed)
|
||||
last_edit = time.time()
|
||||
|
||||
for truth in truths:
|
||||
if truth.content == embed.description:
|
||||
embed.add_field(
|
||||
name="Repeated truth :(",
|
||||
value="This truth was already truthed. Shit AI."
|
||||
)
|
||||
break
|
||||
embed.set_footer(
|
||||
text="Finished generating truth based off of {:,} messages, using server {!r} | {!s}".format(
|
||||
len(messages) - 2,
|
||||
server,
|
||||
thread_id
|
||||
)
|
||||
)
|
||||
await msg.edit(embed=embed)
|
||||
|
||||
@commands.command()
|
||||
@commands.guild_only()
|
||||
async def trump(self, ctx: commands.Context, latest: int = None):
|
||||
"""
|
||||
Generates a truth social post from trump!
|
||||
|
||||
<latest> - limit the training history to the latest <latest> truths.
|
||||
|
||||
This command may take a long time.
|
||||
"""
|
||||
async with ctx.channel.typing():
|
||||
await self.generate_truth(ctx, "trump", latest)
|
||||
|
||||
@commands.command()
|
||||
@commands.guild_only()
|
||||
async def tate(self, ctx: commands.Context, latest: int = None):
|
||||
"""
|
||||
Generates a truth social post from Andrew Tate
|
||||
|
||||
<latest> - limit the training history to the latest <latest> truths.
|
||||
|
||||
This command may take a long time.
|
||||
"""
|
||||
async with ctx.channel.typing():
|
||||
await self.generate_truth(ctx, "tate", latest)
|
||||
|
||||
|
||||
def setup(bot):
|
||||
|
|
|
|||
Loading…
Reference in a new issue