* If possible, select and show the bundle with id bid * in the tree. *
*/ void valueChanged(long bid) { try { if(bid >= 0) { Bundle b = bc.getBundle(bid); if(b != null) { OBRNode obrNode = getOBRNode(b); if(obrNode != null && obrNode != brSelected) { TreePath tp = new TreePath(obrNode.getPath()); showPath(tp, null); } } } } catch (Exception e) { } } /** * Get the OBRNode tree node which matches a bundle. * * @return OBRNode for the specified bundle if it exists, * null otherwise. */ OBRNode getOBRNode(Bundle b) { OBRNode node = (OBRNode)locationMap.get(b.getLocation()); if(node != null) { return node; } for(Iterator it = locationMap.keySet().iterator(); it.hasNext(); ) { String loc = (String)it.next(); node = (OBRNode)locationMap.get(loc); if(Util.bundleEqual(b, node.getBundleRecord())) { return node; } } return null; } /** * Create the sort selection button, with items * defined in SORT_ARRAY/SORT_NAMES */ JButton makeSortSelectionButton() { JButton sortButton = new JButton(sortIcon); sortButton.setToolTipText("Select sorting"); final JPopupMenu sortPopupMenu = new JPopupMenu(); ButtonGroup group = new ButtonGroup(); for(int i = 0; i < SORT_ARRAY.length; i++) { JCheckBoxMenuItem item = new JCheckBoxMenuItem(SORT_NAMES[i]); final int cat = SORT_ARRAY[i]; item.setState(cat == sortCategory); item.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent ev) { sortCategory = cat; refreshList(false); } }); sortPopupMenu.add(item); group.add(item); } sortButton.addMouseListener(new MouseAdapter() { public void mousePressed(MouseEvent e) { showPopup(e); } public void mouseReleased(MouseEvent e) { showPopup(e); } private void showPopup(MouseEvent e) { Component comp = e.getComponent(); sortPopupMenu.show(comp, 0, comp.getSize().height); } }); return sortButton; } boolean bBusy = false; /** * Install or install+start a bundle specified by an OBRNode * using the BundleRepositoryService. Run an a new thread to * avoid blocking the swing thread for potentially long operations. * * @param obrNode Bundle to install/start * @param bStart if true, start, otherewise just install */ void installOrStart(final OBRNode obrNode, final boolean bStart) { if(bBusy) { return; } new Thread() { { start(); } public void run() { try { bBusy = obrNode.bBusy = true; setSelected(obrNode); installOrStartSync(obrNode, bStart); } catch (Exception e) { obrNode.appendLog("" + e + "\n"); } finally { bBusy = obrNode.bBusy = false; setSelected(obrNode); } } }; } void installOrStartSync(OBRNode obrNode, boolean bStart) { BundleRecord br = obrNode.getBundleRecord(); if(br == null) { return; } String updateURL = (String)br.getAttribute(BundleRecord.BUNDLE_UPDATELOCATION); // Check if bundle already is installed. If so, // ask user if it should be updated, installed again or // if the operation should be cancelled. Bundle b = getBundle(br); if(b != null) { boolean bIsRepoBundle = Util.isInRepo(b, updateURL); String[] options = bIsRepoBundle ? (new String[] { "Update", "Cancel", }) : (new String[] { "Update", "Install again", "Cancel", }); String msg = bIsRepoBundle ? "The selected bundle is already installed\n" + "from the repository.\n" + "\n" + "It can be updated from the repository." : "The selected bundle is already installed.\n" + "\n" + "It can be updated from the repository, or\n" + "a new instance can be installed from the\n" + "repository"; int n = JOptionPane .showOptionDialog(recordTree, msg, "Bundle is installed", // title JOptionPane.YES_NO_CANCEL_OPTION, JOptionPane.QUESTION_MESSAGE, null, // icon options, options[0]); if(bIsRepoBundle) { if(n == 0) { // update obrNode.appendLog("update.\n"); } else if(n == 1) { // Cancel return; } } else { if(n == 0) { // Update InputStream in = null; try { URL url = new URL(updateURL); in = new BufferedInputStream(url.openStream()); b.update(in); obrNode.appendLog("Updated from " + url + "\n"); } catch (Exception e) { obrNode.appendLog("Update failed: " + e + "\n"); } finally { try { in.close(); } catch (Exception ignored) { } } return; } else if(n == 1) { // install new obrNode.appendLog("Install new instance.\n"); } else if(n == 2) { // cancel return; } } } // Install the budle from repo BundleRepositoryService obr = getOBR(); // deployBundle writes all info to streams, so we have to // catch that info. The text will be displayed by // the node's toHTML method ByteArrayOutputStream bout = new ByteArrayOutputStream(); PrintStream outStream = new PrintStream(bout, true); // We always resolve. boolean bResolve = true; try { boolean bOK = obr.deployBundle(outStream, // Output stream. outStream, // Error stream. updateURL, bResolve, bStart); if(bOK) { if(sortCategory == SORT_STATUS) { refreshList(false); } } } catch (Exception e) { e.printStackTrace(outStream); } finally { try { outStream.close();} catch (Exception ignored) { } String s = new String(bout.toByteArray()); obrNode.appendLog(s); } setSelected(obrNode); } /** * Refresh the OBR tree and try to reshow/reselect * any previously selected bundle node. * * @param bReload if true, reload the bundle repository * XML files, otherewise, just rebuild the tree. */ synchronized void refreshList(final boolean bReload) { Thread t = new Thread() { public void run() { locationMap.clear(); BundleRecord brOld = brSelected != null ? brSelected.getBundleRecord() : null; setRootText(STR_LOADING); rootNode = new TopNode(STR_TOPNAME); treeModel = new DefaultTreeModel(rootNode); BundleRepositoryService obr = getOBR(); if(obr != null) { if(bReload) { obrErr = ""; try { assertRepoURLs(obr.getRepositoryURLs()); obr.setRepositoryURLs(obr.getRepositoryURLs()); } catch (Exception e) { obrErr = "" + e.getClass().getName() + ""+ "\n" + e.getMessage() + ""; } } int count = obr.getBundleRecordCount(); // String (category) -> Set (BundleRecord) Map categories = new TreeMap(new Comparator() { public int compare(Object o1, Object o2) { return o1.toString().compareToIgnoreCase(o2.toString()); } }); // move all bundle records into a sorted // category map of sets for(int i = 0; i < count; i++) { BundleRecord br = obr.getBundleRecord(i); String loc = (String)br.getAttribute(BundleRecord.BUNDLE_UPDATELOCATION); String category = "other"; if(sortCategory == SORT_CATEGORY) { category = Util.getAttribute(br, BundleRecord.BUNDLE_CATEGORY, "[no category]"); } else if(sortCategory == SORT_VENDOR) { category = Util.getAttribute(br, BundleRecord.BUNDLE_VENDOR, "[no vendor]"); } else if(sortCategory == SORT_STATUS) { if(isInstalled(br)) { category = "Installed"; } else { category = "Not installed"; } } else if(sortCategory == SORT_NONE) { category = SORT_NAMES[SORT_NONE]; } else { int ix = loc.indexOf(":"); if(ix != -1) { category = loc.substring(0, ix); if(loc.startsWith("http://")) { ix = loc.indexOf("/", 8); if(ix != -1) { category = loc.substring(0, ix); } } else { ix = loc.indexOf("/", ix + 1); if(ix != -1) { category = loc.substring(0, ix); } else { ix = loc.indexOf("\\", ix + 1); if(ix != -1) { category = loc.substring(0, ix); } } } } } Set set = (Set)categories.get(category); if(set == null) { set = new TreeSet(new BRComparator()); categories.put(category, set); } set.add(br); } int i = 0; DefaultMutableTreeNode selNode = null; for(Iterator it = categories.keySet().iterator(); it.hasNext();) { String category = (String)it.next(); Set set = (Set)categories.get(category); final DefaultMutableTreeNode categoryNode = new CategoryNode(category); for(Iterator it2 = set.iterator(); it2.hasNext();) { BundleRecord br = (BundleRecord)it2.next(); DefaultMutableTreeNode brNode = new OBRNode(br); categoryNode.add(brNode); i++; String loc = (String)br.getAttribute(BundleRecord.BUNDLE_UPDATELOCATION); locationMap.put(loc, brNode); if(brOld != null && loc.equals(brOld.getAttribute(BundleRecord.BUNDLE_UPDATELOCATION))) { selNode = brNode; } } rootNode.add(categoryNode); } final TreePath selPath = new TreePath(selNode != null ? selNode.getPath() : rootNode.getPath()); showPath(selPath, treeModel); } } }; t.start(); } /** * Show the specified path and possible model (on the Swing thread) * * @param selPath path to show * @param model if not null, set as tree's model before setting * selected path. */ void showPath(final TreePath selPath, final TreeModel model) { SwingUtilities.invokeLater(new Runnable() { public void run() { if(model != null) { recordTree.setModel(model); } recordTree.expandPath(selPath); recordTree.setSelectionPath(selPath); recordTree.scrollPathToVisible(selPath); } }); } /** * Assert that the URLs seem to be valid ULRs. * * @throws RuntimeException if any of the strings in urls * fails to resolve to valid URL. */ void assertRepoURLs(String[] urls) { if(urls == null) { throw new RuntimeException("No URLs set"); } StringBuffer sb = new StringBuffer(); int nConnectionErrs = 0; // for each of the strings, try to create an URL and // do an initial connect() for(int i = 0; i < urls.length; i++) { URLConnection conn = null; try { URL url = new URL(urls[i]); conn = url.openConnection(); conn.connect(); } catch (Exception e) { sb.append(" " + urls[i] + ": " + e); sb.append("\n"); nConnectionErrs++; } finally { // close? } } if(nConnectionErrs > 0) { String msg = "URL connection errors:\n" + sb.toString(); throw new RuntimeException(msg); } } /** * Clear the tree and set the text of the tree's root node. */ void setRootText(final String s) { try { SwingUtilities.invokeAndWait(new Runnable() { public void run() { recordTree.setModel(new DefaultTreeModel(new TopNode(s))); } }); } catch (Exception e) { } } /** * Query the user to a list of repo URLs */ void askRepoURls() { try { StringBuffer sb = new StringBuffer(); String[] urls = getOBR().getRepositoryURLs(); for(int i = 0; i < urls.length; i++) { sb.append(urls[i]); if(i < urls.length - 1) { sb.append("\n"); } } JPanel panel = new JPanel(new BorderLayout()); JTextArea text = new JTextArea(Math.min(3, urls.length), 40); text.setText(sb.toString()); // text.setPreferredSize(new Dimension(300, 100)); JScrollPane scroll = new JScrollPane(text, JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED, JScrollPane.HORIZONTAL_SCROLLBAR_AS_NEEDED); scroll.setPreferredSize(new Dimension(300, 100)); panel.add(scroll, BorderLayout.CENTER); panel.add(new JLabel("Repository URLs."), BorderLayout.NORTH); int option = JOptionPane.showConfirmDialog(this, panel, "Repository URLs", JOptionPane.YES_NO_OPTION); String r2 = text.getText(); if(option == 0 && !r2.equals(sb.toString())) { StringTokenizer st = new StringTokenizer(r2, "\n"); urls = new String[st.countTokens()]; int i = 0; while (st.hasMoreTokens()) { urls[i++] = st.nextToken(); } try { getOBR().setRepositoryURLs(urls); refreshList(true); } catch (Exception e) { obrErr = "" + e; } } } catch (Exception e) { e.printStackTrace(); } } /** * Set the selected bundle by settingt the HTML detail string. */ void setSelected(TreeNode node) { if(node != null && (node instanceof OBRNode)) { brSelected = (OBRNode)node; Bundle b = getBundle(brSelected.getBundleRecord()); if(b != null) { gotoBid(b.getBundleId()); } else { getBundleSelectionModel().clearSelection(); } } else { brSelected = null; } installButton.setEnabled(brSelected != null && !bBusy); startButton.setEnabled(brSelected != null && !bBusy); StringBuffer sb = new StringBuffer(); sb.append("\n"); sb.append("
| "); Util.startFont(sb, "-1"); sb.append(htmlNode.getTitle()); sb.append("\n"); sb.append(" | \n"); String iconURL = htmlNode.getIconURL(); if(iconURL != null && !"".equals(iconURL.trim())) { sb.append("");
sb.append(" | ");
}
} else {
sb.append("");
}
sb.append("
" + "Select a bundle from the bundle repository list, then " + "select the install or start icons." + "
"); /* sb.append("" +
"" +
"Install and start a bundle and its dependencies." +
"
" +
"" +
"Reload the bundle repository list." +
"
" +
" " +
"Change category sorting." +
"
* Sort first by case-insensite name, tehn by version *
*/ class BRComparator implements Comparator { public int compare(Object o1, Object o2) { BundleRecord br1 = (BundleRecord)o1; BundleRecord br2 = (BundleRecord)o2; String s1 = Util.getBRName(br1).toLowerCase(); String s2 = Util.getBRName(br2).toLowerCase(); int n = 0; try { n = s1.compareTo(s2); if(n == 0) { s1 = (String)br1.getAttribute(BundleRecord.BUNDLE_VERSION); s2 = (String)br2.getAttribute(BundleRecord.BUNDLE_VERSION); } n = s1.compareTo(s2); } catch (Exception e) { } return n; } } /** * TreeNode to top of OBR tree. */ class TopNode extends DefaultMutableTreeNode implements HTMLable { String name; public TopNode(String name) { this.name = name; } public String getIconURL() { return null; } public String toString() { return name; } public String getTitle() { return toString(); } public String toHTML() { StringBuffer sb = new StringBuffer(); if(!"".equals(obrErr)) { Util.startFont(sb); sb.append("");
sb.append(obrErr);
sb.append("");
sb.append("");
} else {
Util.startFont(sb);
BundleRepositoryService obr = getOBR();
if(obr != null) {
sb.append("");
sb.append("Repository URLs
");
String[] urls = obr.getRepositoryURLs();
for(int i = 0; i < urls.length; i++) {
sb.append(urls[i]);
if(i < urls.length - 1) {
sb.append("
");
}
}
sb.append("
"); sb.append("Total number of bundles: " + obr.getBundleRecordCount()); sb.append("
"); } appendHelp(sb); sb.append(""); } return sb.toString(); } } /** * Tree node for grouping BundleRecords into categories in OBR tree */ class CategoryNode extends DefaultMutableTreeNode implements HTMLable { String category; public CategoryNode(String category) { this.category = category; } public String getIconURL() { return null; } public String toString() { return category + " (" + getChildCount() + ")"; } public String getTitle() { return toString(); } public String toHTML() { StringBuffer sb = new StringBuffer(); Util.startFont(sb); BundleRepositoryService obr = getOBR(); if(obr != null) { sb.append(""); sb.append("Bundles in this category: " + getChildCount()); sb.append("
"); } appendHelp(sb); sb.append(""); return sb.toString(); } } /** * Tree Node for wrapping a BundleRecord in the OBR tree. */ class OBRNode extends DefaultMutableTreeNode implements HTMLable { String name; StringBuffer log = new StringBuffer(); BundleRecord br; boolean bInstalled = false; boolean bBusy; public OBRNode(BundleRecord br) { super(null); this.br = br; name = Util.getBRName(br); // setIcon(bundleIcon); } public BundleRecord getBundleRecord() { return br; } public void appendLog(String s) { log.append(s); } public String getLog() { return log.toString(); } void setInstalled(boolean bInstalled) { this.bInstalled = bInstalled; } public String toString() { StringBuffer sb = new StringBuffer(); sb.append(name); if(bInstalled) { sb.append(" (installed)"); } return sb.toString(); } public String getIconURL() { String iconURL = (String)br.getAttribute("Application-Icon"); if(iconURL != null && !"".equals(iconURL)) { StringBuffer sb = new StringBuffer(); if(iconURL.startsWith("!")) { if(!iconURL.startsWith("!/")) { iconURL = "!/" + iconURL.substring(1); } iconURL = "jar:" + br.getAttribute(BundleRecord.BUNDLE_UPDATELOCATION) + iconURL; } else if(-1 == iconURL.indexOf(":")) { iconURL = "jar:" + br.getAttribute(BundleRecord.BUNDLE_UPDATELOCATION) + "!/" + iconURL; } return iconURL; } return null; } public String toHTML() { StringBuffer sb = new StringBuffer(); String[] attrs = br.getAttributes(); Map map = new TreeMap(); for(int i = 0; i < attrs.length; i++) { Object obj = br.getAttribute(attrs[i]); map.put(attrs[i], Util.toHTML(obj)); } String desc = (String)br.getAttribute(BundleRecord.BUNDLE_DESCRIPTION); if(desc != null) { Util.startFont(sb); sb.append(""); sb.append(desc); sb.append("
"); sb.append(""); map.remove(BundleRecord.BUNDLE_DESCRIPTION); map.remove(BundleRecord.BUNDLE_DESCRIPTION.toLowerCase()); } sb.append("");
sb.append("");
Util.startFont(sb, "-2");
sb.append(log);
sb.append("");
sb.append(" | ");
sb.append("|
| "); Util.startFont(sb); sb.append(key); sb.append(""); sb.append(" | "); sb.append(""); Util.startFont(sb); sb.append(val); sb.append(""); sb.append(" | "); sb.append("