17424747928

Committed 03 Sep 2025 06:13AM UTC coverage: 12.048% (-0.02%) from 12.066%

Build # 17424747928

Build Type

push

github

Committed by

tkuhn

Commit Message

Update dependencies and adapt to new exceptions in nanopub-java

Run Details

331 of 3866 branches covered (8.56%)

Branch coverage included in aggregate %.

967 of 6908 relevant lines covered (14.0%)

0.61 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

77.78

src/main/java/com/knowledgepixels/nanodash/QueryApiAccess.java

package com.knowledgepixels.nanodash;

import org.apache.commons.lang3.tuple.Pair;
import org.eclipse.rdf4j.model.IRI;
import org.nanopub.extra.services.APINotReachableException;
import org.nanopub.extra.services.ApiResponse;
import org.nanopub.extra.services.FailedApiCallException;
import org.nanopub.extra.services.NotEnoughAPIInstancesException;
import org.nanopub.extra.services.QueryAccess;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

/**
 * Utility class for accessing and managing API queries.
 * Provides methods to retrieve query results, manage query IDs, and fetch the latest versions of nanopublications.
 */
public class QueryApiAccess {

    private QueryApiAccess() {
    }  // no instances allowed

    private static ConcurrentMap<String, String> queryIds = new ConcurrentHashMap<>();
    private static final Logger logger = LoggerFactory.getLogger(QueryApiAccess.class);

    private static ConcurrentMap<String, Pair<Long, String>> latestVersionMap = new ConcurrentHashMap<>();

    private static final String queryIriPattern = "^(.*[^A-Za-z0-9-_])(RA[A-Za-z0-9-_]{43})[/#]([^/#]+)$";

