mirror of
https://github.com/0ceanSlim/grain.git
synced 2024-11-22 08:37:13 +00:00
26 lines
714 B
Go
26 lines
714 B
Go
|
package mongo
|
||
|
|
||
|
import (
|
||
|
"context"
|
||
|
"fmt"
|
||
|
nostr "grain/server/types" // Adjust import path as needed
|
||
|
|
||
|
"go.mongodb.org/mongo-driver/bson"
|
||
|
)
|
||
|
|
||
|
// CheckDuplicateEvent checks if an event with the same ID already exists in the collection.
|
||
|
func CheckDuplicateEvent(ctx context.Context, evt nostr.Event) (bool, error) {
|
||
|
collection := GetCollection(evt.Kind)
|
||
|
filter := bson.M{"id": evt.ID}
|
||
|
|
||
|
var existingEvent nostr.Event
|
||
|
err := collection.FindOne(ctx, filter).Decode(&existingEvent)
|
||
|
if err != nil {
|
||
|
if err.Error() == "mongo: no documents in result" {
|
||
|
return false, nil // No duplicate found
|
||
|
}
|
||
|
return false, fmt.Errorf("error checking for duplicate event: %v", err)
|
||
|
}
|
||
|
return true, nil // Duplicate found
|
||
|
}
|