test: add NIP-22 created_at integration coverage

Author: Priyanshubhartistm

src/handlers/event-message-handler.ts

@@ -165,7 +165,7 @@ export class EventMessageHandler implements IMessageHandler {
       limits.createdAt.maxPositiveDelta > 0 &&
       event.created_at > now + limits.createdAt.maxPositiveDelta
     ) {
-      return `rejected: created_at is more than ${limits.createdAt.maxPositiveDelta} seconds in the future`
+      return `invalid: created_at is more than ${limits.createdAt.maxPositiveDelta} seconds in the future`
     }
 
     if (

test/integration/features/nip-22/nip-22.feature

@@ -0,0 +1,37 @@
+@nip-22
+Feature: NIP-22 created_at timestamp limits
+  Scenario: Event with created_at at current time is accepted
+    Given someone called Alice
+    And created_at limits are set to maxPositiveDelta 900 and maxNegativeDelta 0
+    When Alice drafts a text_note event with content "test event" and created_at 0 seconds from now
+    Then Alice sends their last draft event successfully
+    When Alice subscribes to author Alice
+    Then Alice receives a text_note event from Alice with content "test event"
+
+  Scenario: Event with created_at at positive delta limit is accepted
+    Given someone called Alice
+    And created_at limits are set to maxPositiveDelta 900 and maxNegativeDelta 0
+    When Alice drafts a text_note event with content "test event" and created_at 900 seconds from now
+    Then Alice sends their last draft event successfully
+    When Alice subscribes to author Alice
+    Then Alice receives a text_note event from Alice with content "test event"
+
+  Scenario: Event with created_at above positive delta limit is rejected
+    Given someone called Alice
+    And created_at limits are set to maxPositiveDelta 900 and maxNegativeDelta 0
+    When Alice drafts a text_note event with content "test event" and created_at 901 seconds from now
+    Then Alice sends their last draft event unsuccessfully with reason containing "invalid"
+
+  Scenario: Event older than configured negative delta limit is rejected
+    Given someone called Alice
+    And created_at limits are set to maxPositiveDelta 900 and maxNegativeDelta 3600
+    When Alice drafts a text_note event with content "test event" and created_at -3601 seconds from now
+    Then Alice sends their last draft event unsuccessfully with reason containing "rejected"
+
+  Scenario: Event within configured negative delta limit is accepted
+    Given someone called Alice
+    And created_at limits are set to maxPositiveDelta 900 and maxNegativeDelta 3600
+    When Alice drafts a text_note event with content "test event" and created_at -3590 seconds from now
+    Then Alice sends their last draft event successfully
+    When Alice subscribes to author Alice
+    Then Alice receives a text_note event from Alice with content "test event"

test/integration/features/nip-22/nip-22.feature.ts

@@ -0,0 +1,75 @@
+import { After, Given, Then, When } from '@cucumber/cucumber'
+import { assocPath, pipe } from 'ramda'
+
+import { CommandResult, MessageType } from '../../../../src/@types/messages'
+import { createEvent, sendEvent } from '../helpers'
+
+import { Event } from '../../../../src/@types/event'
+import { expect } from 'chai'
+import { isDraft } from '../shared'
+import { SettingsStatic } from '../../../../src/utils/settings'
+import WebSocket from 'ws'
+
+const setCreatedAtLimits = (maxPositiveDelta: number, maxNegativeDelta: number) => {
+  const settings = SettingsStatic._settings ?? SettingsStatic.createSettings()
+
+  SettingsStatic._settings = pipe(
+    assocPath(['limits', 'event', 'createdAt', 'maxPositiveDelta'], maxPositiveDelta),
+    assocPath(['limits', 'event', 'createdAt', 'maxNegativeDelta'], maxNegativeDelta),
+  )(settings) as any
+}
+
+After({ tags: '@nip-22' }, function() {
+  setCreatedAtLimits(900, 0)
+})
+
+Given(/^created_at limits are set to maxPositiveDelta (\d+) and maxNegativeDelta (\d+)$/, function(
+  maxPositiveDelta: string,
+  maxNegativeDelta: string,
+) {
+  setCreatedAtLimits(Number(maxPositiveDelta), Number(maxNegativeDelta))
+})
+
+When(/^(\w+) drafts a text_note event with content "([^"]+)" and created_at (-?\d+) seconds from now$/, async function(
+  name: string,
+  content: string,
+  offsetSeconds: string,
+) {
+  const { pubkey, privkey } = this.parameters.identities[name]
+  const createdAt = Math.floor(Date.now() / 1000) + Number(offsetSeconds)
+
+  const event: Event = await createEvent(
+    {
+      pubkey,
+      kind: 1,
+      content,
+      created_at: createdAt,
+    },
+    privkey,
+  )
+
+  const draftEvent = event as any
+  draftEvent[isDraft] = true
+
+  this.parameters.events[name].push(event)
+})
+
+Then(/^(\w+) sends their last draft event unsuccessfully with reason containing "([^"]+)"$/, async function(
+  name: string,
+  expectedReason: string,
+) {
+  const ws = this.parameters.clients[name] as WebSocket
+
+  const event = this.parameters.events[name].findLast((lastEvent: Event) => (lastEvent as any)[isDraft])
+  if (!event) {
+    throw new Error(`No draft event found for ${name}`)
+  }
+
+  delete (event as any)[isDraft]
+
+  const command = await sendEvent(ws, event, false) as CommandResult
+
+  expect(command[0]).to.equal(MessageType.OK)
+  expect(command[2]).to.equal(false)
+  expect(command[3].toLowerCase()).to.contain(expectedReason.toLowerCase())
+})

test/unit/handlers/event-message-handler.spec.ts

@@ -291,9 +291,9 @@ describe('EventMessageHandler', () => {
           eventLimits.createdAt.maxPositiveDelta = 100
           event.created_at += 101
 
-          expect((handler as any).canAcceptEvent(event)).to.equal(
-            'rejected: created_at is more than 100 seconds in the future',
-          )
+          expect(
+            (handler as any).canAcceptEvent(event)
+          ).to.equal('invalid: created_at is more than 100 seconds in the future')
         })
       })