add concurrency (#256)

Author: tim-smart

packages/discord-bot/src/Notifications.ts

@@ -2,7 +2,7 @@ import { DiscordGatewayLayer } from "@chat/discord/DiscordGateway"
 import assert from "assert"
 import { Discord, DiscordREST, Ix, UI } from "dfx"
 import { InteractionsRegistry } from "dfx/gateway"
-import { Array, Effect, Layer } from "effect"
+import { Array, Effect, FiberSet, Layer } from "effect"
 import { RolesCache } from "./RolesCache.ts"
 
 export const NotificationsLayer = Effect.gen(function*() {
@@ -76,27 +76,35 @@ export const NotificationsLayer = Effect.gen(function*() {
       const roles = yield* notificationRoles(ix.guild_id!)
 
       const userRoles = new Set(ix.member?.roles ?? [])
+      const fibers = yield* FiberSet.make()
       for (const role of roles) {
         const currentlyHas = userRoles.has(role.id)
         const shouldHave = data.values.includes(role.id)
         if (currentlyHas === shouldHave) {
           continue
         } else if (shouldHave) {
           userRoles.add(role.id)
-          yield* rest.addGuildMemberRole(
-            ix.guild_id!,
-            ix.member!.user.id,
-            role.id
+          yield* FiberSet.run(
+            fibers,
+            rest.addGuildMemberRole(
+              ix.guild_id!,
+              ix.member!.user.id,
+              role.id
+            )
           )
         } else {
           userRoles.delete(role.id)
-          yield* rest.deleteGuildMemberRole(
-            ix.guild_id!,
-            ix.member!.user.id,
-            role.id
+          yield* FiberSet.run(
+            fibers,
+            rest.deleteGuildMemberRole(
+              ix.guild_id!,
+              ix.member!.user.id,
+              role.id
+            )
           )
         }
       }
+      yield* FiberSet.awaitEmpty(fibers)
       return Ix.response({
         type: Discord.InteractionCallbackTypes.UPDATE_MESSAGE,
         data: yield* message(ix, Array.fromIterable(userRoles))