feat: do not resurrect event when syncing in both directions

internal/sync/controller.go

@@ -177,6 +177,18 @@ func (p Controller) diffEvents(sourceEvents []models.Event, sinkEvents []models.
 
 		switch {
 		case !exists:
+			// Don't sync synced events back to their original calendar to prevent resurrecting
+			// deleted events.
+			// Problem:
+			// - Sync event (from calendar A) to create eventCopy (calendar B, SourceID = calendar A).
+			// - Delete event (in calendar A)
+			// - Run sync from calendar B to calendar A. This will copy (and thereby resurrect) the event.
+			//
+			// Solution: Ignore events the originate from the sink, but no longer exist there.
+			if event.Metadata.SourceID == p.sink.GetSourceID() {
+				p.logger.Info("skipping event as it originates from the sink, but no longer exists there", logFields(event)...)
+				continue
+			}
 			p.logger.Info("new event, needs sync", logFields(event)...)
 			createEvents = append(createEvents, event)
 

internal/sync/controller_test.go

@@ -94,6 +94,7 @@ func (suite *ControllerTestSuite) TestDryRun() {
 	suite.source.On("EventsInTimeframe", ctx, startTime, endTime).Return(sourceEvents, nil)
 	suite.sink.On("EventsInTimeframe", ctx, startTime, endTime).Return(sinkEvents, nil)
 	suite.sink.On("DeleteEvent", ctx, mock.AnythingOfType("models.Event")).Return(nil)
+	suite.sink.On("GetSourceID").Return("sinkID")
 	suite.source.On("GetSourceID").Return("sourceID")
 
 	err := suite.controller.SynchroniseTimeframe(ctx, startTime, endTime, true)
@@ -170,6 +171,7 @@ func (suite *ControllerTestSuite) TestCleanUp() {
 	suite.source.On("EventsInTimeframe", ctx, startTime, endTime).Return(sourceEvents, nil)
 	suite.sink.On("EventsInTimeframe", ctx, startTime, endTime).Return(sinkEvents, nil)
 	suite.sink.On("DeleteEvent", ctx, mock.AnythingOfType("models.Event")).Return(nil)
+	suite.sink.On("GetSourceID").Return("sinkID")
 	suite.source.On("GetSourceID").Return("sourceID")
 
 	err := suite.controller.CleanUp(ctx, startTime, endTime)
@@ -213,6 +215,7 @@ func (suite *ControllerTestSuite) TestCreateEventsEmptySink() {
 	suite.source.On("EventsInTimeframe", ctx, startTime, endTime).Return(eventsToCreate, nil)
 	suite.sink.On("EventsInTimeframe", ctx, startTime, endTime).Return(nil, nil)
 	suite.sink.On("CreateEvent", ctx, mock.AnythingOfType("models.Event")).Return(nil)
+	suite.sink.On("GetSourceID").Return("sinkID")
 
 	err := suite.controller.SynchroniseTimeframe(ctx, startTime, endTime, false)
 	assert.NoError(suite.T(), err)
@@ -224,7 +227,7 @@ func (suite *ControllerTestSuite) TestCreateEventsEmptySink() {
 	suite.sink.AssertNotCalled(suite.T(), "DeleteEvent", ctx, mock.AnythingOfType("models.Event"))
 }
 
-// TestDeleteEventsNotInSink verifies that if events are present in the source-adapter, but not in the sink, these
+// TestDeleteEventsNotInSink verifies that if events are present in the sink-adapter, but not in the source, these
 // events are deleted in the sink.
 func (suite *ControllerTestSuite) TestDeleteEventsNotInSink() {
 	ctx := context.Background()
@@ -296,6 +299,7 @@ func (suite *ControllerTestSuite) TestDeleteEventsNotInSink() {
 	suite.sink.On("DeleteEvent", ctx, mock.AnythingOfType("models.Event")).Return(nil)
 	// UpdateEvent gets called because the remaining event in the sink will get updated because there are no transformers configured
 	suite.sink.On("UpdateEvent", ctx, mock.AnythingOfType("models.Event")).Return(nil)
+	suite.sink.On("GetSourceID").Return("sinkID")
 	suite.source.On("GetSourceID").Return("sourceID")
 
 	err := suite.controller.SynchroniseTimeframe(ctx, startTime, endTime, false)
@@ -306,6 +310,41 @@ func (suite *ControllerTestSuite) TestDeleteEventsNotInSink() {
 	suite.sink.AssertNumberOfCalls(suite.T(), "DeleteEvent", expectedDelete)
 }
 
+// TestDeleteEventsNotInSink verifies that if events are present in the sink-adapter, but not in the source, these
+// events are deleted in the sink.
+func (suite *ControllerTestSuite) TestDoNotResurrectEvents() {
+	ctx := context.Background()
+	startTime := time.Now()
+	endTime := startTime.Add(2 * time.Hour)
+	sourceEvents := []models.Event{
+		{
+			ICalUID:     "testID",
+			ID:          "testUID",
+			Title:       "Title 1",
+			Description: "Description",
+			StartTime:   startTime,
+			EndTime:     endTime,
+			AllDay:      false,
+			// originates from sink
+			Metadata:  models.NewEventMetadata("seed1", "uri", "sinkID"),
+			Reminders: []models.Reminder{{Actions: models.ReminderActionDisplay, Trigger: models.ReminderTrigger{PointInTime: startTime.Add(-10 * time.Minute)}}},
+		},
+	}
+	sinkEvents := []models.Event{}
+
+	suite.source.On("EventsInTimeframe", ctx, startTime, endTime).Return(sourceEvents, nil)
+	suite.sink.On("EventsInTimeframe", ctx, startTime, endTime).Return(sinkEvents, nil)
+	suite.sink.On("GetSourceID").Return("sinkID")
+	suite.source.On("GetSourceID").Return("sourceID")
+
+	err := suite.controller.SynchroniseTimeframe(ctx, startTime, endTime, false)
+	assert.NoError(suite.T(), err)
+
+	suite.sink.AssertNotCalled(suite.T(), "CreateEvent", ctx, mock.AnythingOfType("models.Event"))
+	suite.sink.AssertNotCalled(suite.T(), "UpdateEvent", ctx, mock.AnythingOfType("models.Event"))
+	suite.sink.AssertNotCalled(suite.T(), "DeleteEvent", ctx, mock.AnythingOfType("models.Event"))
+}
+
 // TestUpdateEventsPrefilledSink asserts that, given that the sink does contain any events,
 // the controller properly updates the events in the sink.
 // and leaves unmanaged events as they are
@@ -425,6 +464,7 @@ func (suite *ControllerTestSuite) TestUpdateEventsPrefilledSink() {
 	suite.source.On("EventsInTimeframe", ctx, startTime, endTime).Return(sourceEvents, nil)
 	suite.sink.On("EventsInTimeframe", ctx, startTime, endTime).Return(sinkEvents, nil)
 	suite.sink.On("UpdateEvent", ctx, mock.AnythingOfType("models.Event")).Return(nil)
+	suite.sink.On("GetSourceID").Return("sinkID")
 	suite.source.On("GetSourceID").Return("sourceID")
 
 	err := suite.controller.SynchroniseTimeframe(ctx, startTime, endTime, false)
@@ -651,15 +691,32 @@ func TestController_diffEvents(t *testing.T) {
 			expectedUpdateEvents: []models.Event{},
 			expectedDeleteEvents: []models.Event{},
 		},
+		{
+			name: "should not resurrect events already deleted from source when syncing back from sink",
+			source: []models.Event{{
+				Metadata: &models.Metadata{
+					SyncID:   "unicorn",
+					SourceID: "sinkID",
+				},
+				Title: "Foo",
+			}},
+			expectedCreateEvents: []models.Event{},
+			expectedUpdateEvents: []models.Event{},
+			expectedDeleteEvents: []models.Event{},
+		},
 	}
 
 	for _, tc := range tt {
 		t.Run(tc.name, func(t *testing.T) {
 			var source mocks.Source
 			source.On("GetSourceID").Return("sourceID")
 
+			var sink mocks.Sink
+			sink.On("GetSourceID").Return("sinkID")
+
 			var controller = Controller{
 				source: &source,
+				sink:   &sink,
 				logger: log.Default(),
 			}