DataBridge Test Console

CLIENT CONNECTION

WebSocket URL Auth Type Credentials (API Key format: dk_env_keyid.secret)

Disconnected

Connection ID: - | Latency: - | Version: -

CONNECTION STATS

Sent

Received

Errors

Subs

NEW Fluent Query Builder

Chain methods: db.mongo.{db}.{collection}.where().select().limit().get()

Database

Collection

Where Filter (JSON)

Select Fields (comma-separated)

Limit

Sort Field

Sort Direction

FLUENT Insert / Update / Delete

Document for Insert (JSON)

Update (uses Where filter above)

NEW RabbitMQ Proxy Pattern

Dot notation: db.rabbitmq.image.resize({...}) → calls queue image.resize

Queue Path (dot notation)

Timeout (ms)

Payload (JSON)

NEW Service Aliases

Abstract sources: db.services.myService.method({...})

Service Name

Source

Target (queue prefix / task ID / channel)

Timeout (ms)

Execute Service

Service Name

Method (optional)

Payload (JSON)

No services registered

NEW ETL Pipelines

Build and run ETL pipelines: db.etl.create('name').extract(...).map(...).load(...).run()

Pipeline Name

Source Database

Source Collection

Target Collection

Filter (JSON) Mapping (JSON) - field: "{{expression}}"

ETL Run Saved Pipeline

Pipeline Name

Limit (override)

Run result will appear here

DEMO Quick Feature Tests

REDIS Subscribe

Raw Mode (bypass {org}:{resource}:{event} validation)

Channel

Active Subscriptions

No active subscriptions

REDIS Publish

Channel Data (JSON)

Quick Actions

RABBITMQ Subscribe

Exchange

Routing Key

Exchange Type

Active Subscriptions

No active subscriptions

RABBITMQ Publish

Exchange

Routing Key

Data (JSON)

RABBITMQ RPC Call

Queue Name

Timeout (ms)

Payload (JSON)

Quick Actions

CALLS Call Dashboard

🔊 TTS Playing

🎤 User Speaking

🔢 DTMF: -

👂 Listening

💬 Say

Interrupt High Priority

👤 Add Agent

Target Type:

Team:

Announce to caller

⚡ Quick Actions

Set Language:

Conference Mode:

📋 Live Call Events

Click "Listen to Calls" to start monitoring

MONGO Query

Database

Collection

Operation Filter

Document / Update

Options (limit, sort, projection)

MONGO Change Streams

Database

Collection

Quick Actions

CELERY Task Execution

Task ID (MongoDB ObjectId) Parameters (JSON)

Quick Test Buttons

Pending Requests

No pending requests

N8N Workflows

Manage n8n workflows via DataBridge. Requires service or admin API key.

Workflow ID (for get/run)

Filter Status

N8N Execute Workflow

Workflow ID Input Data (JSON)

N8N Executions

Workflow ID (optional)

Execution ID

Status Filter

N8N Credentials

Credential ID (for get)

Quick Actions

TEST Stress Tests

TEST Edge Case Tests

Test Results

Run a test to see results

DataBridge Test Console

CLIENT CONNECTION

CONNECTION STATS

NEW Fluent Query Builder

FLUENT Insert / Update / Delete

NEW RabbitMQ Proxy Pattern

NEW Service Aliases

NEW ETL Pipelines

ETL Run Saved Pipeline

DEMO Quick Feature Tests

REDIS Subscribe

Active Subscriptions

REDIS Publish

Quick Actions

RABBITMQ Subscribe

Active Subscriptions

RABBITMQ Publish

RABBITMQ RPC Call

Quick Actions

CALLS Call Dashboard

MONGO Query

MONGO Change Streams

Quick Actions

CELERY Task Execution

Quick Test Buttons

Pending Requests

N8N Workflows

N8N Execute Workflow

N8N Executions

N8N Credentials

Quick Actions

TEST Stress Tests

TEST Edge Case Tests

Test Results

MESSAGE LOG Clear Tab Export TXT Export JSON Clear All

MESSAGE LOG