Tuya Pulsar WebSocket SDK

A Node.js WebSocket SDK for Tuya Pulsar Message Queue.

Installation

npm install tuya-pulsar-ws-node
# or
yarn add tuya-pulsar-ws-node

Usage

const TuyaWebsocket = require('tuya-pulsar-ws-node').default;
// or with ES6 imports:
// import TuyaWebsocket from 'tuya-pulsar-ws-node';

const client = new TuyaWebsocket({
  accessId: "your_access_id",
  accessKey: "your_access_key",
  url: TuyaWebsocket.URL.CN, // Select appropriate endpoint (CN, US, EU, IN, WE, UE)
  env: TuyaWebsocket.env.PROD,
  maxRetryTimes: 100,
});

client.open(() => {
  console.log('Connection opened');
});

client.message((ws, message) => {
  console.log('Received message:', message);
  // Acknowledge the message to confirm receipt
  client.ackMessage(message.messageId);
});

client.reconnect(() => {
  console.log('Reconnecting...');
});

client.ping(() => {
  console.log('Ping sent');
});

client.pong(() => {
  console.log('Pong received');
});

client.close((ws, ...args) => {
  console.log('Connection closed', ...args);
});

client.error((ws, error) => {
  console.error('Error:', error);
});

// Start receiving messages
client.start();

Configuration

The TuyaWebsocket constructor accepts the following options:

• accessId: Your Tuya Access ID.
• accessKey: Your Tuya Access Key.
• url: WebSocket URL (use TuyaWebsocket.URL helper).
• env: Environment (use TuyaWebsocket.env helper).
• maxRetryTimes: Maximum number of reconnection attempts (default: unlimited).

License

ISC