Description

n8n-nodes-timed-buffer

A custom n8n node that collects incoming messages into a time‑based buffer and emits them all at once. It uses Redis to maintain buffer state and requires a Redis credential to operate.

Installation

Follow the installation guide in the n8n community nodes documentation.

Usage

1. Session Key (String)
   Unique identifier (e.g. conversation-123) to group executions into the same buffer.
2. Content (String)
   Data to buffer (e.g. Hello).
3. Wait Amount (Number)
   Numeric delay before emitting the buffer (e.g. 30).
4. Wait Unit (Dropdown)
   Time unit for the delay: seconds, minutes, hours, or days.
5. Redis Credential (Credential, required)
   Create a Redis credential in n8n and select it here. The node will not function without it.

Node Parameters

Outputs

1. Resume
   Fires once after the wait interval, returning all buffered content:

   [
     {
       "data": [ … ]
     }
   ]
   

2. Skipped
   Fires on any execution arriving during an active interval (returns {}).

Example: Chat Message Buffering

1. Five WhatsApp messages arrive.

2. Four are routed to Skipped.

3. After 10 seconds from the last message, the node sends all five messages in Resume.

   [
     {
       "data": [
         "Hi!",
         "How are you?",
         "What’s up?",
         "Let’s meet.",
         "Bye!"
       ]
     }
   ]
   

License

MIT