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

knowledgepixels / nanopub-registry / 23541488268

25 Mar 2026 12:40PM UTC coverage: 31.704% (+1.1%) from 30.645%
23541488268

push

github

web-flow
Merge pull request #89 from knowledgepixels/perf/db-operation-improvements

perf: optimize DB operations for replication speed

206 of 730 branches covered (28.22%)

Branch coverage included in aggregate %.

689 of 2093 relevant lines covered (32.92%)

5.65 hits per line

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

67.32
src/main/java/com/knowledgepixels/registry/RegistryDB.java
1
package com.knowledgepixels.registry;
2

3
import com.knowledgepixels.registry.db.IndexInitializer;
4
import com.mongodb.MongoClient;
5
import com.mongodb.MongoNamespace;
6
import com.mongodb.ErrorCategory;
7
import com.mongodb.MongoWriteException;
8
import com.mongodb.ServerAddress;
9
import com.mongodb.client.ClientSession;
10
import com.mongodb.client.MongoCollection;
11
import com.mongodb.client.MongoCursor;
12
import com.mongodb.client.MongoDatabase;
13
import com.mongodb.client.model.CountOptions;
14
import com.mongodb.client.model.FindOneAndUpdateOptions;
15
import com.mongodb.client.model.ReturnDocument;
16
import com.mongodb.client.model.UpdateOptions;
17
import net.trustyuri.TrustyUriUtils;
18
import org.bson.Document;
19
import org.bson.conversions.Bson;
20
import org.bson.types.Binary;
21
import org.eclipse.rdf4j.common.exception.RDF4JException;
22
import org.eclipse.rdf4j.model.IRI;
23
import org.eclipse.rdf4j.rio.RDFFormat;
24
import org.nanopub.MalformedNanopubException;
25
import org.nanopub.Nanopub;
26

27
import java.util.Calendar;
28
import org.nanopub.NanopubUtils;
29
import org.nanopub.extra.security.MalformedCryptoElementException;
30
import org.nanopub.extra.security.NanopubSignatureElement;
31
import org.nanopub.extra.security.SignatureUtils;
32
import org.nanopub.jelly.JellyUtils;
33
import org.slf4j.Logger;
34
import org.slf4j.LoggerFactory;
35

36
import java.io.IOException;
37
import java.security.GeneralSecurityException;
38
import java.util.ArrayList;
39

40
import static com.mongodb.client.model.Indexes.ascending;
41

