Discord Bot - Message handler with announcements sync
cgen-43cc4ddef6574e6d853f8790e718549a
This commit is contained in:
Builder.io
parent
9e88ea1991
commit
bc2e0fe10d
1 changed files with 177 additions and 56 deletions
|
|
@ -1,5 +1,4 @@
|
|||
const { createClient } = require("@supabase/supabase-js");
|
||||
const fetch = require("node-fetch");
|
||||
|
||||
// Initialize Supabase
|
||||
const supabase = createClient(
|
||||
|
|
@ -11,23 +10,165 @@ const FEED_CHANNEL_ID = process.env.DISCORD_FEED_CHANNEL_ID;
|
|||
const FEED_GUILD_ID = process.env.DISCORD_FEED_GUILD_ID;
|
||||
const API_BASE = process.env.VITE_API_BASE || "https://api.aethex.dev";
|
||||
|
||||
// Announcement channels to sync
|
||||
// Announcement channels to sync to feed
|
||||
const ANNOUNCEMENT_CHANNELS = process.env.DISCORD_ANNOUNCEMENT_CHANNELS
|
||||
? process.env.DISCORD_ANNOUNCEMENT_CHANNELS.split(",").map((id) => id.trim())
|
||||
: [];
|
||||
|
||||
// Helper: Get arm affiliation from message context
|
||||
function getArmAffiliation(message) {
|
||||
const guildName = message.guild?.name?.toLowerCase() || "";
|
||||
const channelName = message.channel?.name?.toLowerCase() || "";
|
||||
const searchString = `${guildName} ${channelName}`;
|
||||
|
||||
if (searchString.includes("gameforge")) return "gameforge";
|
||||
if (searchString.includes("corp")) return "corp";
|
||||
if (searchString.includes("foundation")) return "foundation";
|
||||
if (searchString.includes("devlink") || searchString.includes("dev-link"))
|
||||
return "devlink";
|
||||
if (searchString.includes("nexus")) return "nexus";
|
||||
if (searchString.includes("staff")) return "staff";
|
||||
|
||||
return "labs";
|
||||
}
|
||||
|
||||
// Handle announcements from designated channels
|
||||
async function handleAnnouncementSync(message) {
|
||||
try {
|
||||
console.log(
|
||||
`[Announcements] Processing from ${message.author.tag} in #${message.channel.name}`,
|
||||
);
|
||||
|
||||
// Get or create system announcement user
|
||||
let { data: adminUser } = await supabase
|
||||
.from("user_profiles")
|
||||
.select("id")
|
||||
.eq("username", "aethex-announcements")
|
||||
.single();
|
||||
|
||||
let authorId = adminUser?.id;
|
||||
|
||||
if (!authorId) {
|
||||
const { data: newUser } = await supabase
|
||||
.from("user_profiles")
|
||||
.insert({
|
||||
username: "aethex-announcements",
|
||||
full_name: "AeThex Announcements",
|
||||
avatar_url: "https://aethex.dev/logo.png",
|
||||
})
|
||||
.select("id");
|
||||
|
||||
authorId = newUser?.[0]?.id;
|
||||
}
|
||||
|
||||
if (!authorId) {
|
||||
console.error("[Announcements] Could not get author ID");
|
||||
await message.react("❌");
|
||||
return;
|
||||
}
|
||||
|
||||
// Prepare content
|
||||
let content = message.content || "Announcement from Discord";
|
||||
|
||||
// Handle embeds
|
||||
if (message.embeds.length > 0) {
|
||||
const embed = message.embeds[0];
|
||||
if (embed.title) content = `**${embed.title}**\n\n${content}`;
|
||||
if (embed.description) content += `\n\n${embed.description}`;
|
||||
}
|
||||
|
||||
// Handle attachments
|
||||
let mediaUrl = null;
|
||||
let mediaType = "none";
|
||||
|
||||
if (message.attachments.size > 0) {
|
||||
const attachment = message.attachments.first();
|
||||
if (attachment) {
|
||||
mediaUrl = attachment.url;
|
||||
const attachmentLower = attachment.name.toLowerCase();
|
||||
|
||||
if ([".jpg", ".jpeg", ".png", ".gif", ".webp"].some((ext) =>
|
||||
attachmentLower.endsWith(ext),
|
||||
)) {
|
||||
mediaType = "image";
|
||||
} else if ([".mp4", ".webm", ".mov", ".avi"].some((ext) =>
|
||||
attachmentLower.endsWith(ext),
|
||||
)) {
|
||||
mediaType = "video";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Determine arm
|
||||
const armAffiliation = getArmAffiliation(message);
|
||||
|
||||
// Prepare post content
|
||||
const postContent = JSON.stringify({
|
||||
text: content,
|
||||
mediaUrl: mediaUrl,
|
||||
mediaType: mediaType,
|
||||
source: "discord",
|
||||
discord_message_id: message.id,
|
||||
discord_channel: message.channel.name,
|
||||
});
|
||||
|
||||
// Create post
|
||||
const { data: createdPost, error: insertError } = await supabase
|
||||
.from("community_posts")
|
||||
.insert({
|
||||
title: content.substring(0, 100) || "Discord Announcement",
|
||||
content: postContent,
|
||||
arm_affiliation: armAffiliation,
|
||||
author_id: authorId,
|
||||
tags: ["discord", "announcement"],
|
||||
category: "announcement",
|
||||
is_published: true,
|
||||
likes_count: 0,
|
||||
comments_count: 0,
|
||||
})
|
||||
.select(
|
||||
`id, title, content, arm_affiliation, author_id, created_at, likes_count, comments_count,
|
||||
user_profiles!community_posts_author_id_fkey (id, username, full_name, avatar_url)`,
|
||||
);
|
||||
|
||||
if (insertError) {
|
||||
console.error("[Announcements] Post creation failed:", insertError);
|
||||
await message.react("❌");
|
||||
return;
|
||||
}
|
||||
|
||||
console.log(
|
||||
`[Announcements] ✅ Synced to AeThex (${armAffiliation} arm)`,
|
||||
);
|
||||
|
||||
await message.react("✅");
|
||||
} catch (error) {
|
||||
console.error("[Announcements] Error:", error);
|
||||
try {
|
||||
await message.react("⚠️");
|
||||
} catch (e) {
|
||||
console.warn("[Announcements] Could not react:", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
name: "messageCreate",
|
||||
async execute(message, client) {
|
||||
// Ignore bot messages
|
||||
// Ignore bot messages and empty messages
|
||||
if (message.author.bot) return;
|
||||
if (!message.content && message.attachments.size === 0) return;
|
||||
|
||||
// Only listen to messages in the feed channel
|
||||
// Check if this is an announcement to sync
|
||||
if (ANNOUNCEMENT_CHANNELS.length > 0 && ANNOUNCEMENT_CHANNELS.includes(message.channelId)) {
|
||||
return handleAnnouncementSync(message);
|
||||
}
|
||||
|
||||
// Check if this is in the feed channel (for user-generated posts)
|
||||
if (FEED_CHANNEL_ID && message.channelId !== FEED_CHANNEL_ID) {
|
||||
return;
|
||||
}
|
||||
|
||||
// Only listen to the correct guild
|
||||
if (FEED_GUILD_ID && message.guildId !== FEED_GUILD_ID) {
|
||||
return;
|
||||
}
|
||||
|
|
@ -41,7 +182,6 @@ module.exports = {
|
|||
.single();
|
||||
|
||||
if (error || !linkedAccount) {
|
||||
// Optionally, send a DM asking them to link their account
|
||||
try {
|
||||
await message.author.send(
|
||||
"To have your message posted to AeThex, please link your Discord account! Use `/verify` command.",
|
||||
|
|
@ -52,7 +192,7 @@ module.exports = {
|
|||
return;
|
||||
}
|
||||
|
||||
// Get user profile for author info
|
||||
// Get user profile
|
||||
const { data: userProfile, error: profileError } = await supabase
|
||||
.from("user_profiles")
|
||||
.select("id, username, full_name, avatar_url")
|
||||
|
|
@ -60,65 +200,54 @@ module.exports = {
|
|||
.single();
|
||||
|
||||
if (profileError || !userProfile) {
|
||||
console.error(
|
||||
"[Feed Sync] Could not fetch user profile:",
|
||||
profileError,
|
||||
);
|
||||
console.error("[Feed Sync] Could not fetch user profile:", profileError);
|
||||
return;
|
||||
}
|
||||
|
||||
// Prepare message content and media
|
||||
// Prepare content
|
||||
let content = message.content || "Shared a message on Discord";
|
||||
|
||||
// Handle embeds and attachments
|
||||
let mediaUrl = null;
|
||||
let mediaType = "none";
|
||||
|
||||
// Check for attachments (images, videos)
|
||||
if (message.attachments.size > 0) {
|
||||
const attachment = message.attachments.first();
|
||||
if (attachment) {
|
||||
mediaUrl = attachment.url;
|
||||
|
||||
// Detect media type
|
||||
const imageExtensions = [".jpg", ".jpeg", ".png", ".gif", ".webp"];
|
||||
const videoExtensions = [".mp4", ".webm", ".mov", ".avi"];
|
||||
|
||||
const attachmentLower = attachment.name.toLowerCase();
|
||||
|
||||
if (imageExtensions.some((ext) => attachmentLower.endsWith(ext))) {
|
||||
if ([".jpg", ".jpeg", ".png", ".gif", ".webp"].some((ext) =>
|
||||
attachmentLower.endsWith(ext),
|
||||
)) {
|
||||
mediaType = "image";
|
||||
} else if (
|
||||
videoExtensions.some((ext) => attachmentLower.endsWith(ext))
|
||||
) {
|
||||
} else if ([".mp4", ".webm", ".mov", ".avi"].some((ext) =>
|
||||
attachmentLower.endsWith(ext),
|
||||
)) {
|
||||
mediaType = "video";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Prepare post content JSON
|
||||
// Determine arm affiliation
|
||||
let armAffiliation = "labs";
|
||||
const guild = message.guild;
|
||||
if (guild) {
|
||||
const guildNameLower = guild.name.toLowerCase();
|
||||
if (guildNameLower.includes("gameforge")) armAffiliation = "gameforge";
|
||||
else if (guildNameLower.includes("corp")) armAffiliation = "corp";
|
||||
else if (guildNameLower.includes("foundation")) armAffiliation = "foundation";
|
||||
else if (guildNameLower.includes("devlink")) armAffiliation = "devlink";
|
||||
else if (guildNameLower.includes("nexus")) armAffiliation = "nexus";
|
||||
else if (guildNameLower.includes("staff")) armAffiliation = "staff";
|
||||
}
|
||||
|
||||
// Prepare post content
|
||||
const postContent = JSON.stringify({
|
||||
text: content,
|
||||
mediaUrl: mediaUrl,
|
||||
mediaType: mediaType,
|
||||
});
|
||||
|
||||
// Determine arm affiliation from guild name or default to 'labs'
|
||||
let armAffiliation = "labs";
|
||||
const guild = message.guild;
|
||||
if (guild) {
|
||||
const guildNameLower = guild.name.toLowerCase();
|
||||
|
||||
if (guildNameLower.includes("gameforge")) armAffiliation = "gameforge";
|
||||
else if (guildNameLower.includes("corp")) armAffiliation = "corp";
|
||||
else if (guildNameLower.includes("foundation"))
|
||||
armAffiliation = "foundation";
|
||||
else if (guildNameLower.includes("devlink")) armAffiliation = "devlink";
|
||||
else if (guildNameLower.includes("nexus")) armAffiliation = "nexus";
|
||||
else if (guildNameLower.includes("staff")) armAffiliation = "staff";
|
||||
}
|
||||
|
||||
// Create post in AeThex
|
||||
// Create post
|
||||
const { data: createdPost, error: insertError } = await supabase
|
||||
.from("community_posts")
|
||||
.insert({
|
||||
|
|
@ -141,30 +270,25 @@ module.exports = {
|
|||
console.error("[Feed Sync] Failed to create post:", insertError);
|
||||
try {
|
||||
await message.react("❌");
|
||||
} catch (reactionError) {
|
||||
console.warn("[Feed Sync] Could not add reaction:", reactionError);
|
||||
} catch (e) {
|
||||
console.warn("[Feed Sync] Could not add reaction:", e);
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
console.log(
|
||||
`[Feed Sync] ✅ Posted message from ${message.author.tag} to AeThex`,
|
||||
`[Feed Sync] ✅ Posted from ${message.author.tag} to AeThex`,
|
||||
);
|
||||
|
||||
// React with success emoji
|
||||
try {
|
||||
await message.react("✅");
|
||||
} catch (reactionError) {
|
||||
console.warn(
|
||||
"[Feed Sync] Could not add success reaction:",
|
||||
reactionError,
|
||||
);
|
||||
console.warn("[Feed Sync] Could not add success reaction:", reactionError);
|
||||
}
|
||||
|
||||
// Send confirmation DM
|
||||
try {
|
||||
await message.author.send(
|
||||
`✅ Your message was posted to AeThex Community Feed! Check it out at https://aethex.dev/feed`,
|
||||
`✅ Your message was posted to AeThex! Check it out at https://aethex.dev/feed`,
|
||||
);
|
||||
} catch (dmError) {
|
||||
console.warn("[Feed Sync] Could not send confirmation DM:", dmError);
|
||||
|
|
@ -174,11 +298,8 @@ module.exports = {
|
|||
|
||||
try {
|
||||
await message.react("⚠️");
|
||||
} catch (reactionError) {
|
||||
console.warn(
|
||||
"[Feed Sync] Could not add warning reaction:",
|
||||
reactionError,
|
||||
);
|
||||
} catch (e) {
|
||||
console.warn("[Feed Sync] Could not add warning reaction:", e);
|
||||
}
|
||||
}
|
||||
},
|
||||
|
|
|
|||
Loading…
Reference in a new issue