Trpc-mqtt NPM | npm.io

Usage

1. Install trpc-mqtt.

# npm
npm install trpc-mqtt mqtt@5
# yarn
yarn add trpc-mqtt mqtt@5
# pnpm
pnpm add trpc-mqtt mqtt@5

2. Use mqttLink in your client code.

import { createTRPCProxyClient } from '@trpc/client';
import { mqttLink } from 'trpc-mqtt/link';
import mqtt from 'mqtt';

import type { AppRouter } from './appRouter';

const client = mqtt.connect('mqtt://localhost');

export const trpc = createTRPCProxyClient<AppRouter>({
  links: [
    mqttLink({
      client,
      requestTopic: "rpc/request"
    })
  ],
});

Note: don't forget to clean up the MQTT client when you're done, using client.end().

3. Use createMQTTHandler to handle incoming calls via mqtt on the server.

import { createMQTTHandler } from 'trpc-mqtt/adapter';

import { appRouter } from './appRouter';

const client = mqtt.connect('mqtt://localhost');

createMQTTHandler({ 
  client,
  requestTopic: "rpc/request",
  router: appRouter
});

Note: same as with the link, don't forget to clean up the MQTT client when you're done, using client.end().