22892118311

Committed 10 Mar 2026 07:39AM UTC coverage: 27.147% (-0.03%) from 27.177%

Build # 22892118311

Build Type

push

github

Committed by

tkuhn

Commit Message

feat: show currently running task on /debug/tasks page

Track the active task name and start time in Task so the debug endpoint
can display what is running and for how long.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Run Details

170 of 686 branches covered (24.78%)

Branch coverage included in aggregate %.

554 of 1981 relevant lines covered (27.97%)

4.94 hits per line

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

0.0

src/main/java/com/knowledgepixels/registry/DebugPage.java

package com.knowledgepixels.registry;

import com.mongodb.client.ClientSession;
import com.mongodb.client.MongoCursor;
import io.vertx.ext.web.RoutingContext;
import org.bson.Document;

import java.io.IOException;

import static com.knowledgepixels.registry.RegistryDB.collection;
import static com.mongodb.client.model.Indexes.ascending;

public class DebugPage extends Page {

    public static void show(RoutingContext context) {
        DebugPage page;
        try (ClientSession s = RegistryDB.getClient().startSession()) {
            s.startTransaction();
            page = new DebugPage(s, context);
            page.show();
        } catch (IOException ex) {
            ex.printStackTrace();
        } finally {
            context.response().end();
            // TODO Clean-up here?
        }
    }

    private DebugPage(ClientSession mongoSession, RoutingContext context) {
        super(mongoSession, context);
    }

    protected void show() throws IOException {
        RoutingContext c = getContext();

        if (getRequestString().matches("/debug/trustPaths")) {
            String counterString = c.request().getParam("trustStateCounter");
            if (counterString == null) {
                print(getTrustPathsTxt(mongoSession));
            } else {
                Long counter = Long.parseLong(counterString);
                print(RegistryDB.getOne(mongoSession, "debug_trustPaths", new Document("trustStateCounter", counter)).getString("trustStateTxt"));
            }
            setRespContentType("text/plain");
        } else if (getRequestString().matches("/debug/endorsements")) {
            MongoCursor<Document> tp = collection("endorsements").find(mongoSession).cursor();
            while (tp.hasNext()) {
                Document d = tp.next();
                println(d.get("agent") + ">" + d.get("pubkey") + " " + d.get("endorsedNanopub") + " " + d.get("source") + " (" + d.get("status") + ")");
            }
            setRespContentType("text/plain");
        } else if (getRequestString().matches("/debug/accounts")) {
            MongoCursor<Document> tp = collection("accounts").find(mongoSession).cursor();
            while (tp.hasNext()) {
                Document d = tp.next();
                println(d.getString("agent") + ">" + d.get("pubkey") + " " + d.get("depth") + " (" + d.get("status") + ")");
            }
        } else if (getRequestString().matches("/debug/tasks")) {
            setRespContentType("text/plain");
            try {
                String currentTask = Task.getCurrentTaskName();
                if (currentTask != null) {
                    long elapsed = System.currentTimeMillis() - Task.getCurrentTaskStartTime();
                    println("Currently running: " + currentTask + " (for " + elapsed + "ms)");
                } else {
                    println("Currently running: (none)");
                }
                println("");
                MongoCursor<Document> tasks = collection(Collection.TASKS.toString()).find(mongoSession)
                        .sort(ascending("not-before")).cursor();
                int count = 0;
                while (tasks.hasNext()) {
                    println(tasks.next().toJson());
                    count++;
                }
                println("Total queued tasks: " + count);
            } catch (Exception ex) {
                println("Error: " + ex.getClass().getName() + ": " + ex.getMessage());
            }
        } else if (getRequestString().matches("/debug/peerState")) {
            setRespContentType("text/plain");
            try {
                long count = collection(Collection.PEER_STATE.toString()).countDocuments(mongoSession);
                println("peerState documents: " + count);
                MongoCursor<Document> ps = collection(Collection.PEER_STATE.toString()).find(mongoSession).cursor();
                while (ps.hasNext()) {
                    println(ps.next().toJson());
                }
            } catch (Exception ex) {
                println("Error: " + ex.getClass().getName() + ": " + ex.getMessage());
            }
        } else {
            c.response().setStatusCode(400).setStatusMessage("Invalid request: " + getFullRequest());
        }
    }

    public static String getTrustPathsTxt(ClientSession mongoSession) {
        String s = "";
        MongoCursor<Document> tp = collection("trustPaths").find(mongoSession).sort(ascending("_id")).cursor();
        while (tp.hasNext()) {
            Document d = tp.next();
            String path = d.getString("_id");
            path = path.replace(" ", " > ");
            if (d.getString("type").equals("extended")) {
                path = path.replaceFirst(" > ([^ ]+)$", " ~ $1");
            }
            s += path + "\n";
        }
        return s;
    }

}

