void setup() {

  // put your setup code here, to run once:

  Serial.begin(9600);

  while (!Serial) {

    ; // wait for serial port to connect. Needed for native USB port only

  }

}

unsigned long timer = 0;

void loop() {

  // put your main code here, to run repeatedly:

  if (millis() - timer > 1000)

  {

    timer = millis();

    Serial.println("hello");

  }

  while (Serial.available() > 0) {

    Serial.print((char)Serial.read());

  }

}

// Load Wi-Fi library

#include <WiFi.h>

#include <WebSocketsServer.h>

WebSocketsServer webSocket = WebSocketsServer(81);

// Replace with your network credentials

const char* ssid = "REPLACE_WITH_YOUR_SSID";

const char* password = "REPLACE_WITH_YOUR_PASSWORD";

void hexdump(const void *mem, uint32_t len, uint8_t cols = 16) {

  const uint8_t* src = (const uint8_t*) mem;

  Serial.printf("\n[HEXDUMP] Address: 0x%08X len: 0x%X (%d)", (ptrdiff_t)src, len, len);

  for (uint32_t i = 0; i < len; i++) {

    if (i % cols == 0) {

      Serial.printf("\n[0x%08X] 0x%08X: ", (ptrdiff_t)src, i);

    }

    Serial.printf("%02X ", *src);

    src++;

  }

  Serial.printf("\n");

}

void webSocketEvent(uint8_t num, WStype_t type, uint8_t * payload, size_t length) {

    switch(type) {

        case WStype_DISCONNECTED:

            Serial.printf("[%u] Disconnected!\n", num);

            break;

        case WStype_CONNECTED:

            {

                IPAddress ip = webSocket.remoteIP(num);

                Serial.printf("[%u] Connected from %d.%d.%d.%d url: %s\n", num, ip[0], ip[1], ip[2], ip[3], payload);

        // send message to client

        webSocket.sendTXT(num, "Connected");

            }

            break;

        case WStype_TEXT:

            Serial.printf("[%u] get Text: %s\n", num, payload);

            // send message to client

            // webSocket.sendTXT(num, "message here");

            // send data to all connected clients

            // webSocket.broadcastTXT("message here");

            break;

        case WStype_BIN:

            Serial.printf("[%u] get binary length: %u\n", num, length);

            hexdump(payload, length);

            // send message to client

            // webSocket.sendBIN(num, payload, length);

            break;

    case WStype_ERROR:      

    case WStype_FRAGMENT_TEXT_START:

    case WStype_FRAGMENT_BIN_START:

    case WStype_FRAGMENT:

    case WStype_FRAGMENT_FIN:

      break;

    }

}

void setup() {

  Serial.begin(9600);

  // Connect to Wi-Fi network with SSID and password

  Serial.print("Connecting to ");

  Serial.println(ssid);

  WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED) {

    delay(500);

    Serial.print(".");

  }

  // Print local IP address

  Serial.println("");

  Serial.println("WiFi connected.");

  Serial.println("IP address: ");

  Serial.println(WiFi.localIP());

  // server address, port and URL

  webSocket.begin();

  // event handler

  webSocket.onEvent(webSocketEvent);

}

unsigned long timer = 0;

int counter = 0;

void loop() {

  webSocket.loop();

  if (millis() - timer > 2000) // send a counter value every 2 sec.

  {

    String numberString = String(counter);

    webSocket.broadcastTXT(numberString);

    counter = counter + 1;

    timer = millis();

  }

}

// where the serial server is (your local machine):

var host = '10.0.1.27:81';

var socket; // the websocket

var sensorValue = 0; // the sensor value

function setup() {

  createCanvas(400, 400);

  // connect to server:

  socket = new WebSocket('ws://' + host);

  // socket connection listener:

  socket.onopen = sendIntro;

  // socket message listener:

  socket.onmessage = readMessage;

}

function draw() {

  background("#2307AF");

  fill(255);

  ellipse(sensorValue, height / 2, 20, 20);

  text(sensorValue, 20, 20);

}

function sendIntro() {

  // convert the message object to a string and send it:

  socket.send("Hello");

}

function readMessage(event) {

  var msg = event.data; // read data from the onmessage event

  sensorValue = Number(msg);

  println(sensorValue); // print it

}

// This example uses an ESP32 Development Board

// to connect to shiftr.io.

//

// You can check on your device after a successful

// connection here: https://www.shiftr.io/try.

//

// by Joël Gähwiler

// https://github.com/256dpi/arduino-mqtt

#define ONBOARD_LED  2

#include <WiFi.h>

#include <MQTT.h>

WiFiClient net;

MQTTClient client;

unsigned long lastMillis = 0;

void connect() {

  Serial.print("checking wifi...");

  while (WiFi.status() != WL_CONNECTED) {

    Serial.print(".");

    delay(1000);

  }

  Serial.print("\nconnecting...");

  while (!client.connect("arduino", "public", "public")) {

    Serial.print(".");

    delay(1000);

  }

  Serial.println("\nconnected!");

  client.subscribe("/idsp5js");

  // client.unsubscribe("/hello");

}

void messageReceived(String &topic, String &payload) {

  Serial.println("incoming: " + topic + " - " + payload);

  if(topic.equals("/idsp5js") && payload.equals("on"))

  {

     digitalWrite(ONBOARD_LED,HIGH);

  }

  else if(topic.equals("/idsp5js") && payload.equals("off"))

  {

     digitalWrite(ONBOARD_LED,LOW);

  }

  // Note: Do not use the client in the callback to publish, subscribe or

  // unsubscribe as it may cause deadlocks when other things arrive while

  // sending and receiving acknowledgments. Instead, change a global variable,

  // or push to a queue and handle it in the loop after calling `client.loop()`.

}

void setup() {

  Serial.begin(9600);

  WiFi.begin("WIFINAME", "PASSWORD");

  // Note: Local domain names (e.g. "Computer.local" on OSX) are not supported

  // by Arduino. You need to set the IP address directly.

  client.begin("public.cloud.shiftr.io", net);

  client.onMessage(messageReceived);

  pinMode(ONBOARD_LED,OUTPUT);

  connect();

}

void loop() {

  client.loop();

  delay(10);  // <- fixes some issues with WiFi stability

  if (!client.connected()) {

    connect();

  }

  // publish a message roughly every second.

  if (millis() - lastMillis > 1000) {

    lastMillis = millis();

    client.publish("/idsesp32", "I am online");

  }

}

// Make sure that this string is in your index.html header:

// <script crossorigin="anonymous" src="https://unpkg.com/mqtt/dist/mqtt.min.js"></script>

// XXXX

var client;

function setup() {

  createCanvas(windowWidth, windowHeight);

 client = mqtt.connect(

    "wss://public:public@public.cloud.shiftr.io",

    {

      clientId: "p5jsids",

    }

  );

  client.on("connect", function () {

    console.log("connected!");

    client.subscribe("/idsesp32");

   });

  client.on("message", function (topic, message) {

     print(topic + ": " + message);

  });

  textSize(30);

}

var lightIsOn = false

var mouseIsPressedOld = false

function draw() {

  if(mouseIsPressed == true && mouseIsPressedOld == false)

  {

    lightIsOn = !lightIsOn;

    if(lightIsOn)

    {

     client.publish("/idsp5js", "on");

    }

    else

    {

     client.publish("/idsp5js", "off"); 

    }

  }

  mouseIsPressedOld = mouseIsPressed;

  if(lightIsOn)

  {

    background(0,0,255);

  }

  else

  {

    background(100);

  }

  text("Click to turn on led",100,100);

}

function keyPressed()

{

}