Broadcast real-time updates of the toilet occupancy from the ESP32 devices to the NestJS application with socket.io server and broadcast the updates to the employees in the organization.
The idea of this project is to provide a real-time API for the status of the toilets occupancy in the company building. This project is just a very general concept and prototype, requiring a lot more work and refinement.
I wanted to see how to create a web application using NestJS, so I spent almost 2 weeks on this project with 0 knowledge about NestJS. For now, I don't want to develop further this project, I will leave it as it is. The code is probably absolute garbage, but whatever.
I managed to implement these basic functionalities:
- Real-time data streaming from multiple ESP32 to the server using WebSockets.
- Broadcasting new toilets statuses to the employees in real-time.
- User can register multiple buildings (organizations), which have many restrooms on different floors and each restroom can contain multiple toilets.
- Each toilet has a unique ID and a token that is used to authenticate the ESP32 device.
- Only authenticated employees can access and see the real-time updates of the toilets in the organization.
- Register a new user by sending a following request to the server:
POST http://localhost:8535/auth/sign-up
{
"email": "[email protected]",
"password": "password",
"firstName": "John",
"lastName": "Doe"
}
- Log in to the application:
POST http://localhost:8535/auth/sign-in
{
"email": "[email protected]",
"password": "password",
}
- Create a new organization (building):
POST http://localhost:8535/organizations
{
"name": "Office Rzeszow",
"address": "Warszawska 1, 35-000 Rzeszów",
"password": "password"
}
- Create a new restroom in the organization:
POST http://localhost:8535/restrooms?organizationId=<organizationId>
{
"name": "General Restroom",
"floor": 1,
"type": "general"
}
- Create a new toilet in the restroom:
POST http://localhost:8535/toilets?organizationId=<organizationId>&restroomId=<restroomId>
{
"name": "Toilet#123",
"type": "men",
"token": "password"
}
- Download the
main.inosketch, fill in the:
wifiSSIDandwifiPasswordwith your WiFi credentials.serverAddresswith the address or domain of the server where the API is running (without thehttp://part).serverPortwith the port of the server where the API is running.authorizationHeadermust be in the formatAuthorization: Basic xxxwherexxxis the base64 encoded string oftoiletId:tokenof the toilet you created.
-
Upload the example sketch to the ESP32 device and check the recieved events in the web application. You have to wire up the reed switch, light sensor or any other sensor that will detect the toilet occupancy and implement the logic in the sketch on your own.
-
Now in order to recieve real time updates of the toilets in the organization as an employee, you need to authenticate in the organization:
POST http://localhost:8535/employee-access/sign-in
{
"organizationId": "<organizationId>",
"password": "password"
}
-
With obtained JWT token, you can download all current toilets statuses from
http://localhost:8535/employee-access/endpoint. -
Now with the
socket.ioclient, you can listen to the real-time updates of the toilets in the organization, but you have to provide JWT token in theAuthorizationheader, which you received after logging in as an employee. You will join to the socket room with people from the same organization.
const socket = io("http://localhost:8535/employee-access", {
extraHeaders: {
Authorization:
"Bearer xxx",
},
});
socket.on("toilet_occupancy", (message) => {
console.log("Toilet occupany update:", message);
});