Skip to content

Commit

Permalink
refactor: add tenant identifiers when creating FHIR document referenc…
Browse files Browse the repository at this point in the history 
…e resource

Signed-off-by: Kathurima Kimathi <kathurimakimathi415@gmail.com>
  • Loading branch information
@KathurimaKimathi
KathurimaKimathi committed Apr 11, 2024
1 parent 3cac70f commit 5af2123
Show file tree
Hide file tree
Showing 2 changed files with 165 additions and 5 deletions.
19 changes: 14 additions & 5 deletions pkg/clinical/usecases/clinical/referral_report.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -257,7 +257,7 @@ func (c *UseCasesClinicalImpl) GenerateReferralReportPDF(ctx context.Context, se
TerminologySystem: common.ReferralNoteLOINCTerminologySystem,
}

_, err = c.CreateDocumentReference(ctx, payload)
err = c.CreateDocumentReference(ctx, payload)
if err != nil {
utils.ReportErrorToSentry(err)
return nil, err
Expand All @@ -267,11 +267,11 @@ func (c *UseCasesClinicalImpl) GenerateReferralReportPDF(ctx context.Context, se
}

// CreateDocumentReference is a helper method to abstract the creation of a document reference
func (c *UseCasesClinicalImpl) CreateDocumentReference(ctx context.Context, payload *DocumentReferencePayload) (bool, error) {
func (c *UseCasesClinicalImpl) CreateDocumentReference(ctx context.Context, payload *DocumentReferencePayload) error {
concept, err := c.GetConcept(ctx, dto.TerminologySourceLOINC, payload.TerminologySystem)
if err != nil {
utils.ReportErrorToSentry(err)
return true, err
return err
}

finalDocStatus := domain.CompositionStatusEnumFinal
Expand Down Expand Up @@ -305,11 +305,20 @@ func (c *UseCasesClinicalImpl) CreateDocumentReference(ctx context.Context, payl
},
}

tags, err := c.GetTenantMetaTags(ctx)
if err != nil {
return err
}

documentReference.Meta = &domain.FHIRMetaInput{
Tag: tags,
}

_, err = c.infrastructure.FHIR.CreateFHIRDocumentReference(ctx, documentReference)
if err != nil {
utils.ReportErrorToSentry(err)
return true, err
return err
}

return false, nil
return nil
}
151 changes: 151 additions & 0 deletions pkg/clinical/usecases/clinical/referral_report_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,9 @@ import (
"io"
"testing"

"github.com/brianvoe/gofakeit"
"github.com/google/uuid"
"github.com/savannahghi/clinical/pkg/clinical/application/common"
"github.com/savannahghi/clinical/pkg/clinical/application/dto"
fakeExtMock "github.com/savannahghi/clinical/pkg/clinical/application/extensions/mock"
"github.com/savannahghi/clinical/pkg/clinical/domain"
Expand All @@ -17,6 +19,7 @@ import (
fakePubSubMock "github.com/savannahghi/clinical/pkg/clinical/infrastructure/services/pubsub/mock"
fakeUploadMock "github.com/savannahghi/clinical/pkg/clinical/infrastructure/services/upload/mock"
clinicalUsecase "github.com/savannahghi/clinical/pkg/clinical/usecases/clinical"
"github.com/savannahghi/scalarutils"
)

func TestUseCasesClinicalImpl_GenerateReferralReportPDF(t *testing.T) {
Expand Down Expand Up @@ -93,6 +96,14 @@ func TestUseCasesClinicalImpl_GenerateReferralReportPDF(t *testing.T) {
},
wantErr: true,
},
{
name: "Sad Case - unable to get tenant meta tags",
args: args{
ctx: addTenantIdentifierContext(ctx),
serviceRequestID: uuid.New().String(),
},
wantErr: true,
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
Expand Down Expand Up @@ -138,10 +149,150 @@ func TestUseCasesClinicalImpl_GenerateReferralReportPDF(t *testing.T) {
return nil, fmt.Errorf("failed to get organization")
}
}
if tt.name == "Sad Case - unable to get tenant meta tags" {
fakeExt.MockGetTenantIdentifiersFn = func(ctx context.Context) (*dto.TenantIdentifiers, error) {
return nil, fmt.Errorf("failed to get tenant identifiers")
}
}

if _, err := c.GenerateReferralReportPDF(tt.args.ctx, tt.args.serviceRequestID); (err != nil) != tt.wantErr {
t.Errorf("UseCasesClinicalImpl.GenerateReferralReportPDF() error = %v, wantErr %v", err, tt.wantErr)
}
})
}
}

