From 33c983f6c5d091ca63d277e5373ea7292ef0855e Mon Sep 17 00:00:00 2001
From: Henrik Hautakoski <henrik.hautakoski@gmail.com>
Date: Mon, 21 Oct 2024 12:27:29 +0200
Subject: [PATCH] internal/server/ship_processor.go: adding FetchDeltas()

---
 internal/server/ship_processor.go | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/internal/server/ship_processor.go b/internal/server/ship_processor.go
index e3ab11e..a722722 100644
--- a/internal/server/ship_processor.go
+++ b/internal/server/ship_processor.go
@@ -66,6 +66,15 @@ func SpawnProccessor(shipStream *shipclient.Stream, loader StateLoader, saver St
 	return processor
 }
 
+func (processor *ShipProcessor) FetchDeltas(value bool) {
+	if value {
+		// empty callback will signal that traces should be included in the response from ship.
+		processor.shipStream.TableDeltaHandler = func(*ship.TableDeltaArray) {}
+	} else {
+		processor.shipStream.TableDeltaHandler = nil
+	}
+}
+
 func (processor *ShipProcessor) SetBlacklist(list types.Blacklist) {
 	processor.blacklist = list
 }