X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=auth%2Fauth-batch%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faaf%2Fauth%2Fbatch%2Freports%2Fbodies%2FNotifyBody.java;h=ec8d1451ca20c0e9f2bf3440831cce40173b2f76;hb=3d1706fcbe7f95830ff6fd23cf679ee55c6d0595;hp=b36cf648b86455935ff81691da04bf94d403ca93;hpb=4c709df6500a95057a92ec3ea5c739738764388d;p=aaf%2Fauthz.git

diff --git a/auth/auth-batch/src/main/java/org/onap/aaf/auth/batch/reports/bodies/NotifyBody.java b/auth/auth-batch/src/main/java/org/onap/aaf/auth/batch/reports/bodies/NotifyBody.java
index b36cf648..ec8d1451 100644
--- a/auth/auth-batch/src/main/java/org/onap/aaf/auth/batch/reports/bodies/NotifyBody.java
+++ b/auth/auth-batch/src/main/java/org/onap/aaf/auth/batch/reports/bodies/NotifyBody.java
@@ -29,195 +29,234 @@ import java.net.URISyntaxException;
 import java.net.URL;
 import java.util.ArrayList;
 import java.util.Collection;
+import java.util.Enumeration;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.TreeMap;
+import java.util.jar.JarEntry;
+import java.util.jar.JarFile;
 
