Compare commits
	
		
			49 Commits
		
	
	
		
			v1.5.12-be
			...
			v2.0.0-bet
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| fcd637cc30 | |||
| 587485d0de | |||
| e0cc99e993 | |||
| d9a8388ac7 | |||
| cb77112976 | |||
| 1c0ddb52ba | |||
| 17f03e9472 | |||
| 213b9c099c | |||
| 687e57b77a | |||
| aea11e0c06 | |||
| bd8f4606c6 | |||
| ac91e71c14 | |||
| 0d3503f4f1 | |||
| 1460c6e5f9 | |||
| fef7e5aa4b | |||
| bda8c3dd98 | |||
| 8702469020 | |||
| 2a0f999f3b | |||
| c89adb6256 | |||
| 1f21954703 | |||
| 3e59ce1366 | |||
| 1f880fc8f1 | |||
| 69bf5f90fa | |||
| 382caeaced | |||
| 47bdf022ec | |||
| 02febfa943 | |||
| 257f4df800 | |||
| bff6e72219 | |||
| 26e905050d | |||
| 046f770a52 | |||
| 2587227e78 | |||
| 0f19dc4f46 | |||
| 721dac1ead | |||
| 08abd1a37f | |||
| da78861613 | |||
| 9231a303f3 | |||
| d12e766cd7 | |||
| af7bc23703 | |||
| de39892f64 | |||
| 40cb835e51 | |||
| eb9d9e74f4 | |||
| d8af3f45e5 | |||
| 96bb8f9c7c | |||
| b8b6893cd0 | |||
| 0a246c1fe4 | |||
| 965ea5da1e | |||
| b8b6f637f2 | |||
| 12044b657b | |||
| 95433b4842 | 
							
								
								
									
										111
									
								
								CHANGELOG.md
									
									
									
									
									
								
							
							
						
						
									
										111
									
								
								CHANGELOG.md
									
									
									
									
									
								
							| @@ -1,5 +1,116 @@ | |||||||
| # Changelog | # Changelog | ||||||
|  |  | ||||||
|  | ## [2.0.0-beta1] - 2025-08-29 | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v2.0.0-beta1 | ||||||
|  | - update version to 2.0.0 in platformio.ini | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta18] - 2025-08-29 | ||||||
|  | ### Added | ||||||
|  | - add display delay for vendor, filament, and spool creation processes | ||||||
|  |  | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta18 | ||||||
|  |  | ||||||
|  | ### Fixed | ||||||
|  | - replace progress bar with message display for remaining weight in sendToApi function | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta17] - 2025-08-29 | ||||||
|  | ### Added | ||||||
|  | - add progress bar updates for vendor and filament creation processes | ||||||
|  |  | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta17 | ||||||
|  | - optimize page limit detection and remove redundant verification code | ||||||
|  |  | ||||||
|  | ### Fixed | ||||||
|  | - update vendor check to use shorthand key in payload | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta16] - 2025-08-29 | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta16 | ||||||
|  | - Refactor NFC interface handling and improve error diagnostics | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta15] - 2025-08-29 | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta15 | ||||||
|  | - enhance NFC write operation diagnostics and improve error handling | ||||||
|  | - enhance NFC write operation handling and prevent tag operations during write | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta14] - 2025-08-29 | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta14 | ||||||
|  | - optimize JSON payload structure and enhance NFC tag validation process | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta13] - 2025-08-29 | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta13 | ||||||
|  | - reorganize clearUserDataArea function for improved clarity and safety | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta12] - 2025-08-29 | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta12 | ||||||
|  |  | ||||||
|  | ### Fixed | ||||||
|  | - reset NFC state on API send failure to allow retry | ||||||
|  | - update createdFilamentId reset value to 65535 for better task handling | ||||||
|  | - update createdVendorId reset value to 65535 for improved API handling | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta11] - 2025-08-29 | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta11 | ||||||
|  |  | ||||||
|  | ### Fixed | ||||||
|  | - update spoolman ID reset values to 65535 for better API response detection | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta10] - 2025-08-29 | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta10 | ||||||
|  | - streamline task creation in checkVendor and checkFilament functions | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta9] - 2025-08-29 | ||||||
|  | ### Added | ||||||
|  | - update vendor and filament ID handling to use NULL and add delays for stability | ||||||
|  |  | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta9 | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta8] - 2025-08-29 | ||||||
|  | ### Added | ||||||
|  | - add delay to ensure proper setting of vendor and filament IDs after API state changes | ||||||
|  |  | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta8 | ||||||
|  |  | ||||||
|  | ### Fixed | ||||||
|  | - correct color_hex key usage and comment out unused date fields in spool creation | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta7] - 2025-08-29 | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta7 | ||||||
|  |  | ||||||
|  | ### Fixed | ||||||
|  | - improve API state handling and vendor name formatting | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## [1.5.12-beta6] - 2025-08-29 | ||||||
|  | ### Changed | ||||||
|  | - update platformio.ini for beta version v1.5.12-beta6 | ||||||
|  | - improve task synchronization in vendor, filament, and spool creation functions | ||||||
|  |  | ||||||
|  |  | ||||||
| ## [1.5.12-beta5] - 2025-08-29 | ## [1.5.12-beta5] - 2025-08-29 | ||||||
| ### Added | ### Added | ||||||
| - enhance NDEF decoding with detailed validation and debugging output | - enhance NDEF decoding with detailed validation and debugging output | ||||||
|   | |||||||
| @@ -9,8 +9,8 @@ | |||||||
| ; https://docs.platformio.org/page/projectconf.html | ; https://docs.platformio.org/page/projectconf.html | ||||||
|  |  | ||||||
| [common] | [common] | ||||||
| version = "1.5.12-beta5" | version = "2.0.0-beta1" | ||||||
| to_old_version = "1.5.0" | to_old_version = "2.0.0" | ||||||
|  |  | ||||||
| ## | ## | ||||||
| [env:esp32dev] | [env:esp32dev] | ||||||
|   | |||||||
							
								
								
									
										285
									
								
								src/api.cpp
									
									
									
									
									
								
							
							
						
						
									
										285
									
								
								src/api.cpp
									
									
									
									
									
								
							| @@ -5,21 +5,10 @@ | |||||||
