@@ -17,7 +17,7 @@ use spacetimedb_datastore::locking_tx_datastore::state_view::{
17
17
IterByColEqMutTx , IterByColRangeMutTx , IterMutTx , IterTx , StateView ,
18
18
} ;
19
19
use spacetimedb_datastore:: locking_tx_datastore:: { MutTxId , TxId } ;
20
- use spacetimedb_datastore:: system_tables:: { system_tables, StClientFields , StClientRow , StModuleRow , ST_CLIENT_ID } ;
20
+ use spacetimedb_datastore:: system_tables:: { system_tables, StModuleRow } ;
21
21
use spacetimedb_datastore:: system_tables:: { StFields , StVarFields , StVarName , StVarRow , ST_MODULE_ID , ST_VAR_ID } ;
22
22
use spacetimedb_datastore:: traits:: {
23
23
InsertFlags , IsolationLevel , Metadata , MutTx as _, MutTxDatastore , Program , RowTypeForTable , Tx as _, TxDatastore ,
@@ -412,32 +412,6 @@ impl RelationalDB {
412
412
. map_err ( DBError :: from)
413
413
}
414
414
415
- /// Look up a client row by identity and connection ID in the `st_clients` system table.
416
- ///
417
- /// `Ok(None)` if no such row exists.
418
- pub fn st_client_row (
419
- & self ,
420
- identity : Identity ,
421
- connection_id : ConnectionId ,
422
- ) -> Result < Option < RowPointer > , DBError > {
423
- let row = StClientRow {
424
- identity : identity. into ( ) ,
425
- connection_id : connection_id. into ( ) ,
426
- } ;
427
-
428
- self . with_read_only ( Workload :: Internal , |tx| {
429
- self . inner
430
- . iter_by_col_range_tx (
431
- tx,
432
- ST_CLIENT_ID ,
433
- col_list ! [ StClientFields :: Identity , StClientFields :: ConnectionId ] ,
434
- & AlgebraicValue :: product ( row) ,
435
- )
436
- . map ( |mut it| it. next ( ) . map ( |row_ref| row_ref. pointer ( ) ) )
437
- } )
438
- . map_err ( DBError :: from)
439
- }
440
-
441
415
/// Update the module associated with this database.
442
416
///
443
417
/// The caller must ensure that:
0 commit comments