42
public class RegistryDB {
43

44
    private RegistryDB() {
45
    }
46

47
    private static final String REGISTRY_DB_NAME = Utils.getEnv("REGISTRY_DB_NAME", "nanopubRegistry");
12✔
48

49
    private static final Logger logger = LoggerFactory.getLogger(RegistryDB.class);
9✔
50

51
    private static MongoClient mongoClient;
52
    private static MongoDatabase mongoDB;
53

54
    /**
55
     * Returns the MongoDB database instance.
56
     *
57
     * @return the MongoDatabase instance
58
     */
59
    public static MongoDatabase getDB() {
60
        return mongoDB;
6✔
61
    }
62

63
    /**
64
     * Returns the MongoDB client instance.
65
     *
66
     * @return the MongoClient instance
67
     */
68
    public static MongoClient getClient() {
69
        return mongoClient;
6✔
70
    }
71

72
    /**
73
     * Returns the specified collection from the MongoDB database.
74
     *
75
     * @param name the name of the collection
76
     * @return the MongoCollection instance
77
     */
78
    public static MongoCollection<Document> collection(String name) {
79
        return mongoDB.getCollection(name);
12✔
80
    }
81

82
    /**
83
     * Initializes the MongoDB connection and sets up collections and indexes if not already initialized.
84
     */
85
    public static void init() {
86
        if (mongoClient != null) {
6✔
87
            logger.info("RegistryDB already initialized");
9✔
88
            return;
3✔
89
        }
90
        final String REGISTRY_DB_HOST = Utils.getEnv("REGISTRY_DB_HOST", "mongodb");
12✔
91
        final int REGISTRY_DB_PORT = Integer.parseInt(Utils.getEnv("REGISTRY_DB_PORT", String.valueOf(ServerAddress.defaultPort())));
18✔
92
        logger.info("Initializing RegistryDB connection to database '{}' at {}:{}", REGISTRY_DB_NAME, REGISTRY_DB_HOST, REGISTRY_DB_PORT);
54✔
93
        mongoClient = new MongoClient(REGISTRY_DB_HOST, REGISTRY_DB_PORT);
18✔
94
        mongoDB = mongoClient.getDatabase(REGISTRY_DB_NAME);
12✔
95

96
        try (ClientSession mongoSession = mongoClient.startSession()) {
9✔
97
            if (!isInitialized(mongoSession)) {
9!
98
                IndexInitializer.initCollections(mongoSession);
6✔
99
            }
100
            initNanopubCounter(mongoSession);
6✔
101
        }
102
    }
3✔
103

104
    /**
105
     * Checks if the database has been initialized.
106
     *
107
     * @param mongoSession the MongoDB client session
108
     * @return true if initialized, false otherwise
109
     */
110
    public static boolean isInitialized(ClientSession mongoSession) {
111
        return getValue(mongoSession, Collection.SERVER_INFO.toString(), "setupId") != null;
24!
112
    }
113

114
    /**
115
     * Renames a collection in the database. If the new collection name already exists, it will be dropped first.
116
     *
117
     * @param oldCollectionName the current name of the collection
118
     * @param newCollectionName the new name for the collection
119
     */
120
    public static void rename(String oldCollectionName, String newCollectionName) {
121
        // Designed as idempotent operation: calling multiple times has same effect as calling once
122
        if (hasCollection(oldCollectionName)) {
9✔
123
            if (hasCollection(newCollectionName)) {
9✔
124
                collection(newCollectionName).drop();
9✔
125
            }
126
            collection(oldCollectionName).renameCollection(new MongoNamespace(REGISTRY_DB_NAME, newCollectionName));
24✔
127
        }
128
    }
3✔
129

130
    /**
131
     * Checks if a collection with the given name exists in the database.
132
     *
133
     * @param collectionName the name of the collection to check
134
     * @return true if the collection exists, false otherwise
135
     */
136
    public static boolean hasCollection(String collectionName) {
137
        return mongoDB.listCollectionNames().into(new ArrayList<>()).contains(collectionName);
30✔
138
    }
139

140
    /**
141
     * Increases the trust state counter in the server info collection.
142
     *
143
     * @param mongoSession the MongoDB client session
144
     */
145
    public static void increaseStateCounter(ClientSession mongoSession) {
146
        MongoCursor<Document> cursor = collection(Collection.SERVER_INFO.toString()).find(mongoSession, new Document("_id", "trustStateCounter")).cursor();
36✔
147
        if (cursor.hasNext()) {
9✔
148
            long counter = cursor.next().getLong("value");
21✔
149
            collection(Collection.SERVER_INFO.toString()).updateOne(mongoSession, new Document("_id", "trustStateCounter"), new Document("$set", new Document("value", counter + 1)));
69✔
150
        } else {
3✔
151
            collection(Collection.SERVER_INFO.toString()).insertOne(mongoSession, new Document("_id", "trustStateCounter").append("value", 0L));
42✔
152
        }
153
    }
3✔
154

155
    /**
156
     * Checks if an element with the given name exists in the specified collection.
157
     *
158
     * @param mongoSession the MongoDB client session
159
     * @param collection   the name of the collection
160
     * @param elementName  the name of the element used as the _id field
161
     * @return true if the element exists, false otherwise
162
     */
163
    public static boolean has(ClientSession mongoSession, String collection, String elementName) {
164
        return has(mongoSession, collection, new Document("_id", elementName));
27✔
165
    }
166

167
    private static final CountOptions hasCountOptions = new CountOptions().limit(1);
21✔
168

169
    /**
170
     * Checks if any document matching the given filter exists in the specified collection.
171
     *
172
     * @param mongoSession the MongoDB client session
173
     * @param collection   the name of the collection
174
     * @param find         the filter to match documents
175
     * @return true if at least one matching document exists, false otherwise
176
     */
177
    public static boolean has(ClientSession mongoSession, String collection, Bson find) {
178
        return collection(collection).countDocuments(mongoSession, find, hasCountOptions) > 0;
39✔
179
    }
180

181
    /**
182
     * Retrieves a cursor for documents matching the given filter in the specified collection.
183
     *
184
     * @param mongoSession the MongoDB client session
185
     * @param collection   the name of the collection
186
     * @param find         the filter to match documents
187
     * @return a MongoCursor for the matching documents
188
     */
189
    public static MongoCursor<Document> get(ClientSession mongoSession, String collection, Bson find) {
190
        return collection(collection).find(mongoSession, find).cursor();
21✔
191
    }
192

193
    /**
194
     * Retrieves the value of an element with the given name from the specified collection.
195
     *
196
     * @param mongoSession the MongoDB client session
197
     * @param collection   the name of the collection
198
     * @param elementName  the name of the element used as the _id field
199
     * @return the value of the element, or null if not found
200
     */
201
    public static Object getValue(ClientSession mongoSession, String collection, String elementName) {
202
        logger.info("Getting value of element '{}' from collection '{}'", elementName, collection);
15✔
203
        Document d = collection(collection).find(mongoSession, new Document("_id", elementName)).first();
36✔
204
        if (d == null) {
6✔
205
            return null;
6✔
206
        }
207
        return d.get("value");
12✔
208
    }
209

210
    /**
211
     * Retrieves the boolean value of an element with the given name from the specified collection.
212
     *
213
     * @param mongoSession the MongoDB client session
214
     * @param collection   the name of the collection
215
     * @param elementName  the name of the element used as the _id field
216
     * @return the value of the element, or null if not found
217
     */
218
    public static boolean isSet(ClientSession mongoSession, String collection, String elementName) {
219
        Document d = collection(collection).find(mongoSession, new Document("_id", elementName)).first();
36✔
220
        if (d == null) {
6✔
221
            return false;
6✔
222
        }
223
        return d.getBoolean("value");
15✔
224
    }
225

226
    /**
227
     * Retrieves a single document matching the given filter from the specified collection.
228
     *
229
     * @param mongoSession the MongoDB client session
230
     * @param collection   the name of the collection
231
     * @param find         the filter to match the document
232
     * @return the matching document, or null if not found
233
     */
234
    public static Document getOne(ClientSession mongoSession, String collection, Bson find) {
235
        return collection(collection).find(mongoSession, find).first();
24✔
236
    }
237

238
    /**
239
     * Retrieves the maximum value of a specified field from the documents in the given collection.
240
     *
241
     * @param mongoSession the MongoDB client session
242
     * @param collection   the name of the collection
243
     * @param fieldName    the field for which to find the maximum value
244
     * @return the maximum value of the specified field, or null if no documents exist
245
     */
246
    public static Object getMaxValue(ClientSession mongoSession, String collection, String fieldName) {
247
        Document doc = collection(collection).find(mongoSession).projection(new Document(fieldName, 1)).sort(new Document(fieldName, -1)).first();
63✔
248
        if (doc == null) {
6✔
249
            return null;
6✔
250
        }
251
        return doc.get(fieldName);
12✔
252
    }
253

254
    /**
255
     * Retrieves the document with the maximum value of a specified field from the documents matching the given filter in the specified collection.
256
     *
257
     * @param mongoSession the MongoDB client session
258
     * @param collection   the name of the collection
259
     * @param find         the filter to match documents
260
     * @param fieldName    the field for which to find the maximum value
261
     * @return the document with the maximum value of the specified field, or null if no matching documents exist
262
     */
263
    public static Document getMaxValueDocument(ClientSession mongoSession, String collection, Bson find, String fieldName) {
264
        return collection(collection).find(mongoSession, find).sort(new Document(fieldName, -1)).first();
45✔
265
    }
266

267
    /**
268
     * Sets or updates a document in the specified collection.
269
     *
270
     * @param mongoSession the MongoDB client session
271
     * @param collection   the name of the collection
272
     * @param update       the document to set or update (must contain an _id field)
273
     */
274
    public static void set(ClientSession mongoSession, String collection, Document update) {
275
        Bson find = new Document("_id", update.get("_id"));
24✔
276
        MongoCursor<Document> cursor = collection(collection).find(mongoSession, find).cursor();
21✔
277
        if (cursor.hasNext()) {
9✔
278
            collection(collection).updateOne(mongoSession, find, new Document("$set", update));
33✔
279
        }
280
    }
3✔
281

282
    /**
283
     * Inserts a document into the specified collection.
284
     *
285
     * @param mongoSession the MongoDB client session
286
     * @param collection   the name of the collection
287
     * @param doc          the document to insert
288
     */
289
    public static void insert(ClientSession mongoSession, String collection, Document doc) {
290
        collection(collection).insertOne(mongoSession, doc);
15✔
291
    }
3✔
292

293
    /**
294
     * Sets the value of an element with the given name in the specified collection.
295
     * If the element does not exist, it will be created.
296
     *
297
     * @param mongoSession the MongoDB client session
298
     * @param collection   the name of the collection
299
     * @param elementId    the name of the element used as the _id field
300
     * @param value        the value to set
301
     */
302
    public static void setValue(ClientSession mongoSession, String collection, String elementId, Object value) {
303
        collection(collection).updateOne(mongoSession, new Document("_id", elementId), new Document("$set", new Document("value", value)), new UpdateOptions().upsert(true));
72✔
304
    }
3✔
305

306
    /**
307
     * Records the hash of a given value in the "hashes" collection.
308
     * Uses upsert to avoid expensive exception-based duplicate handling.
309
     *
310
     * @param mongoSession the MongoDB client session
311
     * @param value        the value to hash and record
312
     */
313
    public static void recordHash(ClientSession mongoSession, String value) {
314
        String hash = Utils.getHash(value);
9✔
315
        collection("hashes").updateOne(mongoSession,
60✔
316
                new Document("value", value),
317
                new Document("$setOnInsert", new Document("value", value).append("hash", hash)),
18✔
318
                new UpdateOptions().upsert(true));
3✔
319
    }
3✔
320

321
    /**
322
     * Retrieves the original value corresponding to a given hash from the "hashes" collection.
323
     *
324
     * @param hash the hash to look up
325
     * @return the original value, or null if not found
326
     */
327
    public static String unhash(String hash) {
328
        try (var c = collection("hashes").find(new Document("hash", hash)).cursor()) {
30✔
329
            if (c.hasNext()) {
9✔
330
                return c.next().getString("value");
24✔
331
            }
332
            return null;
12✔
333
        }
12!
334
    }
335

336
    /**
337
     * Initializes the nanopub counter document to the current maximum counter value
338
     * in the nanopubs collection. Uses $max to ensure the counter is never decreased.
339
     * Safe to call on every startup.
340
     */
341
    private static void initNanopubCounter(ClientSession mongoSession) {
342
        Long maxCounter = (Long) getMaxValue(mongoSession, Collection.NANOPUBS.toString(), "counter");
21✔
343
        if (maxCounter == null) maxCounter = 0L;
15!
344
        collection("counters").updateOne(mongoSession,
69✔
345
                new Document("_id", "nanopubs"),
346
                new Document("$max", new Document("value", maxCounter)),
347
                new UpdateOptions().upsert(true));
3✔
348
        logger.info("Nanopub counter initialized to {}", maxCounter);
12✔
349
    }
3✔
350

351
    /**
352
     * Atomically increments and returns the next nanopub counter value.
353
     * Eliminates the read-then-write race condition that previously caused
354
     * duplicate key errors on the counter index under concurrent load.
355
     */
356
    private static long getNextNanopubCounter(ClientSession mongoSession) {
357
        Document result = collection("counters").findOneAndUpdate(
54✔
358
                mongoSession,
359
                new Document("_id", "nanopubs"),
360
                new Document("$inc", new Document("value", 1L)),
21✔
361
                new FindOneAndUpdateOptions().upsert(true).returnDocument(ReturnDocument.AFTER));
9✔
362
        return result.getLong("value");
15✔
363
    }
364

365
    /**
366
     * Loads a nanopublication into the database.
367
     *
368
     * @param mongoSession the MongoDB client session
369
     * @param nanopub      the nanopublication to load
370
     */
371
    public static boolean loadNanopub(ClientSession mongoSession, Nanopub nanopub) {
372
        return loadNanopub(mongoSession, nanopub, null);
21✔
373
    }
374

375
    /**
376
     * Loads a nanopublication into the database, optionally filtering by public key hash and types.
377
     *
378
     * @param mongoSession the MongoDB client session
379
     * @param nanopub      the nanopublication to load
380
     * @param pubkeyHash   the public key hash to filter by (can be null)
381
     * @param types        the types to filter by (can be empty)
382
     * @return true if the nanopublication was loaded, false otherwise
383
     */
384
    public static boolean loadNanopub(ClientSession mongoSession, Nanopub nanopub, String pubkeyHash, String... types) {
385
        String pubkey = getPubkey(nanopub);
9✔
386
        if (pubkey == null) {
6✔
387
            logger.info("Ignoring invalid nanopub: {}", nanopub.getUri());
15✔
388
            return false;
6✔
389
        }
390
        return loadNanopubVerified(mongoSession, nanopub, pubkey, pubkeyHash, types);
21✔
391
    }
392

393
    /**
394
     * Loads a nanopublication with a pre-verified public key, skipping signature verification.
395
     * Use this when the caller has already verified the signature via getPubkey().
396
     */
397
    static boolean loadNanopubVerified(ClientSession mongoSession, Nanopub nanopub, String verifiedPubkey, String pubkeyHash, String... types) {
398
        if (nanopub.getTripleCount() > 1200) {
12!
399
            logger.info("Nanopub has too many triples ({}): {}", nanopub.getTripleCount(), nanopub.getUri());
×
400
            return false;
×
401
        }
402
        if (nanopub.getByteCount() > 1000000) {
15!
403
            logger.info("Nanopub is too large ({}): {}", nanopub.getByteCount(), nanopub.getUri());
×
404
            return false;
×
405
        }
406
        Calendar creationTime;
407
        try {
408
            creationTime = nanopub.getCreationTime();
9✔
409
        } catch (Exception ex) {
×
410
            logger.info("Nanopub has malformed timestamp, treating as no timestamp: {}", nanopub.getUri());
×
411
            creationTime = null;
×
412
        }
3✔
413
        if (creationTime != null && creationTime.getTimeInMillis() > System.currentTimeMillis() + 60000) {
27!
414
            logger.info("Nanopub has a future timestamp: {}", nanopub.getUri());
×
415
            return false;
×
416
        }
417
        String nanopubUriStr = nanopub.getUri().stringValue();
12✔
418
        for (IRI graphUri : nanopub.getGraphUris()) {
33✔
419
            if (!graphUri.stringValue().startsWith(nanopubUriStr)) {
15!
420
                logger.info("Nanopub has graph URI not matching base URI: {}", nanopub.getUri());
×
421
                return false;
×
422
            }
423
        }
3✔
424
        String ph = Utils.getHash(verifiedPubkey);
9✔
425
        if (pubkeyHash != null && !pubkeyHash.equals(ph)) {
18!
426
            logger.info("Ignoring nanopub with non-matching pubkey: {}", nanopub.getUri());
×
427
            return false;
×
428
        }
429
        recordHash(mongoSession, verifiedPubkey);
9✔
430

431
        String ac = TrustyUriUtils.getArtifactCode(nanopub.getUri().stringValue());
15✔
432
        if (ac == null) {
6!
433
            // I don't think this ever happens, but checking here to be sure
434
            logger.info("ERROR. Unexpected Trusty URI: {}", nanopub.getUri());
×
435
            return false;
×
436
        }
437
        if (has(mongoSession, Collection.NANOPUBS.toString(), ac)) {
18✔
438
            logger.debug("Already loaded: {}", nanopub.getUri());
18✔
439
        } else {
440
            String nanopubString;
441
            byte[] jellyContent;
442
            try {
443
                nanopubString = NanopubUtils.writeToString(nanopub, RDFFormat.TRIG);
12✔
444
                // Save the same thing in the Jelly format for faster loading
445
                jellyContent = JellyUtils.writeNanopubForDB(nanopub);
9✔
446
            } catch (IOException ex) {
×
447
                throw new RuntimeException(ex);
×
448
            }
3✔
449
            long counter = getNextNanopubCounter(mongoSession);
9✔
450
            boolean inserted = false;
6✔
451
            try {
452
                collection(Collection.NANOPUBS.toString()).insertOne(mongoSession, new Document("_id", ac).append("fullId", nanopub.getUri().stringValue()).append("counter", counter).append("pubkey", ph).append("content", nanopubString).append("jelly", new Binary(jellyContent)));
93✔
453
                inserted = true;
6✔
454
            } catch (MongoWriteException e) {
×
455
                if (e.getError().getCategory() != ErrorCategory.DUPLICATE_KEY) throw e;
×
456
                // Another thread inserted this nanopub concurrently — safe to skip
457
                logger.debug("Already loaded (concurrent): {}", nanopub.getUri());
×
458
            }
3✔
459

460
            if (inserted) {
6!
461
                for (IRI invalidatedId : Utils.getInvalidatedNanopubIds(nanopub)) {
33✔
462
                    String invalidatedAc = TrustyUriUtils.getArtifactCode(invalidatedId.stringValue());
12✔
463
                    if (invalidatedAc == null) continue;  // This should never happen; checking here just to be sure
6!
464

465
                    // Add this nanopub also to all lists of invalidated nanopubs:
466
                    collection("invalidations").insertOne(mongoSession, new Document("invalidatingNp", ac).append("invalidatingPubkey", ph).append("invalidatedNp", invalidatedAc));
45✔
467
                    MongoCursor<Document> invalidatedEntries = collection("listEntries").find(mongoSession, new Document("np", invalidatedAc).append("pubkey", ph)).cursor();
42✔
468
                    while (invalidatedEntries.hasNext()) {
9!
469
                        Document invalidatedEntry = invalidatedEntries.next();
×
470
                        addToList(mongoSession, nanopub, ph, invalidatedEntry.getString("type"));
×
471
                    }
×
472

473
                    collection("listEntries").updateMany(mongoSession, new Document("np", invalidatedAc).append("pubkey", ph), new Document("$set", new Document("invalidated", true)));
69✔
474
                    collection("trustEdges").updateMany(mongoSession, new Document("source", invalidatedAc), new Document("$set", new Document("invalidated", true)));
60✔
475
                }
3✔
476
            }
477
        }
478

479
        if (pubkeyHash != null) {
6✔
480
            for (String type : types) {
48✔
481
                // TODO Check if nanopub really has the type?
482
                addToList(mongoSession, nanopub, pubkeyHash, Utils.getTypeHash(mongoSession, type));
21✔
483
                if (type.equals("$")) {
12!
484
                    for (IRI t : NanopubUtils.getTypes(nanopub)) {
33✔
485
                        addToList(mongoSession, nanopub, pubkeyHash, Utils.getTypeHash(mongoSession, t));
21✔
486
                    }
3✔
487
                }
488
            }
489
        }
490

491
        // Add the invalidating nanopubs also to the lists of this nanopub:
492
        try (MongoCursor<Document> invalidations = collection("invalidations").find(mongoSession, new Document("invalidatedNp", ac).append("invalidatingPubkey", ph)).cursor()) {
42✔
493
            if (invalidations.hasNext()) {
9!
494
                collection("listEntries").updateMany(mongoSession, new Document("np", ac).append("pubkey", ph), new Document("$set", new Document("invalidated", true)));
×
495
                collection("trustEdges").updateMany(mongoSession, new Document("source", ac), new Document("$set", new Document("invalidated", true)));
×
496
            }
497
            while (invalidations.hasNext()) {
9!
498
                String iac = invalidations.next().getString("invalidatingNp");
×
499
                try {
500
                    Document npDoc = collection(Collection.NANOPUBS.toString()).find(mongoSession, new Document("_id", iac)).projection(new Document("jelly", 1)).first();
×
501
                    Nanopub inp = JellyUtils.readFromDB(npDoc.get("jelly", Binary.class).getData());
×
502
                    for (IRI type : NanopubUtils.getTypes(inp)) {
×
503
                        addToList(mongoSession, inp, ph, Utils.getTypeHash(mongoSession, type));
×
504
                    }
×
505
                } catch (RDF4JException | MalformedNanopubException ex) {
×
506
                    ex.printStackTrace();
×
507
                }
×
508
            }
×
509

510
        }
511

512
        return true;
6✔
513
    }
514

515
    private static void addToList(ClientSession mongoSession, Nanopub nanopub, String pubkeyHash, String typeHash) {
516
        String ac = TrustyUriUtils.getArtifactCode(nanopub.getUri().stringValue());
15✔
517
        try {
518
            insert(mongoSession, "lists", new Document("pubkey", pubkeyHash).append("type", typeHash)
39✔
519
                    .append("maxPosition", -1L));
6✔
520
        } catch (MongoWriteException e) {
×
521
            // Duplicate key error -- ignore it
522
            if (e.getError().getCategory() != ErrorCategory.DUPLICATE_KEY) throw e;
×
523
        }
3✔
524

525
        if (has(mongoSession, "listEntries", new Document("pubkey", pubkeyHash).append("type", typeHash).append("np", ac))) {
45!
526
            logger.debug("Already listed: {}", nanopub.getUri());
×
527
        } else {
528
            initListPositionIfNeeded(mongoSession, pubkeyHash, typeHash);
12✔
529

530
            for (int attempt = 0; ; attempt++) {
6✔
531
                // Atomically claim next position
532
                Document updated = collection("lists").findOneAndUpdate(mongoSession,
39✔
533
                        new Document("pubkey", pubkeyHash).append("type", typeHash),
24✔
534
                        new Document("$inc", new Document("maxPosition", 1L)),
21✔
535
                        new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER));
3✔
536
                long position = updated.getLong("maxPosition");
15✔
537

538
                // Get checksum from previous entry by exact position lookup (O(1) index hit)
539
                String checksum;
540
                if (position == 0) {
12!
541
                    checksum = NanopubUtils.updateXorChecksum(nanopub.getUri(), NanopubUtils.INIT_CHECKSUM);
18✔
542
                } else {
543
                    Document prevEntry = collection("listEntries").find(mongoSession,
×
544
                            new Document("pubkey", pubkeyHash).append("type", typeHash)
×
545
                                    .append("position", position - 1)).first();
×
546
                    String prevChecksum = (prevEntry != null) ? prevEntry.getString("checksum") : null;
×
547
                    if (prevChecksum == null) {
×
548
                        // Rare: previous entry not yet inserted by concurrent thread; fall back to sorted query
549
                        Document maxDoc = getMaxValueDocument(mongoSession, "listEntries",
×
550
                                new Document("pubkey", pubkeyHash).append("type", typeHash), "position");
×
551
                        prevChecksum = (maxDoc != null) ? maxDoc.getString("checksum") : NanopubUtils.INIT_CHECKSUM;
×
552
                    }
553
                    checksum = NanopubUtils.updateXorChecksum(nanopub.getUri(), prevChecksum);
×
554
                }
555

556
                try {
557
                    collection("listEntries").insertOne(mongoSession, new Document("pubkey", pubkeyHash)
33✔
558
                            .append("type", typeHash).append("position", position).append("np", ac)
30✔
559
                            .append("checksum", checksum).append("invalidated", false));
15✔
560
                    break;
3✔
561
                } catch (MongoWriteException e) {
×
562
                    if (e.getError().getCategory() != ErrorCategory.DUPLICATE_KEY) throw e;
×
563
                    if (has(mongoSession, "listEntries", new Document("pubkey", pubkeyHash)
×
564
                            .append("type", typeHash).append("np", ac))) {
×
565
                        break; // Already listed by concurrent thread
×
566
                    }
567
                    if (attempt >= 100) {
×
568
                        throw new RuntimeException("Failed to insert list entry after " + (attempt + 1) + " attempts");
×
569
                    }
570
                }
571
            }
572
        }
573
    }
