esp32-timed-switch/esp32-timed-switch.ino

491 lines
21 KiB
Arduino
Raw Permalink Normal View History

2023-10-28 15:53:13 +00:00
#include "esp_system.h"
#include "sntp.h"
#include "time.h"
#include <WiFi.h>
#include <WiFiUdp.h>
#include <Preferences.h>
#include "scheduler.h"
#include "scheduler_prefs.h"
2024-04-04 16:58:37 +00:00
// #include "wifi_prefs.h"
2023-10-28 15:53:13 +00:00
2023-11-09 19:07:34 +00:00
// --------------------------------------------
2023-10-28 15:53:13 +00:00
// Init const and global objects
2023-11-09 19:07:34 +00:00
// --------------------------------------------
2023-10-28 15:53:13 +00:00
2024-04-04 16:58:37 +00:00
const char* html_app="<html><head><title>ESP32 timed Switch</title><script src=\"https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.8.3/angular.js\"></script><link rel=\"manifest\" href=\"manifest.json\" /><meta charset=\"UTF-8\"></head><body><h1>Scheduler</h1><script>class Schedule {constructor(scheduleArray) {if (scheduleArray && scheduleArray.length === 24) {this.schedule = scheduleArray.slice();} else {this.schedule = new Array(24).fill(0x000);}}loadFromArrayBuffer = function(buffer) {var view = new DataView(buffer);for (var i = 0; i < 24; i++) {this.schedule[i] = view.getUint16(i * 2);}};updateSegment(hour, segment, state) {if (hour < 0 || hour >= 24) {throw new Error('Hour must be between 0 and 23.');}if (segment < 0 || segment >= 12) {throw new Error('Segment must be between 0 and 11.');}const bitPosition = 11 - segment;if (state) {this.schedule[hour] |= (1 << bitPosition);} else {this.schedule[hour] &= ~(1 << bitPosition);}}serializeForDisplay() {return this.schedule.map(hour => {if (hour === 0xFFF) {return { displayValue: ' ', class: 'on' };} else if (hour === 0x00) {return { displayValue: ' ', class: 'off' };} else {return { displayValue: ' ', class: 'partial' };}});}prepareEditMatrix() {const editMatrix = [];for (let hour = 0; hour < 24; hour++) {const hourSegments = [];for (let segment = 0; segment < 12; segment++) {hourSegments.push({value: (this.schedule[hour] & (1 << segment)) !== 0 ? 1 : 0});}editMatrix.push(hourSegments.reverse());}return editMatrix;}updateFromEditMatrix(editMatrix) {for (let hour = 0; hour < 24; hour++) {let hourValue = 0;for (let segment = 0; segment < 12; segment++) {if (editMatrix[hour][11 - segment].value) {hourValue |= (1 << segment);}}this.schedule[hour] = hourValue;}}serializeToArrayBuffer = function() {var buffer = new ArrayBuffer(24 * 2);var view = new DataView(buffer);for (var i = 0; i < 24; i++) {view.setUint16( i*2, this.schedule[i]);}return buffer;};}var app = angular.module('plugSchedulerApp', []);app.value('api_host', window.location.host);app.factory(\"data\", function(){var sharedData = { api_host: window.location.host};return {getSharedData: function () {return sharedData;}};});app.controller('ApiHostController', ['$scope', 'api_host', 'data', function( $scope, api_host, data) {var ctrl = this;$scope.data = data.getSharedData();window.ctrl = $scope}]);app.controller('PlugScheduleController', ['$scope', '$http', 'data', function( $scope, $http, data) {var ctrl = this;ctrl.editMode = false;$scope.data = data.getSharedData();ctrl.$onInit = function() {ctrl.scheduleObj = new Schedule();ctrl.getSchedule();};ctrl.getSchedule = function() {if (ctrl.plugId === undefined) {return;}var url = `http://${$scope.data.api_host}/api/schedule/${ctrl.plugId}`;$http.get(url, { responseType: 'arraybuffer' }).then(function(response) {ctrl.scheduleObj.loadFromArrayBuffer(response.data);ctrl.displaySchedule = ctrl.scheduleObj.serializeForDisplay();}).catch(function(error) {console.error('Error fetching schedule:', error);});};ctrl.modifySchedule = function() {ctrl.editMode = true;ctrl.editMatrix = ctrl.scheduleObj.prepareEditMatrix();};ctrl.saveSchedule = function() {ctrl.editMode = false;ctrl.scheduleObj.updateFromEditMatrix(ctrl.editMatrix);ctrl.updateSchedule();};ctrl.updateSchedule = function() {var url = `http://${$scope.data.api_host}/api/schedule/${ctrl.plugId}`;var serializedSchedule = ctrl.scheduleObj.serializeToArrayBuffer();$http.post(url, serializedSchedule, {headers: {'Content-Type': 'application/octet-stream'},responseType: 'arraybuffer',transformRequest: []}).then(function(response) {console.log(\"successfully updated\");ctrl.displaySchedule = ctrl.scheduleObj.serializeForDisplay();}, function(error) {alert('Error updating schedule:', error);});};ctrl.checkAll = function(hourIndex) {ctrl.editMatrix[hourIndex].forEach(segment => {segment.value = 1;});};ctrl.uncheckAll = function(hourIndex) {ctrl.editMatrix[hourIndex].forEach(segment => {segment.value = 0;});};ctrl.invertAll = function(hourIndex) {ctrl.editMatrix[hourIndex].forEach(segment => {var inverted = Math.abs( segment.
2023-12-07 18:52:59 +00:00
// PREFERENCES
2023-10-28 15:53:13 +00:00
Preferences preferences;
#define RW_MODE false
#define RO_MODE true
2023-11-02 22:27:48 +00:00
// WIFI
2024-01-18 18:32:12 +00:00
// const char* ssid = "Wokwi-GUEST";
// const char* password = "";
2023-10-28 17:06:10 +00:00
const uint8_t wifi_loop_max = 10;
2023-10-28 15:53:13 +00:00
// NTP
bool sntp_initialized = false;
const char* ntpServer1 = "pool.ntp.org";
const char* ntpServer2 = "time.nist.gov";
const long gmtOffset_sec = 2 * 3600; // GMT + 2
const int daylightOffset_sec = 0;
2023-11-02 22:27:48 +00:00
// TIMER
2023-10-28 15:53:13 +00:00
hw_timer_t*timer_main = NULL;
uint32_t timer_interval = 3000000;
uint16_t timer_interval_in_secs = timer_interval / 1000000;
;
2023-11-02 22:27:48 +00:00
// SCHEDULER
bool brun_scheduler = true;
2023-10-28 15:53:13 +00:00
uint8_t current_hour = HOUR_DEFAULT;
uint8_t current_minute = MINUTE_DEFAULT;
uint8_t current_second = 0;
uint32_t current_ts = 0;
uint32_t next_event_ts = 0;
2023-11-02 22:27:48 +00:00
int scheduler_1[24] ; // = {A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60,A60};
int scheduler_2[24] ; // = {A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00};
2024-01-18 18:32:12 +00:00
int scheduler_3[24] ; // = {A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00};
int scheduler_4[24] ; // = {A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00};
int scheduler_5[24] ; // = {A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00};
int scheduler_6[24] ; // = {A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00};
int scheduler_7[24] ; // = {A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00};
int scheduler_8[24] ; // = {A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00,A00};
2023-11-02 22:27:48 +00:00
int* scheduler_list[] = {
2023-10-28 15:53:13 +00:00
scheduler_1,
2024-01-18 18:32:12 +00:00
scheduler_2,
scheduler_3,
scheduler_4,
scheduler_5,
scheduler_6,
scheduler_7,
scheduler_8,
2023-10-28 15:53:13 +00:00
};
2023-11-02 22:27:48 +00:00
// PINS
unsigned int PIN_1 = 12;
unsigned int PIN_2 = 14;
unsigned int PIN_3 = 27;
unsigned int PIN_4 = 26;
unsigned int PIN_5 = 20;
unsigned int PIN_6 = 33;
unsigned int PIN_7 = 32;
unsigned int PIN_8 = 35;
2024-01-27 18:15:53 +00:00
unsigned int pin_list[8] = {
2023-10-28 15:53:13 +00:00
PIN_1,
2024-01-18 18:32:12 +00:00
PIN_2,
PIN_3,
PIN_4,
PIN_5,
PIN_6,
PIN_7,
PIN_8
2023-10-28 15:53:13 +00:00
};
2023-11-02 22:27:48 +00:00
// HTTP
2023-12-07 18:52:59 +00:00
WiFiClient client;
2023-11-09 19:07:34 +00:00
WiFiServer http_server(3000);
2023-11-02 22:27:48 +00:00
String request;
2023-11-09 19:07:34 +00:00
// --------------------------------------------
2023-10-28 15:53:13 +00:00
// Local functions
2023-11-09 19:07:34 +00:00
// --------------------------------------------
2023-10-28 15:53:13 +00:00
// Time helper
uint32_t get_timestamp( uint8_t hour, uint8_t minute, uint8_t second){
return ( 3600 * hour + 60 * minute + second) % 86400;
}
2023-11-02 22:27:48 +00:00
bool event_keep_waiting( uint32_t current_ts, uint32_t event_ts ){
2023-10-28 15:53:13 +00:00
2023-11-02 22:27:48 +00:00
// basic case
// ts: 11h 41m 11s
// ev: 11h 44m 0s
// ts < ev => TRUE
2023-10-28 15:53:13 +00:00
if ( current_ts < event_ts ){
2023-11-02 22:27:48 +00:00
return true;
2023-10-28 15:53:13 +00:00
}
2023-11-02 22:27:48 +00:00
// if time looped at midnight
// ts: 23h 57m 21s
// ev: 0h 1m 0s
// ts > ev => TRUE (for high to very low values )
2023-10-28 15:53:13 +00:00
if( (current_ts - event_ts) > 600 && event_ts < 300 ) {
2023-11-02 22:27:48 +00:00
return true;
2023-10-28 15:53:13 +00:00
}
2023-11-02 22:27:48 +00:00
// ts: 11h 44m 11s
// ev: 11h 44m 0s
// ts > ev => FALSE
return false;
2023-10-28 15:53:13 +00:00
}
// NTP Callback
void timeavailable(struct timeval *t)
{
Serial.println("NTP::Got time adjustment from NTP!");
sntp_initialized = true;
return;
}
// TIMER Callback
void IRAM_ATTR onTimer(){
2023-11-02 22:27:48 +00:00
brun_scheduler = true;
2023-10-28 17:06:10 +00:00
}
2023-11-02 20:12:18 +00:00
2023-11-02 22:27:48 +00:00
void run_scheduler(){
// Serial.println("onTimer::run");
2023-10-28 15:53:13 +00:00
// Get the current time via NTP, or downgrade
if ( sntp_initialized ){
struct tm timeinfo;
time_t now;
time(&now);
localtime_r(&now, &timeinfo);
current_hour = timeinfo.tm_hour;
current_minute = timeinfo.tm_min;
current_second = timeinfo.tm_sec;
2023-10-28 17:06:10 +00:00
2023-10-28 15:53:13 +00:00
// If no NTP clock
}else{
2023-10-28 17:06:10 +00:00
// Serial.println("onTimer::NO NTP");
2023-10-28 15:53:13 +00:00
current_second += timer_interval_in_secs;
if(current_second >= 60) {
current_second = 0;
current_minute += 1;
if(current_minute >= 60) {
current_minute = 0;
current_hour += 1;
if(current_hour >= 24) {
current_hour = 0;
}
}
}
2023-11-02 22:27:48 +00:00
}
2023-10-28 15:53:13 +00:00
// If not expected to run exit
current_ts = get_timestamp( current_hour, current_minute, current_second );
2024-01-18 18:32:12 +00:00
// Serial.printf("onTimer::check event %d %d\n", current_ts, next_event_ts);
2023-11-02 22:27:48 +00:00
if( event_keep_waiting( current_ts, next_event_ts ) ){
2023-10-28 15:53:13 +00:00
return;
}
// Set the next target
next_event_ts = get_timestamp( current_hour, current_minute + EVENT_INC_MINUTE, current_second );
Serial.println("Reconfigure the Relays!");
// Run the relays reconfiguration
2024-02-01 21:55:41 +00:00
for ( int i = 0; i < 8; i++ ) {
2023-10-28 15:53:13 +00:00
// Get a pointer to the current array
2023-11-02 22:27:48 +00:00
int* scheduler = scheduler_list[i];
2023-10-28 15:53:13 +00:00
unsigned int pin = pin_list[i];
// Set the expected status
uint8_t minutes_by_5 = (current_minute / 5);
2023-11-02 22:27:48 +00:00
int hourly_12_values = scheduler[current_hour];
2023-10-28 15:53:13 +00:00
// Serial.printf("Check hour(%d) >> minutes(%d x 5)\n", hourly_12_values, minutes_by_5);
char buffer[40];
if (( hourly_12_values >> minutes_by_5 ) & 1) {
digitalWrite(pin, HIGH);
sprintf (buffer, "Pin %d is up ", pin);
} else {
digitalWrite(pin, LOW);
sprintf (buffer, "Pin %d is down ", pin);
}
Serial.println(buffer); // Get the expected status
}
Serial.println("Reconfiguration over");
return;
}
2023-11-09 19:07:34 +00:00
// HTTP
2024-02-01 21:55:41 +00:00
const char* getPreferenceName( int plug_id){
switch (plug_id) {
case 0:
return RELAY_1_SCHEDULE;
break;
case 1:
return RELAY_2_SCHEDULE;
break;
case 2:
return RELAY_3_SCHEDULE;
break;
case 3:
return RELAY_4_SCHEDULE;
break;
case 4:
return RELAY_5_SCHEDULE;
break;
case 5:
return RELAY_6_SCHEDULE;
break;
case 6:
return RELAY_7_SCHEDULE;
break;
case 7:
return RELAY_8_SCHEDULE;
break;
}
2023-11-09 19:07:34 +00:00
}
2024-04-04 16:58:37 +00:00
void saveSchedule( int plug_id, uint16_t data[24]){
2024-02-01 21:55:41 +00:00
const char* preference_name = getPreferenceName( plug_id );
2024-04-04 16:58:37 +00:00
preferences.putBytes(preference_name, data, 48);
Serial.print("saving size:");
Serial.print(sizeof(data));
Serial.print(" to ");
2024-02-03 15:07:29 +00:00
Serial.println(preference_name);
2024-04-04 16:58:37 +00:00
uint16_t buf[24];
preferences.getBytes(preference_name, buf, 48);
for ( int iterator=0; iterator < 24; iterator++){
Serial.print(iterator);
Serial.print(" : ");
Serial.print(data[iterator]);
Serial.print(" / ");
Serial.println(buf[iterator]);
}
delay(2000);
2024-02-01 21:55:41 +00:00
}
2023-11-09 19:07:34 +00:00
2024-02-03 15:07:29 +00:00
void sendSchedule(WiFiClient &client, int plug_id) {
2024-04-04 16:58:37 +00:00
uint16_t buf[24];
2024-02-03 15:07:29 +00:00
const char* preference_name = getPreferenceName( plug_id );
2024-04-04 16:58:37 +00:00
Serial.print("sending ");
Serial.println(preference_name);
preferences.getBytes(preference_name, buf, 48);
for ( int iterator=0; iterator < 24; iterator++){
Serial.print(iterator);
Serial.print(" : ");
Serial.println(buf[iterator]);
}
Serial.println("---------------------------");
client.write((const uint8_t*)buf, 24 * sizeof(uint16_t));
2023-11-09 19:07:34 +00:00
}
// --------------------------------------------
// ARDUINO Functions
// --------------------------------------------
2023-10-28 15:53:13 +00:00
void setup(){
// HARDWARE
Serial.begin(115200);
delay(1000);
Serial.println("Starting.");
pinMode(PIN_1, OUTPUT);
pinMode(PIN_2, OUTPUT);
2024-04-04 16:58:37 +00:00
pinMode(PIN_3, OUTPUT);
pinMode(PIN_4, OUTPUT);
pinMode(PIN_5, OUTPUT);
pinMode(PIN_6, OUTPUT);
pinMode(PIN_7, OUTPUT);
pinMode(PIN_8, OUTPUT);
2023-10-28 15:53:13 +00:00
// PREFERENCES
Serial.println("Setup::PREFERENCES");
preferences.begin(PREF_NAMESPACE, RW_MODE);
2024-04-04 16:58:37 +00:00
// preferences.clear();
2023-11-09 19:07:34 +00:00
2023-11-02 22:27:48 +00:00
bool pref_init = preferences.isKey("test");
2024-04-04 16:58:37 +00:00
if (true || pref_init == false) {
2023-11-02 22:27:48 +00:00
Serial.println("preferences not exist");
preferences.putBool("test", true);
2024-02-03 15:07:29 +00:00
saveSchedule(1,scheduler_default_deactivate);
2024-04-04 16:58:37 +00:00
2024-02-03 15:07:29 +00:00
saveSchedule(2,scheduler_default_deactivate);
saveSchedule(3,scheduler_default_deactivate);
saveSchedule(4,scheduler_default_deactivate);
2024-04-04 16:58:37 +00:00
/*
2024-02-03 15:07:29 +00:00
saveSchedule(5,scheduler_default_deactivate);
saveSchedule(6,scheduler_default_deactivate);
saveSchedule(7,scheduler_default_deactivate);
saveSchedule(8,scheduler_default_deactivate);
*/
2023-10-28 15:53:13 +00:00
}
2024-04-04 16:58:37 +00:00
2023-10-28 15:53:13 +00:00
preferences.getBytes(RELAY_1_SCHEDULE, scheduler_1, preferences.getBytesLength(RELAY_1_SCHEDULE));
preferences.getBytes(RELAY_2_SCHEDULE, scheduler_2, preferences.getBytesLength(RELAY_2_SCHEDULE));
2024-01-27 18:15:53 +00:00
preferences.getBytes(RELAY_3_SCHEDULE, scheduler_2, preferences.getBytesLength(RELAY_3_SCHEDULE));
preferences.getBytes(RELAY_4_SCHEDULE, scheduler_2, preferences.getBytesLength(RELAY_4_SCHEDULE));
preferences.getBytes(RELAY_5_SCHEDULE, scheduler_2, preferences.getBytesLength(RELAY_5_SCHEDULE));
preferences.getBytes(RELAY_6_SCHEDULE, scheduler_2, preferences.getBytesLength(RELAY_6_SCHEDULE));
preferences.getBytes(RELAY_7_SCHEDULE, scheduler_2, preferences.getBytesLength(RELAY_7_SCHEDULE));
preferences.getBytes(RELAY_8_SCHEDULE, scheduler_2, preferences.getBytesLength(RELAY_8_SCHEDULE));
2024-04-04 16:58:37 +00:00
2023-10-28 15:53:13 +00:00
preferences.end();
2023-11-02 22:27:48 +00:00
Serial.println("Setup::PREFERENCES::end");
2023-10-28 15:53:13 +00:00
// WIFI
Serial.println("Setup::WIFI");
Serial.printf("Connecting to %s ", ssid);
WiFi.begin(ssid, password);
2023-10-28 17:06:10 +00:00
uint8_t wifi_loop_count = 0;
2023-11-02 22:27:48 +00:00
while (WiFi.status() != WL_CONNECTED or wifi_loop_count < wifi_loop_max ) {
2023-11-09 19:07:34 +00:00
delay(1000);
2023-10-28 17:06:10 +00:00
wifi_loop_count++;
2023-10-28 15:53:13 +00:00
Serial.print(".");
}
2023-11-09 19:07:34 +00:00
2023-10-28 15:53:13 +00:00
// TIMER
Serial.println("Setup::Timer");
timer_main = timerBegin(0, 80, true);
timerAttachInterrupt(timer_main, &onTimer, true);
timerAlarmWrite(timer_main, timer_interval, true);
timerAlarmEnable(timer_main);
// NTP
Serial.println("Setup::NTP");
sntp_set_time_sync_notification_cb(timeavailable);
configTime(gmtOffset_sec, daylightOffset_sec, ntpServer1, ntpServer2);
delay(5000);
// SCHEDULER
Serial.println("Setup::SCHEDULER");
2023-10-28 17:06:10 +00:00
next_event_ts = get_timestamp( HOUR_DEFAULT, MINUTE_DEFAULT, 10 );
2023-10-28 15:53:13 +00:00
// HTTP
Serial.println("Setup::HTTP");
2023-11-09 19:07:34 +00:00
http_server.begin();
2023-11-02 22:27:48 +00:00
Serial.print("Connect to IP Address: ");
Serial.print("http://");
Serial.println(WiFi.localIP());
2023-10-28 15:53:13 +00:00
// Todo
2024-01-18 18:32:12 +00:00
2023-10-28 15:53:13 +00:00
}
2023-11-02 22:27:48 +00:00
2023-10-28 15:53:13 +00:00
void loop(){
2023-11-02 22:27:48 +00:00
if( brun_scheduler == true ){
brun_scheduler = false;
run_scheduler();
2023-10-28 17:06:10 +00:00
}
2023-10-28 15:53:13 +00:00
2023-12-07 18:52:59 +00:00
client = http_server.available();
if (!client) {
2024-01-18 18:32:12 +00:00
// Serial.println("Server not available... skip...");
2023-11-02 22:27:48 +00:00
return;
}
2023-11-09 19:07:34 +00:00
String request = client.readStringUntil('\r');
2024-01-27 18:15:53 +00:00
Serial.print("request: ");
Serial.println(request);
2023-11-02 22:27:48 +00:00
2023-11-09 19:07:34 +00:00
// GET request
if (request.indexOf("GET /api/schedule/") >= 0) {
int startIdIndex = 18;
int endIdIndex = 19;
2024-01-18 18:32:12 +00:00
2024-02-01 21:55:41 +00:00
String plug_idStr = request.substring(startIdIndex, endIdIndex);
int plug_id = plug_idStr.toInt() - 1; // Adjust for 0 index
Serial.print("plug_id " );
Serial.println(plug_id);
if (plug_id >= 0 && plug_id < 8) {
2023-11-09 19:07:34 +00:00
client.println("HTTP/1.1 200 OK");
2024-01-18 18:32:12 +00:00
client.println("Content-Type: text/html");
2023-11-09 19:07:34 +00:00
client.println("Connection: close");
client.println();
2024-02-03 15:07:29 +00:00
sendSchedule(client, plug_id);
2023-11-09 19:07:34 +00:00
} else {
client.println("HTTP/1.1 404 Not Found");
client.println("Connection: close");
client.println();
}
2023-12-07 18:52:59 +00:00
// GET homepage
} else if (request.indexOf("GET /") >= 0) {
client.println("HTTP/1.1 200 OK");
2024-01-18 18:32:12 +00:00
client.println("Content-Type: text/html");
2023-12-07 18:52:59 +00:00
client.println("Connection: close");
client.println();
client.println(html_app);
2024-01-18 18:32:12 +00:00
} else {
2024-01-27 18:15:53 +00:00
2024-01-18 18:32:12 +00:00
// POST request
int slashIndex = request.indexOf("POST /api/schedule/");
if (slashIndex != -1) {
2024-01-27 18:15:53 +00:00
Serial.print("slashIndex: ");
Serial.println(slashIndex);
int nextSlashIndex = slashIndex + 19;
2024-01-18 18:32:12 +00:00
// Extract the plug ID
2024-02-01 21:55:41 +00:00
String plug_idStr = request.substring(nextSlashIndex, nextSlashIndex + 1);
Serial.print("plug_idStr ");
Serial.println(plug_idStr);
int plug_id = plug_idStr.toInt() - 1;
// Force a new line
client.readStringUntil('\n');
2024-01-18 18:32:12 +00:00
// Read the next line which should have the POST body/content
2024-04-04 16:58:37 +00:00
String header ;
while ( header = client.readStringUntil('\n') ){
Serial.print("header: '");
Serial.print(header);
Serial.print(" / ");
Serial.print(header.length());
Serial.println("'");
if( header.length() < 2 ){
Serial.println("parsed headers");
2024-01-27 18:15:53 +00:00
break;
}
}
2024-02-01 21:55:41 +00:00
Serial.println("Done reading. Going for binary.");
2024-04-04 16:58:37 +00:00
char post_body[48];
client.readBytes(post_body, 48);
2024-02-03 15:07:29 +00:00
Serial.print("Read post_body: ");
Serial.println(post_body);
2024-01-18 18:32:12 +00:00
// Update the schedule for the specified plug
2024-02-01 21:55:41 +00:00
if (plug_id >= 0 && plug_id < 8) {
2024-02-03 15:07:29 +00:00
2024-04-04 16:58:37 +00:00
uint16_t byte_value[24];
2024-02-03 15:07:29 +00:00
for (int i=0; i < 24; i++) {
2024-04-04 16:58:37 +00:00
byte_value[i] = (char) post_body[i*2] * 256 + post_body[(i*2)+1];
Serial.print("Byte ");
Serial.print(i);
Serial.print(" : ");
Serial.print(byte_value[i]);
Serial.println("");
2024-02-03 15:07:29 +00:00
}
saveSchedule(plug_id, byte_value );
2024-02-01 21:55:41 +00:00
Serial.println("Schedule updated for plug " + plug_idStr);
2024-01-18 18:32:12 +00:00
} else {
Serial.println("Invalid plug ID");
}
2024-01-27 18:15:53 +00:00
client.println("HTTP/1.1 200 OK");
client.println("Content-Type: text/plain");
client.println("Connection: close");
client.println();
2023-11-02 22:27:48 +00:00
}
}
2023-12-07 18:52:59 +00:00
client.stop();
2023-11-02 22:27:48 +00:00
2023-10-28 15:53:13 +00:00
2023-10-28 17:06:10 +00:00
}