Dispatcher provider IO implementation

Author: djordjeh

src/main/java/de/tillhub/printengine/PrinterImpl.kt

@@ -8,15 +8,19 @@ import de.tillhub.printengine.data.PrinterResult
 import de.tillhub.printengine.data.PrinterSettings
 import de.tillhub.printengine.data.PrinterState
 import de.tillhub.printengine.data.doOnError
+import de.tillhub.printengine.dispatcher.DispatcherProvider
+import de.tillhub.printengine.dispatcher.DispatcherProviderImp
 import de.tillhub.printengine.pax.PaxPrintService
 import de.tillhub.printengine.sunmi.SunmiPrintService
 import de.tillhub.printengine.verifone.VerifonePrintService
 import kotlinx.coroutines.flow.StateFlow
+import kotlinx.coroutines.withContext
 import timber.log.Timber
 
 class PrinterImpl(
     private val printService: PrintService,
-    private val analytics: PrintAnalytics?
+    private val analytics: PrintAnalytics?,
+    private val dispatcherProvider: DispatcherProvider = DispatcherProviderImp()
 ) : Printer {
 
     init {
@@ -34,51 +38,55 @@ class PrinterImpl(
     override fun observePrinterState(): StateFlow<PrinterState> = printService.printerState
 
     override suspend fun getPrinterInfo(): PrinterResult<PrinterInfo> =
-        printService.withPrinterCatching {
-            it.getPrinterInfo().let { info ->
-                PrinterInfo(
-                    info.serialNumber,
-                    info.deviceModel,
-                    info.printerVersion,
-                    info.printerPaperSpec,
-                    info.printingFontType,
-                    info.printerHead,
-                    info.printedDistance,
-                    info.serviceVersion
-                )
+        withContext(dispatcherProvider.iO()) {
+            printService.withPrinterCatching {
+                it.getPrinterInfo().let { info ->
+                    PrinterInfo(
+                        info.serialNumber,
+                        info.deviceModel,
+                        info.printerVersion,
+                        info.printerPaperSpec,
+                        info.printingFontType,
+                        info.printerHead,
+                        info.printedDistance,
+                        info.serviceVersion
+                    )
+                }
+            }.doOnError {
+                logWarning("getting printer info")
             }
-        }.doOnError {
-            logWarning("getting printer info")
         }
 
     override suspend fun startPrintJob(job: PrintJob): PrinterResult<Unit> =
-        printService.withPrinterCatching { controller ->
-            logInfo(
-                """receipt: START #################
+        withContext(dispatcherProvider.iO()) {
+            printService.withPrinterCatching { controller ->
+                logInfo(
+                    """receipt: START #################
                    |${job.description}
                    |receipt END #################
                    |""".trimMargin()
-            )
-            if (settings.enabled && job.isNotEmpty) {
-                controller.setIntensity(settings.printingIntensity)
-                controller.setFontSize(controller.getPrinterInfo().printingFontType)
-                job.commands.forEach { command ->
-                    when (command) {
-                        is PrintCommand.Barcode -> controller.printBarcode(command.barcode)
-                        is PrintCommand.Image -> controller.printImage(command.image)
-                        is PrintCommand.QrCode -> controller.printQr(command.code)
-                        is PrintCommand.RawData -> controller.sendRawData(command.data)
-                        is PrintCommand.Text -> controller.printText(command.text)
-                        PrintCommand.CutPaper -> controller.cutPaper()
-                        PrintCommand.FeedPaper -> controller.feedPaper()
+                )
+                if (settings.enabled && job.isNotEmpty) {
+                    controller.setIntensity(settings.printingIntensity)
+                    controller.setFontSize(controller.getPrinterInfo().printingFontType)
+                    job.commands.forEach { command ->
+                        when (command) {
+                            is PrintCommand.Barcode -> controller.printBarcode(command.barcode)
+                            is PrintCommand.Image -> controller.printImage(command.image)
+                            is PrintCommand.QrCode -> controller.printQr(command.code)
+                            is PrintCommand.RawData -> controller.sendRawData(command.data)
+                            is PrintCommand.Text -> controller.printText(command.text)
+                            PrintCommand.CutPaper -> controller.cutPaper()
+                            PrintCommand.FeedPaper -> controller.feedPaper()
+                        }
                     }
+                    controller.start()
+                    analytics?.logPrintReceipt(job.description)
                 }
-                controller.start()
-                analytics?.logPrintReceipt(job.description)
+            }.doOnError {
+                logWarning("printing job '${job.description}'")
+                analytics?.logErrorPrintReceipt("printing text '${job.description}'")
             }
-        }.doOnError {
-            logWarning("printing job '${job.description}'")
-            analytics?.logErrorPrintReceipt("printing text '${job.description}'")
         }
 
     private fun logInfo(message: String) {

src/main/java/de/tillhub/printengine/dispatcher/DispatcherProvider.kt

@@ -0,0 +1,7 @@
+package de.tillhub.printengine.dispatcher
+
+import kotlinx.coroutines.CoroutineDispatcher
+
+interface DispatcherProvider {
+    fun iO(): CoroutineDispatcher
+}

src/main/java/de/tillhub/printengine/dispatcher/DispatcherProviderImp.kt

@@ -0,0 +1,8 @@
+package de.tillhub.printengine.dispatcher
+
+import kotlinx.coroutines.CoroutineDispatcher
+import kotlinx.coroutines.Dispatchers
+
+class DispatcherProviderImp : DispatcherProvider {
+    override fun iO(): CoroutineDispatcher = Dispatchers.IO
+}