From e2afaab50cd4a08d74d3bedd61582ca056bfafb8 Mon Sep 17 00:00:00 2001 From: Till Faelligen Date: Fri, 19 Nov 2021 10:38:17 +0100 Subject: [PATCH] Fix typo --- syncapi/streams/streams.go | 8 ++++---- syncapi/sync/requestpool.go | 4 ++-- syncapi/syncapi.go | 2 +- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/syncapi/streams/streams.go b/syncapi/streams/streams.go index 48f19dcdb..46de8ad29 100644 --- a/syncapi/streams/streams.go +++ b/syncapi/streams/streams.go @@ -18,7 +18,7 @@ type Streams struct { InviteStreamProvider types.StreamProvider SendToDeviceStreamProvider types.StreamProvider AccountDataStreamProvider types.StreamProvider - PresenceDataStreamProdiver types.StreamProvider + PresenceDataStreamProvider types.StreamProvider DeviceListStreamProvider types.PartitionedStreamProvider } @@ -48,7 +48,7 @@ func NewSyncStreamProviders( StreamProvider: StreamProvider{DB: d}, userAPI: userAPI, }, - PresenceDataStreamProdiver: &PresenceStreamProvider{ + PresenceDataStreamProvider: &PresenceStreamProvider{ StreamProvider: StreamProvider{DB: d}, UserAPI: userAPI, }, @@ -66,7 +66,7 @@ func NewSyncStreamProviders( streams.SendToDeviceStreamProvider.Setup() streams.AccountDataStreamProvider.Setup() streams.DeviceListStreamProvider.Setup() - streams.PresenceDataStreamProdiver.Setup() + streams.PresenceDataStreamProvider.Setup() return streams } @@ -80,6 +80,6 @@ func (s *Streams) Latest(ctx context.Context) types.StreamingToken { SendToDevicePosition: s.SendToDeviceStreamProvider.LatestPosition(ctx), AccountDataPosition: s.AccountDataStreamProvider.LatestPosition(ctx), DeviceListPosition: s.DeviceListStreamProvider.LatestPosition(ctx), - PresenceDataPosition: s.PresenceDataStreamProdiver.LatestPosition(ctx), + PresenceDataPosition: s.PresenceDataStreamProvider.LatestPosition(ctx), } } diff --git a/syncapi/sync/requestpool.go b/syncapi/sync/requestpool.go index 399cd2b32..5de7d3de7 100644 --- a/syncapi/sync/requestpool.go +++ b/syncapi/sync/requestpool.go @@ -210,7 +210,7 @@ func (rp *RequestPool) OnIncomingSyncRequest(req *http.Request, device *userapi. DeviceListPosition: rp.streams.DeviceListStreamProvider.CompleteSync( syncReq.Context, syncReq, ), - PresenceDataPosition: rp.streams.PresenceDataStreamProdiver.CompleteSync( + PresenceDataPosition: rp.streams.PresenceDataStreamProvider.CompleteSync( syncReq.Context, syncReq, ), } @@ -245,7 +245,7 @@ func (rp *RequestPool) OnIncomingSyncRequest(req *http.Request, device *userapi. syncReq.Context, syncReq, syncReq.Since.DeviceListPosition, currentPos.DeviceListPosition, ), - PresenceDataPosition: rp.streams.PresenceDataStreamProdiver.IncrementalSync( + PresenceDataPosition: rp.streams.PresenceDataStreamProvider.IncrementalSync( syncReq.Context, syncReq, syncReq.Since.PresenceDataPosition, currentPos.PresenceDataPosition, ), diff --git a/syncapi/syncapi.go b/syncapi/syncapi.go index 3dfe0c334..9b6d69063 100644 --- a/syncapi/syncapi.go +++ b/syncapi/syncapi.go @@ -109,7 +109,7 @@ func AddPublicRoutes( } presenceConsumer := consumers.NewOutputPresenceDataConsumer( - process, cfg, consumer, syncDB, notifier, streams.PresenceDataStreamProdiver, + process, cfg, consumer, syncDB, notifier, streams.PresenceDataStreamProvider, ) if err = presenceConsumer.Start(); err != nil { logrus.WithError(err).Panicf("failed to start presence consumer")