Básicamente, tengo esta estructura que debe aparecer en mongoDb y tengo que escribir una consulta que primero verificaría si un objeto con el ID de perfil ya existe, enviaría una nueva ID de oferta a la matriz de ofertas de objetos existentes. Y si no existe un objeto con ID de perfil, crearía uno y agregaría la ID de oferta a la matriz de ofertas. ¿Es posible hacerlo en una sola consulta? si es así, ¿alguien podría ayudarme sobre cómo podría implementarse?
type IgnoreOffer struct { ProfileID primitive.ObjectID `json:"profileID" bson:"profileID"` Offers []primitive.ObjectID `json:"offers,omitempty" bson:"offers,omitempty"` }Aquí está mi código, sin embargo, no crea un nuevo objeto en la base de datos.
func getIgnoreOffersCollection() *mongo.Collection { return db.GetMongoCollection("ignoreOffers") } func ignoreOffer(profileId primitive.ObjectID, offerId primitive.ObjectID) error { var offer IgnoreOffer offer.ProfileID = profileId ctx, _ := db.GetTimeoutContext() filter := bson.M{"profileID": profileId} update := bson.M{ "$set": bson.M{ "updatedAt": time.Now(), }, "$push": bson.M{ "offers": offerId, }, } _, err := getIgnoreOffersCollection().UpdateOne(ctx, filter, update) if err != nil { log.Error("could not update ignoreOffer collection, err: ", err) return err } return nil }Necesitas un upsert en tu caso:
_, err := getIgnoreOffersCollection().UpdateOne(ctx, filter, update, options.Update().SetUpsert(true))