How to Handle Fastio Realtime Events with Node.js Express

Fastio provides a WebSocket events feed and a realtime activity feed that can be polled via the REST API at https://api.fast.io/current/. Instead of webhooks, your application connects directly to receive events when files are uploaded, modified, deleted, or shared.

Each payload includes an event object with details like event ID, event type, created timestamp, workspace ID, and file metadata.

Streaming events over WebSockets or polling the activity feed ensures your server stays reactive while remaining securely behind your firewall without exposing public endpoints.

Refer to the Fastio documentation and REST API for payload schemas and activity polling endpoints.

• How to Handle Fastio Realtime Events with NestJSConsuming Fastio real-time events with NestJS enables instant responses to file uploads, modifications, and access...
• How to Handle Fastio Realtime Events with Python FastAPIHandle Fastio real-time file updates in FastAPI using WebSocket event feeds or activity polling. Build reactive AI...
• How to Integrate Fastio Events with Temporal.ioIntegrating Fastio with Temporal.io lets developers start durable workflows whenever files arrive or change in a...
• How to Build Event-Driven Agent Workflows with Fastio EventsFastio enables event-driven agent workflows the moment a file changes through real-time WebSocket event feeds and...
• How to Implement the Fastio API in Ruby on RailsFile sharing in modern applications has evolved past simple blob storage. Implementing the Fastio API in Ruby on Rails...
• How to Process Fastio Events with Apache KafkaStreaming Fastio file changes with Apache Kafka ensures durable, ordered, and scalable event delivery for large-scale...

More on this subject: Agent Integrations and APIs (96 guides)

To handle Fastio real-time events with Node.js Express, prepare these prerequisites:

Fastio Account:

• Sign up for the Fastio Business Trial (14-day trial, card required).
• Create a workspace.
• Generate an API key from your account settings.

Development Environment:

• Node.js 18 or later.
• Project initialization:

mkdir fastio-events-express
cd fastio-events-express
npm init -y
npm install express ws dotenv axios

Create .env:

FASTIO_API_KEY=your_actual_api_key_here
PORT=3000

Give Your AI Agents Persistent Storage

Get real-time file events in your Node.js Express apps. The 14-day Business Trial provides access to workspaces, shares, and activity feeds.

Start Business Trial

Build a secure Express service that maintains an outbound WebSocket connection to Fastio's events stream.

Create index.js:

const express = require('express');
const WebSocket = require('ws');
require('dotenv').config();

const app = express();
const port = process.env.PORT || 3000;
const apiKey = process.env.FASTIO_API_KEY;

app.use(express.json());

// Connect to Fastio WebSocket events feed
function connectEvents() {
  const ws = new WebSocket('wss://api.fast.io/current/events', {
    headers: { Authorization: `Bearer ${apiKey}` }
  });

ws.on('open', () => {
    console.log('Connected to Fastio events feed');
  });

ws.on('message', (data) => {
    try {
      const event = JSON.parse(data);
      console.log(`Event received: ${event.event_type} on ${event.resource?.name || 'resource'}`);
      // Route event to processing logic or AI agents
    } catch (err) {
      console.error('Error parsing event:', err);
    }
  });

ws.on('close', () => {
    console.log('Connection closed. Reconnecting in 5s...');
    setTimeout(connectEvents, 5000);
  });
}

connectEvents();

app.get('/health', (req, res) => {
  res.json({ status: 'ok' });
});

app.listen(port, () => {
  console.log(`Express server running on port ${port}`);
});

This establishes an event listener without exposing public inbound webhook endpoints.