17320701451

Committed 29 Aug 2025 09:55AM UTC coverage: 12.02% (+0.01%) from 12.007%

Build # 17320701451

Build Type

push

github

Committed by

ashleycaselli

Commit Message

refactor: minor code style update

Run Details

330 of 3842 branches covered (8.59%)

Branch coverage included in aggregate %.

950 of 6807 relevant lines covered (13.96%)

0.61 hits per line

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

0.0

src/main/java/com/knowledgepixels/nanodash/page/ChannelPage.java

package com.knowledgepixels.nanodash.page;

import com.knowledgepixels.nanodash.ApiCache;
import com.knowledgepixels.nanodash.NanodashSession;
import com.knowledgepixels.nanodash.User;
import com.knowledgepixels.nanodash.Utils;
import com.knowledgepixels.nanodash.component.NanopubResults;
import com.knowledgepixels.nanodash.component.TitleBar;
import org.apache.wicket.ajax.AjaxRequestTarget;
import org.apache.wicket.ajax.form.AjaxFormChoiceComponentUpdatingBehavior;
import org.apache.wicket.extensions.ajax.markup.html.AjaxLazyLoadPanel;
import org.apache.wicket.markup.html.WebMarkupContainer;
import org.apache.wicket.markup.html.basic.Label;
import org.apache.wicket.markup.html.form.CheckBoxMultipleChoice;
import org.apache.wicket.model.Model;
import org.apache.wicket.request.flow.RedirectToUrlException;
import org.apache.wicket.request.mapper.parameter.PageParameters;
import org.eclipse.rdf4j.model.IRI;
import org.nanopub.extra.services.ApiResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.Optional;

/**
 * Page for displaying a channel of nanopublications associated with a user.
 */
public class ChannelPage extends NanodashPage {

    private static final long serialVersionUID = 1L;
    private static final Logger logger = LoggerFactory.getLogger(ChannelPage.class);

    /**
     * The mount path for this page.
     */
    public static final String MOUNT_PATH = "/channel";

    /**
     * {@inheritDoc}
     */
    @Override
    public String getMountPath() {
        return MOUNT_PATH;
    }

    private Model<ArrayList<String>> selected = new Model<>();
    private IRI userIri;
    private boolean added = false;
    private Map<String, String> pubKeyMap;
    private CheckBoxMultipleChoice<String> pubkeySelection;

    /**
     * Constructor for the ChannelPage.
     *
     * @param parameters Page parameters containing the user ID.
     */
    public ChannelPage(final PageParameters parameters) {
        super(parameters);

        if (parameters.get("id") == null) throw new RedirectToUrlException(ProfilePage.MOUNT_PATH);
        userIri = Utils.vf.createIRI(parameters.get("id").toString());
        NanodashSession session = NanodashSession.get();

        String pageType = "users";
        if (session.getUserIri() != null && userIri.equals(session.getUserIri())) pageType = "mychannel";
        add(new TitleBar("titlebar", this, pageType));

        final String displayName = User.getShortDisplayName(userIri);
        add(new Label("pagetitle", displayName + " (channel) | nanodash"));
        add(new Label("username", displayName));

        ArrayList<String> pubKeyList = new ArrayList<>();
        pubKeyMap = new HashMap<>();
        if (userIri.equals(session.getUserIri())) {
            String lKeyShort = Utils.getShortPubkeyLocationLabel(session.getPubkeyString(), userIri);
            pubKeyList.add(lKeyShort);
            pubKeyMap.put(lKeyShort, session.getPubkeyString());
        }
        for (String pk : User.getPubkeyhashes(userIri, null)) {
            String keyShort = Utils.getShortPubkeyLocationLabel(pk, userIri);
            if (!pubKeyMap.containsKey(keyShort)) {
                pubKeyList.add(keyShort);
                pubKeyMap.put(keyShort, pk);
            }
        }

        pubkeySelection = new CheckBoxMultipleChoice<String>("pubkeygroup", selected, pubKeyList);
        pubkeySelection.setDefaultModelObject(new ArrayList<String>(pubKeyList));
        pubkeySelection.add(new AjaxFormChoiceComponentUpdatingBehavior() {

            private static final long serialVersionUID = -6398658082085108029L;

            @Override
            protected void onUpdate(AjaxRequestTarget target) {
                logger.info("PUBKEYS SELECTED:");
                for (String s : selected.getObject()) {
                    logger.info(" {}", pubKeyMap.get(s));
                }
                logger.info("\n");
                refresh();
                setResponsePage(target.getPage());
                target.appendJavaScript("updateElements();");
            }

        });
        WebMarkupContainer selectPanel = new WebMarkupContainer("selectpanel");
        selectPanel.setVisible(!pubKeyList.isEmpty());
        selectPanel.add(pubkeySelection);
        add(selectPanel);

        refresh();
    }

    /**
     * Checks if auto-refresh is enabled for this page.
     *
     * @return true if auto-refresh is enabled, false otherwise.
     */
    protected boolean hasAutoRefreshEnabled() {
        return true;
    }

