#193

Committed 17 Oct 2024 10:04AM UTC coverage: 77.377% (-0.2%) from 77.619%

Build # #193

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #636 from opensrp/sanitize-spaces-from-productName

sanitize whitespaces from productName

Run Details

7 of 7 new or added lines in 3 files covered. (100.0%)

27 existing lines in 3 files now uncovered.

8277 of 10697 relevant lines covered (77.38%)

0.77 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

26.47

/src/main/java/org/opensrp/queue/RabbitMQReceiver.java

package org.opensrp.queue;

import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;

import javax.annotation.PostConstruct;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.opensrp.service.PlanService;
import org.opensrp.service.TaskGenerator;
import org.smartregister.domain.PlanDefinition;
import org.smartregister.pathevaluator.plan.PlanEvaluator;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Component;

import com.ibm.fhir.model.format.Format;
import com.ibm.fhir.model.parser.FHIRParser;
import com.ibm.fhir.model.parser.exception.FHIRParserException;
import com.ibm.fhir.model.resource.Resource;

@Profile("rabbitmq")
@Component
@RabbitListener(queues = "rabbitmq.task.queue", id = "listener")
public class RabbitMQReceiver {

        private PlanEvaluator planEvaluator;

        @Autowired
        private PlanService planService;
        
        @Autowired
        private QueueHelper queueHelper;
        
        //import task generator to guarantee PathEvaluatorLibrary is instantiated first
        @SuppressWarnings("unused")
        @Autowired
        private TaskGenerator taskGenerator;

        private FHIRParser fhirParser;

        private static Logger logger = LogManager.getLogger(RabbitMQReceiver.class.toString());

        @PostConstruct
        public void init() {
                fhirParser = FHIRParser.parser(Format.JSON);
        }

        @RabbitHandler
        public void receiver(PlanEvaluatorMessage planEvaluatorMessage) {
                logger.info("PlanEvaluatorMessage listener invoked - Consuming Message with Plan Definition Identifier : " + planEvaluatorMessage.getPlanIdentifier());
                initializePathEvaluator(planEvaluatorMessage.getUsername());

                if (planEvaluatorMessage != null && planEvaluator != null) {
                        PlanDefinition planDefinition = planService.getPlan(planEvaluatorMessage.getPlanIdentifier());
                        if (planDefinition != null && planDefinition.getActions() != null && planEvaluatorMessage.getJurisdiction() != null) {
                                planEvaluator.evaluatePlan(planDefinition,
                                                planEvaluatorMessage.getTriggerType(),
                                                planEvaluatorMessage.getJurisdiction(), null);
                        }
                }
        }

        @RabbitHandler
        public void receiver(ResourceEvaluatorMessage resourceEvaluatorMessage) {
                logger.info("ResourceEvaluatorMessage invoked - Consuming Message");
                if (resourceEvaluatorMessage != null) {
                        InputStream stream = resourceEvaluatorMessage.getResource() != null ? new ByteArrayInputStream(
                                        resourceEvaluatorMessage.getResource().getBytes(StandardCharsets.UTF_8)) : null;
                        try {
                                if (stream != null) {
                                        Resource resource = fhirParser.parse(stream);
                                        logger.info("Resource id is : " + resource.getId());
                                        initializePathEvaluator(resourceEvaluatorMessage.getUsername());
                                        if (resource != null && resourceEvaluatorMessage != null
                                                        && resourceEvaluatorMessage.getAction() != null
                                                        && resourceEvaluatorMessage.getAction().getCondition() != null
                                                        && planEvaluator != null) {
                                                planEvaluator.evaluateResource(resource, resourceEvaluatorMessage.getQuestionnaireResponse(),
                                                                resourceEvaluatorMessage.getAction(), resourceEvaluatorMessage.getPlanIdentifier(),
                                                                resourceEvaluatorMessage.getJurisdictionCode(), resourceEvaluatorMessage.getTriggerType());
                                        }
                                }
                        }
                        catch (FHIRParserException e) {
                                logger.error("FHIRParserException occurred " + e.getMessage());
                        }
                }
        }

        private void initializePathEvaluator(String username) {
                if(planEvaluator == null)
                        planEvaluator = new PlanEvaluator(username, queueHelper);
        }

}