3✔
574

575
    /**
576
     * Lazily initializes the maxPosition field on a lists document for lists
577
     * created before this field existed. Uses a one-time sorted query, then
578
     * all subsequent calls use the atomic counter.
579
     */
580
    private static void initListPositionIfNeeded(ClientSession mongoSession, String pubkeyHash, String typeHash) {
581
        Document listDoc = collection("lists").find(mongoSession,
33✔
582
                new Document("pubkey", pubkeyHash).append("type", typeHash)).first();
12✔
583
        if (listDoc == null || listDoc.get("maxPosition") != null) return;
21!
584

585
        Document maxDoc = getMaxValueDocument(mongoSession, "listEntries",
×
586
                new Document("pubkey", pubkeyHash).append("type", typeHash), "position");
×
587
        long maxPos = (maxDoc != null) ? maxDoc.getLong("position") : -1L;
×
588

589
        // Conditional update: only set if maxPosition still doesn't exist (race-safe)
590
        collection("lists").updateOne(mongoSession,
×
591
                new Document("pubkey", pubkeyHash).append("type", typeHash)
×
592
                        .append("maxPosition", new Document("$exists", false)),
×
593
                new Document("$set", new Document("maxPosition", maxPos)));
×
594
    }
×
595

596
    /**
597
     * Builds a comma-separated list of checksums at geometric positions for a given list,
598
     * for use with the afterChecksums parameter during peer sync.
599
     * Returns checksums at positions: max, max-10, max-100, max-1000, max-10000, ...
600
     * Returns null if the list has no entries.
601
     */
