|
|
@@ -166,7 +166,7 @@ func (r *udpForWardingRepository) DeleteUdpForwardingIpsById(ctx context.Context
|
|
|
|
|
|
collection := r.mongoDB.Collection("udp_forwarding_rules")
|
|
|
|
|
|
- err := collection.Remove(ctx, bson.M{"host_id": udpId})
|
|
|
+ err := collection.Remove(ctx, bson.M{"udp_id": udpId})
|
|
|
|
|
|
if err != nil {
|
|
|
if errors.Is(err, mongo.ErrNoDocuments) {
|
