1use std::collections::HashMap;
30use std::error::Error;
31use std::sync::Arc;
32
33use futures::stream::{self, StreamExt};
34use log::{debug, info, trace, warn};
35use tokio::net::TcpStream;
36use tokio::sync::Semaphore;
37use tokio::time::{timeout, Duration};
38
39use dcerpc::rrp::{RegistryClient, RegistrySession};
40use dcerpc::srvsvc::SrvsvcClient;
41use dcerpc::wkssvc::{WkstaUser, WkstaUserClient};
42use smb2_client::SmbClient;
43use crate::transport::smb::{connect_ipc, open_rpc_pipe, smb_user, SmbAuth};
44
45use crate::args::{CollectionMethod, Options};
46use crate::objects::common::UserComputerSession;
47use crate::objects::computer::Computer;
48use crate::objects::user::User;
49
50const DEFAULT_CONCURRENCY: usize = 10; const DEFAULT_PORT_TIMEOUT_MS: u64 = 1_500; const DEFAULT_HOST_TIMEOUT_MS: u64 = 8_000; const DEFAULT_EXPIRY_DAYS: i64 = 60; struct SmbSession { user: String, _client: String }
60
61struct HostFindings {
62 computer_sid: String,
63 smb_sessions: Vec<SmbSession>, logged_on: Vec<WkstaUser>, registry: Vec<RegistrySession>, errors: Vec<String>,
67}
68
69pub async fn run(
71 args: &Options,
72 users: &[User], computers: &mut Vec<Computer>,
74) -> Result<(), Box<dyn Error>> {
75 if !args.collection_method.does_sessions() {
77 debug!("[sessions] collection method does not contact hosts - skipping");
78 return Ok(());
79 }
80
81 let sid_index = build_sid_index(users);
83
84 let expiry_days = DEFAULT_EXPIRY_DAYS;
87 let targets: Vec<(String, String)> = computers
88 .iter()
89 .filter(|c| is_active(c, expiry_days))
90 .map(|c| (c.properties().name().clone(), c.object_identifier().clone()))
91 .collect();
92
93 info!("[sessions] {} active target(s) after expiry/enabled filter", targets.len());
94
95 let sem = Arc::new(Semaphore::new(DEFAULT_CONCURRENCY));
97 let domain = args.domain.clone();
98 let user = smb_user(args.username.as_deref().unwrap_or_default());
99 let password = args.password.clone().unwrap_or_default();
100 let nt_hash = parse_hash(args.hashes.as_deref()); let method = args.collection_method.clone();
102
103 let kerberos_ccache: Option<String> = if args.kerberos {
105 std::env::var("KRB5CCNAME").ok()
106 } else {
107 None
108 };
109 let kdc: String = args
111 .ldapfqdn
112 .clone()
113 .filter(|s| !s.is_empty())
114 .or_else(|| args.ip.clone())
115 .unwrap_or_else(|| args.domain.clone());
116
117 let findings: Vec<HostFindings> = stream::iter(targets)
118 .map(|(host, computer_sid)| {
119 let (sem, domain, user, password, method) =
120 (sem.clone(), domain.clone(), user.clone(), password.clone(), method.clone());
121 let nt_hash = nt_hash;
122 let kerberos_ccache = kerberos_ccache.clone();
123 let kdc = kdc.clone();
124 async move {
125 let _permit = sem.acquire().await.unwrap();
126 enumerate_host(
127 &host, computer_sid, &domain, &user, &password,
128 nt_hash.as_ref(), kerberos_ccache.as_deref(), &kdc, &method,
129 ).await
130 }
131 })
132 .buffer_unordered(DEFAULT_CONCURRENCY)
133 .collect()
134 .await;
135
136 let mut total_sessions = 0usize;
138 for hf in &findings {
139 total_sessions += apply_findings(computers, hf, &sid_index, &args.domain);
140 for e in &hf.errors { warn!("{e}"); }
141 }
142 info!("[sessions] {total_sessions} session(s) enumerated in total across {} host(s)",
143 findings.len());
144
145 Ok(())
146}
147
148#[allow(clippy::too_many_arguments)]
150async fn enumerate_host(
151 host: &str, computer_sid: String,
152 domain: &str, user: &str, password: &str,
153 nt_hash: Option<&[u8; 16]>,
154 kerberos_ccache: Option<&str>,
155 kdc: &str,
156 method: &CollectionMethod,
157) -> HostFindings {
158 if !is_reachable(host, DEFAULT_PORT_TIMEOUT_MS).await {
160 trace!("[{host}] 445/tcp unreachable - skip");
161 return HostFindings {
162 computer_sid,
163 smb_sessions: Vec::new(), logged_on: Vec::new(), registry: Vec::new(),
164 errors: vec![format!("{host}: 445/tcp unreachable")],
165 };
166 }
167
168 let work = async {
171 let mut smb_sessions = Vec::new();
172 let mut logged_on = Vec::new();
173 let mut registry = Vec::new();
174 let mut errors = Vec::new();
175
176 let fatal: Result<(), String> = async {
179 let mut smb = if let Some(ccache) = kerberos_ccache {
181 let spn = format!("cifs/{host}");
183 let (gss_blob, session_key) =
184 crate::transport::kerberos::kerberos_material_for(ccache, &spn, kdc)
185 .await
186 .map_err(|e| format!("{host} krb: {e}"))?;
187 let auth = SmbAuth::Kerberos { gss_blob: &gss_blob, session_key: &session_key };
188 connect_ipc(host, domain, user, auth).await.map_err(|e| format!("{host}: {e}"))?
189 } else {
190 let auth = match nt_hash {
191 Some(h) => SmbAuth::Hash(h),
192 None => SmbAuth::Password(password),
193 };
194 connect_ipc(host, domain, user, auth).await.map_err(|e| format!("{host}: {e}"))?
195 };
196
197 if method.srvsvc() {
198 match srvsvc_sessions(&mut smb, host).await {
199 Ok((_, 5)) => errors.push(format!("[{host}] SRVSVC rc=5 ACCESS_DENIED (hardened / non-admin)")),
200 Ok((s, _)) => smb_sessions = s,
201 Err(e) => errors.push(format!("{host} SRVSVC: {e}")),
202 }
203 }
204 if method.wkssvc() {
205 match enum_wksta(&mut smb, host).await {
206 Ok((_, 5)) => errors.push(format!("[{host}] WKSSVC rc=5 (local admin required)")),
207 Ok((u, _)) => logged_on = dedup_wksta(u),
208 Err(e) => errors.push(format!("{host} WKSSVC: {e}")),
209 }
210 }
211 if method.registry() {
212 match enum_registry(&mut smb, domain, user, password, nt_hash, host).await {
213 Ok(sids) => registry = sids,
214 Err(e) => errors.push(format!("{host} WINREG: {e} (RemoteRegistry stopped?)")),
215 }
216 }
217 Ok(())
218 }.await;
219
220 if let Err(e) = fatal { errors.push(e); }
221 (smb_sessions, logged_on, registry, errors)
222 };
223
224 match timeout(Duration::from_millis(DEFAULT_HOST_TIMEOUT_MS), work).await {
226 Ok((smb_sessions, logged_on, registry, errors)) => HostFindings {
227 computer_sid, smb_sessions, logged_on, registry, errors,
228 },
229 Err(_elapsed) => HostFindings {
230 computer_sid,
231 smb_sessions: Vec::new(), logged_on: Vec::new(), registry: Vec::new(),
232 errors: vec![format!("{host}: per-host timeout")],
233 },
234 }
235}
236
237async fn is_reachable(host: &str, port_timeout_ms: u64) -> bool {
239 matches!(
240 timeout(Duration::from_millis(port_timeout_ms),
241 TcpStream::connect(format!("{host}:445"))).await,
242 Ok(Ok(_))
243 )
244}
245
246fn is_active(c: &Computer, expiry_days: i64) -> bool {
248 if !*c.properties().enabled() { return false; }
249 let pls = c.properties().pwdlastset();
250 if pls <= 0 { return false; }
251 let now = chrono::Utc::now().timestamp();
252 now - pls < expiry_days * 86_400
253}
254
255async fn srvsvc_sessions(smb: &mut SmbClient, host: &str) -> anyhow::Result<(Vec<SmbSession>, u32)> {
257 let pipe = open_rpc_pipe(smb, host, "srvsvc").await?;
258 let mut srv = SrvsvcClient::bind(smb, pipe).await?;
259 let (sessions, rc) = srv.enum_sessions().await?;
260 Ok((sessions.into_iter()
261 .map(|s| SmbSession { user: s.user, _client: s.client }).collect(), rc))
262}
263
264async fn enum_wksta(smb: &mut SmbClient, host: &str) -> anyhow::Result<(Vec<WkstaUser>, u32)> {
265 let pipe = open_rpc_pipe(smb, host, "wkssvc").await?;
266 let mut wk = WkstaUserClient::bind(smb, pipe).await?;
267 Ok(wk.enum_users().await?)
268}
269
270async fn enum_registry(smb: &mut SmbClient, domain: &str, user: &str,
271 password: &str, nt_hash: Option<&[u8; 16]>, host: &str)
272 -> anyhow::Result<Vec<RegistrySession>>
273{
274 let mut reg = match nt_hash {
275 Some(h) => RegistryClient::connect_hash(smb, domain, user, h, host).await
276 .map_err(|e| anyhow::anyhow!("{e}"))?,
277 None => RegistryClient::connect(smb, domain, user, password, host).await
278 .map_err(|e| anyhow::anyhow!("{e}"))?,
279 };
280 reg.logged_on_sids().await.map_err(|e| anyhow::anyhow!("{e}"))
281}
282
283fn build_sid_index(users: &[User]) -> HashMap<String, String> {
290 let mut idx = HashMap::with_capacity(users.len() * 2);
291 for u in users {
292 let sid = u.object_identifier().clone();
293 if sid.is_empty() { continue; }
294 let upn = u.properties().name().to_uppercase(); if let Some(sam) = upn.split('@').next() {
296 idx.entry(sam.to_string()).or_insert_with(|| sid.clone());
297 }
298 idx.insert(upn, sid);
299 }
300 idx
301}
302
303fn resolve(raw: &str, idx: &HashMap<String, String>, domain: &str) -> Option<String> {
308 let bare = raw.rsplit(['\\', '/']).next().unwrap_or(raw).trim();
309 if bare.is_empty() || bare == "?" || bare.ends_with('$') {
310 return None;
311 }
312 let sam = bare.to_uppercase();
313 let upn = format!("{sam}@{}", domain.to_uppercase());
314 idx.get(&upn).or_else(|| idx.get(&sam)).cloned()
315}
316
317fn mk_link(user_sid: String, computer_sid: String) -> UserComputerSession {
319 let mut ucs = UserComputerSession::new();
320 *ucs.user_sid_mut() = user_sid;
321 *ucs.computer_sid_mut() = computer_sid;
322 ucs
323}
324
325fn dedup_wksta(users: Vec<WkstaUser>) -> Vec<WkstaUser> {
327 use std::collections::BTreeSet;
328 let mut seen = BTreeSet::new();
329 users.into_iter()
330 .filter(|u| !u.username.ends_with('$'))
331 .filter(|u| seen.insert((u.logon_domain.clone(), u.username.clone())))
332 .collect()
333}
334
335fn apply_findings(
345 computers: &mut [Computer],
346 hf: &HostFindings,
347 sid_index: &HashMap<String, String>,
348 domain: &str,
349) -> usize {
350 let computer = match computers
351 .iter_mut()
352 .find(|c| c.object_identifier() == &hf.computer_sid)
353 {
354 Some(c) => c,
355 None => {
356 warn!("[sessions] no computer object for SID {}", hf.computer_sid);
357 return 0;
358 }
359 };
360 let comp_sid = hf.computer_sid.clone();
361 let fqdn = computer.properties().name().clone(); let mut count = 0usize;
363
364 {
366 let s = computer.sessions_mut();
367 for sess in &hf.smb_sessions {
368 match resolve(&sess.user, sid_index, domain) {
369 Some(user_sid) => {
370 trace!("[SRVSVC] {} has session on {fqdn}", sess.user);
371 s.results_mut().push(mk_link(user_sid, comp_sid.clone()));
372 count += 1;
373 }
374 None => warn!("[{comp_sid}] unresolved SRVSVC principal '{}'", sess.user),
375 }
376 }
377 *s.collected_mut() = true;
378 }
379
380 {
382 let p = computer.privileged_sessions_mut();
383 for u in &hf.logged_on {
384 match resolve(&u.username, sid_index, domain) {
385 Some(user_sid) => {
386 trace!("[WKSSVC] {}\\{} has session on {fqdn}", u.logon_domain, u.username);
387 p.results_mut().push(mk_link(user_sid, comp_sid.clone()));
388 count += 1;
389 }
390 None => warn!("[{comp_sid}] unresolved WKSSVC principal '{}\\{}'",
391 u.logon_domain, u.username),
392 }
393 }
394 *p.collected_mut() = true;
395 }
396
397 {
399 let r = computer.registry_sessions_mut();
400 for reg in &hf.registry {
401 if reg.sid.is_empty() { continue; }
402 trace!("[WINREG] {} has session on {fqdn}", reg.sid);
403 r.results_mut().push(mk_link(reg.sid.clone(), comp_sid.clone()));
404 count += 1;
405 }
406 *r.collected_mut() = true;
407 }
408
409 debug!("[sessions] Total {count} session(s) on {fqdn}");
410 count
411}
412
413fn parse_hash(h: Option<&str>) -> Option<[u8; 16]> {
418 let raw = h?.trim();
419 let nt = raw.rsplit(':').next().unwrap_or(raw).trim();
420 if nt.len() != 32 || !nt.bytes().all(|b| b.is_ascii_hexdigit()) {
421 return None;
422 }
423 let mut out = [0u8; 16];
424 for (i, byte) in out.iter_mut().enumerate() {
425 *byte = u8::from_str_radix(&nt[i * 2..i * 2 + 2], 16).ok()?;
426 }
427 Some(out)
428}