File: GraphURI.java

package info (click to toggle)
libgrinvin-core-java 1.2-1
  • links: PTS, VCS
  • area: contrib
  • in suites: squeeze
  • size: 3,904 kB
  • ctags: 5,009
  • sloc: java: 23,494; xml: 423; makefile: 15
file content (278 lines) | stat: -rw-r--r-- 11,880 bytes parent folder | download
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
/* GraphURI.java
 * =========================================================================
 * This file is part of the GrInvIn project - http://www.grinvin.org
 * 
 * Copyright (C) 2005-2008 Universiteit Gent
 * 
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or (at
 * your option) any later version.
 * 
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 * 
 * A copy of the GNU General Public License can be found in the file
 * LICENSE.txt provided with the source distribution of this program (see
 * the META-INF directory in the source jar). This license can also be
 * found on the GNU website at http://www.gnu.org/licenses/gpl.html.
 * 
 * If you did not receive a copy of the GNU General Public License along
 * with this program, contact the lead developer, or write to the Free
 * Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
 * 02110-1301, USA.
 */

package org.grinvin.graphs;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.URL;
import java.net.URLDecoder;
import java.util.logging.Level;
import java.util.logging.Logger;

import org.grinvin.factories.FactoryException;
import org.grinvin.factories.FactoryManager;
import org.grinvin.factories.FactoryParameterException;
import org.grinvin.factories.graphs.GraphFactory;
import org.grinvin.io.graphs.GraphBundleLoader;
import org.grinvin.io.IOFormatException;
import org.grinvin.io.InvariantValuesLoader;
import org.grinvin.io.SectionLoader;
import org.grinvin.params.ParameterList;
import org.grinvin.preferences.GrinvinPreferences;
import org.grinvin.preferences.GrinvinPreferences.Preference;

/**
 * Utility class provides a method {@link #load} to load a graph that corresponds
 * to an URI.
 * Currently the following URIs are supported:
 * <ul>
 * <li>Any absolute URI which can be converted to an URL with a supported protocol handler.
 * I.e., URIs with schemes like <tt>file:</tt>, <tt>http:</tt>, <tt>jar:</tt>.
 * The resources are supposed to refer to streams in <tt>.gph</tt>-format.
 * See package <a href="io/package-summary.html#package_description">org.grinvin.io</a>
 * for more information on this format.</li>
 * <li>An absolute URI with scheme <tt>graph:</tt> which represents a graph that
 * can be created by a {@link GraphFactory}.</li>
 * <li>An absolute URI with scheme <tt>classpath:</tt> which represents a graph
 * resource on the class path.</li>
 * <li>A relative URI with scheme <tt>session:</tt> which represents a graph
 * in the current workspace directory.</li>
 * <li>A null URI is equivalent to an URI with scheme <tt>session:</tt>. A graph
 * with a null URI will be assigned a session URI when needed.</li>
 * </ul>
 * An <tt>graph:</tt> URI has the following form:
 * <blockquote>
 *   <b>graph:</b><i>graph_factory-id</i>[<b>?</b><i>name-value-pairs</i>]
 * </blockquote>
 * <p>The <i>graph factory id</i> identifies an object of type {@link GraphFactory}. 
 * If present, the <i>name/value pairs</i> indicate
 * additional parameters for that factory. They are formatted in a style similar
 * to that of HTTP query strings:
 * <blockquote>
 *    name1<b>=</b>value1<b>&</b>name2<b>=</b>value2<b>&</b>...<b>&</b>name3<b>=</b>value3</b>
 * </blockquote>
 * E.g., the following represents the complete graph of order 4
 * <pre>
 *     graph:org.grinvin.factories.CompleteGraphFactory?order=4
 * </pre>
 */
public final class GraphURI {
    
    // make sure clients do not instantiate this class
    private GraphURI() {}
    
    //
    public static boolean isFactoryGenerated(URI uri) {
        return compareScheme("graph", uri);
    }
    
    //
    public static boolean isClasspath(URI uri) {
        return compareScheme("classpath", uri);
    }
    
    //
    public static boolean isFile(URI uri) {
        return compareScheme("file", uri);
    }
    
    //
    public static boolean isGlobal(URI uri) {
        return isFactoryGenerated(uri) || isClasspath(uri);
    }
    
    //
    public static boolean isLocal(URI uri) {
        return isFile(uri);
    }
    
    /**
     * Is this a null URI or an URI with a 'session' scheme. URIs of this
     * type correspond to graphs that reside in memory only (and can be
     * persisted to a workspace).
     */
    public static boolean isSession(URI uri) {
        if (uri == null)
            return true;
        else
            return "session".equals(uri.getScheme());
    }
    
    //
    public static URI createFactory(String ssp) throws URISyntaxException {
        return new URI("graph", ssp, null);
    }
    
    //
    public static URI createSession(String ssp) throws URISyntaxException {
        return new URI("session", ssp, null);
    }
    
    //
    private static boolean compareScheme(String scheme, URI uri) {
        return (uri != null && uri.getScheme().equals(scheme)) ;
    }
    
    /**
     * Return the type corresponding to the given URI.
     */
    public static GraphURIType getType(URI uri) {
        if (GraphURI.isSession(uri)) {
            return GraphURIType.GRAPH_SESSION;
        } else if (GraphURI.isGlobal(uri)) {
            return GraphURIType.GRAPH_GLOBAL;
        } else { // GraphURI.isLocal(uri)
            return GraphURIType.GRAPH_LOCAL;
        }
    }
    
