mirror of
https://github.com/PR0M3TH3AN/bitvid.git
synced 2026-10-29 17:02:28 +00:00
chore(ai): event schema validation tool + fixes
- Created `scripts/agent/validate-events.mjs` to validate event builders against schemas. - Instrumented all event builders in `js/nostrEventSchemas.js` to run validation in dev mode. - Added `tests/event-schemas.test.mjs` to CI suite. - Updated `docs/nostr-event-schemas.md` with validation instructions.
This commit is contained in:
1 parent
7ec337ab3d
commit
653f1925f8
4 files changed
+643
-21
No files matched your search
@@ -0,0 +1,240 @@
|
||||
import { strict as assert } from 'node:assert';
|
||||
|
||||
// Hook console.warn to capture validation warnings
|
||||
const originalWarn = console.warn;
|
||||
const warnings = [];
|
||||
console.warn = (...args) => {
|
||||
// Capture only [schema] or [nostrEventSchemas] warnings
|
||||
const msg = args.join(' ');
|
||||
if (msg.includes('[schema]') || msg.includes('[nostrEventSchemas]')) {
|
||||
warnings.push(msg);
|
||||
}
|
||||
// We can still print to stdout if needed, but for validation we want to capture
|
||||
// originalWarn.apply(console, args);
|
||||
};
|
||||
|
||||
// Import schemas AFTER hooking console
|
||||
const schemas = await import('../../js/nostrEventSchemas.js');
|
||||
const {
|
||||
validateEventAgainstSchema,
|
||||
NOTE_TYPES,
|
||||
buildVideoPostEvent,
|
||||
buildVideoMirrorEvent,
|
||||
buildRepostEvent,
|
||||
buildShareEvent,
|
||||
buildRelayListEvent,
|
||||
buildDmRelayListEvent,
|
||||
buildProfileMetadataEvent,
|
||||
buildMuteListEvent,
|
||||
buildDeletionEvent,
|
||||
buildLegacyDirectMessageEvent,
|
||||
buildDmAttachmentEvent,
|
||||
buildDmReadReceiptEvent,
|
||||
buildDmTypingIndicatorEvent,
|
||||
buildViewEvent,
|
||||
buildZapRequestEvent,
|
||||
buildReactionEvent,
|
||||
buildCommentEvent,
|
||||
buildWatchHistoryEvent,
|
||||
buildSubscriptionListEvent,
|
||||
buildBlockListEvent,
|
||||
buildHashtagPreferenceEvent,
|
||||
buildAdminListEvent
|
||||
} = schemas;
|
||||
|
||||
console.log("Running Event Schema Validator...");
|
||||
|
||||
const failures = [];
|
||||
|
||||
function check(name, builder, params, expectedType) {
|
||||
warnings.length = 0; // Clear warnings
|
||||
try {
|
||||
const event = builder(params);
|
||||
validateEventAgainstSchema(expectedType || event.kind, event); // Pass type if known, else relies on implementation or event.kind mapping
|
||||
|
||||
// Some builders might not set the type explicitly in validate calls if we don't instrument them yet.
|
||||
// So we manually call validateEventAgainstSchema with the expected NOTE_TYPE.
|
||||
if (expectedType) {
|
||||
validateEventAgainstSchema(expectedType, event);
|
||||
}
|
||||
|
||||
if (warnings.length > 0) {
|
||||
failures.push({ name, error: `Generated warnings: ${JSON.stringify(warnings)}` });
|
||||
}
|
||||
|
||||
// specific checks can go here
|
||||
if (!event.created_at) failures.push({ name, error: "Missing created_at" });
|
||||
if (!event.pubkey) failures.push({ name, error: "Missing pubkey" });
|
||||
|
||||
} catch (e) {
|
||||
failures.push({ name, error: `Threw exception: ${e.message}` });
|
||||
}
|
||||
}
|
||||
|
||||
const pubkey = "0000000000000000000000000000000000000000000000000000000000000001";
|
||||
const created_at = Math.floor(Date.now() / 1000);
|
||||
|
||||
// Test cases
|
||||
check("buildVideoPostEvent", buildVideoPostEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
dTagValue: "video-123",
|
||||
content: {
|
||||
version: 3,
|
||||
title: "Test Video",
|
||||
videoRootId: "root-123",
|
||||
url: "https://example.com/video.mp4"
|
||||
}
|
||||
}, NOTE_TYPES.VIDEO_POST);
|
||||
|
||||
check("buildVideoMirrorEvent", buildVideoMirrorEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
tags: [["t", "test"]],
|
||||
content: "Mirror description"
|
||||
}, NOTE_TYPES.VIDEO_MIRROR);
|
||||
|
||||
check("buildRepostEvent", buildRepostEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
eventId: "1111111111111111111111111111111111111111111111111111111111111111",
|
||||
eventRelay: "wss://relay.example.com",
|
||||
serializedEvent: JSON.stringify({ id: "111", kind: 1 })
|
||||
}, NOTE_TYPES.REPOST);
|
||||
|
||||
check("buildShareEvent", buildShareEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
content: "Check this out",
|
||||
video: { id: "2222222222222222222222222222222222222222222222222222222222222222" }
|
||||
}, NOTE_TYPES.SHARE);
|
||||
|
||||
check("buildRelayListEvent", buildRelayListEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
relays: ["wss://relay.example.com", { url: "wss://read.example.com", mode: "read" }]
|
||||
}, NOTE_TYPES.RELAY_LIST);
|
||||
|
||||
check("buildDmRelayListEvent", buildDmRelayListEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
relays: ["wss://dm.example.com"]
|
||||
}, NOTE_TYPES.DM_RELAY_LIST);
|
||||
|
||||
check("buildProfileMetadataEvent", buildProfileMetadataEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
metadata: { name: "Test User", about: "Testing" }
|
||||
}, NOTE_TYPES.PROFILE_METADATA);
|
||||
|
||||
check("buildMuteListEvent", buildMuteListEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
pTags: ["3333333333333333333333333333333333333333333333333333333333333333"]
|
||||
}, NOTE_TYPES.MUTE_LIST);
|
||||
|
||||
check("buildDeletionEvent", buildDeletionEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
eventIds: ["4444444444444444444444444444444444444444444444444444444444444444"],
|
||||
reason: "Mistake"
|
||||
}, NOTE_TYPES.DELETION);
|
||||
|
||||
check("buildLegacyDirectMessageEvent", buildLegacyDirectMessageEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
recipientPubkey: "5555555555555555555555555555555555555555555555555555555555555555",
|
||||
ciphertext: "encryped_content"
|
||||
}, NOTE_TYPES.LEGACY_DM);
|
||||
|
||||
check("buildDmAttachmentEvent", buildDmAttachmentEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
recipientPubkey: "6666666666666666666666666666666666666666666666666666666666666666",
|
||||
attachment: { url: "https://example.com/file.jpg", x: "hash" }
|
||||
}, NOTE_TYPES.DM_ATTACHMENT);
|
||||
|
||||
check("buildDmReadReceiptEvent", buildDmReadReceiptEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
recipientPubkey: "7777777777777777777777777777777777777777777777777777777777777777",
|
||||
eventId: "8888888888888888888888888888888888888888888888888888888888888888"
|
||||
}, NOTE_TYPES.DM_READ_RECEIPT);
|
||||
|
||||
check("buildDmTypingIndicatorEvent", buildDmTypingIndicatorEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
recipientPubkey: "9999999999999999999999999999999999999999999999999999999999999999"
|
||||
}, NOTE_TYPES.DM_TYPING);
|
||||
|
||||
check("buildViewEvent", buildViewEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
pointerValue: "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa",
|
||||
pointerTag: ["e", "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"],
|
||||
dedupeTag: "session-123"
|
||||
}, NOTE_TYPES.VIEW_EVENT);
|
||||
|
||||
check("buildZapRequestEvent", buildZapRequestEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
recipientPubkey: "bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb",
|
||||
amountSats: 100,
|
||||
relays: ["wss://zap.relay.com"]
|
||||
}, NOTE_TYPES.ZAP_REQUEST);
|
||||
|
||||
check("buildReactionEvent", buildReactionEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
pointerTag: ["e", "cccccccccccccccccccccccccccccccccccccccccccccccccccccccccccccccc"],
|
||||
content: "+"
|
||||
}, NOTE_TYPES.VIDEO_REACTION);
|
||||
|
||||
check("buildCommentEvent", buildCommentEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
videoEventId: "dddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddd",
|
||||
content: "Nice video!"
|
||||
}, NOTE_TYPES.VIDEO_COMMENT);
|
||||
|
||||
check("buildWatchHistoryEvent", buildWatchHistoryEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
monthIdentifier: "2023-10",
|
||||
content: JSON.stringify({ version: 2, month: "2023-10", items: [] })
|
||||
}, NOTE_TYPES.WATCH_HISTORY);
|
||||
|
||||
check("buildSubscriptionListEvent", buildSubscriptionListEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
content: "encrypted_subs"
|
||||
}, NOTE_TYPES.SUBSCRIPTION_LIST);
|
||||
|
||||
check("buildBlockListEvent", buildBlockListEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
content: "encrypted_blocks"
|
||||
}, NOTE_TYPES.USER_BLOCK_LIST);
|
||||
|
||||
check("buildHashtagPreferenceEvent", buildHashtagPreferenceEvent, {
|
||||
pubkey,
|
||||
created_at,
|
||||
content: "encrypted_prefs"
|
||||
}, NOTE_TYPES.HASHTAG_PREFERENCES);
|
||||
|
||||
check("buildAdminListEvent (moderation)", (p) => buildAdminListEvent("moderation", p), {
|
||||
pubkey,
|
||||
created_at,
|
||||
hexPubkeys: ["eeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee"]
|
||||
}, NOTE_TYPES.ADMIN_MODERATION_LIST);
|
||||
|
||||
if (failures.length > 0) {
|
||||
console.error("\n❌ Validation Failed:");
|
||||
failures.forEach(f => {
|
||||
console.error(`- ${f.name}: ${f.error}`);
|
||||
});
|
||||
process.exit(1);
|
||||
} else {
|
||||
console.log("\n✅ All events validated successfully.");
|
||||
process.exit(0);
|
||||
}
|
||||
Reference in new issue
Block a user