feat: subscription create need namespace

Signed-off-by: xdlbdy <[email protected]>

internal/controller/trigger/controller.go

@@ -179,13 +179,6 @@ func (ctrl *controller) CreateSubscription(ctx context.Context,
 		})
 		return nil, err
 	}
-	// subscription name can't be repeated in a namespace
-	eventbusID := vanus.NewIDFromUint64(request.Subscription.EventbusId)
-	_sub := ctrl.subscriptionManager.GetSubscriptionByName(ctx, eventbusID, request.Subscription.Name)
-	if _sub != nil {
-		return nil, errors.ErrInvalidRequest.WithMessage(
-			fmt.Sprintf("subscription name %s has exist", request.Subscription.Name))
-	}
 	sub := convert.FromPbSubscriptionRequest(request.Subscription)
 	sub.ID, err = vanus.NewID()
 	sub.CreatedAt = time.Now()
@@ -230,14 +223,6 @@ func (ctrl *controller) UpdateSubscription(ctx context.Context,
 	if request.Subscription.EventbusId != uint64(sub.EventbusID) {
 		return nil, errors.ErrInvalidRequest.WithMessage("can not change eventbus")
 	}
-	if request.Subscription.Name != sub.Name {
-		// subscription name can't be repeated in a namespace
-		_sub := ctrl.subscriptionManager.GetSubscriptionByName(ctx, sub.NamespaceID, request.Subscription.Name)
-		if _sub != nil {
-			return nil, errors.ErrInvalidRequest.WithMessage(
-				fmt.Sprintf("subscription name %s has exist", request.Subscription.Name))
-		}
-	}
 	update := convert.FromPbSubscriptionRequest(request.Subscription)
 	transChange := 0
 	if !sub.Transformer.Exist() && update.Transformer.Exist() {