602
    public static String buildChecksumFallbacks(ClientSession mongoSession, String pubkeyHash, String typeHash) {
603
        Document maxDoc = getMaxValueDocument(mongoSession, "listEntries",
33✔
604
                new Document("pubkey", pubkeyHash).append("type", typeHash), "position");
6✔
605
        if (maxDoc == null) return null;
12✔
606

607
        long maxPosition = maxDoc.getLong("position");
15✔
608
        StringBuilder sb = new StringBuilder();
12✔
609
        sb.append(maxDoc.getString("checksum"));
18✔
610

611
        for (long offset = 10; offset <= maxPosition; offset *= 10) {
33✔
612
            long targetPos = maxPosition - offset;
12✔
613
            Document entry = collection("listEntries").find(mongoSession,
33✔
614
                    new Document("pubkey", pubkeyHash).append("type", typeHash)
9✔
615
                            .append("position", targetPos)).first();
15✔
616
            if (entry != null) {
6!
617
                sb.append(",").append(entry.getString("checksum"));
24✔
618
            }
619
        }
620
        return sb.toString();
9✔
621
    }
622

623
    /**
624
     * Returns the public key string of the Nanopub's signature, or null if not available or invalid.
625
     *
626
     * @param nanopub the nanopub to extract the public key from
627
     * @return The public key string, or null if not available or invalid.
628
     */