| #include <Preferences.h> | #include <Preferences.h> | ||||||
| #include "debug.h" | #include "debug.h" | ||||||
| #include "scale.h" | #include "scale.h" | ||||||
|  | #include "nfc.h" | ||||||
| #include <time.h> | #include <time.h> | ||||||
| volatile spoolmanApiStateType spoolmanApiState = API_IDLE; | volatile spoolmanApiStateType spoolmanApiState = API_IDLE; | ||||||
|  |  | ||||||
| // Returns current date and time in ISO8601 format |  | ||||||
| String getCurrentDateISO8601() { |  | ||||||
|     struct tm timeinfo; |  | ||||||
|     if(!getLocalTime(&timeinfo)) { |  | ||||||
|         Serial.println("Failed to obtain time"); |  | ||||||
|         return "1970-01-01T00:00:00Z"; |  | ||||||
|     } |  | ||||||
|     char timeStringBuff[25]; |  | ||||||
|     strftime(timeStringBuff, sizeof(timeStringBuff), "%Y-%m-%dT%H:%M:%SZ", &timeinfo); |  | ||||||
|     return String(timeStringBuff); |  | ||||||
| } |  | ||||||
|  |  | ||||||
| //bool spoolman_connected = false; | //bool spoolman_connected = false; | ||||||
| String spoolmanUrl = ""; | String spoolmanUrl = ""; | ||||||
| bool octoEnabled = false; | bool octoEnabled = false; | ||||||
| @@ -121,7 +110,7 @@ void sendToApi(void *parameter) { | |||||||
|  |  | ||||||
|     // Wait until API is IDLE |     // Wait until API is IDLE | ||||||
|     while(spoolmanApiState != API_IDLE){ |     while(spoolmanApiState != API_IDLE){ | ||||||
|         Serial.println("Waiting!"); |         vTaskDelay(100 / portTICK_PERIOD_MS); | ||||||
|         yield(); |         yield(); | ||||||
|     } |     } | ||||||
|     spoolmanApiState = API_TRANSMITTING; |     spoolmanApiState = API_TRANSMITTING; | ||||||
| @@ -151,7 +140,7 @@ void sendToApi(void *parameter) { | |||||||
|     else httpCode = http.PUT(updatePayload); |     else httpCode = http.PUT(updatePayload); | ||||||
|  |  | ||||||
|     if (httpCode == HTTP_CODE_OK) { |     if (httpCode == HTTP_CODE_OK) { | ||||||
|         Serial.println("Spoolman erfolgreich aktualisiert"); |         Serial.println("Spoolman Abfrage erfolgreich"); | ||||||
|  |  | ||||||
|         // Restgewicht der Spule auslesen |         // Restgewicht der Spule auslesen | ||||||
|         String payload = http.getString(); |         String payload = http.getString(); | ||||||
| @@ -169,7 +158,8 @@ void sendToApi(void *parameter) { | |||||||
|                 //oledShowMessage("Remaining: " + String(remaining_weight) + "g"); |                 //oledShowMessage("Remaining: " + String(remaining_weight) + "g"); | ||||||
|                 if(!octoEnabled){ |                 if(!octoEnabled){ | ||||||
|                     // TBD: Do not use Strings... |                     // TBD: Do not use Strings... | ||||||
|                     oledShowProgressBar(1, 1, "Spool Tag", ("Done: " + String(remainingWeight) + " g remain").c_str()); |                     //oledShowProgressBar(1, 1, "Spool Tag", ("Done: " + String(remainingWeight) + " g remain").c_str()); | ||||||
|  |                     oledShowMessage("Remaining: " + String(remainingWeight) + "g"); | ||||||
|                     remainingWeight = 0; |                     remainingWeight = 0; | ||||||
|                 }else{ |                 }else{ | ||||||
|                     // ocoto is enabled, trigger octo update |                     // ocoto is enabled, trigger octo update | ||||||
| @@ -184,7 +174,8 @@ void sendToApi(void *parameter) { | |||||||
|                 break; |                 break; | ||||||
|             case API_REQUEST_OCTO_SPOOL_UPDATE: |             case API_REQUEST_OCTO_SPOOL_UPDATE: | ||||||
|                 // TBD: Do not use Strings... |                 // TBD: Do not use Strings... | ||||||
|                 oledShowProgressBar(5, 5, "Spool Tag", ("Done: " + String(remainingWeight) + " g remain").c_str()); |                 //oledShowProgressBar(5, 5, "Spool Tag", ("Done: " + String(remainingWeight) + " g remain").c_str()); | ||||||
|  |                 oledShowMessage("Remaining: " + String(remainingWeight) + "g"); | ||||||
|                 remainingWeight = 0; |                 remainingWeight = 0; | ||||||
|                 break; |                 break; | ||||||
|             case API_REQUEST_VENDOR_CREATE: |             case API_REQUEST_VENDOR_CREATE: | ||||||
| @@ -345,9 +336,8 @@ void sendToApi(void *parameter) { | |||||||
|             break; |             break; | ||||||
|         } |         } | ||||||
|         Serial.println("Fehler beim Senden an Spoolman! HTTP Code: " + String(httpCode)); |         Serial.println("Fehler beim Senden an Spoolman! HTTP Code: " + String(httpCode)); | ||||||
|  |  | ||||||
|         // TBD: really required? |  | ||||||
|         vTaskDelay(2000 / portTICK_PERIOD_MS); |         vTaskDelay(2000 / portTICK_PERIOD_MS); | ||||||
|  |         nfcReaderState = NFC_IDLE; // Reset NFC state to allow retry | ||||||
|     } |     } | ||||||
|  |  | ||||||
|     http.end(); |     http.end(); | ||||||
| @@ -614,9 +604,12 @@ bool updateSpoolBambuData(String payload) { | |||||||
|  |  | ||||||
| // #### Brand Filament | // #### Brand Filament | ||||||
| uint16_t createVendor(String vendor) { | uint16_t createVendor(String vendor) { | ||||||
|  |     oledShowProgressBar(2, 5, "New Brand", "Create new Vendor"); | ||||||
|  |  | ||||||
|     // Create new vendor in Spoolman database using task system |     // Create new vendor in Spoolman database using task system | ||||||
|     // Note: Due to async nature, the ID will be stored in createdVendorId global variable |     // Note: Due to async nature, the ID will be stored in createdVendorId global variable | ||||||
|     createdVendorId = 0; // Reset previous value |     // Note: This function assumes that the caller has already ensured API is IDLE | ||||||
|  |     createdVendorId = 65535; // Reset previous value | ||||||
|      |      | ||||||
|     String spoolsUrl = spoolmanUrl + apiUrl + "/vendor"; |     String spoolsUrl = spoolmanUrl + apiUrl + "/vendor"; | ||||||
|     Serial.print("Create vendor with URL: "); |     Serial.print("Create vendor with URL: "); | ||||||
| @@ -626,7 +619,6 @@ uint16_t createVendor(String vendor) { | |||||||
|     JsonDocument vendorDoc; |     JsonDocument vendorDoc; | ||||||
|     vendorDoc["name"] = vendor; |     vendorDoc["name"] = vendor; | ||||||
|     vendorDoc["comment"] = "automatically generated"; |     vendorDoc["comment"] = "automatically generated"; | ||||||
|     vendorDoc["empty_spool_weight"] = 180; |  | ||||||
|     vendorDoc["external_id"] = vendor; |     vendorDoc["external_id"] = vendor; | ||||||
|  |  | ||||||
|     String vendorPayload; |     String vendorPayload; | ||||||
| @@ -645,19 +637,18 @@ uint16_t createVendor(String vendor) { | |||||||
|     params->spoolsUrl = spoolsUrl; |     params->spoolsUrl = spoolsUrl; | ||||||
|     params->updatePayload = vendorPayload; |     params->updatePayload = vendorPayload; | ||||||
|  |  | ||||||
|     // Check if API is idle before creating task |     // Create task without additional API state check since caller ensures synchronization | ||||||
|     if(spoolmanApiState == API_IDLE){ |     BaseType_t result = xTaskCreate( | ||||||
|         // Erstelle die Task |         sendToApi,                // Task-Funktion | ||||||
|         BaseType_t result = xTaskCreate( |         "SendToApiTask",          // Task-Name | ||||||
|             sendToApi,                // Task-Funktion |         6144,                     // Stackgröße in Bytes | ||||||
|             "SendToApiTask",          // Task-Name |         (void*)params,            // Parameter | ||||||
|             6144,                     // Stackgröße in Bytes |         0,                        // Priorität | ||||||
|             (void*)params,            // Parameter |         NULL                      // Task-Handle (nicht benötigt) | ||||||
|             0,                        // Priorität |     ); | ||||||
|             NULL                      // Task-Handle (nicht benötigt) |  | ||||||
|         ); |     if (result != pdPASS) { | ||||||
|     } else { |         Serial.println("Failed to create vendor task!"); | ||||||
|         Serial.println("Not spawning new task, API still active!"); |  | ||||||
|         delete params; |         delete params; | ||||||
|         vendorDoc.clear(); |         vendorDoc.clear(); | ||||||
|         return 0; |         return 0; | ||||||
| @@ -665,20 +656,28 @@ uint16_t createVendor(String vendor) { | |||||||
|  |  | ||||||
|     vendorDoc.clear(); |     vendorDoc.clear(); | ||||||
|      |      | ||||||
|  |     // Delay for Display Bar | ||||||
|  |     vTaskDelay(1000 / portTICK_PERIOD_MS); | ||||||
|  |  | ||||||
|     // Wait for task completion and return the created vendor ID |     // Wait for task completion and return the created vendor ID | ||||||
|     // Note: createdVendorId will be set by sendToApi when response is received |     // Note: createdVendorId will be set by sendToApi when response is received | ||||||
|     while(spoolmanApiState != API_IDLE) { |     while(createdVendorId == 65535) { | ||||||
|         vTaskDelay(100 / portTICK_PERIOD_MS); |         vTaskDelay(50 / portTICK_PERIOD_MS); | ||||||
|     } |     } | ||||||
|      |      | ||||||
|     return createdVendorId; |     return createdVendorId; | ||||||
| } | } | ||||||
|  |  | ||||||
| uint16_t checkVendor(String vendor) { | uint16_t checkVendor(String vendor) { | ||||||
|  |     oledShowProgressBar(1, 5, "New Brand", "Check Vendor"); | ||||||
|  |  | ||||||
|     // Check if vendor exists using task system |     // Check if vendor exists using task system | ||||||
|     foundVendorId = 0; // Reset previous value |     foundVendorId = 65535; // Reset to invalid value to detect when API response is received | ||||||
|      |      | ||||||
|     String spoolsUrl = spoolmanUrl + apiUrl + "/vendor?name=" + vendor; |     String vendorName = vendor; | ||||||
|  |     vendorName.trim(); | ||||||
|  |     vendorName.replace(" ", "+"); | ||||||
|  |     String spoolsUrl = spoolmanUrl + apiUrl + "/vendor?name=" + vendorName; | ||||||
|     Serial.print("Check vendor with URL: "); |     Serial.print("Check vendor with URL: "); | ||||||
|     Serial.println(spoolsUrl); |     Serial.println(spoolsUrl); | ||||||
|  |  | ||||||
| @@ -693,25 +692,25 @@ uint16_t checkVendor(String vendor) { | |||||||
|     params->updatePayload = ""; // Empty for GET request |     params->updatePayload = ""; // Empty for GET request | ||||||
|  |  | ||||||
|     // Check if API is idle before creating task |     // Check if API is idle before creating task | ||||||
|     if(spoolmanApiState == API_IDLE){ |     while (spoolmanApiState != API_IDLE) | ||||||
|         // Erstelle die Task |     { | ||||||
|         BaseType_t result = xTaskCreate( |         vTaskDelay(100 / portTICK_PERIOD_MS); | ||||||
|             sendToApi,                // Task-Funktion |  | ||||||
|             "SendToApiTask",          // Task-Name |  | ||||||
|             6144,                     // Stackgröße in Bytes |  | ||||||
|             (void*)params,            // Parameter |  | ||||||
|             0,                        // Priorität |  | ||||||
|             NULL                      // Task-Handle (nicht benötigt) |  | ||||||
|         ); |  | ||||||
|     } else { |  | ||||||
|         Serial.println("Not spawning new task, API still active!"); |  | ||||||
|         delete params; |  | ||||||
|         return 0; |  | ||||||
|     } |     } | ||||||
|      |      | ||||||
|     // Wait for task completion |     // Erstelle die Task | ||||||
|     while(spoolmanApiState != API_IDLE) { |     BaseType_t result = xTaskCreate( | ||||||
|         vTaskDelay(100 / portTICK_PERIOD_MS); |         sendToApi,                // Task-Funktion | ||||||
|  |         "SendToApiTask",          // Task-Name | ||||||
|  |         6144,                     // Stackgröße in Bytes | ||||||
|  |         (void*)params,            // Parameter | ||||||
|  |         0,                        // Priorität | ||||||
|  |         NULL                      // Task-Handle (nicht benötigt) | ||||||
|  |     ); | ||||||
|  |      | ||||||
|  |     // Wait until foundVendorId is updated by the API response (not 65535 anymore) | ||||||
|  |     while (foundVendorId == 65535) | ||||||
|  |     { | ||||||
|  |         vTaskDelay(50 / portTICK_PERIOD_MS); | ||||||
|     } |     } | ||||||
|  |  | ||||||
|     // Check if vendor was found |     // Check if vendor was found | ||||||
| @@ -734,9 +733,12 @@ uint16_t checkVendor(String vendor) { | |||||||
| } | } | ||||||
|  |  | ||||||
| uint16_t createFilament(uint16_t vendorId, const JsonDocument& payload) { | uint16_t createFilament(uint16_t vendorId, const JsonDocument& payload) { | ||||||
|  |     oledShowProgressBar(4, 5, "New Brand", "Create Filament"); | ||||||
|  |  | ||||||
|     // Create new filament in Spoolman database using task system |     // Create new filament in Spoolman database using task system | ||||||
|     // Note: Due to async nature, the ID will be stored in createdFilamentId global variable |     // Note: Due to async nature, the ID will be stored in createdFilamentId global variable | ||||||
|     createdFilamentId = 0; // Reset previous value |     // Note: This function assumes that the caller has already ensured API is IDLE | ||||||
|  |     createdFilamentId = 65535; // Reset previous value | ||||||
|      |      | ||||||
|     String spoolsUrl = spoolmanUrl + apiUrl + "/filament"; |     String spoolsUrl = spoolmanUrl + apiUrl + "/filament"; | ||||||
|     Serial.print("Create filament with URL: "); |     Serial.print("Create filament with URL: "); | ||||||
| @@ -744,34 +746,34 @@ uint16_t createFilament(uint16_t vendorId, const JsonDocument& payload) { | |||||||
|  |  | ||||||
|     // Create JSON payload for filament creation |     // Create JSON payload for filament creation | ||||||
|     JsonDocument filamentDoc; |     JsonDocument filamentDoc; | ||||||
|     filamentDoc["name"] = payload["name"].as<String>(); |     filamentDoc["name"] = payload["cn"].as<String>(); | ||||||
|     filamentDoc["vendor_id"] = String(vendorId); |     filamentDoc["vendor_id"] = String(vendorId); | ||||||
|     filamentDoc["material"] = payload["type"].as<String>(); |     filamentDoc["material"] = payload["t"].as<String>(); | ||||||
|     filamentDoc["density"] = (payload["density"].is<String>() && payload["density"].as<String>().length() > 0) ? payload["density"].as<String>() : "1.24"; |     filamentDoc["density"] = (payload["de"].is<String>() && payload["de"].as<String>().length() > 0) ? payload["de"].as<String>() : "1.24"; | ||||||
|     filamentDoc["diameter"] = (payload["diameter"].is<String>() && payload["diameter"].as<String>().length() > 0) ? payload["diameter"].as<String>() : "1.75"; |     filamentDoc["diameter"] = (payload["di"].is<String>() && payload["di"].as<String>().length() > 0) ? payload["di"].as<String>() : "1.75"; | ||||||
|     filamentDoc["weight"] = payload["weight"].as<String>(); |     filamentDoc["weight"] = String(weight); | ||||||
|     filamentDoc["spool_weight"] = payload["spool_weight"].as<String>(); |     filamentDoc["spool_weight"] = payload["sw"].as<String>(); | ||||||
|     filamentDoc["article_number"] = payload["artnr"].as<String>(); |     filamentDoc["article_number"] = payload["an"].as<String>(); | ||||||
|     filamentDoc["extruder_temp"] = payload["extruder_temp"].is<String>() ? payload["extruder_temp"].as<String>() : ""; |     filamentDoc["settings_extruder_temp"] = payload["et"].is<String>() ? payload["et"].as<String>() : ""; | ||||||
|     filamentDoc["bed_temp"] = payload["bed_temp"].is<String>() ? payload["bed_temp"].as<String>() : ""; |     filamentDoc["settings_bed_temp"] = payload["bt"].is<String>() ? payload["bt"].as<String>() : ""; | ||||||
|      |  | ||||||
|     if (payload["artnr"].is<String>()) |     if (payload["an"].is<String>()) | ||||||
|     { |     { | ||||||
|         filamentDoc["external_id"] = payload["artnr"].as<String>(); |         filamentDoc["external_id"] = payload["an"].as<String>(); | ||||||
|         filamentDoc["comment"] = payload["url"].is<String>() ? payload["url"].as<String>() + payload["artnr"].as<String>() : "automatically generated"; |         filamentDoc["comment"] = payload["u"].is<String>() ? payload["u"].as<String>() + payload["an"].as<String>() : "automatically generated"; | ||||||
|     } |     } | ||||||
|     else |     else | ||||||
|     { |     { | ||||||
|         filamentDoc["comment"] = payload["url"].is<String>() ? payload["url"].as<String>() : "automatically generated"; |         filamentDoc["comment"] = payload["u"].is<String>() ? payload["u"].as<String>() : "automatically generated"; | ||||||
|     } |     } | ||||||
|  |  | ||||||
|     if (payload["multi_color_hexes"].is<String>()) { |     if (payload["mc"].is<String>()) { | ||||||
|         filamentDoc["multi_color_hexes"] = payload["multi_color_hexes"].as<String>(); |         filamentDoc["multi_color_hexes"] = payload["mc"].as<String>(); | ||||||
|         filamentDoc["multi_color_direction"] = payload["multi_color_direction"].is<String>() ? payload["multi_color_direction"].as<String>() : ""; |         filamentDoc["multi_color_direction"] = payload["mcd"].is<String>() ? payload["mcd"].as<String>() : ""; | ||||||
|     } |     } | ||||||
|     else |     else | ||||||
|     { |     { | ||||||
|         filamentDoc["color_hex"] = (payload["color"].is<String>() && payload["color"].as<String>().length() >= 6) ? payload["color"].as<String>() : "FFFFFF"; |         filamentDoc["color_hex"] = (payload["c"].is<String>() && payload["c"].as<String>().length() >= 6) ? payload["c"].as<String>() : "FFFFFF"; | ||||||
|     } |     } | ||||||
|  |  | ||||||
|     String filamentPayload; |     String filamentPayload; | ||||||
| @@ -790,19 +792,18 @@ uint16_t createFilament(uint16_t vendorId, const JsonDocument& payload) { | |||||||
|     params->spoolsUrl = spoolsUrl; |     params->spoolsUrl = spoolsUrl; | ||||||
|     params->updatePayload = filamentPayload; |     params->updatePayload = filamentPayload; | ||||||
|  |  | ||||||
|     // Check if API is idle before creating task |     // Create task without additional API state check since caller ensures synchronization | ||||||
|     if(spoolmanApiState == API_IDLE){ |     BaseType_t result = xTaskCreate( | ||||||
|         // Erstelle die Task |         sendToApi,                // Task-Funktion | ||||||
|         BaseType_t result = xTaskCreate( |         "SendToApiTask",          // Task-Name | ||||||
|             sendToApi,                // Task-Funktion |         6144,                     // Stackgröße in Bytes | ||||||
|             "SendToApiTask",          // Task-Name |         (void*)params,            // Parameter | ||||||
|             6144,                     // Stackgröße in Bytes |         0,                        // Priorität | ||||||
|             (void*)params,            // Parameter |         NULL                      // Task-Handle (nicht benötigt) | ||||||
|             0,                        // Priorität |     ); | ||||||
|             NULL                      // Task-Handle (nicht benötigt) |  | ||||||
|         ); |     if (result != pdPASS) { | ||||||
|     } else { |         Serial.println("Failed to create filament task!"); | ||||||
|         Serial.println("Not spawning new task, API still active!"); |  | ||||||
|         delete params; |         delete params; | ||||||
|         filamentDoc.clear(); |         filamentDoc.clear(); | ||||||
|         return 0; |         return 0; | ||||||
| @@ -810,18 +811,23 @@ uint16_t createFilament(uint16_t vendorId, const JsonDocument& payload) { | |||||||
|  |  | ||||||
|     filamentDoc.clear(); |     filamentDoc.clear(); | ||||||
|      |      | ||||||
|  |     // Delay for Display Bar | ||||||
|  |     vTaskDelay(1000 / portTICK_PERIOD_MS); | ||||||
|  |  | ||||||
|     // Wait for task completion and return the created filament ID |     // Wait for task completion and return the created filament ID | ||||||
|     // Note: createdFilamentId will be set by sendToApi when response is received |     // Note: createdFilamentId will be set by sendToApi when response is received | ||||||
|     while(spoolmanApiState != API_IDLE) { |     while(createdFilamentId == 65535) { | ||||||
|         vTaskDelay(100 / portTICK_PERIOD_MS); |         vTaskDelay(50 / portTICK_PERIOD_MS); | ||||||
|     } |     } | ||||||
|      |      | ||||||
|     return createdFilamentId; |     return createdFilamentId; | ||||||
| } | } | ||||||
|  |  | ||||||
| uint16_t checkFilament(uint16_t vendorId, const JsonDocument& payload) { | uint16_t checkFilament(uint16_t vendorId, const JsonDocument& payload) { | ||||||
|  |     oledShowProgressBar(3, 5, "New Brand", "Check Filament"); | ||||||
|  |  | ||||||
|     // Check if filament exists using task system |     // Check if filament exists using task system | ||||||
|     foundFilamentId = 0; // Reset previous value |     foundFilamentId = 65535; // Reset to invalid value to detect when API response is received | ||||||
|  |  | ||||||
|     String spoolsUrl = spoolmanUrl + apiUrl + "/filament?vendor.id=" + String(vendorId) + "&external_id=" + String(payload["artnr"].as<String>()); |     String spoolsUrl = spoolmanUrl + apiUrl + "/filament?vendor.id=" + String(vendorId) + "&external_id=" + String(payload["artnr"].as<String>()); | ||||||
|     Serial.print("Check filament with URL: "); |     Serial.print("Check filament with URL: "); | ||||||
| @@ -837,26 +843,19 @@ uint16_t checkFilament(uint16_t vendorId, const JsonDocument& payload) { | |||||||
|     params->spoolsUrl = spoolsUrl; |     params->spoolsUrl = spoolsUrl; | ||||||
|     params->updatePayload = ""; // Empty for GET request |     params->updatePayload = ""; // Empty for GET request | ||||||
|  |  | ||||||
|     // Check if API is idle before creating task |      // Erstelle die Task | ||||||
|     if(spoolmanApiState == API_IDLE){ |     BaseType_t result = xTaskCreate( | ||||||
|         // Erstelle die Task |         sendToApi,                // Task-Funktion | ||||||
|         BaseType_t result = xTaskCreate( |         "SendToApiTask",          // Task-Name | ||||||
|             sendToApi,                // Task-Funktion |         6144,                     // Stackgröße in Bytes | ||||||
|             "SendToApiTask",          // Task-Name |         (void*)params,            // Parameter | ||||||
|             6144,                     // Stackgröße in Bytes |         0,                        // Priorität | ||||||
|             (void*)params,            // Parameter |         NULL                      // Task-Handle (nicht benötigt) | ||||||
|             0,                        // Priorität |     ); | ||||||
|             NULL                      // Task-Handle (nicht benötigt) |  | ||||||
|         ); |  | ||||||
|     } else { |  | ||||||
|         Serial.println("Not spawning new task, API still active!"); |  | ||||||
|         delete params; |  | ||||||
|         return 0; |  | ||||||
|     } |  | ||||||
|      |      | ||||||
|     // Wait for task completion |     // Wait until foundFilamentId is updated by the API response (not 65535 anymore) | ||||||
|     while(spoolmanApiState != API_IDLE) { |     while (foundFilamentId == 65535) { | ||||||
|         vTaskDelay(100 / portTICK_PERIOD_MS); |         vTaskDelay(50 / portTICK_PERIOD_MS); | ||||||
|     } |     } | ||||||
|  |  | ||||||
|     // Check if filament was found |     // Check if filament was found | ||||||
| @@ -879,25 +878,24 @@ uint16_t checkFilament(uint16_t vendorId, const JsonDocument& payload) { | |||||||
| } | } | ||||||
|  |  | ||||||
| uint16_t createSpool(uint16_t vendorId, uint16_t filamentId, JsonDocument& payload, String uidString) { | uint16_t createSpool(uint16_t vendorId, uint16_t filamentId, JsonDocument& payload, String uidString) { | ||||||
|  |     oledShowProgressBar(5, 5, "New Brand", "Create new Spool"); | ||||||
|  |  | ||||||
|     // Create new spool in Spoolman database using task system |     // Create new spool in Spoolman database using task system | ||||||
|     // Note: Due to async nature, the ID will be stored in createdSpoolId global variable |     // Note: Due to async nature, the ID will be stored in createdSpoolId global variable | ||||||
|     createdSpoolId = 0; // Reset previous value |     // Note: This function assumes that the caller has already ensured API is IDLE | ||||||
|  |     createdSpoolId = 65535; // Reset to invalid value to detect when API response is received | ||||||
|      |      | ||||||
|     String spoolsUrl = spoolmanUrl + apiUrl + "/spool"; |     String spoolsUrl = spoolmanUrl + apiUrl + "/spool"; | ||||||
|     Serial.print("Create spool with URL: "); |     Serial.print("Create spool with URL: "); | ||||||
|     Serial.println(spoolsUrl); |     Serial.println(spoolsUrl); | ||||||
|     String currentDate = getCurrentDateISO8601(); |  | ||||||
|  |  | ||||||
|     // Create JSON payload for spool creation |     // Create JSON payload for spool creation | ||||||
|     JsonDocument spoolDoc; |     JsonDocument spoolDoc; | ||||||
|     spoolDoc["first_used"] = String(currentDate); |  | ||||||
|     spoolDoc["last_used"] = String(currentDate); |  | ||||||
|     spoolDoc["filament_id"] = String(filamentId); |     spoolDoc["filament_id"] = String(filamentId); | ||||||
|     spoolDoc["initial_weight"] = weight > 10 ? String(weight) : "1000"; |     spoolDoc["initial_weight"] = weight > 10 ? String(weight - payload["sw"].as<int>()) : "1000"; | ||||||
|     spoolDoc["spool_weight"] = (payload["spool_weight"].is<String>() && payload["spool_weight"].as<String>().length() > 0) ? payload["spool_weight"].as<String>() : "180"; |     spoolDoc["spool_weight"] = (payload["sw"].is<String>() && payload["sw"].as<String>().length() > 0) ? payload["sw"].as<String>() : "180"; | ||||||
|     spoolDoc["remaining_weight"] = (payload["weight"].is<String>() && payload["weight"].as<String>().length() > 0) ? payload["weight"].as<String>() : "1000"; |     spoolDoc["remaining_weight"] = spoolDoc["initial_weight"]; | ||||||
|     spoolDoc["used_weight"] = "0"; |     spoolDoc["lot_nr"] = (payload["an"].is<String>() && payload["an"].as<String>().length() > 0) ? payload["an"].as<String>() : ""; | ||||||
|     spoolDoc["lot_nr"] = (payload["lotnr"].is<String>() && payload["lotnr"].as<String>().length() > 0) ? payload["lotnr"].as<String>() : ""; |  | ||||||
|     spoolDoc["comment"] = "automatically generated"; |     spoolDoc["comment"] = "automatically generated"; | ||||||
|     spoolDoc["extra"]["nfc_id"] = "\"" + uidString + "\""; |     spoolDoc["extra"]["nfc_id"] = "\"" + uidString + "\""; | ||||||
|  |  | ||||||
| @@ -918,42 +916,57 @@ uint16_t createSpool(uint16_t vendorId, uint16_t filamentId, JsonDocument& paylo | |||||||
|     params->spoolsUrl = spoolsUrl; |     params->spoolsUrl = spoolsUrl; | ||||||
|     params->updatePayload = spoolPayload; |     params->updatePayload = spoolPayload; | ||||||
|  |  | ||||||
|     // Check if API is idle before creating task |     // Create task without additional API state check since caller ensures synchronization | ||||||
|     if(spoolmanApiState == API_IDLE){ |     BaseType_t result = xTaskCreate( | ||||||
|         // Erstelle die Task |         sendToApi,                // Task-Funktion | ||||||
|         BaseType_t result = xTaskCreate( |         "SendToApiTask",          // Task-Name | ||||||
|             sendToApi,                // Task-Funktion |         6144,                     // Stackgröße in Bytes | ||||||
|             "SendToApiTask",          // Task-Name |         (void*)params,            // Parameter | ||||||
|             6144,                     // Stackgröße in Bytes |         0,                        // Priorität | ||||||
|             (void*)params,            // Parameter |         NULL                      // Task-Handle (nicht benötigt) | ||||||
|             0,                        // Priorität |     ); | ||||||
|             NULL                      // Task-Handle (nicht benötigt) |  | ||||||
|         ); |     if (result != pdPASS) { | ||||||
|     } else { |         Serial.println("Failed to create spool task!"); | ||||||
|         Serial.println("Not spawning new task, API still active!"); |  | ||||||
|         delete params; |         delete params; | ||||||
|         return 0; |         return 0; | ||||||
|     } |     } | ||||||
|      |      | ||||||
|     // Wait for task completion and return the created spool ID |     // Wait for task completion and return the created spool ID | ||||||
|     // Note: createdSpoolId will be set by sendToApi when response is received |     // Note: createdSpoolId will be set by sendToApi when response is received | ||||||
|     while(spoolmanApiState != API_IDLE) { |     while(createdSpoolId == 65535) { | ||||||
|         vTaskDelay(100 / portTICK_PERIOD_MS); |         vTaskDelay(50 / portTICK_PERIOD_MS); | ||||||
|     } |     } | ||||||
|  |  | ||||||
|     // daten mit startWriteJsonToTag schreiben |     // Write data to tag with startWriteJsonToTag | ||||||
|     // void startWriteJsonToTag(const bool isSpoolTag, const char* payload); |     // void startWriteJsonToTag(const bool isSpoolTag, const char* payload); | ||||||
|     payload["sm_id"].set(String(createdSpoolId)); |      | ||||||
|  |     // Create optimized JSON structure with sm_id at the beginning for fast-path detection | ||||||
|  |     JsonDocument optimizedPayload; | ||||||
|  |     optimizedPayload["sm_id"] = String(createdSpoolId);  // Place sm_id first for fast scanning | ||||||
|  |     optimizedPayload["b"] = payload["b"].as<String>(); | ||||||
|  |     optimizedPayload["cn"] = payload["an"].as<String>(); | ||||||
|      |      | ||||||
|     String payloadString; |     String payloadString; | ||||||
|     serializeJson(payload, payloadString); |     serializeJson(optimizedPayload, payloadString); | ||||||
|  |      | ||||||
|  |     Serial.println("Optimized JSON with sm_id first:"); | ||||||
|  |     Serial.println(payloadString); | ||||||
|  |      | ||||||
|  |     optimizedPayload.clear(); | ||||||
|  |      | ||||||
|  |     nfcReaderState = NFC_IDLE; | ||||||
|  |  | ||||||
|  |     // Delay for Display Bar | ||||||
|  |     vTaskDelay(1000 / portTICK_PERIOD_MS); | ||||||
|  |      | ||||||
|     startWriteJsonToTag(true, payloadString.c_str()); |     startWriteJsonToTag(true, payloadString.c_str()); | ||||||
|  |  | ||||||
|     return createdSpoolId; |     return createdSpoolId; | ||||||
| } | } | ||||||
|  |  | ||||||
| bool createBrandFilament(JsonDocument& payload, String uidString) { | bool createBrandFilament(JsonDocument& payload, String uidString) { | ||||||
|     uint16_t vendorId = checkVendor(payload["brand"].as<String>()); |     uint16_t vendorId = checkVendor(payload["b"].as<String>()); | ||||||
|     if (vendorId == 0) { |     if (vendorId == 0) { | ||||||
|         Serial.println("ERROR: Failed to create/find vendor"); |         Serial.println("ERROR: Failed to create/find vendor"); | ||||||
|         return false; |         return false; | ||||||
|   | |||||||
| @@ -235,7 +235,7 @@ void oledShowIcon(const char* icon) { | |||||||
|     display.display(); |     display.display(); | ||||||
| } | } | ||||||
|  |  | ||||||
| void oledShowProgressBar(const uint8_t step, const uint8_t numSteps, const char* largeText, const char* statusMessage){ | void oledShowProgressBar(const uint8_t step, const uint8_t numSteps, const char* largeText, const char* statusMessage) { | ||||||
|     assert(step <= numSteps); |     assert(step <= numSteps); | ||||||
|  |  | ||||||
|     // clear data and bar area |     // clear data and bar area | ||||||
|   | |||||||
							
								
								
									
										1302
									
								
								src/nfc.cpp
									
									
									
									
									
								
							
							
						
						
									
										1302
									
								
								src/nfc.cpp
									
									
									
									
									
								
							
										
											
												File diff suppressed because it is too large
												Load Diff
											
										
									
								
							| @@ -16,6 +16,7 @@ typedef enum{ | |||||||
| void startNfc(); | void startNfc(); | ||||||
| void scanRfidTask(void * parameter); | void scanRfidTask(void * parameter); | ||||||
| void startWriteJsonToTag(const bool isSpoolTag, const char* payload); | void startWriteJsonToTag(const bool isSpoolTag, const char* payload); | ||||||
|  | bool quickSpoolIdCheck(String uidString); | ||||||
|  |  | ||||||
| extern TaskHandle_t RfidReaderTask; | extern TaskHandle_t RfidReaderTask; | ||||||
| extern String nfcJsonData; | extern String nfcJsonData; | ||||||
| @@ -23,6 +24,7 @@ extern String activeSpoolId; | |||||||
| extern String lastSpoolId; | extern String lastSpoolId; | ||||||
| extern volatile nfcReaderStateType nfcReaderState; | extern volatile nfcReaderStateType nfcReaderState; | ||||||
| extern volatile bool pauseBambuMqttTask; | extern volatile bool pauseBambuMqttTask; | ||||||
|  | extern volatile bool nfcWriteInProgress; | ||||||
| extern bool tagProcessed; | extern bool tagProcessed; | ||||||
|  |  | ||||||
|  |  | ||||||
|   | |||||||
| @@ -48,8 +48,6 @@ void scale_loop(void * parameter) { | |||||||
|   Serial.println("Scale Loop started"); |   Serial.println("Scale Loop started"); | ||||||
|   Serial.println("++++++++++++++++++++++++++++++"); |   Serial.println("++++++++++++++++++++++++++++++"); | ||||||
|  |  | ||||||
|   scale.tare(); |  | ||||||
|  |  | ||||||
|   for(;;) { |   for(;;) { | ||||||
|     if (scale.is_ready())  |     if (scale.is_ready())  | ||||||
|     { |     { | ||||||
| @@ -119,12 +117,13 @@ void start_scale(bool touchSensorConnected) { | |||||||
|     esp_task_wdt_reset(); |     esp_task_wdt_reset(); | ||||||
|   } |   } | ||||||
|  |  | ||||||
|   if (scale.wait_ready_timeout(1000)) |   while(!scale.is_ready()) { | ||||||
|   { |     vTaskDelay(pdMS_TO_TICKS(5000)); | ||||||
|     scale.set_scale(calibrationValue); // this value is obtained by calibrating the scale with known weights; see the README for details |  | ||||||
|     //scale.tare(); |  | ||||||
|   } |   } | ||||||
|  |  | ||||||
|  |   scale.set_scale(calibrationValue); // this value is obtained by calibrating the scale with known weights; see the README for details | ||||||
|  |   scale.tare(); | ||||||
|  |  | ||||||
|   // Display Gewicht |   // Display Gewicht | ||||||
|   oledShowWeight(0); |   oledShowWeight(0); | ||||||
|  |  | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user