• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

knowledgepixels / nanodash / 17402557487

02 Sep 2025 11:49AM UTC coverage: 12.071% (+0.05%) from 12.023%
17402557487

push

github

tkuhn
Continue on project page development: load and show owners/members

331 of 3866 branches covered (8.56%)

Branch coverage included in aggregate %.

969 of 6904 relevant lines covered (14.04%)

0.62 hits per line

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

79.63
src/main/java/com/knowledgepixels/nanodash/QueryApiAccess.java
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.ApiResponse;
6
import org.nanopub.extra.services.FailedApiCallException;
7
import org.nanopub.extra.services.QueryAccess;
8
import org.slf4j.Logger;
9
import org.slf4j.LoggerFactory;
10

11
import java.util.HashMap;
12
import java.util.Map;
13
import java.util.concurrent.ConcurrentHashMap;
14
import java.util.concurrent.ConcurrentMap;
15

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

22
    private QueryApiAccess() {
23
    }  // no instances allowed
24

25
    private static ConcurrentMap<String, String> queryIds = new ConcurrentHashMap<>();
4✔
26
    private static final Logger logger = LoggerFactory.getLogger(QueryApiAccess.class);
3✔
27

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

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

32
    static {
33
        // TODO Load this dynamically somehow at some point:
34
        load("RAe-oA5eSmkCXCALZ99-0k4imnlI74KPqURfhHOmnzo6A/get-latest-nanopubs-from-pubkeys");
2✔
35
        load("RAuy4N1h4vZ1wgBUMvTiWw2y_Y0_5oFYRTwdq-xj2qqNM/get-latest-nanopubs-from-userid");
2✔
36
        load("RAZbyFSenuKSRMLGlRfrbeu6vQ6g2IEECYZ2zSGcIBIhQ/get-accepted-nanopubs-by-author");
2✔
37
        load("RAiCBvPL2hRGzI8g5L68O-C9yEXryC_vG35GdEm5jtH_s/get-user-stats-from-pubkeys");  // Deactivated for now...
2✔
38
        load("RA3U23LL3xbNwsu92fAqsKb0kagOud4f9TlRQq3evNJck/get-user-stats-from-userid");  // Deactivated for now...
2✔
39
        load("RAcNvmEiUNUb2a7O4fwRvy2x2BCN640AC880fTzFworr8/get-top-creators-last30d");
2✔
40
        load("RAmhy4KQe6I80bA2Da4JziYyKBoXuXIzqo57GDSVgLfDg/get-top-authors");
2✔
41
        load("RA7oUCHG8TEjVQpGTUN5sfu3_IQmza3aSBSCxfJdBc3Rs/get-most-recent-nanopubs");
2✔
42
        load("RA52cg2OzJucmpCb7KSKTgfPV5HKIjsFcmww_rxb7v5zU/get-latest-accepted");
2✔
43
        load("RAPGhXDRzeGu-Qk0AkjleEtxMxqAvJ-dZn7985gzAbyhs/get-publisher-version");
2✔
44
        load("RAvL7pe2ppsfq4mVWTdJjssYGsjrmliNd_sZO2ytLvg1Y/get-most-used-templates-last30d");
2✔
45
        load("RANn4Mu8r8bqJA9KJMGXTQAEGAEvtNKGFsuhRIC6BRIOo/get-latest-nanopubs-by-type");
2✔
46
        load("RAiRsB2YywxjsBMkVRTREJBooXhf2ZOHoUs5lxciEl37I/get-latest-version-of-np");
2✔
47
        load("RA0aZxyh_I0rCJyBepXOWC2tGdI5YYHORFCC-qBR8xHZA/get-all-user-intros");
2✔
48
        load("RA-tlMmQA7iT2wR2aS3PlONrepX7vdXbkzeWluea7AECg/get-suggested-templates-to-get-started");
2✔
49
        load("RAtIndAeo8zYnEvTjFRaHD2AlenvkJHlw6P52JWR_l5dQ/get-type-overview-last-12-months");
2✔
50
        load("RAn3agwsH2yk-8132RJApGYxdPSHHCXDAIYiCaSBBo6tg/get-approved-nanopubs");
2✔
51
        load("RAz1ogtMxSTKSOYwHAfD5M3Y-vd1vd46OZta_vvbqh8kY/find-uri-references");
2✔
52
        load("RAE35dYJQlpnqim7VeKuu07E9I1LQUZpkdYQR4RvU3KMU/get-nanopubs-by-type");
2✔
53
        load("RALZXWg5lZoJoQ0VHL5mpDgNxYpqU6FoDLWGp4rs8A6b8/get-introducing-nanopub");
2✔
54
        load("RAWruhiSmyzgZhVRs8QY8YQPAgHzTfl7anxII1de-yaCs/fulltext-search-on-labels");
2✔
55
        load("RAVEmFh3d6qonTFQ5S9SVqXZh0prrH1YLhSSs0dJvyvpM/find-things");
2✔
56
        load("RAjt1H9rCSr6A9VGzlhye00zPdH69JdGc3kd_2VjDmzVg/get-instances");
2✔
57
        load("RAH06iUwnvj_pRARY15ayJAY5tuJau3rCvHhPPhe49fVI/get-classes-for-thing");
2✔
58
        load("RAJStXEm1wZcg34ZLPqe00VPSzIVCwC2rrxdj_JR8v5DY/find-referencing-nanopubs");  // not yet used...
2✔
59
        load("RAtftxAXJubB4rlm9fOvvHNVIkXvWQLC6Ag_MiV7HL0ow/get-labels-for-thing");  // not yet used...
2✔
60
        load("RARtWHRzNY5hh31X2VB5eOCJAdp9Cjv4CakA0Idqz69MI/get-templates-with-uri");
2✔
61
        load("RAWH0fe1RCpoOgaJE1B2qfTzzdTiBUUK7iIk6l7Zll9mg/get-newer-versions-of-np");
2✔
62
        load("RAQqjXQYlxYQeI4Y3UQy9OrD5Jx1E3PJ8KwKKQlWbiYSw/get-queries");
2✔
63
        load("RAzXDzCHoZmJITgYYquLwDDkSyNf3eKKQz9NfQPYB1cyE/get-latest-thing-nanopub");
2✔
64
        load("RAnpimW7SPwaum2fefdS6_jpzYxcTRGjE-pmgNTL_BBJU/get-projects");
2✔
65
        load("RAJmZoM0xCGE8OL6EgmQBOd1M58ggNkwZ0IUqHOAPRfvE/get-parts");
2✔
66
        load("RA6bgrU3Ezfg5VAiLru0BFYHaSj6vZU6jJTscxNl8Wqvc/get-assertion-templates");
2✔
67
        load("RA4bt3MQRnEPC2nSsdbCJc74wT-e1w68dSCpYVyvG0274/get-provenance-templates");
2✔
68
        load("RAMcdiJpvvk8424AJIH1jsDUQVcPYOLRw0DNnZt_ND_LQ/get-pubinfo-templates");
2✔
69
        load("RAwfurJs7mlYWdW4fSpd6hM1AGjQ_2QMiy3VyOP6vdrlE/get-owners-of-project");
2✔
70
        load("RAHooeYnQyfu4gXNg5g32PlQRlqsfEblsCNG2DjSYF-y0/get-members-of-project");
2✔
71
    }
