Compare commits
6 commits
Author | SHA1 | Date | |
---|---|---|---|
Tobias Reisinger | b827471e6d | ||
Tobias Reisinger | 915c2ccbbf | ||
Tobias Reisinger | 895f5f9373 | ||
Tobias Reisinger | 70e0a1d0b4 | ||
Tobias Reisinger | ea7815535c | ||
Tobias Reisinger | ae411b6dcc |
2
Cargo.lock
generated
2
Cargo.lock
generated
|
@ -182,7 +182,7 @@ dependencies = [
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "teamspeak-query-lib"
|
name = "teamspeak-query-lib"
|
||||||
version = "0.1.2"
|
version = "0.1.5"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"clap",
|
"clap",
|
||||||
"serde",
|
"serde",
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
[package]
|
[package]
|
||||||
name = "teamspeak-query-lib"
|
name = "teamspeak-query-lib"
|
||||||
version = "0.1.2"
|
version = "0.1.5"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
|
|
4
Makefile
4
Makefile
|
@ -2,11 +2,13 @@
|
||||||
|
|
||||||
INSTALL_DIR = $(HOME)/.local/bin
|
INSTALL_DIR = $(HOME)/.local/bin
|
||||||
|
|
||||||
|
export PATH := target/debug:$(PATH)
|
||||||
|
|
||||||
build:
|
build:
|
||||||
@cargo build
|
@cargo build
|
||||||
|
|
||||||
run: build
|
run: build
|
||||||
@PATH=$(PWD)/target/debug:$(PATH) ./ts-control
|
./ts-control
|
||||||
|
|
||||||
install:
|
install:
|
||||||
mkdir -p "$(INSTALL_DIR)"
|
mkdir -p "$(INSTALL_DIR)"
|
||||||
|
|
11
src/cli.rs
11
src/cli.rs
|
@ -1,4 +1,4 @@
|
||||||
use clap::{Args, Parser, Subcommand};
|
use clap::{Args, Parser, Subcommand, ValueEnum};
|
||||||
use telnet::Telnet;
|
use telnet::Telnet;
|
||||||
|
|
||||||
use crate::parameter::ParameterList;
|
use crate::parameter::ParameterList;
|
||||||
|
@ -79,9 +79,18 @@ pub struct UpdateArgs {
|
||||||
speakers: Option<bool>,
|
speakers: Option<bool>,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[derive(Clone, ValueEnum)]
|
||||||
|
pub enum EventArgsFilter {
|
||||||
|
All,
|
||||||
|
Mine,
|
||||||
|
Others,
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Args)]
|
#[derive(Args)]
|
||||||
pub struct EventArgs {
|
pub struct EventArgs {
|
||||||
pub event: Vec<EventType>,
|
pub event: Vec<EventType>,
|
||||||
|
#[arg(long, short)]
|
||||||
|
pub filter: Option<EventArgsFilter>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl FetchArgs {
|
impl FetchArgs {
|
||||||
|
|
|
@ -1,6 +1,8 @@
|
||||||
use telnet::Telnet;
|
use telnet::Telnet;
|
||||||
use crate::commands;
|
|
||||||
use crate::models::{Event, EventType};
|
use crate::{commands, wrappers};
|
||||||
|
use crate::cli::EventArgsFilter;
|
||||||
|
use crate::models::{Client, Event, EventType};
|
||||||
use crate::response::Response;
|
use crate::response::Response;
|
||||||
|
|
||||||
pub fn register_events(connection: &mut Telnet, events: Vec<EventType>) -> Result<(), String> {
|
pub fn register_events(connection: &mut Telnet, events: Vec<EventType>) -> Result<(), String> {
|
||||||
|
@ -12,10 +14,7 @@ pub fn register_events(connection: &mut Telnet, events: Vec<EventType>) -> Resul
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn handle_event_response(connection: &mut Telnet, response: Response) {
|
pub fn handle_event_response(connection: &mut Telnet, event: Event, known_clients: &mut Vec<Client>) {
|
||||||
if let Response::Event(event_type, params) = response {
|
|
||||||
|
|
||||||
let event = Event::new(connection, event_type, params);
|
|
||||||
match serde_json::to_string(&event) {
|
match serde_json::to_string(&event) {
|
||||||
Ok(json) => println!("{}", json),
|
Ok(json) => println!("{}", json),
|
||||||
Err(err) => {
|
Err(err) => {
|
||||||
|
@ -24,13 +23,40 @@ pub fn handle_event_response(connection: &mut Telnet, response: Response) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if let Ok(new_clients) = wrappers::get_clients(connection) {
|
||||||
|
*known_clients = new_clients;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn loop_response_reader(connection: &mut Telnet) {
|
fn try_get_self_clid(connection: &mut Telnet) -> Option<i32> {
|
||||||
|
wrappers::get_self_clid(connection)
|
||||||
|
.unwrap_or_default()
|
||||||
|
.parse()
|
||||||
|
.map(Some)
|
||||||
|
.unwrap_or(None)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn loop_response_reader(connection: &mut Telnet, filter: &EventArgsFilter) {
|
||||||
|
let mut known_clients = wrappers::get_clients(connection).unwrap_or_else(|_| Vec::new());
|
||||||
|
|
||||||
|
let mut self_clid: Option<i32> = try_get_self_clid(connection);
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
match commands::read_response(connection, true, String::new()) {
|
match commands::read_response(connection, true, String::new()) {
|
||||||
Ok(response) => handle_event_response(connection, response),
|
Ok(response) => {
|
||||||
|
if let Response::Event(event_type, params) = response {
|
||||||
|
let event = Event::new(connection, event_type, params, &known_clients);
|
||||||
|
|
||||||
|
if self_clid.is_none() {
|
||||||
|
self_clid = try_get_self_clid(connection);
|
||||||
|
}
|
||||||
|
if !event.should_handle(filter, self_clid) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
handle_event_response(connection, event, &mut known_clients);
|
||||||
|
}
|
||||||
|
}
|
||||||
Err(_) => {
|
Err(_) => {
|
||||||
// print error?
|
// print error?
|
||||||
return;
|
return;
|
||||||
|
|
28
src/main.rs
28
src/main.rs
|
@ -2,9 +2,7 @@ use std::io::{Error, ErrorKind};
|
||||||
|
|
||||||
use telnet::Telnet;
|
use telnet::Telnet;
|
||||||
|
|
||||||
use crate::cli::Commands;
|
use crate::cli::{Commands, EventArgsFilter};
|
||||||
use crate::models::Channel;
|
|
||||||
use crate::models::Client;
|
|
||||||
|
|
||||||
mod wrappers;
|
mod wrappers;
|
||||||
mod commands;
|
mod commands;
|
||||||
|
@ -15,14 +13,10 @@ mod models;
|
||||||
mod response;
|
mod response;
|
||||||
mod command_utils;
|
mod command_utils;
|
||||||
|
|
||||||
fn channel_or_error(channel_res: Result<Option<Channel>, String>) -> Result<Channel, Error> {
|
fn result_or_error<T>(res: Result<Option<T>, String>, result_type: &str) -> Result<T, Error> {
|
||||||
channel_res.map_err(|err| make_action_error("find channel", err))?
|
let error_action = format!("find {}", result_type);
|
||||||
.ok_or_else(|| make_action_error("find channel", String::from("Not Found.")))
|
res.map_err(|err| make_action_error(&error_action, err))?
|
||||||
}
|
.ok_or_else(|| make_action_error(&error_action, String::from("Not Found.")))
|
||||||
|
|
||||||
fn client_or_error(client_res: Result<Option<Client>, String>) -> Result<Client, Error> {
|
|
||||||
client_res.map_err(|err| make_action_error("find client", err))?
|
|
||||||
.ok_or_else(|| make_action_error("find client", String::from("Not Found.")))
|
|
||||||
}
|
}
|
||||||
|
|
||||||
fn connect() -> Result<Telnet, Error> {
|
fn connect() -> Result<Telnet, Error> {
|
||||||
|
@ -88,7 +82,7 @@ fn main() -> Result<(), Error> {
|
||||||
}
|
}
|
||||||
|
|
||||||
if args.want_client() {
|
if args.want_client() {
|
||||||
let client = client_or_error(args.client(&mut connection))?;
|
let client = result_or_error(args.client(&mut connection), "client")?;
|
||||||
|
|
||||||
match wrappers::fetch_client(&mut connection, &[client]) {
|
match wrappers::fetch_client(&mut connection, &[client]) {
|
||||||
Ok(_) => println!("Successfully fetched client."),
|
Ok(_) => println!("Successfully fetched client."),
|
||||||
|
@ -99,7 +93,7 @@ fn main() -> Result<(), Error> {
|
||||||
}
|
}
|
||||||
|
|
||||||
if args.want_channel() {
|
if args.want_channel() {
|
||||||
let channel = channel_or_error(args.channel(&mut connection))?;
|
let channel = result_or_error(args.channel(&mut connection), "channel")?;
|
||||||
|
|
||||||
match wrappers::fetch_channel(&mut connection, channel) {
|
match wrappers::fetch_channel(&mut connection, channel) {
|
||||||
Ok(_) => println!("Successfully fetched channel."),
|
Ok(_) => println!("Successfully fetched channel."),
|
||||||
|
@ -123,8 +117,8 @@ fn main() -> Result<(), Error> {
|
||||||
}
|
}
|
||||||
|
|
||||||
Commands::Move(args) => {
|
Commands::Move(args) => {
|
||||||
let channel = channel_or_error(args.channel(&mut connection))?;
|
let channel = result_or_error(args.channel(&mut connection), "channel")?;
|
||||||
let client = client_or_error(args.client(&mut connection))?;
|
let client = result_or_error(args.client(&mut connection), "client")?;
|
||||||
|
|
||||||
match wrappers::move_client(&mut connection, &channel, &[client]) {
|
match wrappers::move_client(&mut connection, &channel, &[client]) {
|
||||||
Ok(resp) => println!("Successfully moved client: {}", resp),
|
Ok(resp) => println!("Successfully moved client: {}", resp),
|
||||||
|
@ -144,10 +138,12 @@ fn main() -> Result<(), Error> {
|
||||||
}
|
}
|
||||||
|
|
||||||
Commands::Events(args) => {
|
Commands::Events(args) => {
|
||||||
|
let filter = args.filter.unwrap_or(EventArgsFilter::All);
|
||||||
loop {
|
loop {
|
||||||
command_utils::events::register_events(&mut connection, args.event.clone())
|
command_utils::events::register_events(&mut connection, args.event.clone())
|
||||||
.map_err(to_other_error)?;
|
.map_err(to_other_error)?;
|
||||||
command_utils::events::loop_response_reader(&mut connection);
|
|
||||||
|
command_utils::events::loop_response_reader(&mut connection, &filter);
|
||||||
|
|
||||||
// loop_response_reader failed. Let's try to reconnect after 1 second.
|
// loop_response_reader failed. Let's try to reconnect after 1 second.
|
||||||
std::thread::sleep(std::time::Duration::from_secs(1));
|
std::thread::sleep(std::time::Duration::from_secs(1));
|
||||||
|
|
|
@ -3,7 +3,7 @@ use serde::{Deserialize, Serialize};
|
||||||
|
|
||||||
use crate::parameter::{parameter_find, ParameterList};
|
use crate::parameter::{parameter_find, ParameterList};
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug)]
|
#[derive(Serialize, Deserialize, Clone, Debug)]
|
||||||
pub struct Client {
|
pub struct Client {
|
||||||
pub cid: i32,
|
pub cid: i32,
|
||||||
pub clid: i32,
|
pub clid: i32,
|
||||||
|
|
|
@ -1,8 +1,10 @@
|
||||||
use std::fmt::{Display, Formatter};
|
use std::fmt::{Display, Formatter};
|
||||||
use std::str::FromStr;
|
use std::str::FromStr;
|
||||||
|
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize, Serializer};
|
||||||
|
use serde::ser::SerializeStruct;
|
||||||
use telnet::Telnet;
|
use telnet::Telnet;
|
||||||
|
use crate::cli::EventArgsFilter;
|
||||||
|
|
||||||
use crate::models::{Channel, Client};
|
use crate::models::{Channel, Client};
|
||||||
use crate::parameter::{parameter_find, ParameterList};
|
use crate::parameter::{parameter_find, ParameterList};
|
||||||
|
@ -43,7 +45,7 @@ pub enum EventType {
|
||||||
NotifyConnectStatusChange,
|
NotifyConnectStatusChange,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug)]
|
#[derive(Debug)]
|
||||||
pub struct Event {
|
pub struct Event {
|
||||||
pub event_type: EventType,
|
pub event_type: EventType,
|
||||||
pub params: ParameterList,
|
pub params: ParameterList,
|
||||||
|
@ -152,36 +154,58 @@ impl Display for EventType {
|
||||||
}
|
}
|
||||||
|
|
||||||
impl EventType {
|
impl EventType {
|
||||||
|
|
||||||
|
pub fn find_channel(&self, connection: &mut Telnet, params: &ParameterList, param_name: &str) -> Option<Channel> {
|
||||||
|
let id = parameter_find(params, param_name)?
|
||||||
|
.parse::<i32>().unwrap_or(0);
|
||||||
|
wrappers::find_channel(connection, "cid", &id.to_string(), true).unwrap().or(None)
|
||||||
|
}
|
||||||
pub fn get_channel(&self, connection: &mut Telnet, params: &ParameterList) -> Option<Channel> {
|
pub fn get_channel(&self, connection: &mut Telnet, params: &ParameterList) -> Option<Channel> {
|
||||||
match self {
|
match self {
|
||||||
EventType::NotifyClientMoved => {
|
EventType::NotifyClientMoved => {
|
||||||
let id = parameter_find(params, "ctid")?
|
self.find_channel(connection, params, "ctid")
|
||||||
.parse::<i32>().unwrap_or(0);
|
|
||||||
wrappers::find_channel(connection, "cid", &id.to_string(), true).unwrap().or(None)
|
|
||||||
}
|
}
|
||||||
_ => None,
|
_ => None,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn get_client(&self, connection: &mut Telnet, params: &ParameterList) -> Option<Client> {
|
pub fn find_client(&self, connection: &mut Telnet, params: &ParameterList, param_name: &str) -> Option<Client> {
|
||||||
match self {
|
let id = parameter_find(params, param_name)?
|
||||||
EventType::NotifyClientMoved => {
|
|
||||||
let id = parameter_find(params, "clid")?
|
|
||||||
.parse::<i32>().unwrap_or(0);
|
.parse::<i32>().unwrap_or(0);
|
||||||
wrappers::find_client(connection, "clid", &id.to_string(), true).unwrap().or(None)
|
wrappers::find_client(connection, "clid", &id.to_string(), true).unwrap().or(None)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub fn get_client(&self, connection: &mut Telnet, params: &ParameterList) -> Option<Client> {
|
||||||
|
match self {
|
||||||
|
EventType::NotifyClientMoved => {
|
||||||
|
self.find_client(connection, params, "clid")
|
||||||
|
}
|
||||||
EventType::NotifyClientEnterView => {
|
EventType::NotifyClientEnterView => {
|
||||||
Some(Client::from(params.clone()))
|
Some(Client::from(params.clone()))
|
||||||
}
|
}
|
||||||
|
EventType::NotifyTextMessage => {
|
||||||
|
self.find_client(connection, params, "invokerid")
|
||||||
|
}
|
||||||
|
EventType::NotifyClientPoke => {
|
||||||
|
self.find_client(connection, params, "invokerid")
|
||||||
|
}
|
||||||
_ => None,
|
_ => None,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
impl Event {
|
impl Event {
|
||||||
pub fn new(connection: &mut Telnet, event_type: EventType, params: ParameterList) -> Event {
|
pub fn new(connection: &mut Telnet, event_type: EventType, params: ParameterList, known_clients: &[Client]) -> Event {
|
||||||
let channel = event_type.get_channel(connection, ¶ms);
|
let channel = event_type.get_channel(connection, ¶ms);
|
||||||
let client = event_type.get_client(connection, ¶ms);
|
let mut client = event_type.get_client(connection, ¶ms);
|
||||||
|
|
||||||
|
if client.is_none() {
|
||||||
|
let id = parameter_find(¶ms, "clid")
|
||||||
|
.unwrap_or_else(|| String::from("0"))
|
||||||
|
.parse::<i32>().unwrap_or(0);
|
||||||
|
let client_id = id.to_string();
|
||||||
|
client = known_clients.iter().find(|c| c.clid.to_string() == client_id).cloned();
|
||||||
|
}
|
||||||
|
|
||||||
Event {
|
Event {
|
||||||
event_type,
|
event_type,
|
||||||
|
@ -190,4 +214,88 @@ impl Event {
|
||||||
client,
|
client,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub fn get_client_name(&self) -> String {
|
||||||
|
match &self.client {
|
||||||
|
Some(client) => client.client_nickname.clone(),
|
||||||
|
None => String::from("UNKNOWN"),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn get_channel_name(&self) -> String {
|
||||||
|
match &self.channel {
|
||||||
|
Some(channel) => channel.channel_name.clone(),
|
||||||
|
None => String::from("UNKNOWN"),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn get_event_msg(&self) -> String {
|
||||||
|
parameter_find(&self.params, "msg").unwrap_or_else(|| String::from(""))
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn get_message(&self) -> String {
|
||||||
|
match &self.event_type {
|
||||||
|
EventType::NotifyClientPoke => {
|
||||||
|
format!("{}: {}",
|
||||||
|
self.get_client_name(),
|
||||||
|
self.get_event_msg()
|
||||||
|
)
|
||||||
|
}
|
||||||
|
EventType::NotifyTextMessage => {
|
||||||
|
format!("{}: {}",
|
||||||
|
self.get_client_name(),
|
||||||
|
self.get_event_msg()
|
||||||
|
)
|
||||||
|
}
|
||||||
|
EventType::NotifyClientMoved => {
|
||||||
|
format!("{} joined {}",
|
||||||
|
self.get_client_name(),
|
||||||
|
self.get_channel_name()
|
||||||
|
)
|
||||||
|
}
|
||||||
|
EventType::NotifyClientLeftView => {
|
||||||
|
format!("{} left",
|
||||||
|
self.get_client_name()
|
||||||
|
)
|
||||||
|
}
|
||||||
|
EventType::NotifyClientEnterView => {
|
||||||
|
format!("{} connected",
|
||||||
|
self.get_client_name()
|
||||||
|
)
|
||||||
|
}
|
||||||
|
_ => String::from(""),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn is_mine(&self, self_clid: Option<i32>) -> bool {
|
||||||
|
if let Some(self_clid) = self_clid {
|
||||||
|
if let Some(client) = &self.client {
|
||||||
|
return client.clid == self_clid;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
false
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn should_handle(&self, filter: &EventArgsFilter, self_clid: Option<i32>) -> bool {
|
||||||
|
match filter {
|
||||||
|
EventArgsFilter::All => true,
|
||||||
|
EventArgsFilter::Mine => self.is_mine(self_clid),
|
||||||
|
EventArgsFilter::Others => !self.is_mine(self_clid),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl Serialize for Event {
|
||||||
|
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
|
||||||
|
where
|
||||||
|
S: Serializer,
|
||||||
|
{
|
||||||
|
let mut x = serializer.serialize_struct("Event", 4)?;
|
||||||
|
x.serialize_field("type", &self.event_type)?;
|
||||||
|
x.serialize_field("channel", &self.channel)?;
|
||||||
|
x.serialize_field("client", &self.client)?;
|
||||||
|
x.serialize_field("params", &self.params)?;
|
||||||
|
x.serialize_field("message", &self.get_message())?;
|
||||||
|
x.end()
|
||||||
|
}
|
||||||
}
|
}
|
|
@ -5,7 +5,7 @@ pub type ParameterList = HashMap<String, String>;
|
||||||
pub type Parameter = (String, String);
|
pub type Parameter = (String, String);
|
||||||
|
|
||||||
pub fn parameter_find(params: &ParameterList, name: &str) -> Option<String> {
|
pub fn parameter_find(params: &ParameterList, name: &str) -> Option<String> {
|
||||||
params.get(name).map(|value| value.clone())
|
params.get(name).cloned()
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn parameter_list_has(params: &ParameterList, key: &str, value: &str, strict: bool) -> bool {
|
pub fn parameter_list_has(params: &ParameterList, key: &str, value: &str, strict: bool) -> bool {
|
||||||
|
@ -17,7 +17,7 @@ pub fn parameter_list_has(params: &ParameterList, key: &str, value: &str, strict
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return false;
|
false
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn parameter_list_find(param_lists: &Vec<ParameterList>, key: &str, value: &str, strict: bool) -> Option<ParameterList> {
|
pub fn parameter_list_find(param_lists: &Vec<ParameterList>, key: &str, value: &str, strict: bool) -> Option<ParameterList> {
|
||||||
|
@ -44,7 +44,7 @@ pub fn parameter_parse(params_str: &str) -> ParameterList {
|
||||||
|
|
||||||
let mut response_params = ParameterList::new();
|
let mut response_params = ParameterList::new();
|
||||||
parts.iter().for_each(|part| {
|
parts.iter().for_each(|part| {
|
||||||
let (key, value) = part.split_once('=').unwrap_or((part, "1"));
|
let (key, value) = part.split_once('=').unwrap_or((part, ""));
|
||||||
response_params.insert(key.to_string(), decode_value(value));
|
response_params.insert(key.to_string(), decode_value(value));
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -58,7 +58,7 @@ pub fn parameter_to_string(param: Parameter) -> String {
|
||||||
pub fn parameter_list_to_string(parameter_list: ParameterList, sep: &str) -> String {
|
pub fn parameter_list_to_string(parameter_list: ParameterList, sep: &str) -> String {
|
||||||
parameter_list
|
parameter_list
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.map(|param| parameter_to_string(param))
|
.map(parameter_to_string)
|
||||||
.collect::<Vec<String>>()
|
.collect::<Vec<String>>()
|
||||||
.join(sep)
|
.join(sep)
|
||||||
}
|
}
|
||||||
|
@ -66,7 +66,7 @@ pub fn parameter_list_to_string(parameter_list: ParameterList, sep: &str) -> Str
|
||||||
pub fn parameters_to_string(parameters: Vec<Parameter>, sep: &str) -> String {
|
pub fn parameters_to_string(parameters: Vec<Parameter>, sep: &str) -> String {
|
||||||
parameters
|
parameters
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.map(|param| parameter_to_string(param))
|
.map(parameter_to_string)
|
||||||
.collect::<Vec<String>>()
|
.collect::<Vec<String>>()
|
||||||
.join(sep)
|
.join(sep)
|
||||||
}
|
}
|
|
@ -45,7 +45,7 @@ fn get_response_type(type_str: &str) -> Result<ResponseType, String> {
|
||||||
return Ok(ResponseType::Event(event_type));
|
return Ok(ResponseType::Event(event_type));
|
||||||
}
|
}
|
||||||
|
|
||||||
return Ok(ResponseType::Unknown);
|
Ok(ResponseType::Unknown)
|
||||||
}
|
}
|
||||||
|
|
||||||
impl TryFrom<String> for Response {
|
impl TryFrom<String> for Response {
|
||||||
|
@ -54,7 +54,7 @@ impl TryFrom<String> for Response {
|
||||||
fn try_from(response_str: String) -> Result<Self, ResponseError> {
|
fn try_from(response_str: String) -> Result<Self, ResponseError> {
|
||||||
let response_str = response_str.trim_end_matches("\n\r");
|
let response_str = response_str.trim_end_matches("\n\r");
|
||||||
|
|
||||||
let (rsp_type, rsp_params) = split_type_and_params(&response_str)
|
let (rsp_type, rsp_params) = split_type_and_params(response_str)
|
||||||
.map_err(|err| ResponseError {
|
.map_err(|err| ResponseError {
|
||||||
id: -1,
|
id: -1,
|
||||||
msg: err,
|
msg: err,
|
||||||
|
@ -66,7 +66,7 @@ impl TryFrom<String> for Response {
|
||||||
parameter_lists.push(response_params);
|
parameter_lists.push(response_params);
|
||||||
}
|
}
|
||||||
|
|
||||||
return match rsp_type {
|
match rsp_type {
|
||||||
ResponseType::Error => {
|
ResponseType::Error => {
|
||||||
Err(ResponseError::create_error(¶meter_lists[0]))
|
Err(ResponseError::create_error(¶meter_lists[0]))
|
||||||
}
|
}
|
||||||
|
|
|
@ -110,7 +110,7 @@ pub fn get_channel_clients(connection: &mut Telnet, channel: &Channel) -> Result
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn get_self_clid(connection: &mut Telnet) -> Result<String, String> {
|
pub fn get_self_clid(connection: &mut Telnet) -> Result<String, String> {
|
||||||
match commands::whoami(connection)? {
|
match commands::whoami(connection)? {
|
||||||
Response::Data(params) => {
|
Response::Data(params) => {
|
||||||
match parameter::parameter_find(¶ms, "clid") {
|
match parameter::parameter_find(¶ms, "clid") {
|
||||||
|
|
51
ts-control
51
ts-control
|
@ -9,7 +9,8 @@ not away
|
||||||
back
|
back
|
||||||
message
|
message
|
||||||
message-user
|
message-user
|
||||||
events-move"
|
events
|
||||||
|
ntfy-events"
|
||||||
|
|
||||||
_ts_control_get_entity() {
|
_ts_control_get_entity() {
|
||||||
entity=$(_ts_control_single_or_dmenu "$(teamspeak-query-lib "$1s")" "$2")
|
entity=$(_ts_control_single_or_dmenu "$(teamspeak-query-lib "$1s")" "$2")
|
||||||
|
@ -54,6 +55,41 @@ _ts_control_single_or_dmenu() {
|
||||||
fi
|
fi
|
||||||
}
|
}
|
||||||
|
|
||||||
|
handle_ntfy_events() {
|
||||||
|
while read -r data; do
|
||||||
|
msg=$(echo "$data" | jq -r --unbuffered '.message')
|
||||||
|
type=$(echo "$data" | jq -r --unbuffered '.type')
|
||||||
|
mode=$(echo "$data" | jq -r --unbuffered '.params.targetmode')
|
||||||
|
|
||||||
|
echo "$data"
|
||||||
|
|
||||||
|
if [ "$type" = "NotifyTextMessage" ] && [ "$mode" != "1" ]; then
|
||||||
|
continue # Skip all messages that are not direct messages
|
||||||
|
fi
|
||||||
|
|
||||||
|
friendly_type="Event"
|
||||||
|
case $type in
|
||||||
|
"NotifyClientPoke")
|
||||||
|
friendly_type="Poke"
|
||||||
|
;;
|
||||||
|
"NotifyTextMessage")
|
||||||
|
friendly_type="Message"
|
||||||
|
;;
|
||||||
|
esac
|
||||||
|
|
||||||
|
echo "($friendly_type) $target: $msg"
|
||||||
|
|
||||||
|
curl -sSL \
|
||||||
|
-H "Authorization: Bearer $TS3_NTFY_TOKEN" \
|
||||||
|
-d "{
|
||||||
|
\"topic\": \"$TS3_NTFY_TOPIC\",
|
||||||
|
\"message\": \"$msg\",
|
||||||
|
\"title\": \"TS3 $friendly_type\"
|
||||||
|
}" \
|
||||||
|
"$TS3_NTFY_HOST"
|
||||||
|
done
|
||||||
|
}
|
||||||
|
|
||||||
# Add '$' to $1 to add 'End of line' to the regex for grep
|
# Add '$' to $1 to add 'End of line' to the regex for grep
|
||||||
action=$(_ts_control_single_or_dmenu "$actions" "$1$")
|
action=$(_ts_control_single_or_dmenu "$actions" "$1$")
|
||||||
|
|
||||||
|
@ -98,8 +134,13 @@ case $action in
|
||||||
message=$(_ts_control_get_message "$3")
|
message=$(_ts_control_get_message "$3")
|
||||||
teamspeak-query-lib message --strict-client --client "$user" "$message"
|
teamspeak-query-lib message --strict-client --client "$user" "$message"
|
||||||
;;
|
;;
|
||||||
"events-move")
|
"events")
|
||||||
teamspeak-query-lib events NotifyClientMoved NotifyClientEnterView \
|
teamspeak-query-lib events --filter=others NotifyClientMoved NotifyClientEnterView NotifyClientLeftView NotifyTextMessage NotifyClientPoke \
|
||||||
| jq -r --unbuffered '.client.client_nickname + " joined " + .channel.channel_name // "the server"' \
|
| jq -r --unbuffered '.message' \
|
||||||
| tee >(xargs -I{} notify-send "TS3 movement" "{}")
|
| tee >(xargs -I{} notify-send "TS3 Event" "{}")
|
||||||
|
;;
|
||||||
|
"ntfy-events")
|
||||||
|
teamspeak-query-lib events --filter=others NotifyClientPoke NotifyTextMessage \
|
||||||
|
| handle_ntfy_events
|
||||||
|
;;
|
||||||
esac
|
esac
|
||||||
|
|
Loading…
Reference in a new issue