    static {
        // TODO Load this dynamically somehow at some point:
        load("RAe-oA5eSmkCXCALZ99-0k4imnlI74KPqURfhHOmnzo6A/get-latest-nanopubs-from-pubkeys");
        load("RAuy4N1h4vZ1wgBUMvTiWw2y_Y0_5oFYRTwdq-xj2qqNM/get-latest-nanopubs-from-userid");
        load("RAZbyFSenuKSRMLGlRfrbeu6vQ6g2IEECYZ2zSGcIBIhQ/get-accepted-nanopubs-by-author");
        load("RAiCBvPL2hRGzI8g5L68O-C9yEXryC_vG35GdEm5jtH_s/get-user-stats-from-pubkeys");  // Deactivated for now...
        load("RA3U23LL3xbNwsu92fAqsKb0kagOud4f9TlRQq3evNJck/get-user-stats-from-userid");  // Deactivated for now...
        load("RAcNvmEiUNUb2a7O4fwRvy2x2BCN640AC880fTzFworr8/get-top-creators-last30d");
        load("RAmhy4KQe6I80bA2Da4JziYyKBoXuXIzqo57GDSVgLfDg/get-top-authors");
        load("RA7oUCHG8TEjVQpGTUN5sfu3_IQmza3aSBSCxfJdBc3Rs/get-most-recent-nanopubs");
        load("RA52cg2OzJucmpCb7KSKTgfPV5HKIjsFcmww_rxb7v5zU/get-latest-accepted");
        load("RAPGhXDRzeGu-Qk0AkjleEtxMxqAvJ-dZn7985gzAbyhs/get-publisher-version");
        load("RAvL7pe2ppsfq4mVWTdJjssYGsjrmliNd_sZO2ytLvg1Y/get-most-used-templates-last30d");
        load("RANn4Mu8r8bqJA9KJMGXTQAEGAEvtNKGFsuhRIC6BRIOo/get-latest-nanopubs-by-type");
        load("RAiRsB2YywxjsBMkVRTREJBooXhf2ZOHoUs5lxciEl37I/get-latest-version-of-np");
        load("RA0aZxyh_I0rCJyBepXOWC2tGdI5YYHORFCC-qBR8xHZA/get-all-user-intros");
        load("RA-tlMmQA7iT2wR2aS3PlONrepX7vdXbkzeWluea7AECg/get-suggested-templates-to-get-started");
        load("RAtIndAeo8zYnEvTjFRaHD2AlenvkJHlw6P52JWR_l5dQ/get-type-overview-last-12-months");
        load("RAn3agwsH2yk-8132RJApGYxdPSHHCXDAIYiCaSBBo6tg/get-approved-nanopubs");
        load("RAz1ogtMxSTKSOYwHAfD5M3Y-vd1vd46OZta_vvbqh8kY/find-uri-references");
        load("RAE35dYJQlpnqim7VeKuu07E9I1LQUZpkdYQR4RvU3KMU/get-nanopubs-by-type");
        load("RALZXWg5lZoJoQ0VHL5mpDgNxYpqU6FoDLWGp4rs8A6b8/get-introducing-nanopub");
        load("RAWruhiSmyzgZhVRs8QY8YQPAgHzTfl7anxII1de-yaCs/fulltext-search-on-labels");
        load("RAVEmFh3d6qonTFQ5S9SVqXZh0prrH1YLhSSs0dJvyvpM/find-things");
        load("RAjt1H9rCSr6A9VGzlhye00zPdH69JdGc3kd_2VjDmzVg/get-instances");
        load("RAH06iUwnvj_pRARY15ayJAY5tuJau3rCvHhPPhe49fVI/get-classes-for-thing");
        load("RAJStXEm1wZcg34ZLPqe00VPSzIVCwC2rrxdj_JR8v5DY/find-referencing-nanopubs");  // not yet used...
        load("RAtftxAXJubB4rlm9fOvvHNVIkXvWQLC6Ag_MiV7HL0ow/get-labels-for-thing");  // not yet used...
        load("RARtWHRzNY5hh31X2VB5eOCJAdp9Cjv4CakA0Idqz69MI/get-templates-with-uri");
        load("RAWH0fe1RCpoOgaJE1B2qfTzzdTiBUUK7iIk6l7Zll9mg/get-newer-versions-of-np");
        load("RAQqjXQYlxYQeI4Y3UQy9OrD5Jx1E3PJ8KwKKQlWbiYSw/get-queries");
        load("RAzXDzCHoZmJITgYYquLwDDkSyNf3eKKQz9NfQPYB1cyE/get-latest-thing-nanopub");
        load("RAnpimW7SPwaum2fefdS6_jpzYxcTRGjE-pmgNTL_BBJU/get-projects");
        load("RAJmZoM0xCGE8OL6EgmQBOd1M58ggNkwZ0IUqHOAPRfvE/get-parts");
        load("RA6bgrU3Ezfg5VAiLru0BFYHaSj6vZU6jJTscxNl8Wqvc/get-assertion-templates");
        load("RA4bt3MQRnEPC2nSsdbCJc74wT-e1w68dSCpYVyvG0274/get-provenance-templates");
        load("RAMcdiJpvvk8424AJIH1jsDUQVcPYOLRw0DNnZt_ND_LQ/get-pubinfo-templates");
        load("RAwfurJs7mlYWdW4fSpd6hM1AGjQ_2QMiy3VyOP6vdrlE/get-owners-of-project");
        load("RAHooeYnQyfu4gXNg5g32PlQRlqsfEblsCNG2DjSYF-y0/get-members-of-project");
    }

    /**
     * Loads a query ID into the queryIds map.
     *
     * @param queryId The query ID to load.
     */
    static void load(String queryId) {
        queryIds.put(queryId.substring(46), queryId);
    }

    /**
     * Forces the retrieval of an API response for a given query name and parameters.
     * Retries until a valid response is received.
     *
     * @param queryName The name of the query.
     * @return The API response.
     */
    public static ApiResponse forcedGet(String queryName) {
        return forcedGet(queryName, new HashMap<>());
    }