    private synchronized void refresh() {
        if (added) {
            remove("nanopubs");
        }
        added = true;
        final Map<String, String> params = new HashMap<>();
        final String queryName;
        String pubkeyHashes = getPubkeyHashesString();
        if (pubkeyHashes == null) {
            queryName = "get-latest-nanopubs-from-userid";
            params.put("userid", userIri.stringValue());
        } else {
            queryName = "get-latest-nanopubs-from-pubkeys";
            params.put("pubkeyhashes", pubkeyHashes);
            params.put("userid", userIri.stringValue());
        }
        ApiResponse cachedResponse = ApiCache.retrieveResponse(queryName, params);
        if (cachedResponse != null) {
            add(NanopubResults.fromApiResponse("nanopubs", cachedResponse));
        } else {
            add(new AjaxLazyLoadPanel<NanopubResults>("nanopubs") {

                private static final long serialVersionUID = 1L;

                @Override
                public NanopubResults getLazyLoadComponent(String markupId) {
                    ApiResponse r = null;
                    while (true) {
                        try {
                            Thread.sleep(500);
                        } catch (InterruptedException ex) {
                            ex.printStackTrace();
                        }
                        if (!ApiCache.isRunning(queryName, params)) {
                            r = ApiCache.retrieveResponse(queryName, params);
                            if (r != null) break;
                        }
                    }
                    return NanopubResults.fromApiResponse(markupId, r);
                }

                @Override
                protected void onContentLoaded(NanopubResults content, Optional<AjaxRequestTarget> target) {
                    super.onContentLoaded(content, target);
                    if (target.isPresent()) {
                        target.get().appendJavaScript("updateElements();");
                    }
                }

            });
        }
    }

    private String getPubkeyHashesString() {
        String pubkeyHashes = "";
        for (String s : selected.getObject()) {
            pubkeyHashes += " " + pubKeyMap.get(s);
        }
        if (pubkeyHashes.isEmpty()) return null;
        return pubkeyHashes.substring(1);
    }

//        @Override
//        public void onBeforeRender() {
//                super.onBeforeRender();
//                if (hasBeenRendered()) {
//                        setResponsePage(getPageClass(), getPageParameters());
//                }
//        }

}

