yordis request

Signed-off-by: itsitsiridakis <iosif.tsitsiridakis@fanatics.live>

Author: tsitsiridakisiosif

rsworkspace/crates/acp-nats/src/acp_prefix.rs

@@ -7,9 +7,8 @@
 //! malformed dots (consecutive, leading, trailing). Max 128 bytes. Validity is guaranteed at
 //! construction.
 
-use crate::nats_token_policies::MultiTokenPolicy;
 use crate::subject_token_violation::SubjectTokenViolation;
-use trogon_nats::NatsToken;
+use trogon_nats::DottedNatsToken;
 
 /// Error returned when [`AcpPrefix`] validation fails.
 #[derive(Debug, Clone, PartialEq)]
@@ -33,12 +32,12 @@ impl std::error::Error for AcpPrefixError {}
 
 /// NATS-safe ACP prefix. Guarantees validity at construction—invalid instances are unrepresentable.
 #[derive(Clone, Debug)]
-pub struct AcpPrefix(NatsToken<MultiTokenPolicy>);
+pub struct AcpPrefix(DottedNatsToken);
 
 impl AcpPrefix {
     pub fn new(s: impl Into<String>) -> Result<Self, AcpPrefixError> {
         let s = s.into();
-        NatsToken::new(s).map(Self).map_err(AcpPrefixError)
+        DottedNatsToken::new(s).map(Self).map_err(AcpPrefixError)
     }
 
     pub fn as_str(&self) -> &str {

rsworkspace/crates/acp-nats/src/constants.rs

@@ -19,10 +19,6 @@ pub const SESSION_READY_DELAY: Duration = Duration::from_millis(100);
 pub const PROMPT_TIMEOUT_WARNING_SUPPRESSION_WINDOW: Duration = Duration::from_secs(5);
 pub const TEST_PROMPT_TIMEOUT: Duration = Duration::from_secs(5);
 
-pub const MAX_PREFIX_LENGTH: usize = 128;
-pub const MAX_SESSION_ID_LENGTH: usize = 128;
-pub const MAX_METHOD_NAME_LENGTH: usize = 128;
-
 pub const AGENT_UNAVAILABLE: i32 = -32001;
 
 pub const SESSION_PREFIX: &str = ".session.";

rsworkspace/crates/acp-nats/src/ext_method_name.rs

@@ -5,9 +5,8 @@
 //! rejects `*`, `>`, whitespace; allows dotted namespaces (e.g. `vendor.operation`) but rejects
 //! malformed dots (consecutive, leading, trailing). Validity is guaranteed at construction.
 
-use crate::nats_token_policies::MultiTokenPolicy;
 use crate::subject_token_violation::SubjectTokenViolation;
-use trogon_nats::NatsToken;
+use trogon_nats::DottedNatsToken;
 
 /// Error returned when [`ExtMethodName`] validation fails.
 #[derive(Debug, Clone, PartialEq)]
@@ -33,11 +32,13 @@ impl std::error::Error for ExtMethodNameError {}
 ///
 /// Rejects empty, too-long, wildcard, whitespace, and malformed dotted names.
 #[derive(Clone, Debug, PartialEq, Eq, Hash)]
-pub struct ExtMethodName(NatsToken<MultiTokenPolicy>);
+pub struct ExtMethodName(DottedNatsToken);
 
 impl ExtMethodName {
     pub fn new(method: impl AsRef<str>) -> Result<Self, ExtMethodNameError> {
-        NatsToken::new(method).map(Self).map_err(ExtMethodNameError)
+        DottedNatsToken::new(method)
+            .map(Self)
+            .map_err(ExtMethodNameError)
     }
 
     pub fn as_str(&self) -> &str {

rsworkspace/crates/acp-nats/src/lib.rs

@@ -10,7 +10,6 @@ pub(crate) mod in_flight_slot_guard;
 pub mod jetstream;
 pub(crate) mod jsonrpc;
 pub mod nats;
-pub(crate) mod nats_token_policies;
 pub(crate) mod pending_prompt_waiters;
 pub mod session_id;
 pub mod subject_token_violation;

rsworkspace/crates/acp-nats/src/nats_token_policies.rs

@@ -5,7 +5,6 @@
 //! ASCII only (recommended), rejecting `.` `*` `>` and whitespace (forbidden). Validity is
 //! guaranteed at construction.
 
-use crate::nats_token_policies::SingleTokenPolicy;
 use crate::subject_token_violation::SubjectTokenViolation;
 use trogon_nats::NatsToken;
 
@@ -34,7 +33,7 @@ impl std::error::Error for SessionIdError {}
 /// Follows [NATS subject naming](https://docs.nats.io/nats-concepts/subjects#characters-allowed-and-recommended-for-subject-names):
 /// ASCII only; rejects `.`, `*`, `>`, and whitespace. Max 128 characters.
 #[derive(Clone, Debug, PartialEq, Eq, Hash)]
-pub struct AcpSessionId(NatsToken<SingleTokenPolicy>);
+pub struct AcpSessionId(NatsToken);
 
 impl AcpSessionId {
     pub fn new(s: impl AsRef<str>) -> Result<Self, SessionIdError> {

rsworkspace/crates/acp-nats/src/session_id.rs

@@ -44,7 +44,7 @@ pub mod jetstream;
 pub mod messaging;
 pub mod nats_token;
 pub mod subject_token_violation;
-pub mod token;
+pub(crate) mod token;
 
 #[cfg(feature = "test-support")]
 pub mod mocks;
@@ -59,7 +59,7 @@ pub use messaging::{
     RetryPolicy, build_request_headers, headers_with_trace_context, inject_trace_context, publish,
     request, request_with_timeout,
 };
-pub use nats_token::{NatsToken, NatsTokenPolicy};
+pub use nats_token::{DottedNatsToken, NatsToken};
 pub use subject_token_violation::SubjectTokenViolation;
 
 #[cfg(feature = "test-support")]