    /**
     * Forces the retrieval of an API response for a given query name and a single parameter.
     * Retries until a valid response is received.
     *
     * @param queryName  The name of the query.
     * @param paramKey   The key of the parameter.
     * @param paramValue The value of the parameter.
     * @return The API response.
     */
    public static ApiResponse forcedGet(String queryName, String paramKey, String paramValue) {
        Map<String, String> params = new HashMap<>();
        params.put(paramKey, paramValue);
        return forcedGet(queryName, params);
    }

    /**
     * Forces the retrieval of an API response for a given query name and parameters.
     * Retries until a valid response is received.
     *
     * @param queryName The name of the query.
     * @param params    The parameters for the query.
     * @return The API response.
     */
    public static ApiResponse forcedGet(String queryName, Map<String, String> params) {
        while (true) {
            ApiResponse resp = null;
            try {
                resp = QueryApiAccess.get(queryName, params);
            } catch (Exception ex) {
                // TODO We should be more specific about which exceptions we catch here
                //      and generally improve this, as this could hang forever.
                logger.error("Error while forcing API get for query '{}' with params {}", queryName, params, ex);
            }
            if (resp != null) return resp;
            try {
                Thread.sleep(100);
            } catch (InterruptedException ex) {
                logger.error("Interrupted while forcing API get for query '{}' with params {}", queryName, params, ex);
            }
        }
    }

    /**
     * Retrieves an API response for a given query name.
     *
     * @param queryName The name of the query.
     * @return The API response.
     * @throws org.nanopub.extra.services.FailedApiCallException If the API call fails.
     */
    public static ApiResponse get(String queryName) throws FailedApiCallException, APINotReachableException, NotEnoughAPIInstancesException {
        return get(queryName, new HashMap<>());
    }

    /**
     * Retrieves an API response for a given query name and a single parameter.
     *
     * @param queryName  The name of the query.
     * @param paramKey   The key of the parameter.
     * @param paramValue The value of the parameter.
     * @return The API response.
     * @throws org.nanopub.extra.services.FailedApiCallException If the API call fails.
     */
    public static ApiResponse get(String queryName, String paramKey, String paramValue) throws FailedApiCallException, APINotReachableException, NotEnoughAPIInstancesException {
        Map<String, String> params = new HashMap<>();
        params.put(paramKey, paramValue);
        return get(queryName, params);
    }

    /**
     * Retrieves an API response for a given query name and parameters.
     *
     * @param queryName The name of the query.
     * @param params    The parameters for the query.
     * @return The API response.
     * @throws org.nanopub.extra.services.FailedApiCallException If the API call fails.
     */
    public static ApiResponse get(String queryName, Map<String, String> params) throws FailedApiCallException, APINotReachableException, NotEnoughAPIInstancesException {
        String queryId;
        if (queryName.matches("^RA[A-Za-z0-9-_]{43}/.*$")) {
            queryId = queryName;
        } else if (queryIds.containsKey(queryName)) {
            queryId = queryIds.get(queryName);
        } else {
            throw new IllegalArgumentException("Query name not known: " + queryName);
        }
        return QueryAccess.get(queryId, params);
    }

    /**
     * Retrieves the latest version ID of a given nanopublication.
     *
     * @param nanopubId The ID of the nanopublication.
     * @return The latest version ID.
     */
    public static String getLatestVersionId(String nanopubId) {
        long currentTime = System.currentTimeMillis();
        if (!latestVersionMap.containsKey(nanopubId) || currentTime - latestVersionMap.get(nanopubId).getLeft() > 1000 * 60) {
            // Re-fetch if existing value is older than 1 minute
            Map<String, String> params = new HashMap<>();
            params.put("np", nanopubId);
            try {
                ApiResponse r = get("get-latest-version-of-np", params);
                if (r.getData().size() != 1) return nanopubId;
                String l = r.getData().get(0).get("latest");
                latestVersionMap.put(nanopubId, Pair.of(currentTime, l));
            } catch (Exception ex) {
                logger.error("Error while getting latest version of nanopub '{}'", nanopubId, ex);
                return nanopubId;
            }
        }
        return latestVersionMap.get(nanopubId).getRight();
    }