1	package org.opensrp.queue;
2
3	import java.io.ByteArrayInputStream;
4	import java.io.InputStream;
5	import java.nio.charset.StandardCharsets;
6
7	import javax.annotation.PostConstruct;
8
9	import org.apache.logging.log4j.LogManager;
10	import org.apache.logging.log4j.Logger;
11	import org.opensrp.service.PlanService;
12	import org.opensrp.service.TaskGenerator;
13	import org.smartregister.domain.PlanDefinition;
14	import org.smartregister.pathevaluator.plan.PlanEvaluator;
15	import org.springframework.amqp.rabbit.annotation.RabbitHandler;
16	import org.springframework.amqp.rabbit.annotation.RabbitListener;
17	import org.springframework.beans.factory.annotation.Autowired;
18	import org.springframework.context.annotation.Profile;
19	import org.springframework.stereotype.Component;
20
21	import com.ibm.fhir.model.format.Format;
22	import com.ibm.fhir.model.parser.FHIRParser;
23	import com.ibm.fhir.model.parser.exception.FHIRParserException;
24	import com.ibm.fhir.model.resource.Resource;
25
26	@Profile("rabbitmq")
27	@Component
28	@RabbitListener(queues = "rabbitmq.task.queue", id = "listener")
29	public class RabbitMQReceiver {	1✔
30
31	private PlanEvaluator planEvaluator;
32
33	@Autowired
34	private PlanService planService;
35
36	@Autowired
37	private QueueHelper queueHelper;
38
39	//import task generator to guarantee PathEvaluatorLibrary is instantiated first
40	@SuppressWarnings("unused")
41	@Autowired
42	private TaskGenerator taskGenerator;
43
44	private FHIRParser fhirParser;
45
46	private static Logger logger = LogManager.getLogger(RabbitMQReceiver.class.toString());	1✔
47
48	@PostConstruct
49	public void init() {
50	fhirParser = FHIRParser.parser(Format.JSON);	1✔
51	}	1✔
52
53	@RabbitHandler
54	public void receiver(PlanEvaluatorMessage planEvaluatorMessage) {
UNCOV 55	logger.info("PlanEvaluatorMessage listener invoked - Consuming Message with Plan Definition Identifier : " + planEvaluatorMessage.getPlanIdentifier());	×
UNCOV 56	initializePathEvaluator(planEvaluatorMessage.getUsername());	×
57
UNCOV 58	if (planEvaluatorMessage != null && planEvaluator != null) {	×
UNCOV 59	PlanDefinition planDefinition = planService.getPlan(planEvaluatorMessage.getPlanIdentifier());	×
UNCOV 60	if (planDefinition != null && planDefinition.getActions() != null && planEvaluatorMessage.getJurisdiction() != null) {	×
UNCOV 61	planEvaluator.evaluatePlan(planDefinition,	×
UNCOV 62	planEvaluatorMessage.getTriggerType(),	×
UNCOV 63	planEvaluatorMessage.getJurisdiction(), null);	×
64	}
65	}
UNCOV 66	}	×
67
68	@RabbitHandler
69	public void receiver(ResourceEvaluatorMessage resourceEvaluatorMessage) {
70	logger.info("ResourceEvaluatorMessage invoked - Consuming Message");	1✔
71	if (resourceEvaluatorMessage != null) {	1✔
72	InputStream stream = resourceEvaluatorMessage.getResource() != null ? new ByteArrayInputStream(	1✔
73	resourceEvaluatorMessage.getResource().getBytes(StandardCharsets.UTF_8)) : null;	1✔
74	try {
75	if (stream != null) {	1✔
UNCOV 76	Resource resource = fhirParser.parse(stream);	×
UNCOV 77	logger.info("Resource id is : " + resource.getId());	×
UNCOV 78	initializePathEvaluator(resourceEvaluatorMessage.getUsername());	×
UNCOV 79	if (resource != null && resourceEvaluatorMessage != null	×
UNCOV 80	&& resourceEvaluatorMessage.getAction() != null	×
UNCOV 81	&& resourceEvaluatorMessage.getAction().getCondition() != null	×
82	&& planEvaluator != null) {
83	planEvaluator.evaluateResource(resource, resourceEvaluatorMessage.getQuestionnaireResponse(),	×
84	resourceEvaluatorMessage.getAction(), resourceEvaluatorMessage.getPlanIdentifier(),	×
85	resourceEvaluatorMessage.getJurisdictionCode(), resourceEvaluatorMessage.getTriggerType());	×
86	}
87	}
88	}
UNCOV 89	catch (FHIRParserException e) {	×
UNCOV 90	logger.error("FHIRParserException occurred " + e.getMessage());	×
UNCOV 91	}	×
92	}
UNCOV 93	}	×
94
95	private void initializePathEvaluator(String username) {
UNCOV 96	if(planEvaluator == null)	×
UNCOV 97	planEvaluator = new PlanEvaluator(username, queueHelper);	×
UNCOV 98	}	×
99
100	}

opensrp / opensrp-server-core / #193

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous