Implement GH Release announcement (#2).

Author: phorcys420

config.toml.example

@@ -6,6 +6,12 @@ id = "1006346052317753414"        # ID of the #help forum channel
 closedTag = "1006926031434813500" # ID of the post tag that corresponds to a closed post
 openedTag = "1063924583847170098" # ID of the post tag that corresponds to an opened post
 
+[releaseChannel]
+id = "984553991545446411" # ID of the #release channel
+
+[releaseAlertChannel]
+id = "" # ID of the channel where the GitHub webhook is configured
+
 [emojis]
 coder = "971867583156469840"
 vscode = "1078432889995268248"

lib/config.dart

@@ -29,6 +29,8 @@ final List<ConfigType> configTypes = [
       ["helpChannel", "id"],
       ["helpChannel", "closedTag"],
       ["helpChannel", "openedTag"],
+      ["releaseChannel", "id"],
+      ["releaseAlertChannel", "id"],
       ["emojis", "coder"],
       ["emojis", "vscode"],
       ["emojis", "linux"],

lib/discord/client.dart

@@ -11,11 +11,17 @@ import "package:codercord/discord/interactions/multiselects/multiselects.dart"
 
 import "package:logging/logging.dart";
 
+import "package:codercord/github/github.dart";
+import "package:github/github.dart";
+import "package:version/version.dart";
+
 import "package:nyxx/nyxx.dart";
 import "package:nyxx_interactions/nyxx_interactions.dart";
 
 final logger = Logger("Codercord");
 
+RegExp linkText = RegExp("(?<=\\[)(.+)(?=\\])");
+
 class Codercord {
   final List<PresenceBuilder> presenceList = [
     PresenceBuilder.of(activity: ActivityBuilder.game("with Coder OSS")),
@@ -57,6 +63,50 @@ class Codercord {
     interactions.syncOnReady();
   }
 
+  Future<List<Release>> triggerReleaseCheck(RepositorySlug slug) async {
+    Version? lastSentVersion;
+
+    await for (final message in releaseChannel.downloadMessages(limit: 10)) {
+      if (message.author.id == client.self.id && message.embeds.isNotEmpty) {
+        IEmbedField versionField = message.embeds[0].fields.firstWhere(
+          (field) => field.name == "Version",
+        );
+
+        String? messageVersion =
+            linkText.stringMatch(versionField.content)?.replaceFirst("v", "");
+
+        try {
+          lastSentVersion = Version.parse(messageVersion!);
+
+          break;
+        } catch (_) {}
+      }
+    }
+
+    List<Release> releasesToSend;
+    if (lastSentVersion != null) {
+      releasesToSend = await getNewerReleases(slug, lastSentVersion).then(
+        (releases) => releases.reversed.toList(),
+      );
+    } else {
+      releasesToSend = [await getNewestRelease(slug)];
+    }
+
+    for (final release in releasesToSend) {
+      ComponentMessageBuilder releaseMessage = await makeReleaseMessage(
+        slug,
+        release,
+      );
+
+      await releaseChannel.sendMessage(releaseMessage);
+      logger.info(
+        "Sent release announcement for ${slug.fullName} ${release.tagName!}",
+      );
+    }
+
+    return releasesToSend;
+  }
+
   void login() async {
     logger.info("Codercord is loading..");
 
@@ -76,15 +126,18 @@ class Codercord {
         exit(1);
       }
 
-      logger.info("Registering commands..");
-      await registerInteractionHandlers();
-
       logger.info("Codercord is ready !");
 
       logger.info(
         "Invite link: https://discord.com/oauth2/authorize?client_id=$clientId&scope=bot%20applications.commands&permissions=294205377552",
       );
 
+      logger.info("Registering commands..");
+      await registerInteractionHandlers();
+
+      logger.info("Checking for new releases..");
+      await triggerReleaseCheck(coderRepo);
+
       client.eventsWs.onThreadCreated.listen((event) async {
         if (event.newlyCreated && await event.thread.isHelpPost) {
           event.thread.setPostTags([openedTagID]);
@@ -112,6 +165,12 @@ class Codercord {
           await event.message.delete(
             auditReason: "Automatic deletion of channel pin announcements.",
           );
+        } else if (event.message.channel.id == releaseAlertChannel.id &&
+            event.message.author.isInteractionWebhook) {
+          logger.info(
+            "A new message was sent in the release alert channel, checking for new releases..",
+          );
+          await triggerReleaseCheck(coderRepo);
         }
       });
 

lib/github/github.dart

@@ -0,0 +1,58 @@
+import "package:version/version.dart";
+import "package:github/github.dart";
+
+import "package:nyxx_interactions/nyxx_interactions.dart";
+import "package:nyxx/nyxx.dart";
+
+final GitHub github = GitHub();
+
+Future<Release> getNewestRelease(RepositorySlug slug) {
+  return github.repositories.listReleases(slug).first;
+}
+
+Future<List<Release>> getNewerReleases(
+  RepositorySlug slug,
+  Version version,
+) async {
+  Stream<Release> releaseStream =
+      github.repositories.listReleases(slug).takeWhile(
+    (release) {
+      Version releaseVersion = Version.parse(
+        release.tagName!.replaceFirst("v", ""),
+      );
+
+      return releaseVersion > version;
+    },
+  );
+
+  return releaseStream.toList();
+}
+
+Future<ComponentMessageBuilder> makeReleaseMessage(
+  RepositorySlug slug,
+  Release release,
+) async {
+  EmbedBuilder embed = EmbedBuilder()
+    ..title = "New release published ! :tada:"
+    ..addField(
+      name: "Repository",
+      content: "[${slug.fullName}](https://github.com/${slug.fullName})",
+      inline: true,
+    )
+    ..addField(
+      name: "Version",
+      content: "[${release.tagName!}](${release.htmlUrl!})",
+      inline: true,
+    );
+
+  ComponentMessageBuilder message = ComponentMessageBuilder()
+    ..componentRows = [
+      ComponentRowBuilder()
+        ..addComponent(
+          LinkButtonBuilder("Changelog", release.htmlUrl!),
+        )
+    ]
+    ..embeds = [embed];
+
+  return message;
+}

lib/values.dart

@@ -1,11 +1,14 @@
 import "package:codercord/config.dart";
 
+import "package:github/github.dart";
 import "package:nyxx/nyxx.dart";
 
 late final IGuild coderServer;
 late final IGuild emojiServer;
 
-late final IGuildChannel helpChannel;
+late final IForumChannel helpChannel;
+late final ITextChannel releaseChannel;
+late final ITextChannel releaseAlertChannel;
 
 late final Snowflake closedTagID;
 late final Snowflake openedTagID;
@@ -17,6 +20,8 @@ late final IBaseGuildEmoji linuxEmoji;
 late final IBaseGuildEmoji windowsEmoji;
 late final IBaseGuildEmoji macosEmoji;
 
+final RepositorySlug coderRepo = RepositorySlug("coder", "coder");
+
 Future<void> loadValues(INyxxWebsocket client) async {
   coderServer = await client.fetchGuild(Snowflake(config["coderServer"]["id"]),
       withCounts: false);
@@ -25,6 +30,14 @@ Future<void> loadValues(INyxxWebsocket client) async {
     Snowflake(config["helpChannel"]["id"]),
   );
 
+  releaseChannel = await client.fetchChannel(
+    Snowflake(config["releaseChannel"]["id"]),
+  );
+
+  releaseAlertChannel = await client.fetchChannel(
+    Snowflake(config["releaseAlertChannel"]["id"]),
+  );
+
   closedTagID = Snowflake(config["helpChannel"]["closedTag"]);
   openedTagID = Snowflake(config["helpChannel"]["openedTag"]);