    /**
     * Extracts the query ID from a given query IRI.
     *
     * @param queryIri The query IRI.
     * @return The query ID, or null if the IRI is invalid.
     */
    public static String getQueryId(IRI queryIri) {
        if (queryIri == null) return null;
        if (!queryIri.stringValue().matches(queryIriPattern)) return null;
        return queryIri.stringValue().replaceFirst(queryIriPattern, "$2/$3");
    }

    /**
     * Retrieves the query ID for a given query name.
     *
     * @param queryName The name of the query.
     * @return The query ID, or null if the query name is unknown.
     */
    public static String getQueryId(String queryName) {
        return queryIds.get(queryName);
    }

    /**
     * Extracts the query name from a given query IRI.
     *
     * @param queryIri The query IRI.
     * @return The query name, or null if the IRI is invalid.
     */
    public static String getQueryName(IRI queryIri) {
        if (queryIri == null) return null;
        if (!queryIri.stringValue().matches(queryIriPattern)) return null;
        return queryIri.stringValue().replaceFirst(queryIriPattern, "$3");
    }

}

1	package com.knowledgepixels.nanodash;
2
3	import org.apache.commons.lang3.tuple.Pair;
4	import org.eclipse.rdf4j.model.IRI;
5	import org.nanopub.extra.services.APINotReachableException;
6	import org.nanopub.extra.services.ApiResponse;
7	import org.nanopub.extra.services.FailedApiCallException;
8	import org.nanopub.extra.services.NotEnoughAPIInstancesException;
9	import org.nanopub.extra.services.QueryAccess;
10	import org.slf4j.Logger;
11	import org.slf4j.LoggerFactory;
12
13	import java.util.HashMap;
14	import java.util.Map;
15	import java.util.concurrent.ConcurrentHashMap;
16	import java.util.concurrent.ConcurrentMap;
17
18	/**
19	* Utility class for accessing and managing API queries.
20	* Provides methods to retrieve query results, manage query IDs, and fetch the latest versions of nanopublications.
21	*/
22	public class QueryApiAccess {
23
24	private QueryApiAccess() {
25	} // no instances allowed
26
27	private static ConcurrentMap<String, String> queryIds = new ConcurrentHashMap<>();	4✔
28	private static final Logger logger = LoggerFactory.getLogger(QueryApiAccess.class);	3✔
29
30	private static ConcurrentMap<String, Pair<Long, String>> latestVersionMap = new ConcurrentHashMap<>();	4✔
31
32	private static final String queryIriPattern = "^(.*[^A-Za-z0-9-_])(RA[A-Za-z0-9-_]{43})[/#]([^/#]+)$";
33
34	static {
35	// TODO Load this dynamically somehow at some point:
36	load("RAe-oA5eSmkCXCALZ99-0k4imnlI74KPqURfhHOmnzo6A/get-latest-nanopubs-from-pubkeys");	2✔
37	load("RAuy4N1h4vZ1wgBUMvTiWw2y_Y0_5oFYRTwdq-xj2qqNM/get-latest-nanopubs-from-userid");	2✔
38	load("RAZbyFSenuKSRMLGlRfrbeu6vQ6g2IEECYZ2zSGcIBIhQ/get-accepted-nanopubs-by-author");	2✔
39	load("RAiCBvPL2hRGzI8g5L68O-C9yEXryC_vG35GdEm5jtH_s/get-user-stats-from-pubkeys"); // Deactivated for now...	2✔
40	load("RA3U23LL3xbNwsu92fAqsKb0kagOud4f9TlRQq3evNJck/get-user-stats-from-userid"); // Deactivated for now...	2✔
41	load("RAcNvmEiUNUb2a7O4fwRvy2x2BCN640AC880fTzFworr8/get-top-creators-last30d");	2✔
42	load("RAmhy4KQe6I80bA2Da4JziYyKBoXuXIzqo57GDSVgLfDg/get-top-authors");	2✔
43	load("RA7oUCHG8TEjVQpGTUN5sfu3_IQmza3aSBSCxfJdBc3Rs/get-most-recent-nanopubs");	2✔
44	load("RA52cg2OzJucmpCb7KSKTgfPV5HKIjsFcmww_rxb7v5zU/get-latest-accepted");	2✔
45	load("RAPGhXDRzeGu-Qk0AkjleEtxMxqAvJ-dZn7985gzAbyhs/get-publisher-version");	2✔
46	load("RAvL7pe2ppsfq4mVWTdJjssYGsjrmliNd_sZO2ytLvg1Y/get-most-used-templates-last30d");	2✔
47	load("RANn4Mu8r8bqJA9KJMGXTQAEGAEvtNKGFsuhRIC6BRIOo/get-latest-nanopubs-by-type");	2✔
48	load("RAiRsB2YywxjsBMkVRTREJBooXhf2ZOHoUs5lxciEl37I/get-latest-version-of-np");	2✔
49	load("RA0aZxyh_I0rCJyBepXOWC2tGdI5YYHORFCC-qBR8xHZA/get-all-user-intros");	2✔
50	load("RA-tlMmQA7iT2wR2aS3PlONrepX7vdXbkzeWluea7AECg/get-suggested-templates-to-get-started");	2✔
51	load("RAtIndAeo8zYnEvTjFRaHD2AlenvkJHlw6P52JWR_l5dQ/get-type-overview-last-12-months");	2✔
52	load("RAn3agwsH2yk-8132RJApGYxdPSHHCXDAIYiCaSBBo6tg/get-approved-nanopubs");	2✔
53	load("RAz1ogtMxSTKSOYwHAfD5M3Y-vd1vd46OZta_vvbqh8kY/find-uri-references");	2✔
54	load("RAE35dYJQlpnqim7VeKuu07E9I1LQUZpkdYQR4RvU3KMU/get-nanopubs-by-type");	2✔
55	load("RALZXWg5lZoJoQ0VHL5mpDgNxYpqU6FoDLWGp4rs8A6b8/get-introducing-nanopub");	2✔
56	load("RAWruhiSmyzgZhVRs8QY8YQPAgHzTfl7anxII1de-yaCs/fulltext-search-on-labels");	2✔
57	load("RAVEmFh3d6qonTFQ5S9SVqXZh0prrH1YLhSSs0dJvyvpM/find-things");	2✔
58	load("RAjt1H9rCSr6A9VGzlhye00zPdH69JdGc3kd_2VjDmzVg/get-instances");	2✔
59	load("RAH06iUwnvj_pRARY15ayJAY5tuJau3rCvHhPPhe49fVI/get-classes-for-thing");	2✔
60	load("RAJStXEm1wZcg34ZLPqe00VPSzIVCwC2rrxdj_JR8v5DY/find-referencing-nanopubs"); // not yet used...	2✔
61	load("RAtftxAXJubB4rlm9fOvvHNVIkXvWQLC6Ag_MiV7HL0ow/get-labels-for-thing"); // not yet used...	2✔
62	load("RARtWHRzNY5hh31X2VB5eOCJAdp9Cjv4CakA0Idqz69MI/get-templates-with-uri");	2✔
63	load("RAWH0fe1RCpoOgaJE1B2qfTzzdTiBUUK7iIk6l7Zll9mg/get-newer-versions-of-np");	2✔
64	load("RAQqjXQYlxYQeI4Y3UQy9OrD5Jx1E3PJ8KwKKQlWbiYSw/get-queries");	2✔
65	load("RAzXDzCHoZmJITgYYquLwDDkSyNf3eKKQz9NfQPYB1cyE/get-latest-thing-nanopub");	2✔
66	load("RAnpimW7SPwaum2fefdS6_jpzYxcTRGjE-pmgNTL_BBJU/get-projects");	2✔
67	load("RAJmZoM0xCGE8OL6EgmQBOd1M58ggNkwZ0IUqHOAPRfvE/get-parts");	2✔
68	load("RA6bgrU3Ezfg5VAiLru0BFYHaSj6vZU6jJTscxNl8Wqvc/get-assertion-templates");	2✔
69	load("RA4bt3MQRnEPC2nSsdbCJc74wT-e1w68dSCpYVyvG0274/get-provenance-templates");	2✔
70	load("RAMcdiJpvvk8424AJIH1jsDUQVcPYOLRw0DNnZt_ND_LQ/get-pubinfo-templates");	2✔
71	load("RAwfurJs7mlYWdW4fSpd6hM1AGjQ_2QMiy3VyOP6vdrlE/get-owners-of-project");	2✔
72	load("RAHooeYnQyfu4gXNg5g32PlQRlqsfEblsCNG2DjSYF-y0/get-members-of-project");	2✔
73	}	1✔
74
75	/**
76	* Loads a query ID into the queryIds map.
77	*
78	* @param queryId The query ID to load.
79	*/
80	static void load(String queryId) {
81	queryIds.put(queryId.substring(46), queryId);	7✔
82	}	1✔
83
84	/**
85	* Forces the retrieval of an API response for a given query name and parameters.
86	* Retries until a valid response is received.
87	*
88	* @param queryName The name of the query.
89	* @return The API response.
90	*/
91	public static ApiResponse forcedGet(String queryName) {
92	return forcedGet(queryName, new HashMap<>());	6✔
93	}
94
95	/**
96	* Forces the retrieval of an API response for a given query name and a single parameter.
97	* Retries until a valid response is received.
98	*
99	* @param queryName The name of the query.
100	* @param paramKey The key of the parameter.
101	* @param paramValue The value of the parameter.
102	* @return The API response.
103	*/
104	public static ApiResponse forcedGet(String queryName, String paramKey, String paramValue) {
105	Map<String, String> params = new HashMap<>();	×
106	params.put(paramKey, paramValue);	×
107	return forcedGet(queryName, params);	×
108	}
109
110	/**
111	* Forces the retrieval of an API response for a given query name and parameters.
112	* Retries until a valid response is received.
113	*
114	* @param queryName The name of the query.
115	* @param params The parameters for the query.
116	* @return The API response.
117	*/
118	public static ApiResponse forcedGet(String queryName, Map<String, String> params) {
119	while (true) {
120	ApiResponse resp = null;	2✔
121	try {
122	resp = QueryApiAccess.get(queryName, params);	4✔
123	} catch (Exception ex) {	×
124	// TODO We should be more specific about which exceptions we catch here
125	// and generally improve this, as this could hang forever.
126	logger.error("Error while forcing API get for query '{}' with params {}", queryName, params, ex);	×
127	}	1✔
128	if (resp != null) return resp;	4✔
129	try {
130	Thread.sleep(100);	2✔
131	} catch (InterruptedException ex) {	×
132	logger.error("Interrupted while forcing API get for query '{}' with params {}", queryName, params, ex);	×
133	}	1✔
134	}	1✔
135	}
136
137	/**
138	* Retrieves an API response for a given query name.
139	*
140	* @param queryName The name of the query.
141	* @return The API response.
142	* @throws org.nanopub.extra.services.FailedApiCallException If the API call fails.
143	*/
144	public static ApiResponse get(String queryName) throws FailedApiCallException, APINotReachableException, NotEnoughAPIInstancesException {
145	return get(queryName, new HashMap<>());	6✔
146	}
147
148	/**
149	* Retrieves an API response for a given query name and a single parameter.
150	*
151	* @param queryName The name of the query.
152	* @param paramKey The key of the parameter.
153	* @param paramValue The value of the parameter.
154	* @return The API response.
155	* @throws org.nanopub.extra.services.FailedApiCallException If the API call fails.
156	*/
157	public static ApiResponse get(String queryName, String paramKey, String paramValue) throws FailedApiCallException, APINotReachableException, NotEnoughAPIInstancesException {
158	Map<String, String> params = new HashMap<>();	×
159	params.put(paramKey, paramValue);	×
160	return get(queryName, params);	×
161	}
162
163	/**
164	* Retrieves an API response for a given query name and parameters.
165	*
166	* @param queryName The name of the query.
167	* @param params The parameters for the query.
168	* @return The API response.
169	* @throws org.nanopub.extra.services.FailedApiCallException If the API call fails.
170	*/
171	public static ApiResponse get(String queryName, Map<String, String> params) throws FailedApiCallException, APINotReachableException, NotEnoughAPIInstancesException {
172	String queryId;
173	if (queryName.matches("^RA[A-Za-z0-9-_]{43}/.*$")) {	4✔
174	queryId = queryName;	3✔
175	} else if (queryIds.containsKey(queryName)) {	4✔
176	queryId = queryIds.get(queryName);	6✔
177	} else {
178	throw new IllegalArgumentException("Query name not known: " + queryName);	6✔
179	}
180	return QueryAccess.get(queryId, params);	4✔
181	}
182
183	/**
184	* Retrieves the latest version ID of a given nanopublication.
185	*
186	* @param nanopubId The ID of the nanopublication.
187	* @return The latest version ID.
188	*/
189	public static String getLatestVersionId(String nanopubId) {
190	long currentTime = System.currentTimeMillis();	2✔
191	if (!latestVersionMap.containsKey(nanopubId) \|\| currentTime - latestVersionMap.get(nanopubId).getLeft() > 1000 * 60) {	4!
192	// Re-fetch if existing value is older than 1 minute
193	Map<String, String> params = new HashMap<>();	4✔
194	params.put("np", nanopubId);	5✔
195	try {
196	ApiResponse r = get("get-latest-version-of-np", params);	4✔
197	if (r.getData().size() != 1) return nanopubId;	5!
198	String l = r.getData().get(0).get("latest");	8✔
199	latestVersionMap.put(nanopubId, Pair.of(currentTime, l));	8✔
200	} catch (Exception ex) {	×
201	logger.error("Error while getting latest version of nanopub '{}'", nanopubId, ex);	×
202	return nanopubId;	×
203	}	1✔
204	}
205	return latestVersionMap.get(nanopubId).getRight();	7✔
206	}
207
208	/**
209	* Extracts the query ID from a given query IRI.
210	*
211	* @param queryIri The query IRI.
212	* @return The query ID, or null if the IRI is invalid.
213	*/
214	public static String getQueryId(IRI queryIri) {
215	if (queryIri == null) return null;	×
216	if (!queryIri.stringValue().matches(queryIriPattern)) return null;	×
217	return queryIri.stringValue().replaceFirst(queryIriPattern, "$2/$3");	×
218	}
219
220	/**
221	* Retrieves the query ID for a given query name.
222	*
223	* @param queryName The name of the query.
224	* @return The query ID, or null if the query name is unknown.
225	*/
226	public static String getQueryId(String queryName) {
227	return queryIds.get(queryName);	5✔
228	}
229
230	/**
231	* Extracts the query name from a given query IRI.
232	*
233	* @param queryIri The query IRI.
234	* @return The query name, or null if the IRI is invalid.
235	*/
236	public static String getQueryName(IRI queryIri) {
237	if (queryIri == null) return null;	4✔
238	if (!queryIri.stringValue().matches(queryIriPattern)) return null;	7✔
239	return queryIri.stringValue().replaceFirst(queryIriPattern, "$3");	6✔
240	}
241
242	}

knowledgepixels / nanodash / 17424747928

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous