Adding effective policy service

components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/api/PolicyManagementService.java

@@ -562,5 +562,9 @@ public interface PolicyManagementService {
                     required = true)
                     List<PriorityUpdatedPolicyWrapper> priorityUpdatedPolicies);
 
+    @GET
+    @Path("/effective-policy/{deviceType}/{deviceId}")
+    @Permission(name = "Get Effective Policy of Devices", permission = "/device-mgt/policies/view")
+    Response getEffectivePolicy(@PathParam("deviceId") String deviceId, @PathParam("deviceType") String deviceType);
 
 }

components/device-mgt/org.wso2.carbon.device.mgt.api/src/main/java/org/wso2/carbon/device/mgt/jaxrs/service/impl/PolicyManagementServiceImpl.java

@@ -373,4 +373,29 @@ public class PolicyManagementServiceImpl implements PolicyManagementService {
         }
     }
 
+    @GET
+    @Path("/effective-policy/{deviceType}/{deviceId}")
+    @Override
+    public Response getEffectivePolicy(@PathParam("deviceId") String deviceId, @PathParam("deviceType") String deviceType) {
+        PolicyManagerService policyManagementService = DeviceMgtAPIUtils.getPolicyManagementService();
+        final org.wso2.carbon.policy.mgt.common.Policy policy;
+        try {
+            DeviceIdentifier deviceIdentifier = new DeviceIdentifier();
+            deviceIdentifier.setId(deviceId);
+            deviceIdentifier.setType(deviceType);
+            policy = policyManagementService.getEffectivePolicy(deviceIdentifier);
+            if (policy == null) {
+                return Response.status(Response.Status.NOT_FOUND).entity(
+                        new ErrorResponse.ErrorResponseBuilder().setMessage(
+                                "No policy found for device ID '" + deviceId + "'"+ deviceId).build()).build();
+            }
+        } catch (PolicyManagementException e) {
+            String msg = "Error occurred while retrieving policy corresponding to the id '" + deviceType + "'"+ deviceId;
+            log.error(msg, e);
+            return Response.serverError().entity(
+                    new ErrorResponse.ErrorResponseBuilder().setMessage(msg).build()).build();
+        }
+        return Response.status(Response.Status.OK).entity(policy).build();
+    }
+
 }

components/policy-mgt/org.wso2.carbon.simple.policy.decision.point/src/main/java/org/wso2/carbon/simple/policy/decision/point/SimpleEvaluationPoint.java

@@ -33,6 +33,7 @@ public class SimpleEvaluationPoint implements PolicyEvaluationPoint {
     //TODO : to revove the stale reference
     private PolicyManagerService policyManagerService;
     private List<Policy> policyList;
+    PIPDevice pipDevice;
 //    public SimpleEvaluationPoint() {
 //        policyManagerService = PolicyDecisionPointDataHolder.getInstance().getPolicyManagerService();
 //    }
@@ -73,15 +74,26 @@ public class SimpleEvaluationPoint implements PolicyEvaluationPoint {
     @Override
     public Policy getEffectivePolicy(DeviceIdentifier deviceIdentifier) throws PolicyEvaluationException {
 
-        if (policyManagerService == null || policyList.size() == 0) {
-            return null;
-        }
+        try {
+            policyManagerService = getPolicyManagerService();
+            PolicyInformationPoint policyInformationPoint = policyManagerService.getPIP();
+            pipDevice = policyInformationPoint.getDeviceData(deviceIdentifier);
+            policyList = policyInformationPoint.getRelatedPolicies(pipDevice);
 
-        Policy policy = new Policy();
-        Profile profile = new Profile();
-        profile.setProfileFeaturesList(getEffectiveFeatures(deviceIdentifier));
-        policy.setProfile(profile);
-        return policy;
+            if (policyManagerService == null || policyList.size() == 0) {
+                return null;
+            }
+
+            Policy policy = new Policy();
+            Profile profile = new Profile();
+            profile.setProfileFeaturesList(getEffectiveFeatures(deviceIdentifier));
+            policy.setProfile(profile);
+            return policy;
+        } catch (PolicyManagementException e) {
+            String msg = "Error occurred when retrieving the policy related data from policy management service.";
+            log.error(msg, e);
+            throw new PolicyEvaluationException(msg, e);
+        }
     }
 
     private Policy policyResolve(List<Policy> policyList) throws PolicyEvaluationException, PolicyManagementException {