629
    public static String getPubkey(Nanopub nanopub) {
630
        // TODO shouldn't this be moved to a utility class in nanopub-java? there is a similar method in NanopubElement class of nanodash
631
        NanopubSignatureElement el;
632
        try {
633
            el = SignatureUtils.getSignatureElement(nanopub);
9✔
634
            if (el != null && SignatureUtils.hasValidSignature(el) && el.getPublicKeyString() != null) {
24!
635
                return el.getPublicKeyString();
9✔
636
            }
637
        } catch (MalformedCryptoElementException | GeneralSecurityException ex) {
×
638
            logger.error("Error in checking the signature of the nanopub {}", nanopub.getUri());
×
639
        }
3✔
640
        return null;
6✔
641
    }
642

643
    /**
644
     * Calculates a hash representing the current state of the trust paths in the loading collection.
645
     *
646
     * @param mongoSession the MongoDB client session
647
     * @return the calculated trust state hash
648
     */
649
    public static String calculateTrustStateHash(ClientSession mongoSession) {
650
        MongoCursor<Document> tp = collection("trustPaths_loading").find(mongoSession).sort(ascending("_id")).cursor();
×
651
        // TODO Improve this so we don't create the full string just for calculating its hash:
652
        String s = "";
×
653
        while (tp.hasNext()) {
×
654
            Document d = tp.next();
×
655
            s += d.getString("_id") + " (" + d.getString("type") + ")\n";
×
656
        }
×
657
        return Utils.getHash(s);
×
658
    }
659

660
}
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