Skip to content

Commit 24cedcc

Browse files
committed
fix: remove AddonIDOrKey
1 parent 14105c0 commit 24cedcc

2 files changed

Lines changed: 14 additions & 32 deletions

File tree

openmeter/subscription/addon/repo/subscriptionaddon.go

Lines changed: 6 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@ import (
55
"fmt"
66

77
"github.com/openmeterio/openmeter/openmeter/ent/db"
8-
addondb "github.com/openmeterio/openmeter/openmeter/ent/db/addon"
98
dbsubscriptionaddon "github.com/openmeterio/openmeter/openmeter/ent/db/subscriptionaddon"
109
dbsubscriptionaddonquantity "github.com/openmeterio/openmeter/openmeter/ent/db/subscriptionaddonquantity"
1110
subscriptionaddon "github.com/openmeterio/openmeter/openmeter/subscription/addon"
@@ -56,20 +55,12 @@ func (r *subscriptionAddonRepo) Get(ctx context.Context, params subscriptionaddo
5655
return entutils.TransactingRepo(ctx, r, func(ctx context.Context, repo *subscriptionAddonRepo) (*subscriptionaddon.SubscriptionAddon, error) {
5756
query := querySubscriptionAddon(repo.db.SubscriptionAddon.Query())
5857

59-
if params.ID != "" {
60-
query = query.Where(
61-
dbsubscriptionaddon.ID(params.ID),
62-
dbsubscriptionaddon.Namespace(params.Namespace),
63-
)
64-
if params.SubscriptionID != "" {
65-
query = query.Where(dbsubscriptionaddon.SubscriptionID(params.SubscriptionID))
66-
}
67-
} else {
68-
query = query.Where(
69-
dbsubscriptionaddon.Namespace(params.Namespace),
70-
dbsubscriptionaddon.SubscriptionID(params.SubscriptionID),
71-
dbsubscriptionaddon.HasAddonWith(addondb.Or(addondb.ID(params.AddonIDOrKey), addondb.Key(params.AddonIDOrKey))),
72-
)
58+
query = query.Where(
59+
dbsubscriptionaddon.ID(params.ID),
60+
dbsubscriptionaddon.Namespace(params.Namespace),
61+
)
62+
if params.SubscriptionID != "" {
63+
query = query.Where(dbsubscriptionaddon.SubscriptionID(params.SubscriptionID))
7364
}
7465

7566
entity, err := query.Only(ctx)

openmeter/subscription/addon/service.go

Lines changed: 8 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -77,31 +77,22 @@ type GetSubscriptionAddonInput struct {
7777

7878
// SubscriptionID
7979
SubscriptionID string `json:"subscriptionId"`
80-
81-
// AddonIDOrKey
82-
AddonIDOrKey string `json:"addonIdOrKey"`
8380
}
8481

8582
func (i GetSubscriptionAddonInput) Validate() error {
8683
var errs []error
8784

88-
if i.NamespacedID.Namespace == "" {
89-
errs = append(errs, errors.New("namespace is required"))
85+
if err := i.NamespacedID.Validate(); err != nil {
86+
errs = append(errs, err)
9087
}
9188

92-
if i.ID == "" {
93-
if i.SubscriptionID == "" {
94-
errs = append(errs, errors.New("subscription id must be provided if assignment id is not provided"))
95-
} else if _, err := ulid.Parse(i.SubscriptionID); err != nil {
96-
errs = append(errs, errors.New("subscription id is not a valid ULID"))
97-
}
89+
if _, err := ulid.Parse(i.NamespacedID.ID); err != nil {
90+
errs = append(errs, errors.New("assignment id is not a valid ULID"))
91+
}
9892

99-
if i.AddonIDOrKey == "" {
100-
errs = append(errs, errors.New("add-on id or key must be provided if assignment id is not provided"))
101-
}
102-
} else {
103-
if _, err := ulid.Parse(i.ID); err != nil {
104-
errs = append(errs, errors.New("assignment id is not a valid ULID"))
93+
if i.SubscriptionID != "" {
94+
if _, err := ulid.Parse(i.NamespacedID.ID); err != nil {
95+
errs = append(errs, errors.New("subscription id is not a valid ULID"))
10596
}
10697
}
10798

0 commit comments

Comments
 (0)