Skip to content

Commit d2caff5

Browse files
authored
introducing a factory method to create instances of GetGpcStructuredTaskDefinition class (#991)
1 parent 5b0f9f7 commit d2caff5

File tree

2 files changed

+21
-10
lines changed

2 files changed

+21
-10
lines changed

service/src/main/java/uk/nhs/adaptors/gp2gp/ehr/request/EhrExtractRequestHandler.java

Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -97,19 +97,13 @@ private EhrExtractStatus saveExtractStatusDocument(EhrExtractStatus ehrExtractSt
9797
}
9898

9999
private void createGetGpcStructuredTask(EhrExtractStatus ehrExtractStatus) {
100-
var getGpcStructuredTaskDefinition = GetGpcStructuredTaskDefinition.builder()
101-
.nhsNumber(ehrExtractStatus.getEhrRequest().getNhsNumber())
102-
.taskId(randomIdGeneratorService.createNewId())
103-
.conversationId(ehrExtractStatus.getConversationId())
104-
.requestId(ehrExtractStatus.getEhrRequest().getRequestId())
105-
.toAsid(ehrExtractStatus.getEhrRequest().getToAsid())
106-
.fromAsid(ehrExtractStatus.getEhrRequest().getFromAsid())
107-
.toOdsCode(ehrExtractStatus.getEhrRequest().getToOdsCode())
108-
.fromOdsCode(ehrExtractStatus.getEhrRequest().getFromOdsCode())
109-
.build();
100+
var getGpcStructuredTaskDefinition = GetGpcStructuredTaskDefinition.getGetGpcStructuredTaskDefinition(randomIdGeneratorService,
101+
ehrExtractStatus);
110102
taskDispatcher.createTask(getGpcStructuredTaskDefinition);
111103
}
112104

105+
106+
113107
private EhrExtractStatus.EhrRequest prepareMinimalEhrRequest(Document header, Document payload) {
114108
return EhrExtractStatus.EhrRequest.builder()
115109
.messageId(getRequiredValue(header, MESSAGE_ID_PATH))

service/src/main/java/uk/nhs/adaptors/gp2gp/gpc/GetGpcStructuredTaskDefinition.java

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,10 @@
66
import lombok.Getter;
77
import lombok.experimental.SuperBuilder;
88
import lombok.extern.jackson.Jacksonized;
9+
import uk.nhs.adaptors.gp2gp.common.service.RandomIdGeneratorService;
910
import uk.nhs.adaptors.gp2gp.common.task.TaskDefinition;
1011
import uk.nhs.adaptors.gp2gp.common.task.TaskType;
12+
import uk.nhs.adaptors.gp2gp.ehr.model.EhrExtractStatus;
1113

1214
/**
1315
* Task definition for downloading Structured Record from GCP
@@ -26,4 +28,19 @@ public class GetGpcStructuredTaskDefinition extends TaskDefinition {
2628
public TaskType getTaskType() {
2729
return GET_GPC_STRUCTURED;
2830
}
31+
32+
public static GetGpcStructuredTaskDefinition getGetGpcStructuredTaskDefinition(RandomIdGeneratorService randomIdGeneratorService,
33+
EhrExtractStatus ehrExtractStatus) {
34+
var getGpcStructuredTaskDefinition = GetGpcStructuredTaskDefinition.builder()
35+
.nhsNumber(ehrExtractStatus.getEhrRequest().getNhsNumber())
36+
.taskId(randomIdGeneratorService.createNewId())
37+
.conversationId(ehrExtractStatus.getConversationId())
38+
.requestId(ehrExtractStatus.getEhrRequest().getRequestId())
39+
.toAsid(ehrExtractStatus.getEhrRequest().getToAsid())
40+
.fromAsid(ehrExtractStatus.getEhrRequest().getFromAsid())
41+
.toOdsCode(ehrExtractStatus.getEhrRequest().getToOdsCode())
42+
.fromOdsCode(ehrExtractStatus.getEhrRequest().getFromOdsCode())
43+
.build();
44+
return getGpcStructuredTaskDefinition;
45+
}
2946
}

0 commit comments

Comments
 (0)