From db7c862fa8cd4e7bbd41a7822f81924defaa2a18 Mon Sep 17 00:00:00 2001 From: Aditya Siregar Date: Sun, 10 Aug 2025 20:58:32 +0700 Subject: [PATCH] fix unit --- internal/processor/unit_processor.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/internal/processor/unit_processor.go b/internal/processor/unit_processor.go index e8cd268..732d4b3 100644 --- a/internal/processor/unit_processor.go +++ b/internal/processor/unit_processor.go @@ -1,6 +1,7 @@ package processor import ( + "apskel-pos-be/internal/appcontext" "apskel-pos-be/internal/entities" "apskel-pos-be/internal/mappers" "apskel-pos-be/internal/models" @@ -54,7 +55,8 @@ func (p *UnitProcessorImpl) CreateUnit(ctx context.Context, req *models.CreateUn } func (p *UnitProcessorImpl) GetUnitByID(ctx context.Context, id uuid.UUID) (*models.UnitResponse, error) { - organizationID := uuid.Nil // This should come from context + contextInfo := appcontext.FromGinContext(ctx) + organizationID := contextInfo.OrganizationID unit, err := p.unitRepo.GetByID(ctx, id, organizationID) if err != nil { @@ -124,7 +126,8 @@ func (p *UnitProcessorImpl) ListUnits(ctx context.Context, organizationID uuid.U } func (p *UnitProcessorImpl) UpdateUnit(ctx context.Context, id uuid.UUID, req *models.UpdateUnitRequest) (*models.UnitResponse, error) { - organizationID := uuid.Nil + contextInfo := appcontext.FromGinContext(ctx) + organizationID := contextInfo.OrganizationID existingUnit, err := p.unitRepo.GetByID(ctx, id, organizationID) if err != nil { @@ -159,7 +162,8 @@ func (p *UnitProcessorImpl) UpdateUnit(ctx context.Context, id uuid.UUID, req *m } func (p *UnitProcessorImpl) DeleteUnit(ctx context.Context, id uuid.UUID) error { - organizationID := uuid.Nil + contextInfo := appcontext.FromGinContext(ctx) + organizationID := contextInfo.OrganizationID err := p.unitRepo.Delete(ctx, id, organizationID) if err != nil {