mosaic-client/dev.catbit.mosaic.client.data.repository/MosaicRepositoryImpl

MosaicRepositoryImpl

class MosaicRepositoryImpl(network: MosaicNetwork, database: MosaicDatabase, fileSystem: MosaicFileSystem, networkParametersHolder: NetworkParametersHolder) : MosaicRepository

Constructors

constructor(network: MosaicNetwork, database: MosaicDatabase, fileSystem: MosaicFileSystem, networkParametersHolder: NetworkParametersHolder)

Functions

deleteFile

open suspend override fun deleteFile(fileName: String): Result<Unit>

deletePlainData

open suspend override fun deletePlainData(dataKey: String): Result<Unit>

deletePlainDataByIds

open suspend override fun deletePlainDataByIds(dataKeys: List<String>): Result<Unit>

deleteSegmentedData

open suspend override fun deleteSegmentedData(segmentKey: String, dataKey: String): Result<Unit>

deleteSegmentedDataByIds

open suspend override fun deleteSegmentedDataByIds(segmentKey: String, dataKeys: List<String>): Result<Unit>

downloadFile

open suspend override fun downloadFile(url: String, headers: Map<String, String>?, body: Any?, httpMethod: HttpMethod, targetFileName: String, mimeType: String?, onProgress: suspend (Float) -> Unit, onDownloadFinished: suspend () -> Unit, onDownloadFailure: suspend (Throwable) -> Unit): Result<Unit>

Downloads a file into the device's public/general storage (system Downloads location). See dev.catbit.mosaic.core.data.schemas.event.events.networking.DownloadFileEventSchema for the full per-platform behavior contract.

downloadFileToDisk

open suspend override fun downloadFileToDisk(url: String, headers: Map<String, String>?, body: Any?, httpMethod: HttpMethod, targetFileName: String, onProgress: suspend (Float) -> Unit, onDownloadFinished: suspend () -> Unit, onDownloadFailure: suspend (Throwable) -> Unit): Result<Unit>

downloadFileToMemory

open suspend override fun downloadFileToMemory(url: String, headers: Map<String, String>?, body: Any?, httpMethod: HttpMethod, onProgress: suspend (Float) -> Unit, onDownloadFinished: suspend (ByteArray) -> Unit, onDownloadFailure: suspend (Throwable) -> Unit): Result<Unit>

dropCaches

open suspend override fun dropCaches(dropScreensCache: Boolean, dropInitialGraphCache: Boolean, dropVersionCache: Boolean): Result<Unit>

fileExists

open suspend override fun fileExists(fileName: String): Result<Boolean>

getAllPlainData

open suspend override fun getAllPlainData(): Result<Map<String, Any>>

getAllSegmentedData

open suspend override fun getAllSegmentedData(segmentKey: String): Result<Map<String, Any>>

getFile

open suspend override fun getFile(fileName: String): Result<ByteArray?>

getFilePlatformFile

open suspend override fun getFilePlatformFile(fileName: String): Result<PlatformFile?>

getFileStreaming

open suspend override fun getFileStreaming(fileName: String): Result<Flow<ByteArray>?>

getInitialGraph

open suspend override fun getInitialGraph(): Result<GraphModel>

getPlainData

open suspend override fun getPlainData(dataKey: String): Result<Any>

getPlainDataByIds

open suspend override fun getPlainDataByIds(dataKeys: List<String>): Result<Map<String, Any>>

getScreen

open suspend override fun getScreen(screenId: String, headers: Map<String, String>?, body: Any?, httpMethod: HttpMethod, timeoutMillis: Long?): Result<ScreenModel>

getSegmentedData

open suspend override fun getSegmentedData(segmentKey: String, dataKey: String): Result<Any>

getSegmentedDataByIds

open suspend override fun getSegmentedDataByIds(segmentKey: String, dataKeys: List<String>): Result<Map<String, Any>>

getVersion

open suspend override fun getVersion(): Result<Unit>

Checks the backend's cache-busting version against the locally stored one, wiping the graph/screens cache when the remote version is newer. Never blocks the caller for long (offline or any failure is captured in the returned Result rather than thrown).

saveFile

open suspend override fun saveFile(fileName: String, data: ByteArray): Result<Unit>

savePlainData

open suspend override fun savePlainData(dataKey: String, data: Any): Result<Unit>

saveSegmentedData

open suspend override fun saveSegmentedData(segmentKey: String, dataKey: String, data: Any): Result<Unit>

sendHttpRequest

open suspend override fun sendHttpRequest(url: String, headers: Map<String, String>?, body: Any?, httpMethod: HttpMethod, timeoutMillis: Long?): Result<HttpResponse>

uploadFile

open suspend override fun uploadFile(url: String?, headers: Map<String, String>?, httpMethod: HttpMethod, contentType: String?, platformFile: PlatformFile, onProgress: suspend (Float) -> Unit): Result<UploadResult>

wipePlainData

open suspend override fun wipePlainData(): Result<Unit>

wipeSegmentedData

open suspend override fun wipeSegmentedData(segmentKey: String): Result<Unit>