Adding simple policy evaluation decision point

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

@@ -0,0 +1,62 @@
+/*
+*  Copyright (c) 2015 WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
+*
+*  WSO2 Inc. licenses this file to you under the Apache License,
+*  Version 2.0 (the "License"); you may not use this file except
+*  in compliance with the License.
+*  You may obtain a copy of the License at
+*
+*    http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing,
+* software distributed under the License is distributed on an
+* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+* KIND, either express or implied.  See the License for the
+* specific language governing permissions and limitations
+* under the License.
+*/
+
+package org.wso2.carbon.policy.decision.point.simple;
+
+import org.wso2.carbon.device.mgt.common.DeviceIdentifier;
+import org.wso2.carbon.policy.mgt.common.Policy;
+import org.wso2.carbon.policy.mgt.common.PolicyEvaluationException;
+import org.wso2.carbon.policy.mgt.common.PolicyEvaluationPoint;
+import org.wso2.carbon.policy.mgt.common.ProfileFeature;
+
+import java.util.List;
+
+public class PolicyEvaluationServiceImpl implements PolicyEvaluationPoint {
+
+    private SimpleEvaluationImpl evaluation;
+
+    public PolicyEvaluationServiceImpl() {
+        evaluation = new SimpleEvaluationImpl();
+    }
+
+    @Override
+    public Policy getEffectivePolicy(DeviceIdentifier deviceIdentifier) throws PolicyEvaluationException {
+        return evaluation.getEffectivePolicy(deviceIdentifier);
+    }
+
+    @Override
+    public List<ProfileFeature> getEffectiveFeatures(List<Policy> policyList, DeviceIdentifier deviceIdentifier) throws PolicyEvaluationException {
+
+        List<ProfileFeature> effectiveFeatures = evaluation.getEffectivePolicy(deviceIdentifier).
+                getProfile().getProfileFeaturesList();
+
+/*        PolicyOperation policyOperation = new PolicyOperation();
+
+        List<ProfileOperation> profileOperationList = new ArrayList<ProfileOperation>();
+        for (ProfileFeature feature : effectiveFeatures) {
+            ProfileOperation operation = new ProfileOperation();
+
+            operation.setCode(feature.getFeatureCode());
+            operation.setPayLoad(feature.getContent());
+            profileOperationList.add(operation);
+        }
+        policyOperation.setProfileOperations(profileOperationList);
+        policyOperation.setCode(PolicyManagementConstants.POLICY_BUNDLE);*/
+        return effectiveFeatures;
+    }
+}

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

@@ -0,0 +1,32 @@
+/*
+*  Copyright (c) 2015 WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
+*
+*  WSO2 Inc. licenses this file to you under the Apache License,
+*  Version 2.0 (the "License"); you may not use this file except
+*  in compliance with the License.
+*  You may obtain a copy of the License at
+*
+*    http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing,
+* software distributed under the License is distributed on an
+* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+* KIND, either express or implied.  See the License for the
+* specific language governing permissions and limitations
+* under the License.
+*/
+
+
+package org.wso2.carbon.policy.decision.point.simple;
+
+import org.wso2.carbon.device.mgt.common.DeviceIdentifier;
+import org.wso2.carbon.policy.mgt.common.Policy;
+import org.wso2.carbon.policy.mgt.common.PolicyEvaluationException;
+
+public interface SimpleEvaluation  {
+
+    void sortPolicies() throws PolicyEvaluationException;
+
+    Policy getEffectivePolicy(DeviceIdentifier deviceIdentifier)  throws PolicyEvaluationException;
+
+}

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

@@ -0,0 +1,86 @@
+/*
+*  Copyright (c) 2015 WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
+*
+*  WSO2 Inc. licenses this file to you under the Apache License,
+*  Version 2.0 (the "License"); you may not use this file except
+*  in compliance with the License.
+*  You may obtain a copy of the License at
+*
+*    http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing,
+* software distributed under the License is distributed on an
+* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+* KIND, either express or implied.  See the License for the
+* specific language governing permissions and limitations
+* under the License.
+*/
+
+package org.wso2.carbon.policy.decision.point.simple;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.wso2.carbon.device.mgt.common.DeviceIdentifier;
+import org.wso2.carbon.policy.decision.point.internal.PolicyDecisionPointDataHolder;
+import org.wso2.carbon.policy.mgt.common.*;
+import org.wso2.carbon.policy.mgt.core.PolicyManagerService;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+public class SimpleEvaluationImpl implements SimpleEvaluation {
+
+    private static final Log log = LogFactory.getLog(SimpleEvaluationImpl.class);
+    //TODO : to revove the stale reference
+    private PolicyManagerService policyManagerService;
+    private List<Policy> policyList = new ArrayList<Policy>();
+
+//    public SimpleEvaluationImpl() {
+//        policyManagerService = PolicyDecisionPointDataHolder.getInstance().getPolicyManagerService();
+//    }
+
+    @Override
+    public Policy getEffectivePolicy(DeviceIdentifier deviceIdentifier) throws PolicyEvaluationException {
+        Policy policy = new Policy();
+        PolicyAdministratorPoint policyAdministratorPoint;
+        PolicyInformationPoint policyInformationPoint;
+        policyManagerService = getPolicyManagerService();
+
+        try {
+            if (policyManagerService != null) {
+
+                policyInformationPoint = policyManagerService.getPIP();
+                PIPDevice pipDevice = policyInformationPoint.getDeviceData(deviceIdentifier);
+                policyList = policyInformationPoint.getRelatedPolicies(pipDevice);
+                policyAdministratorPoint = policyManagerService.getPAP();
+                sortPolicies();
+                if(!policyList.isEmpty()) {
+                    policy = policyList.get(0);
+                } else {
+                    policyAdministratorPoint.removePolicyUsed(deviceIdentifier);
+                    return null;
+                }
+                //TODO : UNCOMMENT THE FOLLOWING CASE
+                policyAdministratorPoint.setPolicyUsed(deviceIdentifier, 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);
+        }
+        return policy;
+    }
+
+
+    @Override
+    public void sortPolicies() throws PolicyEvaluationException {
+        Collections.sort(policyList);
+    }
+
+    private PolicyManagerService getPolicyManagerService() {
+        return PolicyDecisionPointDataHolder.getInstance().getPolicyManagerService();
+    }
+}