1✔
72

73
    /**
74
     * Loads a query ID into the queryIds map.
75
     *
76
     * @param queryId The query ID to load.
77
     */
78
    static void load(String queryId) {
79
        queryIds.put(queryId.substring(46), queryId);
7✔
80
    }
1✔
81

82
    /**
83
     * Forces the retrieval of an API response for a given query name and parameters.
84
     * Retries until a valid response is received.
85
     *
86
     * @param queryName The name of the query.
87
     * @return The API response.
88
     */
89
    public static ApiResponse forcedGet(String queryName) {
90
        return forcedGet(queryName, new HashMap<>());
6✔
91
    }
92

93
    /**
94
     * Forces the retrieval of an API response for a given query name and a single parameter.
95
     * Retries until a valid response is received.
96
     *
97
     * @param queryName  The name of the query.
98
     * @param paramKey   The key of the parameter.
99
     * @param paramValue The value of the parameter.
100
     * @return The API response.
101
     */
102
    public static ApiResponse forcedGet(String queryName, String paramKey, String paramValue) {
103
        Map<String, String> params = new HashMap<>();
×
104
        params.put(paramKey, paramValue);
×
105
        return forcedGet(queryName, params);
×
106
    }
107

108
    /**
109
     * Forces the retrieval of an API response for a given query name and parameters.
110
     * Retries until a valid response is received.
111
     *
112
     * @param queryName The name of the query.
113
     * @param params    The parameters for the query.
114
     * @return The API response.
115
     */
116
    public static ApiResponse forcedGet(String queryName, Map<String, String> params) {
117
        while (true) {
118
            ApiResponse resp = null;
2✔
119
            try {
120
                resp = QueryApiAccess.get(queryName, params);
4✔
121
            } catch (Exception ex) {
1✔
122
                // TODO We should be more specific about which exceptions we catch here
123
                //      and generally improve this, as this could hang forever.
124
                logger.error("Error while forcing API get for query '{}' with params {}", queryName, params, ex);
17✔
125
            }
1✔
126
            if (resp != null) return resp;
4✔
127
            try {
128
                Thread.sleep(100);
2✔
129
            } catch (InterruptedException ex) {
×
130
                logger.error("Interrupted while forcing API get for query '{}' with params {}", queryName, params, ex);
×
131
            }
1✔
132
        }
1✔
133
    }
