feat: bulk invocie edit [WIP]

Author: turip

openmeter/billing/adapter/invoice.go

@@ -13,6 +13,7 @@ import (
 	"github.com/openmeterio/openmeter/api"
 	"github.com/openmeterio/openmeter/openmeter/app"
 	"github.com/openmeterio/openmeter/openmeter/billing"
+	"github.com/openmeterio/openmeter/openmeter/customer"
 	"github.com/openmeterio/openmeter/openmeter/ent/db"
 	"github.com/openmeterio/openmeter/openmeter/ent/db/billinginvoice"
 	"github.com/openmeterio/openmeter/openmeter/ent/db/billinginvoiceline"
@@ -606,33 +607,56 @@ func (a *adapter) UpdateInvoice(ctx context.Context, in billing.UpdateInvoiceAda
 
 func (a *adapter) GetInvoiceOwnership(ctx context.Context, in billing.GetInvoiceOwnershipAdapterInput) (billing.GetOwnershipAdapterResponse, error) {
 	if err := in.Validate(); err != nil {
-		return billing.GetOwnershipAdapterResponse{}, billing.ValidationError{
+		return nil, billing.ValidationError{
 			Err: err,
 		}
 	}
 
 	return entutils.TransactingRepo(ctx, a, func(ctx context.Context, tx *adapter) (billing.GetOwnershipAdapterResponse, error) {
-		dbInvoice, err := tx.db.BillingInvoice.Query().
-			Where(billinginvoice.ID(in.ID)).
-			Where(billinginvoice.Namespace(in.Namespace)).
-			First(ctx)
+		dbInvoices, err := tx.db.BillingInvoice.Query().
+			Where(
+				billinginvoice.IDIn(
+					lo.Map(
+						in.InvoiceIDs,
+						func(invoiceID billing.InvoiceID, _ int) string {
+							return invoiceID.ID
+						},
+					)...,
+				),
+			).
+			All(ctx)
 		if err != nil {
-			if db.IsNotFound(err) {
-				return billing.GetOwnershipAdapterResponse{}, billing.NotFoundError{
-					Entity: billing.EntityInvoice,
-					ID:     in.ID,
-					Err:    err,
+			return nil, err
+		}
+
+		invoiceToCustomerID := lo.SliceToMap(dbInvoices, func(dbInvoice *db.BillingInvoice) (billing.InvoiceID, customer.CustomerID) {
+			return billing.InvoiceID{
+					Namespace: dbInvoice.Namespace,
+					ID:        dbInvoice.ID,
+				}, customer.CustomerID{
+					Namespace: dbInvoice.Namespace,
+					ID:        dbInvoice.CustomerID,
 				}
+		})
+
+		// Let's validate if we got all the invoices (and most importantly look up invoices with
+		// namespaceID, to prevent looking up invoices with different than expected namespace ID)
+		var notFoundErrs []error
+		for _, invoiceID := range in.InvoiceIDs {
+			if _, found := invoiceToCustomerID[invoiceID]; !found {
+				notFoundErrs = append(notFoundErrs, billing.NotFoundError{
+					Entity: billing.EntityInvoice,
+					ID:     invoiceID.ID,
+					Err:    fmt.Errorf("invoice not found: %s", invoiceID.ID),
+				})
 			}
+		}
 
-			return billing.GetOwnershipAdapterResponse{}, err
+		if len(notFoundErrs) > 0 {
+			return nil, errors.Join(notFoundErrs...)
 		}
 
-		return billing.GetOwnershipAdapterResponse{
-			Namespace:  dbInvoice.Namespace,
-			InvoiceID:  dbInvoice.ID,
-			CustomerID: dbInvoice.CustomerID,
-		}, nil
+		return invoiceToCustomerID, nil
 	})
 }
 

openmeter/billing/invoice.go

@@ -867,14 +867,18 @@ type (
 
 type UpdateInvoiceAdapterInput = Invoice
 
-type GetInvoiceOwnershipAdapterInput = InvoiceID
+type GetInvoiceOwnershipAdapterInput struct {
+	InvoiceIDs []InvoiceID
+}
 
-type GetOwnershipAdapterResponse struct {
-	Namespace  string
-	InvoiceID  string
-	CustomerID string
+func (i GetInvoiceOwnershipAdapterInput) Validate() error {
+	if len(i.InvoiceIDs) == 0 {
+		return errors.New("invoice IDs are required")
+	}
 }
 
+type GetOwnershipAdapterResponse map[InvoiceID]customer.CustomerID
+
 type DeleteInvoiceInput = InvoiceID
 
 type UpdateInvoiceLinesInternalInput struct {
@@ -1061,3 +1065,19 @@ func (i UpdateInvoiceFieldsInput) Validate() error {
 }
 
 type RecalculateGatheringInvoicesInput = customer.CustomerID
+
+type StandardImmutableInvoiceUpdate struct {
+	UpsertValidationIssues mo.Option[ValidationIssues]
+}
+
+type BulkUpdateInvoicesInput struct {
+	IncludeDeletedLines                  bool
+	Invoices                             []InvoiceID
+	GatheringInvoiceEditFunction         func(*Invoice) error
+	StandardMutableInvoiceEditFunction   func(*Invoice) error
+	StandardImmutableInvoiceEditFunction func(*Invoice) (StandardImmutableInvoiceUpdate, error)
+}
+
+type BulkUpdateInvoicesResult struct {
+	InvoicesByID map[InvoiceID]Invoice
+}

openmeter/billing/service.go

@@ -70,6 +70,7 @@ type InvoiceService interface {
 	DeleteInvoice(ctx context.Context, input DeleteInvoiceInput) error
 	// UpdateInvoice updates an invoice as a whole
 	UpdateInvoice(ctx context.Context, input UpdateInvoiceInput) (Invoice, error)
+	BulkUpdateInvoices(ctx context.Context, input BulkUpdateInvoicesInput) (BulkUpdateInvoicesResult, error)
 
 	// SimulateInvoice generates an invoice based on the provided input, but does not persist it
 	// can be used to execute the invoice generation logic without actually creating an invoice in the database

openmeter/billing/service/invoice.go

@@ -977,6 +977,26 @@ func (s *Service) UpdateInvoice(ctx context.Context, input billing.UpdateInvoice
 	)
 }
 
+func (s *Service) BulkUpdateInvoices(ctx context.Context, input billing.BulkUpdateInvoicesInput) (billing.BulkUpdateInvoicesResult, error) {
+	if err := input.Validate(); err != nil {
+		return billing.BulkUpdateInvoicesResult{}, billing.ValidationError{
+			Err: err,
+		}
+	}
+
+	return transaction.Run(ctx, s.adapter, func(ctx context.Context) (billing.BulkUpdateInvoicesResult, error) {
+		invoiceToCustomerID, err := s.adapter.GetInvoiceOwnership(ctx, billing.GetInvoiceOwnershipAdapterInput{
+			InvoiceIDs: input.Invoices,
+		})
+		if err != nil {
+			return billing.BulkUpdateInvoicesResult{}, fmt.Errorf("getting invoice ownership: %w", err)
+		}
+	})
+
+	return transcationForInvoiceManipulation(ctx, s, invoicesByCustomer, func(ctx context.Context) (billing.BulkUpdateInvoicesResult, error) {
+	})
+}
+
 // updateInvoice calls the adapter to update the invoice and returns the updated invoice including any expands that are
 // the responsibility of the service
 func (s Service) updateInvoice(ctx context.Context, in billing.UpdateInvoiceAdapterInput) (billing.Invoice, error) {

openmeter/billing/service/invoicebulk.go

@@ -0,0 +1,50 @@
+package billingservice
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/openmeterio/openmeter/openmeter/billing"
+	"github.com/openmeterio/openmeter/openmeter/customer"
+	"github.com/openmeterio/openmeter/pkg/framework/transaction"
+)
+
+func (s *Service) BulkUpdateInvoices(ctx context.Context, input billing.BulkUpdateInvoicesInput) (billing.BulkUpdateInvoicesResult, error) {
+	if err := input.Validate(); err != nil {
+		return billing.BulkUpdateInvoicesResult{}, billing.ValidationError{
+			Err: err,
+		}
+	}
+
+	return transaction.Run(ctx, s.adapter, func(ctx context.Context) (billing.BulkUpdateInvoicesResult, error) {
+		invoiceToCustomerID, err := s.adapter.GetInvoiceOwnership(ctx, billing.GetInvoiceOwnershipAdapterInput{
+			InvoiceIDs: input.Invoices,
+		})
+		if err != nil {
+			return billing.BulkUpdateInvoicesResult{}, fmt.Errorf("getting invoice ownership: %w", err)
+		}
+
+		invoiceIDsByCustomerID := map[customer.CustomerID][]billing.InvoiceID{}
+		for invoiceID, customerID := range invoiceToCustomerID {
+			invoiceIDsByCustomerID[customerID] = append(invoiceIDsByCustomerID[customerID], invoiceID)
+		}
+
+		for customerID, invoiceIDs := range invoiceIDsByCustomerID {
+			xxx, err := transcationForInvoiceManipulation(ctx, s, customerID, func(ctx context.Context) (billing.BulkUpdateInvoicesResult, error) {
+				invoices := make([]*billing.Invoice, 0, len(invoiceIDs))
+				for _, invoiceID := range invoiceIDs {
+					invoice, err := s.GetInvoiceByID(ctx, billing.GetInvoiceByIdInput{
+						Invoice: invoiceID,
+						Expand: billing.InvoiceExpandAll.
+					SetDeletedLines(input.IncludeDeletedLines),
+					})
+					if err != nil {
+						return billing.BulkUpdateInvoicesResult{}, fmt.Errorf("getting invoice: %w", err)
+					}
+			})
+			if err != nil {
+				return billing.BulkUpdateInvoicesResult{}, fmt.Errorf("updating invoices: %w", err)
+			}
+		}
+	})
+}

openmeter/billing/service/lineservice/linebase.go

@@ -109,7 +109,7 @@ func (l lineBase) Validate(ctx context.Context, invoice *billing.Invoice) error
 	// Expanding the split lines are mandatory for the lineservice to work properly.
 	if l.line.SplitLineGroupID != nil && l.line.SplitLineHierarchy == nil {
 		return billing.ValidationError{
-			Err: fmt.Errorf("split line group[%s] has no hierarchy expanded hierarchy", *l.line.SplitLineGroupID),
+			Err: fmt.Errorf("split line group[%s] has no expanded hierarchy, while being part of a split line group", *l.line.SplitLineGroupID),
 		}
 	}