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

Merge pull request #18 from MutinyWallet/block-nip95

Browse Source 
Block nip95
This commit is contained in:
Tony Giorgio
2023-04-26 19:21:10 -05:00
committed by GitHub
parent fbcca9a96c fa1f295acf
commit c721d5c9a6
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,
}
/// 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
#[event(fetch)]
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) => {
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
let published_notes = ctx.kv("PUBLISHED_NOTES")?;
if published_notes
@@ -164,6 +183,24 @@ pub async fn main(req: Request, env: Env, _ctx: Context) -> Result<Response> {
ClientMessage::Event(event) => {
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
let published_notes =
ctx.kv("PUBLISHED_NOTES").expect("get kv");