feat: create episode of care

gqlgen.yml

@@ -22,6 +22,7 @@ autobind:
   - "github.com/savannahghi/scalarutils"
   - "github.com/savannahghi/enumutils"
   - "github.com/savannahghi/firebasetools"
+  - "github.com/savannahghi/clinical/pkg/clinical/application/dto"
   - "github.com/savannahghi/clinical/pkg/clinical/domain"
   - "github.com/savannahghi/clinical/pkg/clinical/presentation/graph"
   - "github.com/savannahghi/clinical/pkg/clinical/infrastructure/services/openconceptlab"

pkg/clinical/application/dto/enums.go

@@ -7,3 +7,12 @@ const (
 	MFLCode   OrganizationIdentifierType = "MFLCode"
 	Other     OrganizationIdentifierType = "Other"
 )
+
+type EpisodeOfCareStatusEnum string
+
+const (
+	EpisodeOfCareStatusEnumPlanned   EpisodeOfCareStatusEnum = "planned"
+	EpisodeOfCareStatusEnumActive    EpisodeOfCareStatusEnum = "active"
+	EpisodeOfCareStatusEnumFinished  EpisodeOfCareStatusEnum = "finished"
+	EpisodeOfCareStatusEnumCancelled EpisodeOfCareStatusEnum = "cancelled"
+)

pkg/clinical/application/dto/input.go

@@ -10,3 +10,8 @@ type OrganizationInput struct {
 	PhoneNumber string                   `json:"phoneNumber,omitempty"`
 	Identifiers []OrganizationIdentifier `json:"identifiers,omitempty"`
 }
+
+type EpisodeOfCareInput struct {
+	Status    EpisodeOfCareStatusEnum `json:"status"`
+	PatientID string                  `json:"patientID"`
+}

pkg/clinical/application/dto/output.go

@@ -13,3 +13,9 @@ type Organization struct {
 	Identifiers  []OrganizationIdentifier `json:"identifiers"`
 	PhoneNumbers []string                 `json:"phoneNumbers"`
 }
+
+type EpisodeOfCare struct {
+	ID        string                  `json:"id"`
+	Status    EpisodeOfCareStatusEnum `json:"status"`
+	PatientID string                  `json:"patientID"`
+}

pkg/clinical/infrastructure/datastore/cloudhealthcare/fhir.go