func TestUseCasesClinicalImpl_CreateDocumentReference(t *testing.T) {
ref := fmt.Sprintf("ServiceRequest/%s", gofakeit.UUID())
url := gofakeit.URL()
mimeType := "application/json"
title := fmt.Sprintf("%s's Document Reference", gofakeit.Name())
subjectRef := fmt.Sprintf("Subject/%s", gofakeit.UUID())
type args struct {
ctx context.Context
payload *clinicalUsecase.DocumentReferencePayload
}
tests := []struct {
name string
args args
wantErr bool
}{
{
name: "Happy case: create document reference",
args: args{
ctx: addTenantIdentifierContext(context.Background()),
payload: &clinicalUsecase.DocumentReferencePayload{
Subject: &domain.FHIRReferenceInput{
Reference: &subjectRef,
},
Attachment: &domain.FHIRAttachment{
ContentType: (*scalarutils.Code)(&mimeType),
URL: (*scalarutils.URL)(&url),
Title: &title,
},
Related: &domain.FHIRReference{
Reference: &ref,
},
TerminologySystem: common.ReferralNoteLOINCTerminologySystem,
},
},
wantErr: false,
},
{
name: "Sad case: unable to create document reference",
args: args{
ctx: addTenantIdentifierContext(context.Background()),
payload: &clinicalUsecase.DocumentReferencePayload{
Subject: &domain.FHIRReferenceInput{
Reference: &subjectRef,
},
Attachment: &domain.FHIRAttachment{
ContentType: (*scalarutils.Code)(&mimeType),
URL: (*scalarutils.URL)(&url),
Title: &title,
},
Related: &domain.FHIRReference{
Reference: &ref,
},
TerminologySystem: common.ReferralNoteLOINCTerminologySystem,
},
},
wantErr: true,
},
{
name: "Sad case: unable to get concept",
args: args{
ctx: addTenantIdentifierContext(context.Background()),
payload: &clinicalUsecase.DocumentReferencePayload{
Subject: &domain.FHIRReferenceInput{
Reference: &subjectRef,
},
Attachment: &domain.FHIRAttachment{
ContentType: (*scalarutils.Code)(&mimeType),
URL: (*scalarutils.URL)(&url),
Title: &title,
},
Related: &domain.FHIRReference{
Reference: &ref,
},
TerminologySystem: common.ReferralNoteLOINCTerminologySystem,
},
},
wantErr: true,
},
{
name: "Sad case: unable to get tenant meta tags",
args: args{
ctx: addTenantIdentifierContext(context.Background()),
payload: &clinicalUsecase.DocumentReferencePayload{
Subject: &domain.FHIRReferenceInput{
Reference: &subjectRef,
},
Attachment: &domain.FHIRAttachment{
ContentType: (*scalarutils.Code)(&mimeType),
URL: (*scalarutils.URL)(&url),
Title: &title,
},
Related: &domain.FHIRReference{
Reference: &ref,
},
TerminologySystem: common.ReferralNoteLOINCTerminologySystem,
},
},
wantErr: true,
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
fakeExt := fakeExtMock.NewFakeBaseExtensionMock()
fakeFHIR := fakeFHIRMock.NewFHIRMock()
fakeOCL := fakeOCLMock.NewFakeOCLMock()
fakePubSub := fakePubSubMock.NewPubSubServiceMock()
fakeUpload := fakeUploadMock.NewFakeUploadMock()
fakeAdvantage := fakeAdvantageMock.NewFakeAdvantageMock()

infra := infrastructure.NewInfrastructureInteractor(fakeExt, fakeFHIR, fakeOCL, fakeUpload, fakePubSub, fakeAdvantage)
c := clinicalUsecase.NewUseCasesClinicalImpl(infra)

if tt.name == "Sad case: unable to create document reference" {
fakeFHIR.MockCreateFHIRDocumentReferenceFn = func(ctx context.Context, documentReference *domain.FHIRDocumentReferenceInput) (*domain.FHIRDocumentReference, error) {
return nil, fmt.Errorf("failed to create FHIR document reference")
}
}
if tt.name == "Sad case: unable to get concept" {
fakeOCL.MockGetConceptFn = func(ctx context.Context, org, source, concept string, includeMappings, includeInverseMappings bool) (*domain.Concept, error) {
return nil, fmt.Errorf("failed to get concept")
}
}
if tt.name == "Sad case: unable to get tenant meta tags" {
fakeExt.MockGetTenantIdentifiersFn = func(ctx context.Context) (*dto.TenantIdentifiers, error) {
return nil, fmt.Errorf("failed to get tenant identifiers")
}
}

if err := c.CreateDocumentReference(tt.args.ctx, tt.args.payload); (err != nil) != tt.wantErr {
t.Errorf("UseCasesClinicalImpl.CreateDocumentReference() error = %v, wantErr %v", err, tt.wantErr)
}
})
}
}

0 comments on commit 5af2123

Please sign in to comment.