From 9c03b0a4fa38971dfe83bd135aefb3c482a18380 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Thu, 10 Dec 2020 18:57:10 +0000
Subject: Refactor sync tokens (#1628)

* Refactor sync tokens

* Comment out broken notifier test

* Update types, sytest-whitelist

* More robust token checking

* Remove New functions for streaming tokens

* Export Logs in StreamingToken

* Fix tests
---
 syncapi/consumers/eduserver_sendtodevice.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'syncapi/consumers/eduserver_sendtodevice.go')

diff --git a/syncapi/consumers/eduserver_sendtodevice.go b/syncapi/consumers/eduserver_sendtodevice.go
index 07324fcd..0c3f52cd 100644
--- a/syncapi/consumers/eduserver_sendtodevice.go
+++ b/syncapi/consumers/eduserver_sendtodevice.go
@@ -107,7 +107,7 @@ func (s *OutputSendToDeviceEventConsumer) onMessage(msg *sarama.ConsumerMessage)
 	s.notifier.OnNewSendToDevice(
 		output.UserID,
 		[]string{output.DeviceID},
-		types.NewStreamToken(0, streamPos, nil),
+		types.StreamingToken{SendToDevicePosition: streamPos},
 	)
 
 	return nil
-- 
cgit v1.2.3