nostr/gossip
1
0
Fork 0
mirror of https://github.com/mikedilger/gossip.git synced 2024-09-29 00:11:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

command: reaction_stats

Browse Source
This commit is contained in:
Mike Dilger 2024-08-06 10:44:22 +12:00
parent 465d4099c3
commit ff008e0143
1 changed files with 28 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
gossip-bin/src/commands.rs
View File

@ -25,7 +25,7 @@ impl Command {
}
}
const COMMANDS: [Command; 37] = [
const COMMANDS: [Command; 38] = [
Command {
cmd: "oneshot",
usage_params: "{depends}",
@ -171,6 +171,11 @@ const COMMANDS: [Command; 37] = [
usage_params: "",
desc: "Use much faster disk access. A crash can corrupt your local data, unless your filesystem preserves write ordering",
},
Command {
cmd: "reaction_stats",
usage_params: "",
desc: "Show statistics on reactions",
},
Command {
cmd: "rebuild_indices",
usage_params: "",
@ -210,7 +215,7 @@ const COMMANDS: [Command; 37] = [
cmd: "wgpu_renderer",
usage_params: "true | false",
desc: "Enable/Disable the WGPU rendering backend",
}
},
];
pub fn handle_command(mut args: env::Args, runtime: &Runtime) -> Result<bool, Error> {
@ -264,6 +269,7 @@ pub fn handle_command(mut args: env::Args, runtime: &Runtime) -> Result<bool, Er
"print_relays" => print_relays(command)?,
"print_seen_on" => print_seen_on(command, args)?,
"rapid" => {} // is handled early in main.rs
"reaction_stats" => reaction_stats(command, args)?,
"rebuild_indices" => rebuild_indices()?,
"rename_person_list" => rename_person_list(command, args)?,
"reprocess_recent" => reprocess_recent(command, runtime)?,
@ -914,6 +920,26 @@ pub fn giftwraps(_cmd: Command) -> Result<(), Error> {
Ok(())
}
pub fn reaction_stats(_cmd: Command, mut _args: env::Args) -> Result<(), Error> {
use std::collections::HashMap;
let mut reactions: HashMap<String, usize> = HashMap::new();
let mut filter = Filter::new();
filter.add_event_kind(EventKind::Reaction);
let events = GLOBALS.storage.find_events_by_filter(&filter, |_| true)?;
for event in events {
reactions
.entry(event.content.clone())
.and_modify(|count| *count += 1)
.or_insert(1);
}
let mut reactions: Vec<(String, usize)> = reactions.drain().collect();
reactions.sort_by(|a, b| b.1.cmp(&a.1));
for (reaction, count) in reactions {
println!("{} {}", count, reaction);
}
Ok(())
}
pub fn reprocess_recent(_cmd: Command, runtime: &Runtime) -> Result<(), Error> {
login()?;