1	package com.knowledgepixels.registry;
2
3	import com.mongodb.client.ClientSession;
4	import com.mongodb.client.MongoCursor;
5	import io.vertx.ext.web.RoutingContext;
6	import org.bson.Document;
7
8	import java.io.IOException;
9
10	import static com.knowledgepixels.registry.RegistryDB.collection;
11	import static com.mongodb.client.model.Indexes.ascending;
12
13	public class DebugPage extends Page {
14
15	public static void show(RoutingContext context) {
16	DebugPage page;
17	try (ClientSession s = RegistryDB.getClient().startSession()) {	×
18	s.startTransaction();	×
19	page = new DebugPage(s, context);	×
20	page.show();	×
21	} catch (IOException ex) {	×
22	ex.printStackTrace();	×
23	} finally {
24	context.response().end();	×
25	// TODO Clean-up here?
26	}
27	}	×
28
29	private DebugPage(ClientSession mongoSession, RoutingContext context) {
30	super(mongoSession, context);	×
31	}	×
32
33	protected void show() throws IOException {
34	RoutingContext c = getContext();	×
35
36	if (getRequestString().matches("/debug/trustPaths")) {	×
37	String counterString = c.request().getParam("trustStateCounter");	×
38	if (counterString == null) {	×
39	print(getTrustPathsTxt(mongoSession));	×
40	} else {
41	Long counter = Long.parseLong(counterString);	×
42	print(RegistryDB.getOne(mongoSession, "debug_trustPaths", new Document("trustStateCounter", counter)).getString("trustStateTxt"));	×
43	}
44	setRespContentType("text/plain");	×
45	} else if (getRequestString().matches("/debug/endorsements")) {	×
46	MongoCursor<Document> tp = collection("endorsements").find(mongoSession).cursor();	×
47	while (tp.hasNext()) {	×
48	Document d = tp.next();	×
49	println(d.get("agent") + ">" + d.get("pubkey") + " " + d.get("endorsedNanopub") + " " + d.get("source") + " (" + d.get("status") + ")");	×
50	}	×
51	setRespContentType("text/plain");	×
52	} else if (getRequestString().matches("/debug/accounts")) {	×
53	MongoCursor<Document> tp = collection("accounts").find(mongoSession).cursor();	×
54	while (tp.hasNext()) {	×
55	Document d = tp.next();	×
56	println(d.getString("agent") + ">" + d.get("pubkey") + " " + d.get("depth") + " (" + d.get("status") + ")");	×
57	}	×
58	} else if (getRequestString().matches("/debug/tasks")) {	×
59	setRespContentType("text/plain");	×
60	try {
61	String currentTask = Task.getCurrentTaskName();	×
62	if (currentTask != null) {	×
63	long elapsed = System.currentTimeMillis() - Task.getCurrentTaskStartTime();	×
64	println("Currently running: " + currentTask + " (for " + elapsed + "ms)");	×
65	} else {	×
66	println("Currently running: (none)");	×
67	}
68	println("");	×
69	MongoCursor<Document> tasks = collection(Collection.TASKS.toString()).find(mongoSession)	×
70	.sort(ascending("not-before")).cursor();	×
71	int count = 0;	×
72	while (tasks.hasNext()) {	×
73	println(tasks.next().toJson());	×
74	count++;	×
75	}
76	println("Total queued tasks: " + count);	×
77	} catch (Exception ex) {	×
78	println("Error: " + ex.getClass().getName() + ": " + ex.getMessage());	×
79	}	×
80	} else if (getRequestString().matches("/debug/peerState")) {	×
81	setRespContentType("text/plain");	×
82	try {
83	long count = collection(Collection.PEER_STATE.toString()).countDocuments(mongoSession);	×
84	println("peerState documents: " + count);	×
85	MongoCursor<Document> ps = collection(Collection.PEER_STATE.toString()).find(mongoSession).cursor();	×
86	while (ps.hasNext()) {	×
87	println(ps.next().toJson());	×
88	}
89	} catch (Exception ex) {	×
90	println("Error: " + ex.getClass().getName() + ": " + ex.getMessage());	×
91	}	×
92	} else {
93	c.response().setStatusCode(400).setStatusMessage("Invalid request: " + getFullRequest());	×
94	}
95	}	×
96
97	public static String getTrustPathsTxt(ClientSession mongoSession) {
98	String s = "";	×
99	MongoCursor<Document> tp = collection("trustPaths").find(mongoSession).sort(ascending("_id")).cursor();	×
100	while (tp.hasNext()) {	×
101	Document d = tp.next();	×
102	String path = d.getString("_id");	×
103	path = path.replace(" ", " > ");	×
104	if (d.getString("type").equals("extended")) {	×
105	path = path.replaceFirst(" > ([^ ]+)$", " ~ $1");	×
106	}
107	s += path + "\n";	×
108	}	×
109	return s;	×
110	}
111
112	}

knowledgepixels / nanopub-registry / 22892118311

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