Control My Desk Light

#include <WiFiClientSecure.h>
#include <PubSubClient.h>
#include <WiFi.h>            // Include the WiFi library
#include <HTTPClient.h>    
 
const char* ca_cert = \
"-----BEGIN CERTIFICATE-----\n" \
"LONG RSA KEY INFO HERE \n" \
"-----END CERTIFICATE-----\n";
 
const char* device_cert = \
"-----BEGIN CERTIFICATE-----\n" \
"LONG RSA KEY INFO HERE \n" \
"-----END CERTIFICATE-----\n";
 
const char* private_key = \
"-----BEGIN RSA PRIVATE KEY-----\n" \
"LONG RSA KEY INFO HERE \n" \
"-----END RSA PRIVATE KEY-----\n";
 
WiFiClientSecure net;
PubSubClient client(net);
 
void sendHttpToWLED(String url, String payloadStr) {
  HTTPClient http;
  http.begin(url);
  http.addHeader("Content-Type", "application/json");
 
  int httpResponseCode = http.POST(payloadStr);
 
  if (httpResponseCode > 0) {
    Serial.print("HTTP Response code: ");
    Serial.println(httpResponseCode);
  } else {
    Serial.print("Error on sending POST: ");
    Serial.println(httpResponseCode);
  }
 
  http.end();
}
 
void messageReceived(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message arrived [");
  Serial.print(topic);
  Serial.print("] ");
  for (unsigned int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();
 
  // Convert payload to String
  String payloadStr = String((char*)payload).substring(0, length);
 
  // Define the WLED HTTP API endpoint
  String url = "http://10.0.0.125/json/state";  // Replace with the actual IP of your WLED device
 
  // Send the received MQTT payload directly to the WLED device as an HTTP request
  sendHttpToWLED(url, payloadStr);
}
 
void setup() {
  Serial.begin(115200);
 
  WiFi.begin("--YOUR WIFI SSID--", "--YOUR WIFI PASSWORD--");
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.println("Connecting to WiFi...");
  }
  Serial.println("Connected to WiFi");
 
  net.setCACert(ca_cert);
  net.setCertificate(device_cert);
  net.setPrivateKey(private_key);
 
  client.setServer("--YOUR AWS IOT ENDPOINT ADDRESS--", 8883);
  client.setCallback(messageReceived);
 
  if (client.connect("-- YOUR AWS IOT CLIENT ID --")) {
    Serial.println("Connected to AWS IoT");
    client.subscribe("-- YOUR AWS IOT TOPIC --");  // Subscribe to the topic where commands will be sent
  } else {
    Serial.print("AWS IoT connection failed, state: ");
    Serial.println(client.state());
  }
}
 
void loop() {
  if (!client.connected()) {
    Serial.println("Disconnected from AWS IoT. Attempting reconnection...");
    while (!client.connect("-- YOUR AWS IOT CLIENT ID --")) {
      delay(1000);
      Serial.print(".");
    }
    Serial.println("Reconnected to AWS IoT");
    client.subscribe("lights");
  }
 
  client.loop();  // Handle AWS IoT MQTT messages
}

sudo npm install @aws-sdk/client-iot-data-plane 

sudo pnpm install @aws-sdk/client-iot-data-plane 

import { useState, useEffect } from 'react';
 
useEffect(() => {
  const triggerLightFlash = async () => {
    try {
      const response = await fetch('/api/publish', {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
        },
        body: JSON.stringify({ color: '#FF0000' }),  // Set the color to red
      });
      console.log('Light flash triggered:', await response.json());
    } catch (error) {
      console.error('Error triggering light flash:', error);
    }
  };
 
  triggerLightFlash();
}, []);

import { IoTDataPlaneClient, PublishCommand } from "@aws-sdk/client-iot-data-plane";
 
export default async function handler(req, res) {
  const { color } = req.body;
 
  const client = new IoTDataPlaneClient({
    region: "us-east-1", // Replace with your AWS region
    credentials: {
      accessKeyId: process.env.AWS_ACCESS_KEY_ID,
      secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY,
    }
  });
 
  // Turn the light on with the specified color
  const paramsOn = {
    topic: "lights",
    payload: JSON.stringify({
      "seg": [
        {
          "col": [[parseInt(color.slice(1, 3), 16), parseInt(color.slice(3, 5), 16), parseInt(color.slice(5, 7), 16)]],
          "fx": 0,  // Solid color (no effect)
          "bri": 255  // Full brightness
        }
      ]
    }),
    qos: 1
  };
 
  // Turn the light off after a short delay
  const paramsOff = {
    topic: "lights",
    payload: JSON.stringify({
      "seg": [
        {
          "col": [[0, 0, 0]],  // Black (off)
          "fx": 0,  // Solid color (no effect)
          "bri": 0  // Turn off brightness
        }
      ]
    }),
    qos: 1
  };
 
  try {
    // Send the command to turn the light on
    await client.send(new PublishCommand(paramsOn));
 
    // Wait for 1 second to simulate a quick flash
    await new Promise(resolve => setTimeout(resolve, 1000));
 
    // Send the command to turn the light off
    await client.send(new PublishCommand(paramsOff));
 
    res.status(200).json({ message: "Light blinked successfully and turned off", data: { color } });
  } catch (err) {
    res.status(500).json({ message: "Error controlling the light", error: err });
  }
}