discord-bot/src/bin/update_committee.rs

use serenity::{
  all::{ChunkGuildFilter, GuildId, GuildMembersChunkEvent},
  async_trait,
  client::{Context, EventHandler},
  model::gateway::GatewayIntents,
  Client,
};
use skynet_discord_bot::{
  common::{
    database::{db_init, DataBase},
    set_roles::committee,
  },
  get_config, Config,
};
use std::{process, sync::Arc};
use tokio::sync::RwLock;

#[tokio::main]
async fn main() {
  let config = get_config();
  let db = match db_init(&config).await {
    Ok(x) => x,
    Err(_) => return,
  };

  // Intents are a bitflag, bitwise operations can be used to dictate which intents to use
  let intents = GatewayIntents::GUILDS | GatewayIntents::GUILD_MESSAGES | GatewayIntents::MESSAGE_CONTENT | GatewayIntents::GUILD_MEMBERS;
  // Build our client.
  let mut client = Client::builder(&config.discord_token, intents)
    .event_handler(Handler {})
    .cache_settings(serenity::cache::Settings::default())
    .await
    .expect("Error creating client");

  {
    let mut data = client.data.write().await;

    data.insert::<Config>(Arc::new(RwLock::new(config)));
    data.insert::<DataBase>(Arc::new(RwLock::new(db)));
  }

  if let Err(why) = client.start().await {
    println!("Client error: {why:?}");
  }
}

struct Handler;
#[async_trait]
impl EventHandler for Handler {
  async fn cache_ready(&self, ctx: Context, guilds: Vec<GuildId>) {
    for guild in guilds {
      ctx.shard.chunk_guild(guild, Some(2000), false, ChunkGuildFilter::None, None);
    }
    println!("Cache built successfully!");
  }

  async fn guild_members_chunk(&self, ctx: Context, chunk: GuildMembersChunkEvent) {
    if (chunk.chunk_index + 1) == chunk.chunk_count {
      // u[date committee server
      committee::check_committee(&ctx).await;

      // finish up
      process::exit(0);
    }
  }
}