Make no capacity logs less verbose and have capacity configurable via…

… env var

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "zumble"
-version = "0.2.1"
+version = "0.3.0"
 edition = "2021"
 
 [dependencies]
@@ -34,6 +34,7 @@ tokio-rustls = "0.23.4"
 tracing = "0.1.37"
 tracing-subscriber = "0.3.16"
 prometheus = { version = "0.13.3", features = ["process"] }
+konst = "0.3.8"
 
 [profile.release]
 codegen-units = 1

charts/zumble/Chart.yaml

@@ -1,5 +1,5 @@
 apiVersion: v2
 name: zumble
 type: application
-version: 1.1.0
-appVersion: v0.1.3
+version: 1.2.0
+appVersion: v0.3.0

charts/zumble/templates/deployment.yaml

@@ -37,6 +37,8 @@ spec:
  env:
  - name: RUST_LOG
  value: {{ .Values.logLevel }}
+ - name: CLIENT_CAPACITY
+ value: "{{ .Values.config.clientCapacity }}"
  envFrom:
  - secretRef:
  name: {{ include "zumble.fullname" . }}

charts/zumble/values.yaml

@@ -66,3 +66,6 @@ logLevel: info
 api:
  username: admin
  password: changeme
+
+config:
+ clientCapacity: 2048

src/client.rs

@@ -18,6 +18,7 @@ use tokio::net::{TcpStream, UdpSocket};
 use tokio::sync::mpsc::Sender;
 use tokio::time::timeout;
 use tokio_rustls::server::TlsStream;
+use konst::{primitive::parse_usize, result::unwrap_ctx};
 
 pub struct Client {
  pub version: Version,
@@ -71,7 +72,7 @@ impl Client {
  publisher: Sender<ClientMessage>,
  ) -> Self {
  let tokens = authenticate.get_tokens().iter().map(|token| token.to_string()).collect();
- let capacity = 4096;
+ let capacity = unwrap_ctx!(parse_usize(&std::env::var("CLIENT_CAPACITY").unwrap_or("2048".to_string())));
  let mut targets = Vec::with_capacity(capacity);
  targets.resize_with(capacity, Default::default);
 

src/handler/voice_packet.rs

@@ -85,7 +85,7 @@ impl Handler for VoicePacket<Clientbound> {
  match client_read.publisher.try_send(ClientMessage::SendVoicePacket(self.clone())) {
  Ok(_) => {}
  Err(err) => {
- if err.to_string() == "channel closed" {
+ if err.to_string() == "channel closed" || err.to_string() == "no available capacity" {
  tracing::debug!(
  "error sending voice packet message to {}: {}",
  client_read.authenticate.get_username(),

src/state.rs

@@ -176,7 +176,7 @@ impl ServerState {
  }) {
  Ok(_) => {}
  Err(err) => {
- if err.to_string() == "channel closed" {
+ if err.to_string() == "channel closed" || err.to_string() == "no available capacity" {
  tracing::debug!("failed to send message to {}: {}", client_read.authenticate.get_username(), err);
  } else {
  tracing::error!("failed to send message to {}: {}", client_read.authenticate.get_username(), err);