+import org.onap.aaf.auth.batch.helpers.LastNotified;
 import org.onap.aaf.auth.batch.reports.Notify;
 import org.onap.aaf.auth.env.AuthzTrans;
 import org.onap.aaf.cadi.Access;
 import org.onap.aaf.misc.env.APIException;
 
 public abstract class NotifyBody {
-	private static final String DUPL = "<td style=\"text-indent: 4em;\">''</td>";
-	private static final Map<String,NotifyBody> bodyMap = new HashMap<>();
+    private static final String DUPL = "<td style=\"text-indent: 4em;\">''</td>";
+    private static final Map<String,NotifyBody> bodyMap = new HashMap<>();
 
-	protected Map<String,List<List<String>>> rows;
-	private final String name;
-	private final String type;
-	private String date;
-	private int escalation;
-	private int count;
-	
-	public NotifyBody(final String type, final String name) {
-		rows = new TreeMap<>();
-		this.name = name;
-		this.type = type;
-		date="";
-		escalation = 1;
-		count = 0;
-	}
-	
-	public void store(List<String> row) {
-		if(!row.isEmpty()) {
-			if("info".equals(row.get(0))) {
-				if(row.size()>2) {
-					date = row.get(2);
-				}
-				if(row.size()>3) {
-					escalation = Integer.parseInt(row.get(3));
-				}
-				return;
-			} else if(type.equals(row.get(0))) {
-				String user = user(row);
-				if(user!=null) {
-					List<List<String>> lss = rows.get(user); 
-					if(lss == null) {
-						lss = new ArrayList<>();
-						rows.put(user,lss);
-					}
-					lss.add(row);
-				}
-			}
-		}
-	}
+    protected Map<String,List<List<String>>> rows;
+    protected final String env;
+    protected final String gui_url;
+    
+    private final String name;
+    private final String type;
+    private String date;
+    private int escalation;
+    private int count;
+    
+    public NotifyBody(Access access, final String type, final String name) {
+        rows = new TreeMap<>();
+        this.name = name;
+        this.type = type;
+        date="";
+        escalation = 1;
+        count = 0;
+        env = access.getProperty("CASS_ENV","DEVL");
+        gui_url = access.getProperty("GUI_URL", "");
+    }
+    
+    public void store(List<String> row) {
+        if(!row.isEmpty()) {
+            if("info".equals(row.get(0))) {
+                if(row.size()>2) {
+                    date = row.get(2);
+                }
+                if(row.size()>3) {
+                    escalation = Integer.parseInt(row.get(3));
+                }
+                return;
+            } else if(type.equals(row.get(0))) {
+                String user = user(row);
+                if(user!=null) {
+                    List<List<String>> lss = rows.get(user); 
+                    if(lss == null) {
+                        lss = new ArrayList<>();
+                        rows.put(user,lss);
+                    }
+                    lss.add(row);
+                }
+            }
+        }
+    }
 
-	public String name() {
-		return name;
-	}
-	
-	public String type() {
-		return type;
-	}
-	
-	public String date() {
-		return date;
-	}
-	public int escalation() {
-		return escalation;
-	}
-	
-	public Set<String> users() {
-		return rows.keySet();
-	}
-	
-	/**
-	 * ID must be set from Row for Email lookup
-	 * 
-	 * @param trans
-	 * @param n
-	 * @param id
-	 * @param row
-	 * @return
-	 */
-	public abstract boolean body(AuthzTrans trans, StringBuilder sb, int indent, Notify n, String id);
-	
-	/**
-	 * Return "null" if user not found in row... Code will handle.
-	 * @param row
-	 * @return
-	 */
-	protected abstract String user(List<String> row);
-	
-	/**
-	 * Get Notify Body based on key of
-	 * type|name
-	 */
-	public static NotifyBody get(String key) {
-		return bodyMap.get(key);
-	}
-	
-	/**
-	 * Return set of loaded NotifyBodies
-	 * 
-	 */
-	public static Collection<NotifyBody> getAll() {
-		// Note: The same Notify Body is entered several times with different keys.
-		// Therefore, need a Set of Values, not all the Values.
-		Set<NotifyBody> set = new HashSet<>();
-		set.addAll(bodyMap.values());
-		return set;
-	}
-	
-	/**
-	 * @param propAccess 
-	 * @throws URISyntaxException 
-	 * 
-	 */
-	public static void load(Access access) throws APIException, IOException {
-		// class load available NotifyBodies
-		ClassLoader cl = Thread.currentThread().getContextClassLoader();
-		Package pkg = NotifyBody.class.getPackage();
-		String path = pkg.getName().replace('.', '/');
-		URL url = cl.getResource(path);
-		if(url == null) {
-			throw new APIException("Cannot load resources from " + path);
-		}
-		File dir;
-		try {
-			dir = new File(url.toURI());
-		} catch (URISyntaxException e) {
-			throw new APIException(e);
-		}
-		if(dir.exists()) {
-			String[] files = dir.list();
-			if(files!=null) {
-				for(String sf : files) {
-					int dot = sf.indexOf('.');
-					if(dot>=0) {
-						String cls = pkg.getName()+'.'+sf.substring(0,dot);
-						try {
-							Class<?> c = cl.loadClass(cls);
-							if(c!=null) {
-								if(!Modifier.isAbstract(c.getModifiers())) {
-									Constructor<?> cst = c.getConstructor(Access.class);
-									NotifyBody nb = (NotifyBody)cst.newInstance(access);
-									if(nb!=null) {
-										bodyMap.put("info|"+nb.name, nb);
-										bodyMap.put(nb.type+'|'+nb.name, nb);
-									}
-								}
-							}
-						} catch (ClassNotFoundException | NoSuchMethodException | SecurityException | InstantiationException | IllegalAccessException | IllegalArgumentException | InvocationTargetException e) {
-							e.printStackTrace();
-						}
-					}
-				}
-			}
-		}
-	}
+    public String name() {
+        return name;
+    }
+    
+    public String type() {
+        return type;
+    }
+    
+    public String date() {
+        return date;
+    }
+    public int escalation() {
+        return escalation;
+    }
+    
+    public Set<String> users() {
+        return rows.keySet();
+    }
+    
+    /**
+     * ID must be set from Row for Email lookup
+     * 
+     * @param trans
+     * @param n
+     * @param id
+     * @param row
+     * @return
+     */
+    public abstract boolean body(AuthzTrans trans, StringBuilder sb, int indent, Notify n, String id);
+    
+    /**
+     * Return "null" if user not found in row... Code will handle.
+     * @param row
+     * @return
+     */
+    protected abstract String user(List<String> row);
+    
+    /**
+     * Provide a context-sensitive Subject, which includes ENV as well as details
+     * 
+     * @return
+     */
+    public abstract String subject();
 
-	protected void println(StringBuilder sb, int indent, Object ... objs) {
-		for(int i=0;i<indent;++i) {
-			sb.append(' ');
-		}
-		for(Object o : objs) {
-			sb.append(o.toString());
-		}
-		sb.append('\n');
-	}
-	
-	protected String printCell(StringBuilder sb, int indent, String current, String prev) {
-		if(current.equals(prev)) {
-			println(sb,indent,DUPL);
-		} else {
-			printCell(sb,indent,current);
-		}
-		return current; // use to set prev...
-	}
-	
-	protected void printCell(StringBuilder sb, int indent, String current) {
-		println(sb,indent,"<td>",current,"</td>");
-	}
-	
-	public synchronized void inc() {
-		++count;
-	}
-	
-	public int count() {
-		return count;
-	}
+    /**
+     * Record the fact that a particular Notification was marked as "sent" by Emailer.
+     * 
+     * @param trans
+     * @param approver
+     * @param ln
+     */
+    public abstract void record(AuthzTrans trans, StringBuilder query, String id, List<String> notified, LastNotified ln);
+    
+    /**
+     * Get Notify Body based on key of
+     * type|name
+     */
+    public static NotifyBody get(String key) {
+        return bodyMap.get(key);
+    }
+    
+    /**
+     * Return set of loaded NotifyBodies
+     * 
+     */
+    public static Collection<NotifyBody> getAll() {
+        // Note: The same Notify Body is entered several times with different keys.
+        // Therefore, need a Set of Values, not all the Values.
+        Set<NotifyBody> set = new HashSet<>();
+        set.addAll(bodyMap.values());
+        return set;
+    }
+    
+    /**
+     * @param propAccess 
+     * @throws URISyntaxException 
+     * 
+     */
+    public static void load(Access access) throws APIException, IOException {
+        // class load available NotifyBodies
+        ClassLoader cl = Thread.currentThread().getContextClassLoader();
+        Package pkg = NotifyBody.class.getPackage();
+        String path = pkg.getName().replace('.', '/');
+        URL url = cl.getResource(path);
+        List<String> classNames = new ArrayList<>();
+        String urlString = url.toString();
+        if(urlString.startsWith("jar:file:")) {
+            int exclam = urlString.lastIndexOf('!');
+            JarFile jf = new JarFile(urlString.substring(9,exclam));
+            try {
+                Enumeration<JarEntry> jfe = jf.entries();
+                while(jfe.hasMoreElements()) {
+                    String name = jfe.nextElement().getName();
+                    if(name.startsWith(path) && name.endsWith(".class")) {
+                        classNames.add(name.substring(0,name.length()-6).replace('/', '.'));
+                    }
+                }
+            } finally {
+                jf.close();
+            }
+        } else {
+            File dir = new File(url.getFile());
+            for( String f : dir.list()) {
+                if(f.endsWith(".class")) {
+                    classNames.add(pkg.getName()+'.'+f.substring(0,f.length()-6));
+                }
+            }
+        }
+        for(String cls : classNames) {
+            try {
+                Class<?> c = cl.loadClass(cls);
+                if(c!=null) {
+                    if(!Modifier.isAbstract(c.getModifiers())) {
+                        Constructor<?> cst = c.getConstructor(Access.class);
+                        NotifyBody nb = (NotifyBody)cst.newInstance(access);
+                        if(nb!=null) {
+                            bodyMap.put("info|"+nb.name, nb);
+                            bodyMap.put(nb.type+'|'+nb.name, nb);
+                        }
+                    }
+                }
+            } catch (ClassNotFoundException | NoSuchMethodException | SecurityException | InstantiationException | IllegalAccessException | IllegalArgumentException | InvocationTargetException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    protected void print(StringBuilder sb, int indent, Object ... objs) {
+        for(int i=0;i<indent;++i) {
+            sb.append(' ');
+        }
+        for(Object o : objs) {
+            sb.append(o.toString());
+        }
+    }
+            
+    protected void println(StringBuilder sb, int indent, Object ... objs) {
+        print(sb,indent,objs);
+        sb.append('\n');
+    }
+
+    protected void printf(StringBuilder sb, int indent, String fmt, Object ... objs) {
+        print(sb,indent,String.format(fmt, objs));
+    }
+
+    protected String printCell(StringBuilder sb, int indent, String current, String prev) {
+        if(current.equals(prev)) {
+            println(sb,indent,DUPL);
+        } else {
+            printCell(sb,indent,current);
+        }
+        return current; // use to set prev...
+    }
+    
+    protected void printCell(StringBuilder sb, int indent, String current) {
+        println(sb,indent,"<td>",current,"</td>");
+    }
+    
+    public synchronized void inc() {
+        ++count;
+    }
+    
+    public int count() {
+        return count;
+    }
 }