Skip to content

Rewrite NostrApiExamples #239

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
tcheeric merged 1 commit into from
Jul 31, 2025
Merged

Rewrite NostrApiExamples #239

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
171 changes: 30 additions & 141 deletions nostr-java-examples/src/main/java/nostr/examples/NostrApiExamples.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package nostr.examples;

import lombok.extern.slf4j.Slf4j;
import nostr.api.NIP01;
import nostr.api.NIP04;
import nostr.api.NIP05;
Expand All @@ -9,53 +8,40 @@
import nostr.api.NIP25;
import nostr.api.NIP28;
import nostr.api.NIP30;
import nostr.event.entities.ChannelProfile;
import nostr.base.PublicKey;
import nostr.base.Relay;
import nostr.event.entities.UserProfile;
import nostr.event.BaseTag;
import nostr.base.Kind;
import nostr.event.entities.ChannelProfile;
import nostr.event.entities.Reaction;
import nostr.event.entities.UserProfile;
import nostr.event.filter.AuthorFilter;
import nostr.event.filter.Filters;
import nostr.event.filter.KindFilter;
import nostr.event.filter.SinceFilter;
import nostr.event.impl.GenericEvent;
import nostr.event.tag.EventTag;
import nostr.event.tag.GenericTag;
import nostr.event.tag.PubKeyTag;
import nostr.id.Identity;
import nostr.util.NostrException;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.autoconfigure.SpringBootApplication;

import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import lombok.extern.slf4j.Slf4j;

