* org.onap.aaf
* ===========================================================================
* Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
+ *
+ * Modifications Copyright (C) 2019 IBM.
* ===========================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
/**
* Use this constructor to indicate when last Notified
- * @param last_notified
+ * @param lastNotified
*/
- public Pending(Date last_notified) {
+ public Pending(Date lastNotified) {
qty = 1;
- hasNew = last_notified==null;
- earliest = last_notified;
+ hasNew = lastNotified==null;
+ earliest = lastNotified;
}
/**
import com.datastax.driver.core.Statement;
public class LastNotified {
- private Map<String,Date> lastNotified = new TreeMap<>();
+ private Map<String,Date> lastNotifiedVar = new TreeMap<>();
private Session session;
public static final Date NEVER = new Date(0);
private static final String SELECT = "SELECT user,target,key,last FROM authz.notified";
query.append('\'');
if(cnt>=30) {
endQuery(query);
- add(session.execute(query.toString()),lastNotified, (x,y) -> false);
+ add(session.execute(query.toString()),lastNotifiedVar, (x,y) -> false);
query.setLength(0);
startQuery(query);
cnt=0;
}
if(cnt>0) {
endQuery(query);
- add(session.execute(query.toString()),lastNotified, (x,y) -> false);
+ add(session.execute(query.toString()),lastNotifiedVar, (x,y) -> false);
}
}
}
public Date lastNotified(String key) {
- Date d = lastNotified.get(key);
+ Date d = lastNotifiedVar.get(key);
return d==null?NEVER:d;
}
try {
Statement stmt = new SimpleStatement( SELECT );
results = session.execute(stmt);
- add(results,lastNotified, (fullKey, last) -> {
+ add(results,lastNotifiedVar, (fullKey, last) -> {
if(delRange.inRange(last)) {
String[] params = Split.splitTrim('|', fullKey,3);
if(params.length==3) {
return org;
}
- public static Organization get(AuthzTrans trans) throws OrganizationException {
+ public static Organization get(AuthzTrans trans){
String domain = FQI.reverseDomain(trans.user());
Organization org = orgs.get(domain);
if (org==null) {
return type.y.y.add(new Pair<String,Object>(tag,"version".equals(tag)?new Version(value):value));
}
- public Pair<String, Pair<HttpCode<TRANS, ?>, List<Pair<String, Object>>>> prep(TRANS trans, String compare) throws IOException, ServletException {
+ public Pair<String, Pair<HttpCode<TRANS, ?>, List<Pair<String, Object>>>> prep(TRANS trans, String compare){
Pair<String, Pair<HttpCode<TRANS,?>, List<Pair<String, Object>>>> c,rv=null;
if (types.size()==1 && "".equals((c=types.get(0)).x)) { // if there are no checks for type, skip
rv = c;
public class AAF_FS extends AbsService<AuthzEnv, AuthzTrans> {
- public AAF_FS(final AuthzEnv env) throws APIException, IOException, CadiException {
+ public AAF_FS(final AuthzEnv env) throws IOException, CadiException {
super(env.access(),env);
try {
///////////////////////
* @param facade
* @throws Exception
*/
- public static void init(final AAF_Hello oauthHello) throws Exception {
+ public static void init(final AAF_Hello oauthHello){
////////
// Simple "GET" API
///////
// Add other Supported APIs here as created
}
- public void routeAll(HttpMethods meth, String path, API api, LocateCode code) throws Exception {
+ public void routeAll(HttpMethods meth, String path, API api, LocateCode code){
route(env,meth,path,code,""); // this will always match
}
private ConfigDAO configDAO;
private boolean permToRegister;
- public LocateServiceImpl(AuthzTrans trans, AAF_Locate locate, Mapper<IN,OUT,Endpoints,MgmtEndpoints,Configuration,ERROR> mapper) throws APIException {
+ public LocateServiceImpl(AuthzTrans trans, AAF_Locate locate, Mapper<IN,OUT,Endpoints,MgmtEndpoints,Configuration,ERROR> mapper){
this.mapper = mapper;
this.locateDAO = locate.locateDAO;
this.configDAO = locate.configDAO;