Documentation

npm install @pushflodev/sdk

import { PushFloClient } from '@pushflodev/sdk';

// Initialize with your publish key
const client = new PushFloClient({
  publishKey: 'pub_xxxxxxxxxxxxx',
});

// Connect and subscribe to a channel
client.connect();

const subscription = client.subscribe('orders:user-123', {
  onMessage: (message) => {
    console.log('Order status:', message.content);
    // Update your UI here
  },
  onSubscribed: () => console.log('Subscribed!'),
});

// Clean up when component unmounts
// subscription.unsubscribe();
// client.disconnect();

import { PushFloServer } from '@pushflodev/sdk/server';
import { NextResponse } from 'next/server';

const pushflo = new PushFloServer({
  secretKey: 'sec_xxxxxxxxxxxxx',
});

export async function PATCH(request: Request) {
  const { orderId, status, userId } = await request.json();

  // Update your database
  await db.orders.update({ id: orderId, status });

  // Notify the user in real-time
  await pushflo.publish(`orders:user-${userId}`, {
    orderId,
    status,
  }, { eventType: 'order-updated' });

  return NextResponse.json({ success: true });
}

import { PushFloProvider } from '@pushflodev/sdk/react';

export function Providers({ children }) {
  return (
    <PushFloProvider publishKey="pub_xxxxxxxxxxxxx">
      {children}
    </PushFloProvider>
  );
}

import { useChannel } from '@pushflodev/sdk/react';

export function OrderUpdates({ userId }) {
  const { messages, connectionState } = useChannel(`orders:user-${userId}`);

  return (
    <div>
      <p>Status: {connectionState}</p>
      {messages.map((msg) => (
        <div key={msg.id}>{msg.content.status}</div>
      ))}
    </div>
  );
}