fix: fallback to create when resource isn't found while update (#24)

Revolyssup · web-flow · commit 0ed4a1885534 · 2023-12-01T18:06:09.000+08:00
diff --git a/pkg/adapter/etcd.go b/pkg/adapter/etcd.go
@@ -163,10 +163,13 @@ func (a *adapter) handleUpdateEvent(ctx context.Context, ev *Event) {
 			return
 		}
 		if prevKV == nil {
-			log.Error("object not found (during update event), ignore it",
+			log.Info("object not found (during update event), ignore it",
 				zap.Int64("revision", rev),
 				zap.String("key", ev.Key),
 			)
+			// Fallback to add event when the resource isn't found
+			ev.Type = EventAdd
+			a.handleAddEvent(ctx, ev)
 			return
 		}
 		rev, prev, ok, err := a.backend.Update(ctx, ev.Key, ev.Value, prevKV.ModRevision, 0)

Original file line number	Diff line number	Diff line change
`@@ -163,10 +163,13 @@ func (a adapter) handleUpdateEvent(ctx context.Context, ev Event) {`
`163`	`163`	`return`
`164`	`164`	`}`
`165`	`165`	`if prevKV == nil {`
`166`		`- log.Error("object not found (during update event), ignore it",`
	`166`	`+ log.Info("object not found (during update event), ignore it",`
`167`	`167`	`zap.Int64("revision", rev),`
`168`	`168`	`zap.String("key", ev.Key),`
`169`	`169`	`)`
	`170`	`+ // Fallback to add event when the resource isn't found`
	`171`	`+ ev.Type = EventAdd`
	`172`	`+ a.handleAddEvent(ctx, ev)`
`170`	`173`	`return`
`171`	`174`	`}`
`172`	`175`	`rev, prev, ok, err := a.backend.Update(ctx, ev.Key, ev.Value, prevKV.ModRevision, 0)`