aljaz/blastr
1
0
Fork 0
mirror of https://github.com/aljazceru/blastr.git synced 2025-12-19 06:54:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

Block nip95

Browse Source
This commit is contained in:
benthecarman
2023-04-26 19:02:31 -05:00
parent fbcca9a96c
commit fa1f295acf
1 changed files with 37 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
src/lib.rs
View File

@@ -29,6 +29,10 @@ pub struct PublishedNote {
date: String, date: String,
} }
/// The list of event kinds that are disallowed for the Nostr relay
/// currently, this is just the NIP-95 event
const DISALLOWED_EVENT_KINDS: [u32; 1] = [1064];
/// Main function for the Cloudflare Worker that triggers off of a HTTP req /// Main function for the Cloudflare Worker that triggers off of a HTTP req
#[event(fetch)] #[event(fetch)]
pub async fn main(req: Request, env: Env, _ctx: Context) -> Result<Response> { pub async fn main(req: Request, env: Env, _ctx: Context) -> Result<Response> {
@@ -55,6 +59,21 @@ pub async fn main(req: Request, env: Env, _ctx: Context) -> Result<Response> {
ClientMessage::Event(event) => { ClientMessage::Event(event) => {
console_log!("got an event from client: {}", event.id); console_log!("got an event from client: {}", event.id);
// check if disallowed event kind
if DISALLOWED_EVENT_KINDS.contains(&event.kind.as_u32()) {
console_log!(
"invalid event kind {}: {}",
event.kind.as_u32(),
event.id
);
let relay_msg = RelayMessage::new_ok(
event.id,
false,
"disallowed event kind",
);
return relay_response(relay_msg);
};
// check if we've already published it before // check if we've already published it before
let published_notes = ctx.kv("PUBLISHED_NOTES")?; let published_notes = ctx.kv("PUBLISHED_NOTES")?;
if published_notes if published_notes
@@ -164,6 +183,24 @@ pub async fn main(req: Request, env: Env, _ctx: Context) -> Result<Response> {
ClientMessage::Event(event) => { ClientMessage::Event(event) => {
console_log!("got an event from client: {}", event.id); console_log!("got an event from client: {}", event.id);
// check if disallowed event kind
if DISALLOWED_EVENT_KINDS.contains(&event.kind.as_u32()) {
console_log!(
"invalid event kind {}: {}",
event.kind.as_u32(),
event.id
);
let relay_msg = RelayMessage::new_ok(
event.id,
false,
"disallowed event kind",
);
server
.send_with_str(&relay_msg.as_json())
.expect("failed to send response");
continue;
};
// check if we've already published it before // check if we've already published it before
let published_notes = let published_notes =
ctx.kv("PUBLISHED_NOTES").expect("get kv"); ctx.kv("PUBLISHED_NOTES").expect("get kv");