134

135
    /**
136
     * Retrieves an API response for a given query name.
137
     *
138
     * @param queryName The name of the query.
139
     * @return The API response.
140
     * @throws org.nanopub.extra.services.FailedApiCallException If the API call fails.
141
     */
142
    public static ApiResponse get(String queryName) throws FailedApiCallException {
143
        return get(queryName, new HashMap<>());
6✔
144
    }
145

146
    /**
147
     * Retrieves an API response for a given query name and a single parameter.
148
     *
149
     * @param queryName  The name of the query.
150
     * @param paramKey   The key of the parameter.
151
     * @param paramValue The value of the parameter.
152
     * @return The API response.
153
     * @throws org.nanopub.extra.services.FailedApiCallException If the API call fails.
154
     */
155
    public static ApiResponse get(String queryName, String paramKey, String paramValue) throws FailedApiCallException {
156
        Map<String, String> params = new HashMap<>();
×
157
        params.put(paramKey, paramValue);
×
158
        return get(queryName, params);
×
159
    }
160

161
    /**
162
     * Retrieves an API response for a given query name and parameters.
163
     *
164
     * @param queryName The name of the query.
165
     * @param params    The parameters for the query.
166
     * @return The API response.
167
     * @throws org.nanopub.extra.services.FailedApiCallException If the API call fails.
168
     */
169
    public static ApiResponse get(String queryName, Map<String, String> params) throws FailedApiCallException {
170
        String queryId;
171
        if (queryName.matches("^RA[A-Za-z0-9-_]{43}/.*$")) {
4✔
172
            queryId = queryName;
3✔
173
        } else if (queryIds.containsKey(queryName)) {
4✔
174
            queryId = queryIds.get(queryName);
6✔
175
        } else {
176
            throw new IllegalArgumentException("Query name not known: " + queryName);
6✔
177
        }
178
        return QueryAccess.get(queryId, params);
4✔
179
    }
180

181
    /**
182
     * Retrieves the latest version ID of a given nanopublication.
183
     *
184
     * @param nanopubId The ID of the nanopublication.
185
     * @return The latest version ID.
186
     */
187
    public static String getLatestVersionId(String nanopubId) {
188
        long currentTime = System.currentTimeMillis();
2✔
189
        if (!latestVersionMap.containsKey(nanopubId) || currentTime - latestVersionMap.get(nanopubId).getLeft() > 1000 * 60) {
4!
190
            // Re-fetch if existing value is older than 1 minute
191
            Map<String, String> params = new HashMap<>();
4✔
192
            params.put("np", nanopubId);
5✔
193
            try {
194
                ApiResponse r = get("get-latest-version-of-np", params);
4✔
195
                if (r.getData().size() != 1) return nanopubId;
5!
196
                String l = r.getData().get(0).get("latest");
8✔
197
                latestVersionMap.put(nanopubId, Pair.of(currentTime, l));
8✔
198
            } catch (Exception ex) {
×
199
                logger.error("Error while getting latest version of nanopub '{}'", nanopubId, ex);
×
200
                return nanopubId;
×
201
            }
1✔
202
        }
203
        return latestVersionMap.get(nanopubId).getRight();
7✔
204
    }
205

206
    /**
207
     * Extracts the query ID from a given query IRI.
208
     *
209
     * @param queryIri The query IRI.
210
     * @return The query ID, or null if the IRI is invalid.
211
     */
212
    public static String getQueryId(IRI queryIri) {
213
        if (queryIri == null) return null;
×
214
        if (!queryIri.stringValue().matches(queryIriPattern)) return null;
×
215
        return queryIri.stringValue().replaceFirst(queryIriPattern, "$2/$3");
×
216
    }
217

218
    /**
219
     * Retrieves the query ID for a given query name.
220
     *
221
     * @param queryName The name of the query.
222
     * @return The query ID, or null if the query name is unknown.
223
     */
224
    public static String getQueryId(String queryName) {
225
        return queryIds.get(queryName);
5✔
226
    }
227

228
    /**
229
     * Extracts the query name from a given query IRI.
230
     *
231
     * @param queryIri The query IRI.
232
     * @return The query name, or null if the IRI is invalid.
233
     */
234
    public static String getQueryName(IRI queryIri) {
235
        if (queryIri == null) return null;
4✔
236
        if (!queryIri.stringValue().matches(queryIriPattern)) return null;
7✔
237
        return queryIri.stringValue().replaceFirst(queryIriPattern, "$3");
6✔
238
    }
239

240
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc