From 67aed48d6291a9baaf534763bfc424174251bb51 Mon Sep 17 00:00:00 2001
From: Jon Bauer <jon@covelop.org>
Date: Mon, 20 Jan 2025 23:27:08 -0800
Subject: [PATCH] Handle write operations inside FlatMap in Future

---
 .../DAO/CDMessageDAO+MessageStore.swift              | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/EdgeAgentSDK/Pluto/Sources/PersistentStorage/DAO/CDMessageDAO+MessageStore.swift b/EdgeAgentSDK/Pluto/Sources/PersistentStorage/DAO/CDMessageDAO+MessageStore.swift
index 8497c4b0..4bc15964 100644
--- a/EdgeAgentSDK/Pluto/Sources/PersistentStorage/DAO/CDMessageDAO+MessageStore.swift
+++ b/EdgeAgentSDK/Pluto/Sources/PersistentStorage/DAO/CDMessageDAO+MessageStore.swift
@@ -44,11 +44,13 @@ extension CDMessageDAO: MessageStore {
             .first()
             .map { $0.first }
             .flatMap { pair in
-                self.updateOrCreate(
-                    msg.id,
-                    context: writeContext
-                ) { cdobj, _ in
-                    try cdobj.fromDomain(msg: msg, direction: direction, pair: pair)
+                Future {
+                    self.updateOrCreate(
+                        msg.id,
+                        context: writeContext
+                    ) { cdobj, _ in
+                        try cdobj.fromDomain(msg: msg, direction: direction, pair: pair)
+                    }
                 }
             }
             .map { _ in }