fit: add weekly fitness post

.eslintrc

@@ -11,7 +11,6 @@
     "eslint:recommended"
   ],
   "rules": {
-    "no-unused-vars": "off",
     "@typescript-eslint/no-namespace": 0,
     "@typescript-eslint/no-unused-vars": ["warn", { "argsIgnorePattern": "^_", "varsIgnorePattern": "^_" }],
     "@typescript-eslint/ban-ts-comment": "off"

bot/src/Main.ts

@@ -21,6 +21,7 @@ import { subscribe } from "./commands/subscribe/Subscribe";
 import { throw_rps } from "./commands/throw/Throw";
 import * as Meetup from "./commands/meetup/RegisterMeetup";
 import * as Fit from "./commands/fit/Fit";
+import { fitSlashConfig, fitInteractionHandler } from "@bored-bot/fitness";
 
 // slash commands
 import { aqi } from "./interactions/aqi";
@@ -58,10 +59,15 @@ const registerSlashCommands = async() => {
    const { DISCORD_TOKEN, DISCORD_CLIENT_ID, SERVER_ID } = env;
 
    const rest = new REST ({ version: "9" }).setToken (DISCORD_TOKEN);
+
+   const interactionConfigs = [
+      fitSlashConfig.toJSON()
+   ]   
 
    return rest.put (
       Routes.applicationGuildCommands (DISCORD_CLIENT_ID, SERVER_ID),
-      { body: interactions.flatMap (it => it.config) }
+      // @ts-ignore
+      { body: interactions.flatMap (it => it.config).concat(interactionConfigs) }
    ).then (_ => { log.debug ("Slash Commands Registered"); });
 };
 
@@ -135,7 +141,8 @@ const handleMessage = (message: Discord.Message) => {
 const handleCommandInteraction = (interaction: Discord.ChatInputCommandInteraction, world: World) => {
    const handlers = interactions
       .filter (it => it.config.some (c => c.name === interaction.commandName))
-      .map (it => it.handle);
+      .map (it => it.handle)
+      .concat([fitInteractionHandler (world.mongodb)]);
 
    handlers.forEach (f => f (interaction, world));
 };

bot/src/commands/fit/Fit.ts

@@ -4,17 +4,17 @@ import { channels } from "../../deprecating/channels";
 import * as Command from "../../deprecating/Command";
 import * as Format from "../../deprecating/Format";
 
-import * as Balance from "./Balance";
 import * as Settings from "./Settings";
 import * as Admin from "./Admin";
 import * as UserAuth from "./UserAuth";
 import * as UserProfile from "./UserProfile";
-// import * as ActivityWebhook from "./ActivityWebhook";
-import * as Promotions from "./Promotions";
 import * as LastActive from "./LastActive";
 
 // @ts-ignore
-import * as Fit2 from "@bored-bot/fitness";
+import {
+   stravaWebhookHandler,
+   schedulePost
+} from "@bored-bot/fitness";
 
 import { env } from "../../environment";
 import { getInstance } from "../../deprecating/legacy_instance";
@@ -39,7 +39,7 @@ const fit = Command.filtered ({
       Filter.inChannel (env.CHANNEL_STRAVA)
    ),
 
-   callback: message =>
+   callback: message => 
       match (Command.route (message))
          .with ("auth", () => UserAuth.onBoarding (message))
          .with ("profile", () => UserProfile.render(message))
@@ -109,10 +109,11 @@ export const routes = (client: Discord.Client) => [
    {
       method:  "POST",
       path:    "/fit/api/webhook",
-      handler: req => Fit2.stravaWebhookHandler (client, getInstance ().mongodb) (req)
+      handler: req => stravaWebhookHandler (client, getInstance ().mongodb) (req)
    }
 ];
 
 export const startup = (client: Discord.Client) : void => {
    LastActive.beginFlush (client);
+   schedulePost(client, getInstance().mongodb);
 };

packages/fitness/package.json

@@ -12,6 +12,7 @@
   "dependencies": {
     "date-fns": "^2.28.0",
     "discord.js": "^14.10.2",
+    "node-schedule": "^2.0.0",
     "superagent": "^7.1.3"
   },
   "devDependencies": {

packages/fitness/src/EffortScore.js

@@ -0,0 +1,4 @@
+export const effortScore = (xp, score = 1) => {
+   const needs = score * 5;
+   return xp > needs ? effortScore(xp - needs, score + 1) : score + xp / needs;
+};

packages/fitness/src/MondayRecap.js

@@ -0,0 +1,65 @@
+import { startOfWeek } from "date-fns";
+import { EmbedBuilder } from "discord.js";
+import schedule from "node-schedule";
+import { loggedWorkoutCollection } from "./LoggedWorkout";
+import { effortScore } from "./EffortScore";
+
+const unique = (arr) => Array.from(new Set(arr));
+const notNull = (x) => !!x;
+
+/**
+ * @param {import("discord.js").Client} discord
+ * @param {import("mongodb").Db} db
+ */
+export const createRecap = (discord, db) => async () => {
+   const workouts = loggedWorkoutCollection(db);
+   const monday = startOfWeek(new Date(), { weekStartsOn: 1 });
+
+   const workoutsThisWeek = await workouts
+      .find({ insertedDate: { $gt: monday.toISOString() } })
+      .toArray();
+
+   const discordIds = unique(workoutsThisWeek.map((x) => x.discordId));
+
+   const guild = await discord.guilds.fetch(process.env.SERVER_ID);
+   const members = await guild.members.fetch(discordIds);
+   await guild.members.fetch(discordIds);
+
+   return new EmbedBuilder({
+      color: 0x4287f5,
+      author: {
+         icon_url: "https://imgur.com/iRWWVZY.png",
+         name: "Monday Moist Recap",
+      },
+      description:
+         "Here's everyone's total 💦 score from the last week!\n\n" +
+         members
+            .filter((m) => workoutsThisWeek.some((x) => x.discordId === m.id))
+            .map((member) => {
+               const exp = workoutsThisWeek
+                  .filter((x) => x.discordId === member.id)
+                  .reduce((sum, a) => sum + a.exp, 0);
+
+               return {
+                  username: member.nickname ?? member.user.username,
+                  score: effortScore(exp),
+               };
+            })
+            .filter(notNull)
+            .sort((a, b) => (a.score > b.score ? -1 : 1))
+            .map((x) => `🔹 **${x.username}** ${x.score.toFixed(1)}`)
+            .join("\n"),
+   });
+};
+
+export const schedulePost = async (discord, db) => {
+   const create = createRecap(discord, db);
+
+   const post = async () => {
+      const embed = await create();
+      const channel = await discord.channels.fetch(process.env.CHANNEL_STRAVA);
+      await channel.send({ embeds: [embed] });
+   };
+
+   schedule.scheduleJob("0 9 * * MON", () => post());
+};

packages/fitness/src/PostWorkout.js

@@ -9,6 +9,7 @@ import {
 
 import { userCollection } from "./User";
 import { loggedWorkoutCollection } from "./LoggedWorkout";
+import { effortScore } from "./EffortScore";
 
 const log = console.log.bind(console, "[fit/PostWorkout]");
 
@@ -36,11 +37,6 @@ const expFromStreams = (maxHR, streams) => {
 
 const expFromTime = (duration) => duration / 60;
 
-const effortScore = (xp, score = 1) => {
-   const needs = score * 5;
-   return xp > needs ? effortScore(xp - needs, score + 1) : score + xp / needs;
-};
-
 const workoutFromActivity = (user, activity, streams) => {
    const exp = user.maxHR ? expFromStreams(user.maxHR, streams) : null;
 

packages/fitness/src/index.js

@@ -1 +1,30 @@
 export { stravaWebhookHandler } from "./LoggedWorkout";
+export { schedulePost } from "./MondayRecap";
+
+import { PermissionFlagsBits, SlashCommandBuilder } from "discord.js";
+import { createRecap } from "./MondayRecap";
+
+export const fitSlashConfig = new SlashCommandBuilder()
+   .setName("fit_admin")
+   .setDescription("foo bar")
+   .setDefaultMemberPermissions(PermissionFlagsBits.KickMembers)
+   .addSubcommand((cmd) =>
+      cmd
+         .setName("monday")
+         .setDescription("Preview the fitness bot's monday post."),
+   );
+
+export const fitInteractionHandler = (db) => async (interaction) => {
+   if ("fit_admin" === interaction.commandName) {
+      const sub = interaction.options.getSubcommand();
+
+      if ("monday" === sub) {
+         const embed = await createRecap(interaction.client, db)();
+         interaction.reply({
+            content: "Here is a preview of the upcoming monday recap",
+            embeds: [embed],
+            ephemeral: true,
+         });
+      }
+   }
+};