DataManager implements IDataManager, IInstanceListener { @Override public Set<String> getAllPolicy() { return cachingTablePolicy.getAllKeys(); } DataManager(); @Override void addListener(IDataManagerListener listener); @Override void removeListener(IDataManagerListener listener); @Override void addListener(IDataManagerUsedBucketIdsListener listener); @Override void removeListener(IDataManagerUsedBucketIdsListener listener); void setManager(boolean manager); void init(); void destroy(); @Override void setCacheManager(ICacheManager cacheManager); @Override void reloadGateway(String ip); void setTopologyClient(ITopologyClient topologyClient); @Override Set<String> getAllApiIds(); @Override boolean isApiExist(String apiId); @Override void addApi(Api api); @Override boolean endpointExists(String endpoint); @Override void updateApi(Api api); @Override void removeApi(String id); @Override Api getApiById(String id); @Override Api getApiById(String id, boolean getFullDetails); @Override Set<String> getAllAuthIds(); @Override void addAuth(Auth auth); @Override void updateAuth(Auth auth); @Override void removeAuth(String id); @Override Auth getAuthById(String id); @Override Auth getAuthById(String id, boolean getFullDetails); @Override Auth getAuthByAuthKey(String authKey); @Override Auth getAuthByOAuth(String clientId, String clientSecret); @Override Auth getAuthByUserPass(String username, String password); @Override Auth getWsseAuth(String username, String password, boolean isPasswordText, String nonce, String created); @Override Auth getAuthByIP(String ip); @Override Auth getAuthMatching(IAuthMatcher authMatcher); @Override Set<String> getAllPolicy(); @Override void addPolicy(Policy policy); @Override void updatePolicy(Policy policy); @Override void removePolicy(String id); @Override Policy getPolicyById(String id); @Override Policy getPolicyById(String id, boolean getFullDetails); @Override void createBucket(String policyId, QuotaRLBucket bucket); @Override void addAuthsToBucket(String policyId, String bucketId, QuotaRLBucket bucket); @Override void addAuthsToBucket(List<String> policyIds, String bucketId, QuotaRLBucket authIds); @Override void appendAuthsToBucket(List<String> policyIds, String bucketId, QuotaRLBucket authIds); @Override void removeAuthFromBucket(String policyId, String bucketId, String authId); @Override void removeAuthsFromBucket(List<String> policyIds, String bucketId, List<String> authIds); @Override void removeBucket(String policyId, String bucketId); @Override void removeBucket(List<String> policyIds, String bucketId); @Override List<CallDescriptor> getMatchingPolicies(Api api); @Override List<CallDescriptor> getMatchingPolicies(Api api, Auth auth); @Override APIContext getApiContextById(Integer id); @Override Context getPolicyContextById(Integer id); @Override void fillLimitsById(Integer contextId, Limit limit); @Override void putSettingString(String key, String value); @Override void clearSettingString(String key); @Override String getSettingString(String key); @Override void addKey(Key key); @Override Set<String> getAllKeyIds(); @Override Key getKeyById(String id); @Override Key getKeyById(String id, boolean getFullDetails); @Override void updateKey(Key key); @Override void removeKey(String id); @Override void addCert(Certificate cert); @Override Set<String> getAllCertIds(); @Override Set<String> getAllCertIdsForKeyId(String keyId); @Override Certificate getCertById(String id); @Override Certificate getCertById(String id, boolean getFullDetails); @Override void updateCert(Certificate cert); @Override void removeCert(String id); @Override Key generateKey(String id); @Override CertificateRequest getCSR(String keyId); @Override Certificate selfSignKey(String keyId, CertificateRequest csr); @Override void addKeyListener(IEntryListener<String, Key> listener); @Override void removeKeyListener(IEntryListener<String, Key> listener); void setCachedLogLevel(String key, LogLevel level); void clearCachedLogLevel(String key); LogLevel getCachedLogLevel(String key); @Override void addLogLevelListener(IEntryListener<String, LogLevel> listener); @Override void removeLogLevelListener(IEntryListener<String, LogLevel> listener); void setCachedLoggingCategory(Category category, boolean enabled); void clearCachedLoggingCategory(Category category); boolean getCachedLoggingCategory(Category category); @Override boolean deployApi(String apiId, byte[] jarData); @Override ApiJar getApiJar(String apiId); @Override boolean undeployApi(String apiId); @Override void addApiDeploymentListener(IEntryListener<String, ApiJar> listener); @Override void removeApiDeploymentListener(IEntryListener<String, ApiJar> listener); @Override void instanceAdded(InstanceEvent event); @Override void instanceRemoved(InstanceEvent event); @Override void setLogLevel(LogLevel level); @Override LogLevel getLogLevel(); @Override void setSMXLogLevel(LogLevel level); @Override LogLevel getSMXLogLevel(); @Override void setSyslogLevel(LogLevel level); @Override LogLevel getSyslogLevel(); @Override void setLoggingCategory(Category category, boolean enabled); @Override boolean getLoggingCategory(Category category); @Override Set<String> getAllCA(); @Override void addCA(Certificate cert); @Override Certificate getCAById(String id); @Override void updateCA(Certificate cert); @Override void removeCA(String id); @Override void addCAListener(IEntryListener<String, Certificate> listener); @Override void removeCAListener(IEntryListener<String, Certificate> listener); @Override void addCRL(SSLCRL clr); @Override SSLCRL getCRLById(String id); @Override void updateCRL(SSLCRL crl); @Override void removeCRL(String id); @Override Collection<SSLCRL> getAllCRLValues(); @Override Set<String> getAllCRL(); @Override void addCrlListener(IEntryListener<String,SSLCRL> listener); @Override void removeCrlListener(IEntryListener<String,SSLCRL> listener); @SuppressWarnings("unchecked") void setCachingTableApiDetails(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableAuthDetails(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableAuthIdToAuthToken(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableKeyDetails(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableCertificateDetails(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableCADetails(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableApi(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableAuth(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableAuthIpAddress(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTablePolicy(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableContext(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableSettings(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableKey(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableCertificate(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableLogLevel(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableCA(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableCRL(ICacheTable<K, V> iCacheTable); @SuppressWarnings("unchecked") void setCachingTableApiJars(ICacheTable<K, V> iCacheTable); void setListeners(Set<IDataManagerListener> listeners); void setUsedBucketIds(Set<Integer> usedBucketIds); @Override void addApiListener(IEntryListener<String, Api> listener); @Override void removeApiListener(IEntryListener<String, Api> listener); @Override boolean isIpAllowed(Api api, String ip); @Override void addGlobalProxyListener3(IEntryListener<String, String> listener); @Override void removeGlobalProxyListener3(IEntryListener<String, String> listener);  }
@Test public void testGetAllPolicy() { Policy policy = new Policy(); policy.setId("id1"); dataManager.addPolicy(policy); Policy policy2 = new Policy(); policy2.setId("id2"); dataManager.addPolicy(policy2); Set<String> policies = dataManager.getAllPolicy(); assertNotNull("No policy found", policies); List<String> policyList = new ArrayList<String>(); for (String policyStr : policies) { policyList.add(policyStr); } assertEquals("Auth count is correct", 2, policyList.size()); assertTrue("Both Auths are found", (policyList.get(0).equals(policy.getId()) || policyList.get(0).equals(policy2.getId())) && (policyList.get(1).equals(policy.getId()) || policyList.get(1).equals(policy2.getId()))); dataManager.removePolicy(policy.getId()); dataManager.removePolicy(policy2.getId()); }