1	package com.knowledgepixels.nanodash.page;
2
3	import com.knowledgepixels.nanodash.ApiCache;
4	import com.knowledgepixels.nanodash.NanodashSession;
5	import com.knowledgepixels.nanodash.User;
6	import com.knowledgepixels.nanodash.Utils;
7	import com.knowledgepixels.nanodash.component.NanopubResults;
8	import com.knowledgepixels.nanodash.component.TitleBar;
9	import org.apache.wicket.ajax.AjaxRequestTarget;
10	import org.apache.wicket.ajax.form.AjaxFormChoiceComponentUpdatingBehavior;
11	import org.apache.wicket.extensions.ajax.markup.html.AjaxLazyLoadPanel;
12	import org.apache.wicket.markup.html.WebMarkupContainer;
13	import org.apache.wicket.markup.html.basic.Label;
14	import org.apache.wicket.markup.html.form.CheckBoxMultipleChoice;
15	import org.apache.wicket.model.Model;
16	import org.apache.wicket.request.flow.RedirectToUrlException;
17	import org.apache.wicket.request.mapper.parameter.PageParameters;
18	import org.eclipse.rdf4j.model.IRI;
19	import org.nanopub.extra.services.ApiResponse;
20	import org.slf4j.Logger;
21	import org.slf4j.LoggerFactory;
22
23	import java.util.ArrayList;
24	import java.util.HashMap;
25	import java.util.Map;
26	import java.util.Optional;
27
28	/**
29	* Page for displaying a channel of nanopublications associated with a user.
30	*/
31	public class ChannelPage extends NanodashPage {
32
33	private static final long serialVersionUID = 1L;
34	private static final Logger logger = LoggerFactory.getLogger(ChannelPage.class);	×
35
36	/**
37	* The mount path for this page.
38	*/
39	public static final String MOUNT_PATH = "/channel";
40
41	/**
42	* {@inheritDoc}
43	*/
44	@Override
45	public String getMountPath() {
46	return MOUNT_PATH;	×
47	}
48
49	private Model<ArrayList<String>> selected = new Model<>();	×
50	private IRI userIri;
51	private boolean added = false;	×
52	private Map<String, String> pubKeyMap;
53	private CheckBoxMultipleChoice<String> pubkeySelection;
54
55	/**
56	* Constructor for the ChannelPage.
57	*
58	* @param parameters Page parameters containing the user ID.
59	*/
60	public ChannelPage(final PageParameters parameters) {
61	super(parameters);	×
62
63	if (parameters.get("id") == null) throw new RedirectToUrlException(ProfilePage.MOUNT_PATH);	×
64	userIri = Utils.vf.createIRI(parameters.get("id").toString());	×
65	NanodashSession session = NanodashSession.get();	×
66
67	String pageType = "users";	×
68	if (session.getUserIri() != null && userIri.equals(session.getUserIri())) pageType = "mychannel";	×
69	add(new TitleBar("titlebar", this, pageType));	×
70
71	final String displayName = User.getShortDisplayName(userIri);	×
72	add(new Label("pagetitle", displayName + " (channel) \| nanodash"));	×
73	add(new Label("username", displayName));	×
74
75	ArrayList<String> pubKeyList = new ArrayList<>();	×
76	pubKeyMap = new HashMap<>();	×
77	if (userIri.equals(session.getUserIri())) {	×
78	String lKeyShort = Utils.getShortPubkeyLocationLabel(session.getPubkeyString(), userIri);	×
79	pubKeyList.add(lKeyShort);	×
80	pubKeyMap.put(lKeyShort, session.getPubkeyString());	×
81	}
82	for (String pk : User.getPubkeyhashes(userIri, null)) {	×
83	String keyShort = Utils.getShortPubkeyLocationLabel(pk, userIri);	×
84	if (!pubKeyMap.containsKey(keyShort)) {	×
85	pubKeyList.add(keyShort);	×
86	pubKeyMap.put(keyShort, pk);	×
87	}
88	}	×
89
90	pubkeySelection = new CheckBoxMultipleChoice<String>("pubkeygroup", selected, pubKeyList);	×
91	pubkeySelection.setDefaultModelObject(new ArrayList<String>(pubKeyList));	×
92	pubkeySelection.add(new AjaxFormChoiceComponentUpdatingBehavior() {	×
93
94	private static final long serialVersionUID = -6398658082085108029L;
95
96	@Override
97	protected void onUpdate(AjaxRequestTarget target) {
98	logger.info("PUBKEYS SELECTED:");	×
99	for (String s : selected.getObject()) {	×
100	logger.info(" {}", pubKeyMap.get(s));	×
101	}	×
102	logger.info("\n");	×
103	refresh();	×
104	setResponsePage(target.getPage());	×
105	target.appendJavaScript("updateElements();");	×
106	}	×
107
108	});
109	WebMarkupContainer selectPanel = new WebMarkupContainer("selectpanel");	×
110	selectPanel.setVisible(!pubKeyList.isEmpty());	×
111	selectPanel.add(pubkeySelection);	×
112	add(selectPanel);	×
113
114	refresh();	×
115	}	×
116
117	/**
118	* Checks if auto-refresh is enabled for this page.
119	*
120	* @return true if auto-refresh is enabled, false otherwise.
121	*/
122	protected boolean hasAutoRefreshEnabled() {
123	return true;	×
124	}
125
126	private synchronized void refresh() {
127	if (added) {	×
128	remove("nanopubs");	×
129	}
130	added = true;	×
131	final Map<String, String> params = new HashMap<>();	×
132	final String queryName;
133	String pubkeyHashes = getPubkeyHashesString();	×
134	if (pubkeyHashes == null) {	×
135	queryName = "get-latest-nanopubs-from-userid";	×
136	params.put("userid", userIri.stringValue());	×
137	} else {
138	queryName = "get-latest-nanopubs-from-pubkeys";	×
139	params.put("pubkeyhashes", pubkeyHashes);	×
140	params.put("userid", userIri.stringValue());	×
141	}
142	ApiResponse cachedResponse = ApiCache.retrieveResponse(queryName, params);	×
143	if (cachedResponse != null) {	×
144	add(NanopubResults.fromApiResponse("nanopubs", cachedResponse));	×
145	} else {
146	add(new AjaxLazyLoadPanel<NanopubResults>("nanopubs") {	×
147
148	private static final long serialVersionUID = 1L;
149
150	@Override
151	public NanopubResults getLazyLoadComponent(String markupId) {
152	ApiResponse r = null;	×
153	while (true) {
154	try {
155	Thread.sleep(500);	×
156	} catch (InterruptedException ex) {	×
157	ex.printStackTrace();	×
158	}	×
159	if (!ApiCache.isRunning(queryName, params)) {	×
160	r = ApiCache.retrieveResponse(queryName, params);	×
161	if (r != null) break;	×
162	}
163	}
164	return NanopubResults.fromApiResponse(markupId, r);	×
165	}
166
167	@Override
168	protected void onContentLoaded(NanopubResults content, Optional<AjaxRequestTarget> target) {
169	super.onContentLoaded(content, target);	×
170	if (target.isPresent()) {	×
171	target.get().appendJavaScript("updateElements();");	×
172	}
173	}	×
174
175	});
176	}
177	}	×
178
179	private String getPubkeyHashesString() {
180	String pubkeyHashes = "";	×
181	for (String s : selected.getObject()) {	×
182	pubkeyHashes += " " + pubKeyMap.get(s);	×
183	}	×
184	if (pubkeyHashes.isEmpty()) return null;	×
185	return pubkeyHashes.substring(1);	×
186	}
187
188	// @Override
189	// public void onBeforeRender() {
190	// super.onBeforeRender();
191	// if (hasBeenRendered()) {
192	// setResponsePage(getPageClass(), getPageParameters());
193	// }
194	// }
195
196	}

knowledgepixels / nanodash / 17320701451

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