    private static class ClasspathSectionLoader implements SectionLoader {
        public InputStream openSection(String name) throws IOException {
            return GraphURI.class.getResource(name).openStream();
        }
    }
    
    /**
     * Load the graph that corresponds to the given URI into the given graph bundle.
     * @param uri URI that represents the graph
     * @param graphBundle Graph bundle which will hold the result. Preferably empty.
     * @throws GraphURIException when the graph could not be obtained from the given URI.
     */
    public static void load(URI uri, GraphBundle graphBundle, SectionLoader sloader) throws GraphURIException {
        
        if (! uri.isAbsolute()) {
            throw new GraphURIException("URI should be absolute: " + uri);
        }
        try {
            if (isClasspath(uri)) {
                URL url = GraphURI.class.getResource(uri.getSchemeSpecificPart());
                if (url == null)
                    throw new GraphURIException("Graph could not be found: " + uri);
                URL metaInfoURL = GraphURI.class.getResource(uri.getSchemeSpecificPart() + "/meta-info.xml");
                if (metaInfoURL == null)
                    GraphBundleLoader.loadFromZip(graphBundle,url.openStream());
                else
                    GraphBundleLoader.load(graphBundle, new ClasspathSectionLoader(), uri.getSchemeSpecificPart());
            } else if (isGlobal(uri)) {
                String raw = uri.getRawSchemeSpecificPart();
                int pos = raw.indexOf('?');
                if (pos >= 0)
                    loadGraphScheme(raw.substring(0,pos), raw.substring(pos+1), graphBundle);
                else
                    loadGraphScheme(raw, "", graphBundle);
            } else if (isSession(uri)) {
                if (sloader != null)
                    GraphBundleLoader.load(graphBundle, sloader, uri.getSchemeSpecificPart());
                else
                    throw new GraphURIException("Session graph could not be loaded without SectionLoader: " + uri);
            } else { // file: uri (on local file system)
                try {
                    URL url = uri.toURL();
                    File directory = new File(uri);
                    if (directory.isDirectory()) {
                        GraphBundleLoader.loadFromDirectory(graphBundle, directory);
                    } else {
                        GraphBundleLoader.loadFromZip(graphBundle,url.openStream());
                    }
                } catch (MalformedURLException ex) {
                    throw new IllegalArgumentException("URI not supported: " + uri);
                }
            }
        } catch (IOException ioex) {
            throw new GraphURIException("URI could not be loaded", ioex);
        }
        
    }
    
    /**
     * Load a graph factory with the given id.
     */
    private static GraphFactory getFactory(String rawFactoryId) throws GraphURIException {
        try {
            String factoryId = URLDecoder.decode(rawFactoryId, "UTF-8");
            return FactoryManager.getGraphFactoryBroker().get(factoryId);
        } catch (UnsupportedEncodingException ex) {
            throw new RuntimeException("Encoding UTF-8 unexpectedly not known", ex);
        } 
    }
    
    /**
     * Load a graph for a 'graph:'-URI.
     */
    private static void loadGraphScheme(String rawFactoryId, String queryString, GraphBundle bundle) throws GraphURIException {
        GraphFactory factory = getFactory(rawFactoryId);
        if (factory == null)
            throw new GraphURIException("Could not create factory " + rawFactoryId);
        ParameterList list = factory.getParameters();
        try {
            factory.setParameterValues(list.parseQueryString(queryString));
            factory.createGraph(bundle);
            
            //load cached invariant values
            String cachedFilename = rawFactoryId + "-" + queryString.replace('&', '_').replace('=','_') + ".xml";
            File cachedFile = new File(GrinvinPreferences.getInstance().getStringPreference(Preference.GRINVIN_CACHE_DIR) + "/invariantvalues/" + cachedFilename);
            if (cachedFile.exists()) {
                try {
                    InvariantValuesLoader.load(bundle, new FileInputStream(cachedFile));
                } catch (IOFormatException ex) {
                    //something wrong with the xml file
                    //ignore this, the file will be regenerated on the next save
                    Logger.getLogger("org.grinvin.io").log(Level.WARNING, "Failed to load cached invariant values for " + rawFactoryId + "?" + queryString, ex);
                }
            } else {
                // import old values
                cachedFile = new File(GrinvinPreferences.getInstance().getStringPreference(Preference.GRINVIN_CACHE_DIR_1_0) + "/" + cachedFilename);
                if (cachedFile.exists()) {
                    try {
                        InvariantValuesLoader.load_1_0(bundle, new FileInputStream(cachedFile));
                    } catch (IOFormatException ex) {
                        //something wrong with the xml file
                        //ignore this, the file will be regenerated on the next save
                        Logger.getLogger("org.grinvin.io").log(Level.WARNING, "Failed to import old cached invariant values for " + rawFactoryId + "?" + queryString, ex);
                    }
                }
            }
            
        } catch (FactoryParameterException ex) {
            throw new GraphURIException("Could not initialize parameters", ex);
        } catch (FactoryException ex) {
            throw new GraphURIException("Could not create graph", ex);
        } catch (IllegalArgumentException ex) {
            throw new GraphURIException("Could not handle parameters", ex);
        } catch (Exception ex) {
            // makes sure Grinvin does not go down with defunct graph factories
            throw new GraphURIException("Undefined exception in factory", ex);
        }
    }
}