Skip to content

Commit

Permalink
Adding TODOs.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Jul 6, 2024
1 parent 2fde58a commit 2842b1e
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions sources/mongo/change_event.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@ type ChangeEvent struct {
}

func NewChangeEvent(rawChangeEvent bson.M) (*ChangeEvent, error) {
// TODO: Add tests
operationType, isOk := rawChangeEvent["operationType"]
if !isOk {
return nil, fmt.Errorf("failed to get operationType from change event: %v", rawChangeEvent)
Expand Down Expand Up @@ -93,6 +94,7 @@ func (c ChangeEvent) getFullDocument() (bson.M, error) {
}

func (c ChangeEvent) ToMessage() (*Message, error) {
// TODO: Add tests
switch c.operationType {
case "delete":
// TODO: Think about providing the `before` row for a deleted event.
Expand Down

0 comments on commit 2842b1e

Please sign in to comment.