/**
*
* @author eric
* Example demonstrating several nostr-java API calls.
*/
@Slf4j
@SpringBootApplication
public class NostrApiExamples implements ApplicationRunner {
public class NostrApiExamples {

private static final Identity RECIPIENT = Identity.generateRandomIdentity();
private static final Identity SENDER = Identity.generateRandomIdentity();

private static final UserProfile PROFILE = new UserProfile(SENDER.getPublicKey(), "Nostr Guy", "guy@nostr-java.io", "It's me!", null);
private final static Map<String, String> RELAYS = Map.of("local", "localhost:5555");
private static final Map<String, String> RELAYS = Map.of("local", "localhost:5555");

static {
try {
Expand All @@ -65,109 +51,28 @@ public class NostrApiExamples implements ApplicationRunner {
}
}

@Override
public void run(ApplicationArguments args) throws Exception {
try {
log.debug("================= The Beginning");
logAccountsData();

ExecutorService executor = Executors.newFixedThreadPool(10);

// executor.submit(() -> {
// try {
// metaDataEvent();
// } catch(Throwable t) { log.log(Level.SEVERE, t.getMessage(), t); };
// });

executor.submit(() -> {
try {
sendTextNoteEvent();
} catch(Throwable t) { log.error(t.getMessage(), t); }
});

// executor.submit(() -> {
// try {
// sendEncryptedDirectMessage();
// } catch(Throwable t) { log.log(Level.SEVERE, t.getMessage(), t); };
// });

// executor.submit(() -> {
// try {
// mentionsEvent();
// } catch(Throwable t) { log.log(Level.SEVERE, t.getMessage(), t); };
// });

// executor.submit(() -> {
// try {
// deletionEvent();
// } catch(Throwable t) { log.log(Level.SEVERE, t.getMessage(), t); };
// });
//
// executor.submit(() -> {
// try {
// ephemerealEvent();
// } catch(Throwable t) { log.log(Level.SEVERE, t.getMessage(), t); };
// });
//
// executor.submit(() -> {
// try {
// reactionEvent();
// } catch(Throwable t) { log.log(Level.SEVERE, t.getMessage(), t); }
// });
//
// executor.submit(() -> {
// try {
// reactionEvent();
// } catch(Throwable t) { log.log(Level.SEVERE, t.getMessage(), t); };
// });

// executor.submit(() -> {
// try {
// replaceableEvent();
// } catch(Throwable t) { log.log(Level.SEVERE, t.getMessage(), t); };
// });
//
// executor.submit(() -> {
// try {
// internetIdMetadata();
// } catch(Throwable t) { log.log(Level.SEVERE, t.getMessage(), t); };
// });
//
// executor.submit(() -> {
// try {
// filters();
// } catch(Throwable t) { log.log(Level.SEVERE, t.getMessage(), t); }
// });
//
// executor.submit(() -> {
// createChannel();
// });
// executor.submit(() -> {
// updateChannelMetadata();
// });
//
// executor.submit(() -> {
// sendChannelMessage();
// });
//
// executor.submit(() -> {
// hideMessage();
// });
//
// executor.submit(() -> {
// muteUser();
// });

stop(executor);

if (executor.isTerminated()) {
log.debug("================== The End");
}

} catch (IllegalArgumentException ex) {
log.error("", ex);
throw new NostrException(ex);
}
public static void main(String[] args) throws Exception {
new NostrApiExamples().run();
}

public void run() throws Exception {
logAccountsData();

metaDataEvent();
sendTextNoteEvent();
sendEncryptedDirectMessage();
mentionsEvent();
deletionEvent();
ephemerealEvent();
reactionEvent();
replaceableEvent();
internetIdMetadata();
filters();
createChannel();
updateChannelMetadata();
sendChannelMessage();
hideMessage();
muteUser();
}

private static GenericEvent sendTextNoteEvent() {
Expand Down Expand Up @@ -207,7 +112,6 @@ private static void deletionEvent() {
logHeader("deletionEvent");

var event = sendTextNoteEvent();
List<BaseTag> tags = new ArrayList<>(List.of(new EventTag(event.getId())));

var nip09 = new NIP09(SENDER);
nip09.createDeletionEvent(event)
Expand Down Expand Up @@ -246,9 +150,8 @@ private static void reactionEvent() {
var nip25 = new NIP25(RECIPIENT);
var reactionEvent = nip25.createReactionEvent(event.getEvent(), Reaction.LIKE, new Relay("localhost:5555"));
reactionEvent.signAndSend(RELAYS);
nip25.createReactionEvent(event.getEvent(), "💩", new Relay("localhost:5555")).signAndSend();
nip25.createReactionEvent(event.getEvent(), "\uD83D\uDCA9", new Relay("localhost:5555")).signAndSend();
Copy link

Copilot AI Jul 31, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

[nitpick] The Unicode escape sequence \uD83D\uDCA9 for the emoji is less readable than the original emoji character. Consider using the actual emoji character for better code readability.

Suggested change
nip25.createReactionEvent(event.getEvent(), "\uD83D\uDCA9", new Relay("localhost:5555")).signAndSend();
nip25.createReactionEvent(event.getEvent(), "💩", new Relay("localhost:5555")).signAndSend();

Copilot uses AI. Check for mistakes.

//Using Custom Emoji as reaction
BaseTag eventTag = NIP01.createEventTag(event.getEvent().getId());
nip25.createReactionEvent(
eventTag,
Expand Down Expand Up @@ -283,7 +186,7 @@ private static void internetIdMetadata() {
.send(RELAYS);
}

public static void filters() throws InterruptedException {
private static void filters() throws InterruptedException {
Copy link

Copilot AI Jul 31, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The filters() method visibility was changed from public to private, which may break external usage if this method was intended to be part of the public API for examples.

Suggested change
private static void filters() throws InterruptedException {
public static void filters() throws InterruptedException {

Copilot uses AI. Check for mistakes.
logHeader("filters");

var date = Calendar.getInstance();
Expand Down Expand Up @@ -375,7 +278,7 @@ private static void logAccountsData() {
'\n' + "* PublicKey HEX: " + SENDER.getPublicKey().toString() +
'\n' + '\n' + "################################ ACCOUNTS END ################################";

log.info(msg);
System.out.println(msg);
Copy link

Copilot AI Jul 31, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

[nitpick] Replacing structured logging (log.info) with System.out.println reduces the ability to control log levels and formatting. Consider using a simple logger or at least System.err for error cases.

Copilot uses AI. Check for mistakes.
}

private static void logHeader(String header) {
Expand All @@ -389,18 +292,4 @@ private static void logHeader(String header) {
}
System.out.println();
}

private static void stop(ExecutorService executor) {
try {
executor.shutdown();
executor.awaitTermination(60, TimeUnit.SECONDS);
} catch (InterruptedException e) {
log.error("termination interrupted");
} finally {
if (!executor.isTerminated()) {
log.error("killing non-finished tasks");
}
executor.shutdownNow();
}
}
}