@@ -136,7 +136,7 @@ func (fh StoreImpl) SearchFHIREpisodeOfCare(ctx context.Context, params map[stri
 
 // CreateEpisodeOfCare is the final common pathway for creation of episodes of
 // care.
-func (fh StoreImpl) CreateEpisodeOfCare(ctx context.Context, episode domain.FHIREpisodeOfCare) (*domain.EpisodeOfCarePayload, error) {
+func (fh StoreImpl) CreateEpisodeOfCare(ctx context.Context, episode domain.FHIREpisodeOfCareInput) (*domain.EpisodeOfCarePayload, error) {
 	payload, err := converterandformatter.StructToMap(episode)
 	if err != nil {
 		return nil, fmt.Errorf("unable to turn episode of care input into a map: %w", err)

pkg/clinical/infrastructure/datastore/cloudhealthcare/fhir_unit_test.go

@@ -2903,7 +2903,7 @@ func TestStoreImpl_CreateEpisodeOfCare(t *testing.T) {
 	OrgRef := "Organization/"
 	type args struct {
 		ctx     context.Context
-		episode domain.FHIREpisodeOfCare
+		episode domain.FHIREpisodeOfCareInput
 	}
 	tests := []struct {
 		name    string
@@ -2914,13 +2914,13 @@ func TestStoreImpl_CreateEpisodeOfCare(t *testing.T) {
 			name: "Happy case: create episode of care",
 			args: args{
 				ctx: context.Background(),
-				episode: domain.FHIREpisodeOfCare{
+				episode: domain.FHIREpisodeOfCareInput{
 					ID:     &UUID,
 					Status: &status,
-					Patient: &domain.FHIRReference{
+					Patient: &domain.FHIRReferenceInput{
 						Reference: &PatientRef,
 					},
-					ManagingOrganization: &domain.FHIRReference{
+					ManagingOrganization: &domain.FHIRReferenceInput{
 						Reference: &OrgRef,
 					},
 				},
@@ -2931,13 +2931,13 @@ func TestStoreImpl_CreateEpisodeOfCare(t *testing.T) {
 			name: "Happy case: create episode of care, episode does not exist",
 			args: args{
 				ctx: context.Background(),
-				episode: domain.FHIREpisodeOfCare{
+				episode: domain.FHIREpisodeOfCareInput{
 					ID:     &UUID,
 					Status: &status,
-					Patient: &domain.FHIRReference{
+					Patient: &domain.FHIRReferenceInput{
 						Reference: &PatientRef,
 					},
-					ManagingOrganization: &domain.FHIRReference{
+					ManagingOrganization: &domain.FHIRReferenceInput{
 						Reference: &OrgRef,
 					},
 				},
@@ -2948,13 +2948,13 @@ func TestStoreImpl_CreateEpisodeOfCare(t *testing.T) {
 			name: "Sad case: failed to search FHIR episode of care",
 			args: args{
 				ctx: context.Background(),
-				episode: domain.FHIREpisodeOfCare{
+				episode: domain.FHIREpisodeOfCareInput{
 					ID:     &UUID,
 					Status: &status,
-					Patient: &domain.FHIRReference{
+					Patient: &domain.FHIRReferenceInput{
 						Reference: &PatientRef,
 					},
-					ManagingOrganization: &domain.FHIRReference{
+					ManagingOrganization: &domain.FHIRReferenceInput{
 						Reference: &OrgRef,
 					},
 				},
@@ -2965,13 +2965,13 @@ func TestStoreImpl_CreateEpisodeOfCare(t *testing.T) {
 			name: "Sad case: failed to create FHIR resource",
 			args: args{
 				ctx: context.Background(),
-				episode: domain.FHIREpisodeOfCare{
+				episode: domain.FHIREpisodeOfCareInput{
 					ID:     &UUID,
 					Status: &status,
-					Patient: &domain.FHIRReference{
+					Patient: &domain.FHIRReferenceInput{
 						Reference: &PatientRef,
 					},
-					ManagingOrganization: &domain.FHIRReference{
+					ManagingOrganization: &domain.FHIRReferenceInput{
 						Reference: &OrgRef,
 					},
 				},

pkg/clinical/infrastructure/datastore/cloudhealthcare/mock/fhir_mock.go

@@ -12,7 +12,7 @@ import (
 
 // FHIRMock struct implements mocks of FHIR methods.
 type FHIRMock struct {
-	MockCreateEpisodeOfCareFn    func(ctx context.Context, episode domain.FHIREpisodeOfCare) (*domain.EpisodeOfCarePayload, error)
+	MockCreateEpisodeOfCareFn    func(ctx context.Context, episode domain.FHIREpisodeOfCareInput) (*domain.EpisodeOfCarePayload, error)
 	MockSearchFHIRConditionFn    func(ctx context.Context, params map[string]interface{}) (*domain.FHIRConditionRelayConnection, error)
 	MockCreateFHIRConditionFn    func(ctx context.Context, input domain.FHIRConditionInput) (*domain.FHIRConditionRelayPayload, error)
 	MockCreateFHIROrganizationFn func(ctx context.Context, input domain.FHIROrganizationInput) (*domain.FHIROrganizationRelayPayload, error)
@@ -69,23 +69,23 @@ type FHIRMock struct {
 
 // NewFHIRMock initializes a new instance of FHIR mock
 func NewFHIRMock() *FHIRMock {
-	UUID := uuid.New().String()
-	PatientRef := "Patient/1"
-	OrgRef := "Organization/1"
-	status := domain.EpisodeOfCareStatusEnumActive
-
 	return &FHIRMock{
-		MockCreateEpisodeOfCareFn: func(ctx context.Context, episode domain.FHIREpisodeOfCare) (*domain.EpisodeOfCarePayload, error) {
+		MockCreateEpisodeOfCareFn: func(ctx context.Context, episode domain.FHIREpisodeOfCareInput) (*domain.EpisodeOfCarePayload, error) {
+			UUID := uuid.New().String()
+			PatientRef := "Patient/1"
+			OrgRef := "Organization/1"
+			status := domain.EpisodeOfCareStatusEnumActive
 			return &domain.EpisodeOfCarePayload{
 				EpisodeOfCare: &domain.FHIREpisodeOfCare{
 					ID:            &UUID,
 					Text:          &domain.FHIRNarrative{},
 					Identifier:    []*domain.FHIRIdentifier{},
-					Status:        &(status),
+					Status:        &status,
 					StatusHistory: []*domain.FHIREpisodeofcareStatushistory{},
 					Type:          []*domain.FHIRCodeableConcept{},
 					Diagnosis:     []*domain.FHIREpisodeofcareDiagnosis{},
 					Patient: &domain.FHIRReference{
+						ID:        &UUID,
 						Reference: &PatientRef,
 					},
 					ManagingOrganization: &domain.FHIRReference{
@@ -101,6 +101,7 @@ func NewFHIRMock() *FHIRMock {
 			}, nil
 		},
 		MockCreateFHIRConditionFn: func(ctx context.Context, input domain.FHIRConditionInput) (*domain.FHIRConditionRelayPayload, error) {
+			UUID := uuid.New().String()
 			return &domain.FHIRConditionRelayPayload{
 				Resource: &domain.FHIRCondition{
 					ID:                 &UUID,
@@ -134,6 +135,7 @@ func NewFHIRMock() *FHIRMock {
 			}, nil
 		},
 		MockCreateFHIROrganizationFn: func(ctx context.Context, input domain.FHIROrganizationInput) (*domain.FHIROrganizationRelayPayload, error) {
+			UUID := uuid.New().String()
 			active := true
 			name := gofakeit.Name()
 			uri := ""
@@ -182,12 +184,14 @@ func NewFHIRMock() *FHIRMock {
 			return true, nil
 		},
 		MockOpenEpisodesFn: func(ctx context.Context, patientReference string) ([]*domain.FHIREpisodeOfCare, error) {
+			UUID := uuid.New().String()
+			PatientRef := "Patient/1"
+			OrgRef := "Organization/1"
 			return []*domain.FHIREpisodeOfCare{
 				{
 					ID:            &UUID,
 					Text:          &domain.FHIRNarrative{},
 					Identifier:    []*domain.FHIRIdentifier{},
-					Status:        &(status),
 					StatusHistory: []*domain.FHIREpisodeofcareStatushistory{},
 					Type:          []*domain.FHIRCodeableConcept{},
 					Diagnosis:     []*domain.FHIREpisodeofcareDiagnosis{},
@@ -209,12 +213,14 @@ func NewFHIRMock() *FHIRMock {
 			return &domain.FHIREncounterRelayPayload{}, nil
 		},
 		MockGetFHIREpisodeOfCareFn: func(ctx context.Context, id string) (*domain.FHIREpisodeOfCareRelayPayload, error) {
+			UUID := uuid.New().String()
+			PatientRef := "Patient/1"
+			OrgRef := "Organization/1"
 			return &domain.FHIREpisodeOfCareRelayPayload{
 				Resource: &domain.FHIREpisodeOfCare{
 					ID:            &UUID,
 					Text:          &domain.FHIRNarrative{},
 					Identifier:    []*domain.FHIRIdentifier{},
-					Status:        &(status),
 					StatusHistory: []*domain.FHIREpisodeofcareStatushistory{},
 					Type:          []*domain.FHIRCodeableConcept{},
 					Diagnosis:     []*domain.FHIREpisodeofcareDiagnosis{},
@@ -236,6 +242,8 @@ func NewFHIRMock() *FHIRMock {
 			return []*domain.FHIREncounter{}, nil
 		},
 		MockSearchFHIREpisodeOfCareFn: func(ctx context.Context, params map[string]interface{}) (*domain.FHIREpisodeOfCareRelayConnection, error) {
+			PatientRef := "Patient/1"
+			OrgRef := "Organization/1"
 			return &domain.FHIREpisodeOfCareRelayConnection{
 				Edges: []*domain.FHIREpisodeOfCareRelayEdge{
 					{
@@ -336,6 +344,7 @@ func NewFHIRMock() *FHIRMock {
 			return &domain.FHIRConditionRelayPayload{}, nil
 		},
 		MockGetFHIREncounterFn: func(ctx context.Context, id string) (*domain.FHIREncounterRelayPayload, error) {
+			UUID := uuid.New().String()
 			PatientRef := "Patient/" + uuid.NewString()
 			return &domain.FHIREncounterRelayPayload{
 				Resource: &domain.FHIREncounter{
@@ -548,7 +557,7 @@ func NewFHIRMock() *FHIRMock {
 }
 
 // CreateEpisodeOfCare is a mock implementation of CreateEpisodeOfCare method
-func (fh *FHIRMock) CreateEpisodeOfCare(ctx context.Context, episode domain.FHIREpisodeOfCare) (*domain.EpisodeOfCarePayload, error) {
+func (fh *FHIRMock) CreateEpisodeOfCare(ctx context.Context, episode domain.FHIREpisodeOfCareInput) (*domain.EpisodeOfCarePayload, error) {
 	return fh.MockCreateEpisodeOfCareFn(ctx, episode)
 }
 

pkg/clinical/presentation/graph/healthpassport.graphql → pkg/clinical/presentation/graph/clinical.graphql

@@ -1,10 +1,15 @@
 extend type Query {
   patientHealthTimeline(input: HealthTimelineInput!): HealthTimeline!
   getMedicalData(patientID: String!): MedicalData
+
+  episodeOfCare(id: ID!): EpisodeOfCare
 }
 
 extend type Mutation {
   createFHIROrganization(
     input: FHIROrganizationInput!
   ): FHIROrganizationRelayPayload!
-}
+
+  createEpisodeOfCare(episodeOfCare: EpisodeOfCareInput!): EpisodeOfCare
+  endEpisodeOfCare(id: ID!): EpisodeOfCare
+}

pkg/clinical/presentation/graph/enums.graphql

@@ -0,0 +1,6 @@
+enum EpisodeOfCareStatusEnum {
+  planned
+  active
+  finished
+  cancelled
+}