dockware-core/shipments/ShipmentsRepositoryImpl

ShipmentsRepositoryImpl

class ShipmentsRepositoryImpl(fortressApiService: FortressApiService, profileRepository: ProfileRepository, organizationRepository: OrganizationRepository) : ShipmentsRepository

Constructors

constructor(fortressApiService: FortressApiService, profileRepository: ProfileRepository, organizationRepository: OrganizationRepository)

Types

Companion

object Companion

Properties

sharedShipments

open override val sharedShipments: StateFlow<List<Shipment>>

shipments

open override val shipments: StateFlow<List<Shipment>>

shipmentTrees

open override val shipmentTrees: StateFlow<List<ShipmentTree>>

Functions

archiveShipment

open suspend override fun archiveShipment(shipmentId: String): Result<Shipment>

Soft-deletes a shipment, moving it to the archive.

archiveShipments

open suspend override fun archiveShipments(shipmentIds: List<String>): Result<List<Shipment>>

Archive multiple shipments (batch operation)

archiveShipmentScan

open suspend override fun archiveShipmentScan(shipmentScanId: String): Result<ShipmentScan>

Deletes a shipment scan.

clearShipments

open override fun clearShipments()

Clear all shipment data (used when user logs out)

createPickTicketShipmentEntry

open suspend override fun createPickTicketShipmentEntry(shipmentId: String, shipmentScanId: String, jobId: String, fileName: String): Result<ShipmentEntry>

Create a shipment entry for a pick ticket image Links the already-uploaded pick ticket image to the shipment and scan

createShipment

open suspend override fun createShipment(title: String, metadata: Map<String, Any>?): Result<Shipment>

Creates a new shipment.

createShipmentScan

open suspend override fun createShipmentScan(shipmentId: String, title: String, dimensions: Dimensions?, weight: Float?, freightClass: String?, locationData: LocationData?, notes: String?, status: String?, scanType: ShipmentScanType): Result<ShipmentScan>

Records a new scan event for a shipment.

fetchAllShipmentData

open suspend override fun fetchAllShipmentData(pollScansEvery: Long?)

Triggers a full refresh of all shipment data, including scans and entries.

fetchMostRecentShipmentEntries

open suspend override fun fetchMostRecentShipmentEntries(shipmentIds: List<String>): Result<Map<String, List<ShipmentEntry>>>

Optimized: Implement parallel batch fetching for entries

fetchShipmentAndScans

open suspend override fun fetchShipmentAndScans(shipmentId: String): Result<Pair<Shipment, List<ShipmentScan>>>

Fetches both the shipment details and its scans in parallel.

fetchShipmentEntries

open suspend override fun fetchShipmentEntries(shipmentScanId: String): Result<List<ShipmentEntry>>

Fetches all entries (files, images, point clouds) attached to a specific scan.

fetchShipmentScans

open suspend override fun fetchShipmentScans(shipmentId: String): Result<List<ShipmentScan>>

Fetches all scans associated with a specific shipment.

open suspend override fun fetchShipmentScans(shipmentIds: List<String>): Result<Map<String, List<ShipmentScan>>>

Optimized: Implement parallel batch fetching for scans

fetchShipmentTrees

open suspend override fun fetchShipmentTrees(pollScansEvery: Long?): Result<ShipmentWithSharing>

Optimized: Implement parallel fetching of scans and entries

processCloudDimensions

open suspend override fun processCloudDimensions(snapshotZipData: ByteArray, shipmentId: String, shipmentScanId: String, progressCallback: (String) -> Unit?, validationResult: SnapshotValidator.ValidationResult?): Boolean

Optimized: Extract cloud processing to separate function

renameShipment

open suspend override fun renameShipment(shipmentId: String, newTitle: String): Result<Shipment>

Rename a shipment

shareShipment

open suspend override fun shareShipment(shipmentId: String, recipientEmail: String, expiration: String?): Result<ShipmentSharing>

Shares a shipment with another user via email.

shipmentEntriesOf

open override fun shipmentEntriesOf(shipmentId: String): StateFlow<List<ShipmentEntry>>

Provides a reactive stream of entries for a single shipment.

open override fun shipmentEntriesOf(shipmentIds: Set<String>): StateFlow<List<List<ShipmentEntry>>>

Provides a reactive stream of entries (files/metadata) for a set of shipment IDs.

shipmentScansOf

open override fun shipmentScansOf(shipmentId: String): StateFlow<List<ShipmentScan>>

Provides a reactive stream of scans for a single shipment.

open override fun shipmentScansOf(shipmentIds: Set<String>): StateFlow<List<List<ShipmentScan>>>

Provides a reactive stream of scans for a specific set of shipment IDs.

shipmentTree

open override fun shipmentTree(shipmentId: String): StateFlow<ShipmentTree>

Returns a reactive stream for a specific ShipmentTree.

unarchiveShipment

open suspend override fun unarchiveShipment(shipmentId: String): Result<Shipment>

Unarchive a shipment (restore)

updateShipmentMetadata

open suspend override fun updateShipmentMetadata(shipmentId: String, metadata: Map<String, Any>): Result<Shipment>

Updates metadata of a shipment Ensure original metadata fields of shipment are included to not overwrite data.

updateShipmentScan

open suspend override fun updateShipmentScan(shipmentScanId: String, metadata: Map<String, Any>): Result<ShipmentScan>

Updates raw metadata for a specific scan.

updateShipmentScanManualDimensions

open suspend override fun updateShipmentScanManualDimensions(shipmentScanId: String, dimensions: Dimensions): Result<ShipmentScan>

Updates a scan with manually measured dimensions.

updateShipmentScanQualityApprovedByUser

open suspend override fun updateShipmentScanQualityApprovedByUser(scanId: String, approved: Boolean, currentMetadata: Map<String, Any>): Result<ShipmentScan>

Updates the quality approval status for a scan, usually triggered by manual user review.

updateShipmentScanType

open suspend override fun updateShipmentScanType(scanId: String, scanType: ShipmentScanType): Result<ShipmentScan>

Update shipment scan type to match the document type

updateShipmentScanUserDimensions

open suspend override fun updateShipmentScanUserDimensions(shipmentScanId: String, dimensions: Dimensions, newCenter: Vector3): Result<ShipmentScan>

Updates the bounding box/user-adjusted dimensions for a 3D scan.

updateShipmentScanWeight

open suspend override fun updateShipmentScanWeight(shipmentScanId: String, weight: Float?): Result<ShipmentScan>

Updates the weight of the scanned object.

uploadBarcodes

open suspend override fun uploadBarcodes(barcodeData: List<BarcodeData>, shipmentId: String, shipmentScanId: String, progressCallback: (String) -> Unit?): Result<Shipment>

Optimized: Extract barcode upload to separate function

uploadImages

open suspend override fun uploadImages(images: List<ByteArray>, shipmentId: String, shipmentScanId: String, progressCallback: (String) -> Unit?): List<Pair<StorageObject, ShipmentEntry>?>

Optimized: Extract image upload to separate function

uploadLogLines

open suspend override fun uploadLogLines(logList: List<LogEntry>): Result<String>

Uploads SDK/Application logs to the Dockware server for troubleshooting.