From a856d53be940c8df3c273f31dc8ecb273ebdb184 Mon Sep 17 00:00:00 2001 From: cheetah Date: Sun, 30 Mar 2025 15:15:54 +0200 Subject: [PATCH] first commit --- .gitignore | 5 + data/index.html | 289 +++++++++++++++++++++++ data/promisexhr.js | 3 + data/script.js | 147 ++++++++++++ data/style.css | 454 +++++++++++++++++++++++++++++++++++++ include/README | 39 ++++ lib/README | 46 ++++ platformio.ini | 29 +++ src/board.h | 11 + src/config.cpp | 321 ++++++++++++++++++++++++++ src/config.h | 88 +++++++ src/display.cpp | 131 +++++++++++ src/display.h | 23 ++ src/dwd.cpp | 121 ++++++++++ src/dwd.h | 29 +++ src/main.cpp | 428 ++++++++++++++++++++++++++++++++++ src/main.h | 55 +++++ src/mowas.cpp | 82 +++++++ src/mowas.h | 33 +++ src/pocsag_encoder.cpp | 246 ++++++++++++++++++++ src/pocsag_encoder.h | 29 +++ src/pocsag_transmitter.cpp | 151 ++++++++++++ src/pocsag_transmitter.h | 66 ++++++ src/utils.cpp | 12 + src/webserver.cpp | 426 ++++++++++++++++++++++++++++++++++ src/webserver.h | 25 ++ test/README | 11 + 27 files changed, 3300 insertions(+) create mode 100644 .gitignore create mode 100644 data/index.html create mode 100644 data/promisexhr.js create mode 100644 data/script.js create mode 100644 data/style.css create mode 100644 include/README create mode 100644 lib/README create mode 100644 platformio.ini create mode 100644 src/board.h create mode 100644 src/config.cpp create mode 100644 src/config.h create mode 100644 src/display.cpp create mode 100644 src/display.h create mode 100644 src/dwd.cpp create mode 100644 src/dwd.h create mode 100644 src/main.cpp create mode 100644 src/main.h create mode 100644 src/mowas.cpp create mode 100644 src/mowas.h create mode 100644 src/pocsag_encoder.cpp create mode 100644 src/pocsag_encoder.h create mode 100644 src/pocsag_transmitter.cpp create mode 100644 src/pocsag_transmitter.h create mode 100644 src/utils.cpp create mode 100644 src/webserver.cpp create mode 100644 src/webserver.h create mode 100644 test/README diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..89cc49c --- /dev/null +++ b/.gitignore @@ -0,0 +1,5 @@ +.pio +.vscode/.browse.c_cpp.db* +.vscode/c_cpp_properties.json +.vscode/launch.json +.vscode/ipch diff --git a/data/index.html b/data/index.html new file mode 100644 index 0000000..772c79c --- /dev/null +++ b/data/index.html @@ -0,0 +1,289 @@ + + + + + esp32-procsag + + + + + + + + +
+
+ +
+ +
+

pocsag-tx

+
+ + + + + + + + + +
+ + +
+
+
+
+ + +
+
+
+
+ +
+
+

Clear Queue manually (if config>clear queue after tx is not enabled)

+
+
+ +
+
+
+
+
    +
+
+

Add Contact

+

RIC + Function + Text Length

+ + + +

Contact Name + Default Message

+ + + +
+ + + +
+
+
+
+

Semtech Modem Configuration

+
+ + + + + + + + + + + + + + + + + + +
+ +
+
+

Device Configuration

+
+ + + + + + +
+ +
+
+

MosQuiTTo Broker Configuration

+
+ + + + + + + + + + + + + 
transmit_topic = topic + "/transmit"
+ 
clear_topic = topic + "/clear"
+ 
state_topic = topic + "/state"
+
+ +
+
+

Reboot to Apply Settings

+
+
+ +
+
+
+
+

Access-Point Credentials

+
+ + + + +
+ +
+
+

Home-WiFi Credentials

+
+ + + + +
+ +
+
+

Alt. WiFi Credentials

+
+ + + + +
+ +
+
+

Reboot to Apply Settings

+
+
+ +
+
+
+
+

DWD Settings

+
+ + + + + + + + + + + + + + + + + + + + + + + +
+ +
+
+
+
+

Time Beacon

+
+ + + + + + + + + + + + + + + + + + +
+ +
+
+

Trigger Time Beacon

+
+
+ +
+
+
+
+

Idle Beacon

+
+ + + + + + + + + +
+ +
+
+
+
+
+
+ + + + \ No newline at end of file diff --git a/data/promisexhr.js b/data/promisexhr.js new file mode 100644 index 0000000..816c426 --- /dev/null +++ b/data/promisexhr.js @@ -0,0 +1,3 @@ +function promiseXHR(a,b,g){var n="XMLHttpRequest",h="setRequestHeader",k="constructor",t="hasOwnProperty",u="POST",v="content-type",w="x-requested-with",x=Object,y=function(d){return encodeURIComponent(d).replace(/%20/g,"+")},c,e,f,l,z,m; +if(b)switch(b[k]){case self.FormData:l=1;break;case x:for(p in m="_="+(new Date).getTime(),b)if(b[t](p))for(b[p]&&b[p][k]==Array||(b[p]=[b[p]]),c=0;cc.indexOf("?")?"?":"&")+b);a=new self[n]; +a.open(e,c);for(p in f)f[t](p)&&(a[h](c=p.toLowerCase(),f[p]),c==v&&(l=1),c==w&&(z=1));z||a[h](w,n);l||e==u&&a[h](v,"application/x-www-form-urlencoded")}return new Promise(function(A,B){a.onreadystatechange=function(){4==a.readyState&&A(a)};g|0&&setTimeout(function(){B("timeout");a.abort()},g);a.send(b)})}self.Promise||document.write("") \ No newline at end of file diff --git a/data/script.js b/data/script.js new file mode 100644 index 0000000..8ed493c --- /dev/null +++ b/data/script.js @@ -0,0 +1,147 @@ +function promiseXHR(a,b,g){var n="XMLHttpRequest",h="setRequestHeader",k="constructor",t="hasOwnProperty",u="POST",v="content-type",w="x-requested-with",x=Object,y=function(d){return encodeURIComponent(d).replace(/%20/g,"+")},c,e,f,l,z,m; +if(b)switch(b[k]){case self.FormData:l=1;break;case x:for(p in m="_="+(new Date).getTime(),b)if(b[t](p))for(b[p]&&b[p][k]==Array||(b[p]=[b[p]]),c=0;cc.indexOf("?")?"?":"&")+b);a=new self[n]; +a.open(e,c);for(p in f)f[t](p)&&(a[h](c=p.toLowerCase(),f[p]),c==v&&(l=1),c==w&&(z=1));z||a[h](w,n);l||e==u&&a[h](v,"application/x-www-form-urlencoded")}return new Promise(function(A,B){a.onreadystatechange=function(){4==a.readyState&&A(a)};g|0&&setTimeout(function(){B("timeout");a.abort()},g);a.send(b)})}self.Promise||document.write("") +// + +// TIME=HHMMDDMMYY + +const topNav = document.getElementById("topnav") +function selTab(evt, id) { + var tabcontent, tablinks + tablinks = document.getElementsByClassName("tablinks") + tabcontent = document.getElementsByClassName("tabcontent") + + for (let tab of tabcontent) { + tab.style.display = "none" + var link = tab.dataset.src + if (link) { + tab.getElementsByTagName("iframe")[0].setAttribute("src", "") + } + } + for(let link of tablinks) + link.className = "tablinks" + var act = document.getElementById(id) + act.style.display = "flex" + evt.currentTarget.className += " active" + + var link = act.dataset.src + if(link) { + act.getElementsByTagName("iframe")[0].setAttribute("src", link) + } + topNav.className = "topnav" +} +function toggleResponsive() { + topNav.className = topNav.className === "topnav" ? "topnav responsive" : "topnav" + //topNav.className = ["topnav","responsive"].slice(0,1+(x.className === "topnav")).join(" ") +} + +let contactsData = [] +function delContact(i) { + contactsData.splice(i, 1); + storeContacts() + window.location.reload() +} +function addContact(doReloadAfter) { + contactsData.push({ + r: parseInt(document.querySelector('#newcon_r').value), + f: parseInt(document.querySelector('#newcon_f').value), + tl: parseInt(document.querySelector('#newcon_tl').value), + n: document.querySelector('#newcon_n').value, + t: document.querySelector('#newcon_t').value, + }) + storeContacts() + if (doReloadAfter) window.location.reload() +} +function resetContacts() { + if (confirm("do you want to delete all contacts?")) { + promiseXHR("/contacts.json", JSON.stringify([])) + .then(() => alert("reset contacts")) + } +} +function storeContacts() { + promiseXHR("/contacts.json", JSON.stringify(contactsData)) + .then(() => alert("stored contacts")) +} +let firstFetch = true +function fetchCfgVals() { + if (!firstFetch) return + firstFetch = false + promiseXHR("/config.json").then(j=>{ + const res = JSON.parse(j.responseText) + console.log(res) + for (let key in res) { + let e = document.getElementById(key) || document.getElementsByName(key)[0] + if (!!e) { + if (e.type == 'checkbox') { + e.checked = res[key]; + } else { + e.value = res[key] + } + } + } + }) + promiseXHR("/contacts.json").then(j=>{ + const contactlist = document.getElementById("contactlist") + contactsData = JSON.parse(j.responseText) + console.log("received contacts from esp", contactsData) + for (let contactI in contactsData) { + const contact = contactsData[contactI] + const li = document.createElement("li") + li.innerHTML = `
+

${ contact.n }

+ + + + + 
RIC=${ contact.r } F=${ contact.f } TL=${ contact.tl }
+ + +
+
+ +
+ ` + contactlist.appendChild(li) + } + }) +} + +document.getElementById("defaultTab").click() +for (let i of document.getElementsByTagName("input")) i.placeholder = i.name + +function calculateTimeToTxTxt(type) { + document.querySelector("input[name='text']").value = calculateTime(type) +} +function calculateTime(type) { + const now = new Date(); + + // Extract date components + const hh = String(now.getHours()).padStart(2, '0'); + const mm = String(now.getMinutes()).padStart(2, '0'); + const DD = String(now.getDate()).padStart(2, '0'); + const MM = String(now.getMonth() + 1).padStart(2, '0'); // Months are 0-based + const YY = String(now.getFullYear()).slice(-2); // Get last two digits of the year + + // Construct the formatted string + const formattedTime = `${hh}${mm}${DD}${MM}${YY}`; + + switch (type) { + case 'tpl': + return `#ZEIT=${formattedTime}#ZEIT=${formattedTime}`; + case 'swissphone': + return `;TIME=${formattedTime};TIME=${formattedTime}`; + default: + return 'Invalid type'; + } +} +function populateTimezones() { + const timezones = Intl.supportedValuesOf('timeZone'); + const select = document.getElementById("time_zone"); + timezones.forEach(zone => { + const option = document.createElement("option"); + option.value = zone; + option.textContent = zone; + select.appendChild(option); + }); +} +populateTimezones(); \ No newline at end of file diff --git a/data/style.css b/data/style.css new file mode 100644 index 0000000..4b0c3e5 --- /dev/null +++ b/data/style.css @@ -0,0 +1,454 @@ +:root { + --primary-color: #007bff; /* Blau für den Button */ + --primary-hover: #0056b3; /* Dunkleres Blau bei Hover */ + --border-radius: 6px; + --padding: 10px 15px; + --font-size: 16px; + --transition: all 0.3s ease-in-out; +} + + +body, html { + height: 100%; + margin: 0; + font-family: Arial; +} + +.system-info { + padding: 20px; + font-family: Arial, sans-serif; + flex-grow: 1; + overflow-y: auto; +} +.system-info p { + margin: 8px 0; +} +.system-info h1 { + font-size: 24px; + margin-bottom: 10px; +} +.status-table { + width: 100%; + border-collapse: collapse; + margin-top: 20px; +} +.status-table th, .status-table td { + padding: 10px; + border: 1px solid #ccc; + text-align: left; + vertical-align: top; +} +.status-table th { + background-color: #f4f4f4; + font-weight: bold; +} +#refresh-button { + background: none; + border: none; + cursor: pointer; +} +#refresh-button:hover { + color: #007BFF; +} + +h2.external-links { + margin-top: 40px; + text-align: center; + font-size: 20px; + margin-bottom: 15px; +} + +.link-buttons { + display: flex; + justify-content: center; + gap: 20px; +} + +.link-buttons .button { + background-color: #04AA6D; + color: white; + padding: 15px 20px; + text-decoration: none; + border-radius: 5px; + font-size: 18px; + transition: background-color 0.3s ease; +} + + +.active, .cfgheader:hover { + background-color: #ccc; +} +.cfgpanel { +} +.cfgpanel:hover td, .cfgpanel:active td{ + background-color: #808080 !important; + color: white; +} + +th.cfg { + padding:5pt +} +table.stat { + margin:0px 0px 5px 0px; +} + +.hamburger { + position: relative; + display: inline-block; + width: 1.25em; + height: 0.8em; + margin-right: 0.3em; + border-top: 0.2em solid #fff; + border-bottom: 0.2em solid #fff; +} + +.hamburger:before { + content: ""; + position: absolute; + top: 0.3em; + left: 0px; + width: 100%; + border-top: 0.2em solid #fff; +} + +.wrapper { + height: 100%; + display: flex; + flex-direction: column; + margin: 0; +} +.tci { + flex-grow: 1; border: none; margin: 0; padding: 0; overflow-y: auto; +} +.footer { + background-color: #333; + display: flex; + justify-content: space-between; +} + +td.ch { + text-align: right; + padding: 0px 8px; +} +td.act { + text-align: center; +} +table, th, td { + border: 1px solid black; + border-collapse: collapse; + background-color: #ddd +} + +td#caption { + text-align: center; + background-color: #aaa; + font-weight: bold; +} + +td#sfreq { + background-color: #ccc; +} + +.content { + display: flex; + flex: 1; + flex-direction: column; + overflow: auto; + height: 100%; +} +.tabcontent { + display: none; + flex: 1; + border-top: none; + flex-direction: column; + overflow: auto; +} + +html { + font-family: Helvetica; + display: inline-block; + margin: 0px auto; + text-align: left; +} +h1{ + color: #0F3376; + font-size: 24px +} + +.button2 { + background-color: #f44336; +} +:disabled.save { + opacity: 0.5; +} +.save { + background-color: #CC1111; /* 0F33C6; */ + border: white; + border-width: 1; + color: white; + padding: 8px 30px; + text-align: center; + text-decoration: none; + display: block; + font-size: 14px; + margin: 0 +} + +.ttgoinfo { + color: white; + padding: 8px 10px; + display: block; + font-size: 14px; + margin: 0 +} +.ctlbtn { + background-color: #ccc; + border: black; + border-width: 1; + color: black; + padding: 4px 30px; + text-align: center; + text-decoration: none; + display: block; + font-size: 4vh; + margin-top: 0.3em; + margin-left: 0.3em; + margin-right: 0.3em; +} +.update { + margin: 0; + display: block; +} + +#map { + height: 100%; +} + +.ldot { + height: 15px; + width: 15px; + margin-top: 8px; + margin-left: -1px; + border-radius: 50%; + display: inline-block; +} + +.ybg { + background-color: orange; + background-image: -webkit-gradient(linear, left top, left bottom, from(yellow), to(orange)); + background-image: linear-gradient(top, yellow, orange); +} +.gbg { + background-color: green; + background-image: -webkit-gradient(linear, left top, left bottom, from(lime), to(green)); + background-image: linear-gradient(top, lime, green); +} +.rbg { + background-color: red; + background-image: -webkit-gradient(linear, left top, left bottom, from(orange), to(red)); + background-image: linear-gradient(top, orange, red); +} + +#sonde_statbar .ldot { + margin-right: 3px; +} + +/* Add a black background color to the top navigation */ +.topnav { + background-color: #333; + overflow: hidden; +} + +/* Style the links inside the navigation bar */ +.topnav a { + float: left; + display: block; + color: #f2f2f2; + text-align: center; + padding: 14px 16px; + text-decoration: none; + font-size: 17px; +} + +/* Change the color of links on hover */ +.topnav a:hover { + background-color: #ddd; + color: black; +} + +/* Add an active class to highlight the current page */ +.topnav a.active { + background-color: #04AA6D; + color: white; +} + +/* Hide the link that should open and close the topnav on small screens */ +.topnav .icon { + display: none; + padding-bottom: 12px; + padding-top: 11px; +} + +/* When the screen is less than 600 pixels wide, hide all links, except for the first one ("Home"). Show the link that contains should open and close the topnav (.icon) */ +@media screen and (max-width: 600px) { + .topnav a:not(.active) {display: none;} + .topnav a.icon { + float: right; + display: block; + } +} + +/* The "responsive" class is added to the topnav with JavaScript when the user clicks on the icon. This class makes the topnav look good on small screens (display the links vertically instead of horizontally) */ +@media screen and (max-width: 600px) { + .topnav.responsive {position: relative;} + .topnav.responsive a.icon { + position: absolute; + right: 0; + top: 0; + } + .topnav.responsive a { + float: none; + display: block; + text-align: left; + } +} + + +/* Buttons */ +button, .btn { + background: var(--primary-color); + color: white; + padding: var(--padding); + border: none; + border-radius: var(--border-radius); + font-size: var(--font-size); + cursor: pointer; + transition: var(--transition); + box-shadow: 0 4px 8px rgba(0, 123, 255, 0.3); /* Schatten hinzufügen */ +} + +button:hover, .btn:hover { + background: var(--primary-hover); + box-shadow: 0 6px 12px rgba(0, 123, 255, 0.4); /* Stärkerer Schatten bei Hover */ +} + +button:focus { + outline: none; + box-shadow: 0 0 5px rgba(0, 123, 255, 0.7); /* Deutlicher Fokus-Effekt */ +} + +/* Zusätzliche Button-Stile für den Fokus */ +button:active { + background: #0056b3; + transform: scale(0.98); /* Kleine Verkleinerung beim Klicken */ +} + +/* Button Group */ +.button-group { + display: flex; + gap: 10px; +} + +.button-group button { + flex: 1; + font-weight: bold; /* Button-Text fett für mehr Gewicht */ + transition: transform 0.2s ease-in-out; +} + +/* Hover und Fokus Effekte für Buttons in der Gruppe */ +.button-group button:hover { + transform: scale(1.05); /* Leichtes Vergrößern bei Hover */ +} + +/* Input-Felder */ +input, select, textarea { + width: 100%; + padding: var(--padding); + border: 1px solid #ccc; + border-radius: var(--border-radius); + font-size: var(--font-size); + transition: var(--transition); +} + +input:focus, select:focus, textarea:focus { + border-color: var(--primary-color); + outline: none; + box-shadow: 0 0 5px rgba(0, 123, 255, 0.5); +} + +/* Form-Labels */ +label { + display: block; + margin-bottom: 5px; + font-weight: bold; +} + +/* Styling für Checkboxen und Radios */ +input[type="checkbox"], input[type="radio"] { + width: auto; + margin-right: 5px; +} + +/* Disabled-Zustand */ +button:disabled, input:disabled { + background: #ccc; + cursor: not-allowed; +} + +.styled-form { + max-width: 400px; + margin: auto; + display: flex; + flex-direction: column; + gap: 10px; +} +.no-top-margin { + margin-top: unset; +} +.button-group { + display: flex; + gap: 10px; +} + +.button-group button { + flex: 1; +} + + +/* General styles for headers */ +h1, h2, h3 { + font-family: 'Arial', sans-serif; /* A clean font for headers */ + font-weight: bold; + margin: 10px 0; + color: #333; /* Dark gray text */ + text-align: center; /* Center all headers */ +} + +/* Specific styles for h1 */ +h1 { + font-size: 2.5rem; /* Large font for main title */ + color: var(--primary-color); /* Primary color for h1 */ + text-align: center; /* Center the main title */ + text-transform: uppercase; /* Uppercase letters for emphasis */ + letter-spacing: 2px; /* Add some spacing between letters */ + margin-top: 20px; + margin-bottom: 20px; +} + +/* Specific styles for h2 */ +h2 { + font-size: 2rem; /* Slightly smaller than h1 */ + color: #444; /* Slightly lighter gray */ + /* text-align: left; Align to the left */ + text-transform: capitalize; /* Capitalize first letter of each word */ + margin-bottom: 15px; +} + +/* Specific styles for h3 */ +h3 { + font-size: 1.5rem; /* Smaller than h2 */ + color: #666; /* Even lighter gray for less emphasis */ + /* text-align: left; Align to the left */ + margin-bottom: 10px; + font-weight: normal; /* Make it normal weight for less emphasis */ +} diff --git a/include/README b/include/README new file mode 100644 index 0000000..194dcd4 --- /dev/null +++ b/include/README @@ -0,0 +1,39 @@ + +This directory is intended for project header files. + +A header file is a file containing C declarations and macro definitions +to be shared between several project source files. You request the use of a +header file in your project source file (C, C++, etc) located in `src` folder +by including it, with the C preprocessing directive `#include'. + +```src/main.c + +#include "header.h" + +int main (void) +{ + ... +} +``` + +Including a header file produces the same results as copying the header file +into each source file that needs it. Such copying would be time-consuming +and error-prone. With a header file, the related declarations appear +in only one place. If they need to be changed, they can be changed in one +place, and programs that include the header file will automatically use the +new version when next recompiled. The header file eliminates the labor of +finding and changing all the copies as well as the risk that a failure to +find one copy will result in inconsistencies within a program. + +In C, the usual convention is to give header files names that end with `.h'. +It is most portable to use only letters, digits, dashes, and underscores in +header file names, and at most one dot. + +Read more about using header files in official GCC documentation: + +* Include Syntax +* Include Operation +* Once-Only Headers +* Computed Includes + +https://gcc.gnu.org/onlinedocs/cpp/Header-Files.html diff --git a/lib/README b/lib/README new file mode 100644 index 0000000..6debab1 --- /dev/null +++ b/lib/README @@ -0,0 +1,46 @@ + +This directory is intended for project specific (private) libraries. +PlatformIO will compile them to static libraries and link into executable file. + +The source code of each library should be placed in a an own separate directory +("lib/your_library_name/[here are source files]"). + +For example, see a structure of the following two libraries `Foo` and `Bar`: + +|--lib +| | +| |--Bar +| | |--docs +| | |--examples +| | |--src +| | |- Bar.c +| | |- Bar.h +| | |- library.json (optional, custom build options, etc) https://docs.platformio.org/page/librarymanager/config.html +| | +| |--Foo +| | |- Foo.c +| | |- Foo.h +| | +| |- README --> THIS FILE +| +|- platformio.ini +|--src + |- main.c + +and a contents of `src/main.c`: +``` +#include +#include + +int main (void) +{ + ... +} + +``` + +PlatformIO Library Dependency Finder will find automatically dependent +libraries scanning project source files. + +More information about PlatformIO Library Dependency Finder +- https://docs.platformio.org/page/librarymanager/ldf.html diff --git a/platformio.ini b/platformio.ini new file mode 100644 index 0000000..6180047 --- /dev/null +++ b/platformio.ini @@ -0,0 +1,29 @@ +; PlatformIO Project Configuration File +; +; Build options: build flags, source filter +; Upload options: custom upload port, speed and extra flags +; Library options: dependencies, extra library storages +; Advanced options: extra scripting +; +; Please visit documentation for the other options and examples +; https://docs.platformio.org/page/projectconf.html + +[env:ttgo-lora32-v2] +platform = espressif32 +board = ttgo-lora32-v2 +board_build.embed_txtfiles = + data/index.html + data/script.js + data/style.css +framework = arduino +lib_deps = + jgromes/RadioLib@^7.1.2 + ropg/ezTime@^0.8.3 + esphome/AsyncTCP-esphome@^2.1.4 + esphome/ESPAsyncWebServer-esphome@^3.3.0 + bblanchon/ArduinoJson@^7.3.1 + knolleary/PubSubClient@^2.8 + thingpulse/ESP8266 and ESP32 OLED driver for SSD1306 displays@^4.6.1 +monitor_speed = 115200 +board_build.mcu = esp32 +upload_speed = 921600 diff --git a/src/board.h b/src/board.h new file mode 100644 index 0000000..bfe6695 --- /dev/null +++ b/src/board.h @@ -0,0 +1,11 @@ +// Better +#define LORA_SCK 5 +#define LORA_MISO 19 +#define LORA_MOSI 27 +#define LORA_SS 18 +#define LORA_DIO0 26 +#define LORA_DIO1 33 +#define LORA_DIO2 34 + +#undef LORA_RST +#define LORA_RST 14 \ No newline at end of file diff --git a/src/config.cpp b/src/config.cpp new file mode 100644 index 0000000..186c636 --- /dev/null +++ b/src/config.cpp @@ -0,0 +1,321 @@ +#include "config.h" + +const char* ConfigFilePath = "/config.json"; +const char* ContactsFilePath = "/contacts.json"; + +void setup_storage(cfg_t *out) { + if (!SPIFFS.begin(true)) { + Serial.println("SPIFFS Mount Failed"); + return; + } + if (!SPIFFS.exists(ConfigFilePath)) { + create_default_config(); + } else { + read_config(out); + } + if (!SPIFFS.exists(ContactsFilePath)) { + create_default_contactlist(); + } +} +void read_config(cfg_t *out) { + File file = SPIFFS.open(ConfigFilePath, "r"); + if (!file) { + Serial.println("Failed to open config file"); + return; + } + + JsonDocument doc; + DeserializationError error = deserializeJson(doc, file); + if (error) { + Serial.println("Failed to parse config file"); + return; + } + + String ap_ssid = doc["ap_ssid"].as(); + String ap_pass = doc["ap_pass"].as(); + String wifi1_ssid = doc["wifi1_ssid"].as(); + String wifi1_pass = doc["wifi1_pass"].as(); + String wifi2_ssid = doc["wifi2_ssid"].as(); + String wifi2_pass = doc["wifi2_pass"].as(); + wifi1_pass.toCharArray(out->wifi1_pass, sizeof(out->wifi1_pass)); + wifi1_ssid.toCharArray(out->wifi1_ssid, sizeof(out->wifi1_ssid)); + wifi2_pass.toCharArray(out->wifi2_pass, sizeof(out->wifi2_pass)); + wifi2_ssid.toCharArray(out->wifi2_ssid, sizeof(out->wifi2_ssid)); + ap_ssid.toCharArray(out->ap_ssid, sizeof(out->ap_ssid)); + ap_pass.toCharArray(out->ap_pass, sizeof(out->ap_pass)); + // + // + // + float freq = doc["tx_freq"].as(); + float baud = doc["tx_baud"].as(); + float dev = doc["tx_dev"].as(); + int power = doc["tx_power"].as(); + bool empty_queue = doc["tx_empty_queue"].as(); + out->tx_freq = freq; + out->tx_baud = baud; + out->tx_dev = dev; + out->tx_power = power; + out->tx_empty_queue = empty_queue; + // + // + // + int mqtt_port = doc["mqtt_port"].as(); + String mqtt_host = doc["mqtt_host"].as(); + String mqtt_user = doc["mqtt_user"].as(); + String mqtt_pass = doc["mqtt_pass"].as(); + String mqtt_topic = doc["mqtt_topic"].as(); + mqtt_host.toCharArray(out->mqtt_host, sizeof(out->mqtt_host)); + mqtt_user.toCharArray(out->mqtt_user, sizeof(out->mqtt_user)); + mqtt_pass.toCharArray(out->mqtt_pass, sizeof(out->mqtt_pass)); + mqtt_topic.toCharArray(out->mqtt_topic, sizeof(out->mqtt_topic)); + out->mqtt_port = mqtt_port; + // + // + // + int broadcast_ric = doc["broadcast_ric"].as(); + int broadcast_fun = doc["broadcast_fun"].as(); + out->broadcast_ric = broadcast_ric; + out->broadcast_fun = broadcast_fun; + // + int dwd_interval = doc["dwd_interval"].as(); + bool dwd_enable = doc["dwd_enable"].as(); + String dwd_region = doc["dwd_region"].as(); + out->dwd_interval = dwd_interval; + out->dwd_enable = dwd_enable; + dwd_region.toCharArray(out->dwd_region, sizeof(out->dwd_region)); + if (doc["dwd_fun"].is()) { + int dwd_fun = doc["dwd_fun"].as(); + out->dwd_fun = dwd_fun; + } + // + int mowas_interval = doc["mowas_interval"].as(); + bool mowas_enable = doc["mowas_enable"].as(); + String mowas_region = doc["mowas_region"].as(); + out->mowas_interval = mowas_interval; + out->mowas_enable = mowas_enable; + mowas_region.toCharArray(out->mowas_region, sizeof(out->mowas_region)); + if (doc["mowas_fun"].is()) { + int mowas_fun = doc["mowas_fun"].as(); + out->mowas_fun = mowas_fun; + } + // + // + if (doc["time_interval"].is()) { + int time_interval = doc["time_interval"].as(); + bool time_enable = doc["time_enable"].as(); + out->time_enable = time_enable; + out->time_interval = time_interval; + int time_ric = doc["time_ric"].as(); + int time_fun = doc["time_fun"].as(); + out->time_ric = time_ric; + out->time_fun = time_fun; + + int time_mode = doc["time_mode"].as(); + out->time_mode = time_mode; + + if (doc["time_zone"].is()) { + String time_zone = doc["time_zone"].as(); + time_zone.toCharArray(out->time_zone, sizeof(out->time_zone)); + } + } + if (doc["idle_interval"].is()) { + int idle_interval = doc["idle_interval"].as(); + bool idle_enable = doc["idle_enable"].as(); + int idle_mode = doc["idle_mode"].as(); + out->idle_enable = idle_enable; + out->idle_interval = idle_interval; + out->idle_mode = idle_mode; + } + if (doc["pocsag_german"].is()) { + bool pocsag_german = doc["pocsag_german"].as(); + out->pocsag_german = pocsag_german; + } + if (doc["device_name"].is()) { + String device_name = doc["device_name"].as(); + device_name.toCharArray(out->device_name, sizeof(out->device_name)); + } + if (doc["oled_timeout"].is()) { + int oled_timeout = doc["oled_timeout"].as(); + out->oled_timeout = oled_timeout; + } + Serial.println("Loaded Configuration:"); + Serial.printf("AP SSID: %s\n", out->ap_ssid); + Serial.printf("AP Password: %s\n", out->ap_pass); + Serial.printf("1. SSID: '%s'\n", out->wifi1_ssid); + Serial.printf("1. Password: '%s'\n", out->wifi1_pass); + Serial.printf("2. SSID: '%s'\n",out->wifi2_ssid); + Serial.printf("2. Password: '%s'\n",out->wifi2_pass); + Serial.printf("MQTT Host/Port: '%s':%d\n", out->mqtt_host, out->mqtt_port); + Serial.printf("User/Password: '%s':'%s'\n",out->mqtt_user, out->mqtt_pass); + Serial.printf("Topic: '%s'\n",out->mqtt_topic); + Serial.println(); + Serial.printf("German POCSAG: %d\n", out->pocsag_german); + Serial.printf("Transmitter: %f MHz @%dbd - dev=%dkHz\n", out->tx_freq, out->tx_baud, out->tx_dev); + Serial.printf("Broadcast: RIC %d fun=%d\n", out->broadcast_ric, out->broadcast_fun); + Serial.printf("DWD: Enable=%d Interval=%dm SubRIC=%d Region=%s\n", out->dwd_enable, out->dwd_interval, out->dwd_fun, out->dwd_region); + Serial.printf("MoWaS: Enable=%d Interval=%dm SubRIC=%d Region=%s\n", out->mowas_enable, out->mowas_interval, out->mowas_fun, out->mowas_region); + Serial.printf("Time: Enable=%d Interval=%dm RIC=%d SubRIC=%d Mode=%d Zone=%s\n", out->time_enable, out->time_interval, out->time_ric, out->time_fun, out->time_mode, out->time_zone); + // + doc.clear(); + file.close(); +} +String cfg_tostring() { + File file = SPIFFS.open(ConfigFilePath, "r"); + if (!file) { + Serial.println("Failed to open config file"); + return ""; + } + String output = file.readString(); + file.close(); + return output; +} +void create_default_config() { + Serial.println("creating default config"); + + JsonDocument doc; + + doc["wifi1_ssid"] = ""; + doc["wifi1_pass"] = ""; + doc["wifi2_ssid"] = ""; + doc["wifi2_pass"] = ""; + doc["ap_ssid"] = "POCSAG"; + doc["ap_pass"] = "Motorola"; + // modem + doc["tx_freq"] = 434.230f; + doc["tx_baud"] = 1200; + doc["tx_dev"] = 4.5; + doc["tx_power"] = 13; + doc["tx_empty_queue"] = false; + // mqtt + doc["mqtt_host"] = ""; + doc["mqtt_user"] = ""; + doc["mqtt_pass"] = ""; + doc["mqtt_topic"] = ""; + doc["mqtt_port"] = 1883; + // + doc["broadcast_ric"] = 9999; + doc["broadcast_fun"] = 3; + // + doc["dwd_fun"] = 3; + doc["dwd_interval"] = 5; + doc["dwd_enable"] = false; + doc["dwd_region"] = ""; + doc["mowas_fun"] = 3; + doc["mowas_interval"] = 5; + doc["mowas_enable"] = false; + doc["mowas_region"] = ""; + + doc["time_enable"] = false; + doc["time_interval"] = 720; + doc["time_ric"] = 0; + doc["time_fun"] = 3; + doc["time_mode"] = 0; + doc["time_zone"] = "Europe/Berlin"; + + doc["idle_enable"] = false; + doc["idle_interval"] = 1; + doc["idle_mode"] = 0; + + doc["pocsag_german"] = false; + doc["oled_timeout"] = 2; + doc["device_name"] = "smartPOC"; + File file = SPIFFS.open(ConfigFilePath, "w"); + if (!file) { + Serial.println("Failed to open config file for writing"); + return; + } + + serializeJson(doc, file); + file.close(); + doc.clear(); + + Serial.println("Configuration saved."); +} +// +void create_default_contactlist() { + Serial.println("creating default contacts"); + + JsonArray jArr; + JsonObject testContact; + testContact["r"] = 133701; + testContact["n"] = "Contact Name"; + testContact["f"] = 3; + testContact["tl"] = 80; + testContact["t"] = "Test"; + jArr.add(testContact); + // + + File file = SPIFFS.open(ContactsFilePath, "w"); + if (!file) { + Serial.println("Failed to open config file for writing"); + return; + } + + serializeJson(jArr, file); + file.close(); + jArr.clear(); + + Serial.println("Contacts saved."); +} +String contacts_tostring() { + File file = SPIFFS.open(ContactsFilePath, "r"); + if (!file) { + Serial.println("Failed to open contacts file"); + return ""; + } + String output = file.readString(); + file.close(); + return output; +} +void contacts_write(String data) { + File file = SPIFFS.open(ContactsFilePath, "w"); + if (!file) { + Serial.println("Failed to open contacts file for writing"); + return; + } + file.print(data); + file.close(); + Serial.println("Contacts saved."); +} +// +JsonDocument transactionJson; +void cfg_startTransaction() { + File file = SPIFFS.open(ConfigFilePath, "r"); + if (!file) { + Serial.println("Failed to open config file"); + return; + } + DeserializationError error = deserializeJson(transactionJson, file); + if (error) { + Serial.println("Failed to parse config file"); + return; + } + file.close(); +} +void cfg_adjust(String key, bool val) { + Serial.printf("adjustng cfg %s\n", key); + transactionJson[key] = val; +} +void cfg_adjust(String key, String val) { + Serial.printf("adjustng cfg %s = '%s'\n", key, val); + transactionJson[key] = val; +} +void cfg_adjust(String key, float val) { + Serial.printf("adjustng cfg %s = %f\n", key, val); + transactionJson[key] = val; +} +void cfg_adjust(String key, int val) { + Serial.printf("adjustng cfg %s = %d\n", key, val); + transactionJson[key] = val; +} +void cfg_write() { + File file = SPIFFS.open(ConfigFilePath, "w"); + if (!file) { + Serial.println("Failed to open config file for writing"); + return; + } + serializeJson(transactionJson, file); + file.close(); + //transactionJson.clear(); + Serial.println("wrote cfg"); +} \ No newline at end of file diff --git a/src/config.h b/src/config.h new file mode 100644 index 0000000..8d05b85 --- /dev/null +++ b/src/config.h @@ -0,0 +1,88 @@ +#define CFG_TIME_RIC "time_ric" + +#if !defined(_CONFIG_H) +#define _CONFIG_H + + +#include "FS.h" +#define FORMAT_SPIFFS_IF_FAILED true + +#include "SPIFFS.h" +#include + + +typedef struct { + byte version; + char wifi1_ssid[33]; + char wifi1_pass[65]; + char wifi2_ssid[33]; + char wifi2_pass[65]; + char ap_ssid[33]; + char ap_pass[65]; + // + float tx_freq; + float tx_dev; + int tx_baud; + int tx_power; + // + char mqtt_host[63]; + uint16_t mqtt_port; + char mqtt_user[63]; + char mqtt_pass[63]; + char mqtt_topic[63]; + // + bool tx_empty_queue; + // brodcasts + int broadcast_ric; + int broadcast_fun; + + // dwd + int dwd_interval; + bool dwd_enable; + char dwd_region[8]; + int dwd_fun; + // mowas + int mowas_interval; + bool mowas_enable; + char mowas_region[32]; + int mowas_fun; + + //time + int time_interval; + bool time_enable; + int time_ric; + int time_fun; + int time_mode; + char time_zone[33]; + //idle + bool idle_enable; + int idle_interval; + int idle_mode; + + // umlauts + bool pocsag_german; + // device name + char device_name[33]; + // oled + int oled_timeout; +} cfg_t; + +void setup_storage(cfg_t *out); +void read_config(cfg_t *out); +void write_config(); +void create_default_config(); +// contacts +void create_default_contactlist(); +String contacts_tostring(); +void contacts_write(String data); + +// +String cfg_tostring(void); +void cfg_adjust(String key, bool val); +void cfg_adjust(String key, int val); +void cfg_adjust(String key, float val); +void cfg_adjust(String key, String value); +void cfg_startTransaction(); +void cfg_write(); + +#endif \ No newline at end of file diff --git a/src/display.cpp b/src/display.cpp new file mode 100644 index 0000000..1f06ad0 --- /dev/null +++ b/src/display.cpp @@ -0,0 +1,131 @@ +#include + +SSD1306Wire display(0x3c, SDA, SCL); + +void display_setup() { + display.init(); + + // clear the display + display.clear(); +//demo + display.flipScreenVertically(); + display.setFont(ArialMT_Plain_10); + + display.setTextAlignment(TEXT_ALIGN_LEFT); + // display.setFont(ArialMT_Plain_10); + // display.drawString(0, 0, "Hello world"); + // display.setFont(ArialMT_Plain_16); + // display.drawString(0, 10, "Hello world"); + display.setFont(ArialMT_Plain_24); + display.drawString(0, 0, "smartPOC"); + +//end demo + // display.setFont(ArialMT_Plain_10); + // display.setTextAlignment(TEXT_ALIGN_RIGHT); + // display.drawString(128, 54, String(millis())); + // write the buffer to the display + display.display(); +} + +bool displayEnableNotifications; +unsigned long lastNotificationTime = 0; +const char *displayStateText; +const char *displayErrorText; +unsigned long activeDisplayTimeLeft = 0; + +// POCSAG TX LIVE DATA transmitterOffset +void display_update_state(const char *text) { + displayEnableNotifications = true; + displayStateText = text; + lastNotificationTime = millis(); + display_update_state_draw(); +} +void display_update_state_draw() { + display.clear(); + display.setFont(ArialMT_Plain_24); + display.drawString(0, 0, "smartPOC"); + display.setFont(ArialMT_Plain_16); + display.drawString(0, 24, "starting up:"); + display.setFont(ArialMT_Plain_10); + display.drawString(0, 40, displayStateText); + display.display(); +} + +char bufferFreqText[10]; +void display_idle(cfg_t *cfg_ref, char *timeStr) { + display.clear(); + display.setFont(ArialMT_Plain_16); + display.setTextAlignment(TEXT_ALIGN_CENTER); + display.drawString(64, 0, "smartPOC"); + display.drawLine(0, 17, 128, 17); + display.setTextAlignment(TEXT_ALIGN_LEFT); + // + sprintf(bufferFreqText, " %.3f", cfg_ref->tx_freq, cfg_ref->tx_baud); + display.drawString(0, 16, bufferFreqText); + // + sprintf(bufferFreqText, "%dbd", cfg_ref->tx_baud); + display.setTextAlignment(TEXT_ALIGN_RIGHT); + display.drawString(128, 16, bufferFreqText); + // + sprintf(bufferFreqText, "%s", cfg_ref->device_name); + display.setTextAlignment(TEXT_ALIGN_LEFT); + display.setFont(ArialMT_Plain_10); + display.drawString(0, 52, bufferFreqText); + + if (WiFi.isConnected()) { + display.setFont(ArialMT_Plain_10); + display.drawString(0, 32, WiFi.localIP().toString()); + display.setFont(ArialMT_Plain_10); + display.drawString(0, 42, timeStr); + } else { + } + display.display(); + //display.sendCommand(0xA3); +} +char bufferTransmitterText[40]; +void display_transmit(POCSAGTransmitter *transmitter) { + display.clear(); + display.setFont(ArialMT_Plain_24); + display.drawString(0, 0, "smartPOC"); + display.setFont(ArialMT_Plain_16); + display.drawString(0, 24, "transmitting"); + + uint32_t curWord = transmitter->getTransmitWord(); + switch (curWord) { + case 0x7A89C197: // idle + sprintf(bufferTransmitterText, " %3d / %3d", transmitter->getTransmitPos(), transmitter->getTransmitLength()); + break; + case 0x7CD215D8: // sync + sprintf(bufferTransmitterText, "< SYNC > %3d / %3d", transmitter->getTransmitPos(), transmitter->getTransmitLength()); + break; + default: + sprintf(bufferTransmitterText, "%8X %3d / %3d", transmitter->getTransmitWord(), transmitter->getTransmitPos(), transmitter->getTransmitLength()); + break; + } + + display.setFont(ArialMT_Plain_10); + display.drawString(0, 48, bufferTransmitterText); + display.display(); +} +void display_report(const char *text) { + +} +void display_loop(bool transmitterActive, POCSAGTransmitter *transmitter, cfg_t *cfg_ref, char *timeStr) { + if (transmitterActive) { + activeDisplayTimeLeft = millis(); + } + + if (cfg_ref->oled_timeout > 0) { + if (activeDisplayTimeLeft + (cfg_ref->oled_timeout * 60e3) < millis()) { + display.displayOff(); + } else { + display.displayOn(); + } + } + if (transmitterActive) + display_transmit(transmitter); + else + display_idle(cfg_ref, timeStr); +} + +// local time, ip addr, transmitter name? \ No newline at end of file diff --git a/src/display.h b/src/display.h new file mode 100644 index 0000000..e7e7c41 --- /dev/null +++ b/src/display.h @@ -0,0 +1,23 @@ +#if !defined(_DISPLAY_H) +#define _DISPLAY_H + +#include +#include +#include "SSD1306Wire.h" +#include +#include + +void display_setup(); +// void display_loop(bool transmitterActive); +void display_loop(bool transmitterActive, POCSAGTransmitter *transmitter); +void display_loop(bool transmitterActive, POCSAGTransmitter *transmitter, cfg_t *cfg_ref); +void display_loop(bool transmitterActive, POCSAGTransmitter *transmitter, cfg_t *cfg_ref, char *timeStr); + +void display_update_state_draw(); +void display_update_state(const char *text); + + +void display_report(const char *text); + + +#endif \ No newline at end of file diff --git a/src/dwd.cpp b/src/dwd.cpp new file mode 100644 index 0000000..a75f49b --- /dev/null +++ b/src/dwd.cpp @@ -0,0 +1,121 @@ +#include "dwd.h" + +String emptyDWDResponse = "Es sind keine Warnungen"; + +DWDClient::DWDClient(WiFiClient *client) +{ + _client = client; +} + +void DWDClient::begin(int intervalMinutes, String region) +{ + this->rssUrl = "https://wettwarn.de/rss/"; + this->rssUrl.concat(region); + this->rssUrl.concat(".rss"); + + this->checkInterval = 60e3 * intervalMinutes; + Serial.printf("[DWD]: check Interval : %dms\n", this->checkInterval); + this->check(); +} +void DWDClient::loop() +{ + if (millis() - this->lastCheck >= this->checkInterval) + { + this->lastCheck = millis(); + this->check(); + } +} +bool DWDClient::isDirty() +{ + if (this->_dirty) + { + this->_dirty = false; + return true; + } + return false; +} +void DWDClient::check() +{ + Serial.println("[DWD]: checking " + this->rssUrl); + this->_http.begin(this->rssUrl); + + int httpCode = this->_http.GET(); + + if (httpCode > 0) + { + this->rssData = this->_http.getString(); + if (this->rssData.length() == 0) + { + Serial.println("Error: Empty RSS feed response!"); + return; + } + this->currentMessage = this->parseRSS(this->rssData); + Serial.println("[DWD]: Current Message = " + this->currentMessage); + if (this->currentMessage.equals(this->lastMessage) == false) + { + if (this->currentMessage.indexOf(emptyDWDResponse) == -1) { + this->_dirty = true; + } + this->lastMessage = this->currentMessage; + } + } + else + { + Serial.printf("HTTP request failed, error: %s\n", this->_http.errorToString(httpCode).c_str()); + } + + this->_http.end(); +} +String DWDClient::parseRSS(String xmlData) +{ + int itemStart = 0, itemEnd = 0; + + while ((itemStart = xmlData.indexOf("", itemEnd)) != -1) + { + itemEnd = xmlData.indexOf("", itemStart); + if (itemEnd == -1) + break; + + String itemData = xmlData.substring(itemStart, itemEnd); // Extract the block + + // Extract Description (with CDATA) + // static String descriptionTag = ; + String description = this->extractTagContent(itemData, "description"); + description.replace("DWD UNWETTERWARNUNG:", "DWD:"); + description.replace("DWD WETTERWARNUNG:", "DWD:"); + description.replace(" in ", " "); + description.replace(" von ", "/"); + + int pos = description.indexOf("Quelle:"); + if (pos > -1) + { + description = description.substring(0, pos); // Truncate at "Quelle:" + } + return description; + } + return emptyString; +} +String DWDClient::extractTagContent(String source, String tag) +{ + int start = source.indexOf("<" + tag + ">"); + int end = source.indexOf("", start); + + if (start == -1 || end == -1) + return "Not Found"; + + String content = source.substring(start + tag.length() + 2, end); + + // Handle CDATA safely + int cdataStart = content.indexOf("", cdataStart); + + if (cdataStart != -1 && cdataEnd != -1 && cdataEnd > cdataStart) + { + content = content.substring(cdataStart + 9, cdataEnd); // Extract CDATA content + } + + content.replace("
", " "); + content.replace("\n", " "); + + return content; +} diff --git a/src/dwd.h b/src/dwd.h new file mode 100644 index 0000000..544cbca --- /dev/null +++ b/src/dwd.h @@ -0,0 +1,29 @@ +#if !defined(_DWD_H) +#define _DWD_H + +#include +#include +class DWDClient +{ +public: + WiFiClient *_client; + String currentMessage; + + explicit DWDClient(WiFiClient *client); + void begin(int intervalMinutes, String region); + void check(); + void loop(); + bool isDirty(); + +private: + bool _dirty; + unsigned long lastCheck = 0; + unsigned long checkInterval = 300000; + String lastMessage; + String rssUrl; + String rssData; + HTTPClient _http; + String parseRSS(String xmlData); + String extractTagContent(String source, String tag); +}; +#endif \ No newline at end of file diff --git a/src/main.cpp b/src/main.cpp new file mode 100644 index 0000000..b0a14a9 --- /dev/null +++ b/src/main.cpp @@ -0,0 +1,428 @@ +#include + +#include + +SX1278 radio = new Module(LORA_SS, LORA_DIO0, LORA_RST); +POCSAGTransmitter transmitter; + +cfg_t globcfg; +bool mqtt_enable = false; +bool wifi_hotspot = false; +bool old_tx_state = false; +char *timeString = new char[33]{}; +// +// +// +void setup() +{ + setup_leds(); + + delay(2e2); + Serial.begin(115200); + + display_setup(); + setup_storage(&globcfg); + display_update_state("loaded cfg"); + // memdebug + Serial.print("Free Heap Size after reading Config:"); + Serial.println(ESP.getFreeHeap()); + + Serial.println("starting up modem"); + float bitrate = globcfg.tx_baud / 1000.0; + int state = radio.beginFSK(globcfg.tx_freq, bitrate, globcfg.tx_dev); + if (state == 0) { + Serial.println(F("success!")); + } else { + Serial.print(F("failed, code ")); + Serial.println(state); + display_update_state("modem fail"); + // TODO: add solution to this + while (true) { + digitalWrite(PIN_LED, HIGH); + delay(850); + digitalWrite(PIN_LED, LOW); + delay(250); + } + } + // + radio.setOutputPower(globcfg.tx_power); + Serial.println("initialized modem"); + display_update_state("init modem"); + transmitter.begin(&radio); + Serial.println("initialized transmitter"); + display_update_state("init pocsag-stack"); + // + setup_network(); + webserver_setup(); + setup_mqtt(); + setup_broadcasts(); + // memdebug + Serial.print("Free Heap Size after setup:"); + Serial.println(ESP.getFreeHeap()); + // leds + digitalWrite(PIN_LED, LOW); +} +// +// Network: WiFi 1+2 or Hotspot-Mode +// +void setup_network() +{ + WiFi.mode(WIFI_STA); + WiFi.setHostname(globcfg.device_name); + + unsigned long connectTimeout = 10e3; + uint8_t connectResult; + bool wifi1valid = strlen(globcfg.wifi1_ssid) > 2; + bool wifi2valid = strlen(globcfg.wifi2_ssid) > 2; + // + if (wifi1valid) + { + display_update_state("trying wifi 1"); + Serial.println("connecting to WiFi 1"); + WiFi.begin(globcfg.wifi1_ssid, globcfg.wifi1_pass); + while ((WiFi.status() != WL_CONNECTED) && (millis() < 10000)) + { + delay(10); + } + connectResult = WiFi.status(); + Serial.printf("result=%d\n", connectResult); + if (connectResult == WL_CONNECTED) + { + Serial.println(WiFi.localIP()); + return; + } + // while (WiFi.status() != WL_CONNECTED) + // { + // delay(500); + // Serial.print("."); + // } + } + if (wifi2valid) + { + display_update_state("trying wifi 2"); + Serial.println("connecting to WiFi 2"); + WiFi.begin(globcfg.wifi2_ssid, globcfg.wifi2_pass); + while ((WiFi.status() != WL_CONNECTED) && (millis() < 22000)) + { + delay(10); + } + connectResult = WiFi.status(); + Serial.printf("result=%d\n", connectResult); + if (connectResult == WL_CONNECTED) + { + Serial.println(WiFi.localIP()); + return; + } + } + // + display_update_state("init hotspot mode"); + Serial.println("wifi failed to connect, going AP"); + WiFi.mode(WIFI_AP); + WiFi.softAP(globcfg.ap_ssid, globcfg.ap_pass); + wifi_hotspot = true; +} +// +// MQTT +// +WiFiClient wifiMqttClient; +PubSubClient mqttClient(wifiMqttClient); +String clear_topic, transmit_topic, state_topic; +void setup_mqtt() +{ + if (wifi_hotspot) + { + Serial.println("hotspot prevents mqtt"); + return; + } // dont + mqtt_enable = strlen(globcfg.mqtt_host) > 5; + if (!mqtt_enable) + { + Serial.println("MQTT not wanted, exiting setup"); + return; + } // if we should not do this + mqttClient.setServer(globcfg.mqtt_host, globcfg.mqtt_port); + display_update_state("connecting to MQTT"); + Serial.printf("connecting to mqtt %s\n", globcfg.mqtt_host); + if (mqttClient.connect(globcfg.mqtt_user, globcfg.mqtt_user, globcfg.mqtt_pass)) + { + // succ + mqttClient.setCallback(mqtt_callback); + // + transmit_topic = String(globcfg.mqtt_topic); + transmit_topic.concat("/transmit"); + mqttClient.subscribe(transmit_topic.c_str()); + + clear_topic = String(globcfg.mqtt_topic); + clear_topic.concat("/clear"); + mqttClient.subscribe(clear_topic.c_str()); + + state_topic = String(globcfg.mqtt_topic); + state_topic.concat("/state"); + mqttClient.publish(state_topic.c_str(), "false"); + // + Serial.println("connected to mqtt"); + } + else + { + Serial.printf("failed to connect to mqtt, state= %d\n", mqttClient.state()); + } +} +void mqtt_callback(char *topic, byte *payload, unsigned int length) +{ + JsonDocument doc; + deserializeJson(doc, payload); + if (clear_topic.equals(topic)) + { + txControllerBatchClear(); + return; + } + Serial.println("rx mqtt"); + + if (doc["ric"].is() && doc["msg"].is()) + { + String text = doc["msg"].as(); + text = txHandleUmlauts(text); + int addr = doc["ric"].as(); + int func = 3; + if (doc["fun"].is()) + { + func = doc["fun"].as(); + } + char *messageText = new char[text.length() + 1]{}; + text.toCharArray(messageText, text.length() + 1); + txControllerInsert((uint32_t)addr, (uint8_t)func, messageText); + delete []messageText; + // if (transmitter.isActive() == false) + // { + // if (mqtt_enable) + // { + // mqttClient.publish(state_topic.c_str(), "true"); + // } + // } + txControllerBatchStart(); + } +} +void mqtt_loop(bool tx_state) { + mqttClient.loop(); + if (old_tx_state != tx_state) { + if (tx_state) + mqttClient.publish(state_topic.c_str(), "true"); + else + mqttClient.publish(state_topic.c_str(), "false"); + } +} +// +// LEDs +// +void setup_leds() { + pinMode(PIN_LED, OUTPUT); + digitalWrite(PIN_LED, HIGH); +} +void leds_loop(bool tx_state) { + if (old_tx_state != tx_state) + digitalWrite(PIN_LED, tx_state); +} +// +// +// +void serlog_loop(bool tx_state) { + if (tx_state != old_tx_state) + if (tx_state) + Serial.println("Transmitter Active"); + else + Serial.println("Transmitter Standby"); +} +// +// +// +// +void loop() +{ + bool tx_state = transmitter.isActive(); + display_loop(tx_state, &transmitter, &globcfg, timeString); + if (old_tx_state == true && tx_state == false && globcfg.tx_empty_queue) + txControllerBatchClear(); + // + serlog_loop(tx_state); + leds_loop(tx_state); + if (mqtt_enable) + mqtt_loop(tx_state); + + broadcast_loop(); + heap_loop(); + old_tx_state = tx_state; +} +// +// TX Stack +// +struct UmlautMap { + char utf8; + char replacement; +}; +UmlautMap umlautMapGermany[] = { + {0xDC, 0x5D}, {0xC4, 0x5B}, {0xD6, 0x5C}, + {0xFC, 0x7D}, {0xE4, 0x7B}, {0xF6, 0x7C}, + {0xDF, 0x7E} +}; +UmlautMap umlautMapIntl[] = { + {0xDC, 0x56}, {0xC4, 0x41}, {0xD6, 0x4F}, + {0xFC, 0x75}, {0xE4, 0x61}, {0xF6, 0x6F}, + {0xDF, 0x73} +}; +String txHandleUmlauts(String input) { + bool useGermanMap = globcfg.pocsag_german; + UmlautMap* map = useGermanMap ? umlautMapGermany : umlautMapIntl; + int mapSize = useGermanMap ? sizeof(umlautMapGermany) / sizeof(UmlautMap) + : sizeof(umlautMapIntl) / sizeof(UmlautMap); + for (int i = 0; i < mapSize; i++) { + input.replace(map[i].utf8, map[i].replacement); + } + return input; +} +void txControllerInsert(uint32_t ric, uint8_t functionBit, char *text) +{ + transmitter.queuePage(ric, functionBit, text); +} +void txControllerBatchStart() +{ + transmitter.transmitBatch(); +} +void txControllerBatchClear() +{ + transmitter.clearQueue(); +} +int txControllerBatchQueueCount() +{ + return transmitter.getQueueCount(); +} +// +// DWD + MoWaS + Time + Idle +// +WiFiClient wifiHttpClient; +DWDClient dwdClient(&wifiHttpClient); +MoWaSClient mowasClient(&wifiHttpClient); + +Timezone utcTime; +Timezone localTime; +bool time_beacon_first = true; +unsigned long lastTimeBeaconTime = 0; + + +String formattedTime; +char *idleBeaconText = new char[1]{}; +bool idle_beacon_first = true; +unsigned long lastIdleBeaconTime = 0; +// +void setup_broadcasts() +{ + if (wifi_hotspot) { + mqtt_enable = false; + globcfg.dwd_enable = false; + globcfg.mowas_enable = false; + globcfg.time_enable = false; + } + // DWD + if (globcfg.dwd_interval < 1) + globcfg.dwd_enable = false; + if (globcfg.dwd_enable) + dwdClient.begin(globcfg.dwd_interval, globcfg.dwd_region); + // MoWaS + if (globcfg.mowas_interval < 1) + globcfg.mowas_enable = false; + if (globcfg.mowas_enable) + mowasClient.begin(globcfg.mowas_interval, globcfg.mowas_region); + // Time + if (globcfg.time_enable) { + waitForSync(30e3); + localTime.setLocation(globcfg.time_zone); + } +} +void broadcast_loop() +{ + if (globcfg.dwd_enable) + { + dwdClient.loop(); + if (dwdClient.isDirty()) + { + dwdClient.currentMessage = txHandleUmlauts(dwdClient.currentMessage); + char *messageText = new char[dwdClient.currentMessage.length() + 1]{}; + dwdClient.currentMessage.toCharArray(messageText, dwdClient.currentMessage.length() + 1); + Serial.println(F("[DWD] Transmitting Warning")); + transmitter.queuePage(globcfg.broadcast_ric, globcfg.dwd_fun + 0, messageText); + delete []messageText; + transmitter.transmitBatch(); + } + } + if (globcfg.mowas_enable) + { + mowasClient.loop(); + if (mowasClient.isDirty()) + { + mowasClient.currentMessage = txHandleUmlauts(mowasClient.currentMessage); + char *messageText = new char[mowasClient.currentMessage.length() + 1]{}; + mowasClient.currentMessage.toCharArray(messageText, mowasClient.currentMessage.length() + 1); + Serial.println(F("[MoWaS] Transmitting Warning")); + transmitter.queuePage(globcfg.broadcast_ric, globcfg.mowas_fun + 0, messageText); + delete []messageText; + transmitter.transmitBatch(); + } + } + if (globcfg.time_enable) { + events(); + + // re-use this var ;) + formattedTime = utcTime.dateTime("Y-m-d H:i:s"); + formattedTime.toCharArray(timeString, formattedTime.length() + 1); + + if (time_beacon_first || millis() - lastTimeBeaconTime >= globcfg.time_interval * 60e3) { + lastTimeBeaconTime = millis(); + time_beacon_first = false; + switch (globcfg.time_mode) { + case 0: // TPL-Eng SubRIC 1(B) @ Service OTA + formattedTime = "***1***" + utcTime.dateTime("Hidmy"); + break; + case 1: // TPL-Ger + formattedTime = "#ZEIT=" + localTime.dateTime("Hidmy") + "#ZEIT=" + localTime.dateTime("Hidmy"); + break; + case 2: // Shitphone + formattedTime = ";TIME=" + localTime.dateTime("Hidmy") + ";TIME=" + localTime.dateTime("Hidmy"); + break; + } + char *messageText = new char[formattedTime.length() + 1]{}; + formattedTime.toCharArray(messageText, formattedTime.length() + 1); + Serial.println(F("[Time] Transmitting Time")); + transmitter.queuePage(globcfg.time_ric, globcfg.time_fun + 0, messageText); + delete []messageText; + formattedTime.clear(); + transmitter.transmitBatch(); + } + } + if (globcfg.idle_enable) { + if (idle_beacon_first || millis() - lastIdleBeaconTime >= globcfg.idle_interval * 60e3) { + lastIdleBeaconTime = millis(); + idle_beacon_first = false; + Serial.println(F("[Idle] Transmitting Beacon")); + transmitter.queuePage(0, 0, idleBeaconText); + transmitter.transmitBatch(); + } + } +} +void broadcastTriggerTimeBeacon() { + time_beacon_first = true; +} +// +// Heap Management Logs +// +unsigned long lastReportTime = 0; +const unsigned long reportInterval = 60000; +void heap_loop() +{ + if (millis() - lastReportTime >= reportInterval) + { + lastReportTime = millis(); + Serial.print(F("Free Heap Size: ")); + Serial.print(ESP.getFreeHeap()); + Serial.print(F("Free min Heap Size: ")); + Serial.println(ESP.getMinFreeHeap()); + } +} \ No newline at end of file diff --git a/src/main.h b/src/main.h new file mode 100644 index 0000000..f1faa95 --- /dev/null +++ b/src/main.h @@ -0,0 +1,55 @@ +#if !defined(_MAIN_H) +#define _MAIN_H +#define PIN_LED 25 + +#include +#include +#include +#include +#include +#include + +#include +#include + +#ifdef DEBUG + #define dbg(format, arg...) {printf("%s:%d " format , __FILE__ , __LINE__ , ## arg);} + #define err(format, arg...) {printf("%s:%d " format , __FILE__ , __LINE__ , ## arg);} + #define info(format, arg...) {printf("%s:%d " format , __FILE__ , __LINE__ , ## arg);} + #define warn(format, arg...) {printf("%s:%d " format , __FILE__ , __LINE__ , ## arg);} +#else + #define dbg(format, arg...) do {} while (0) + #define err(format, arg...) {printf("%s:%d " format , __FILE__ , __LINE__ , ## arg);} + #define info(format, arg...) {printf("%s:%d " format , __FILE__ , __LINE__ , ## arg);} + #define warn(format, arg...) {printf("%s:%d " format , __FILE__ , __LINE__ , ## arg);} +#endif + +#define RADIOLIB_LOW_LEVEL 1 +#define RADIOLIB_GODMODE 1 +// +// #define POCSAG_DEBUG 1 +// #define POCSAG_DEBUG_PORT Serial +#include +#include +#include +#include +#include +#include + +void txControllerBatchClear(); +void txControllerBatchStart(); +int txControllerBatchQueueCount(); +String txHandleUmlauts(String message); +void txControllerInsert(uint32_t ric, uint8_t functionBit, char *text); +void setup_radio(); +void setup_network(); +void setup_mqtt(); +void setup_broadcasts(); +void setup_leds(); +// +void mqtt_callback(char* topic, byte* payload, unsigned int length); +// +void broadcast_loop(); +void broadcastTriggerTimeBeacon(); +void heap_loop(); +#endif \ No newline at end of file diff --git a/src/mowas.cpp b/src/mowas.cpp new file mode 100644 index 0000000..aba6e5d --- /dev/null +++ b/src/mowas.cpp @@ -0,0 +1,82 @@ +#include "mowas.h" + +String mowasDWDMessageIDPrefix = "dwd."; +MoWaSClient::MoWaSClient(WiFiClient *client) +{ + _client = client; +} + +void MoWaSClient::begin(int intervalMinutes, String region) +{ + this->dashboardUrl = "https://warnung.bund.de/api31/dashboard/"; + this->dashboardUrl.concat(region); + this->dashboardUrl.concat(".json"); + + this->checkInterval = 60e3 * intervalMinutes; + Serial.printf("[MoWas]: check Interval : %dms\n", this->checkInterval); + this->check(); +} +void MoWaSClient::loop() +{ + if (millis() - this->lastCheck >= this->checkInterval) + { + // retry once + if (!this->check()) + this->check(); + this->lastCheck = millis(); + } +} +bool MoWaSClient::isDirty() +{ + if (this->_dirty) + { + this->_dirty = false; + return true; + } + return false; +} +bool MoWaSClient::check() +{ + Serial.println("[MoWaS]: checking " + this->dashboardUrl); + this->_http.begin(this->dashboardUrl); + + int httpCode = this->_http.GET(); + + if (httpCode > 0) + { + this->dashboardData = this->_http.getString(); + if (this->dashboardData.length() == 0) + { + Serial.println("Error: Empty JSON response!"); + return true; + } + this->currentMessage = this->parseDashboard(this->dashboardData); + Serial.println("[MoWaS]: Current Message = " + this->currentMessage); + if (this->currentMessage.equals(this->lastMessage) == false) + { + this->_dirty = true; + this->lastMessage = this->currentMessage; + } + this->_http.end(); + return true; + } + else + { + Serial.printf("HTTP request failed, error: %s\n", this->_http.errorToString(httpCode).c_str()); + this->_http.end(); + return false; + } +} +String MoWaSClient::parseDashboard(String jsonData) +{ + JsonDocument doc; + deserializeJson(doc, jsonData); + if (doc.size() > 0) { + String alarmID = doc[0]["id"]; + // Ignore MoWaS alarms with DWD + if (alarmID.indexOf(mowasDWDMessageIDPrefix) == 0) return emptyString; + + return doc[0]["payload"]["data"]["headline"]; + } + return emptyString; +} diff --git a/src/mowas.h b/src/mowas.h new file mode 100644 index 0000000..7beff5c --- /dev/null +++ b/src/mowas.h @@ -0,0 +1,33 @@ +#if !defined(_MOWAS_H) +#define _MOWAS_H + +#include +#include +#include +class MoWaSClient +{ +public: + WiFiClient *_client; + String currentMessage; + + explicit MoWaSClient(WiFiClient *client); + void begin(int intervalMinutes, String region); + bool check(); + void loop(); + bool isDirty(); + +private: + bool _dirty; + unsigned long lastCheck = 0; + unsigned long checkInterval = 300000; + String lastMessage; + + String dashboardData; + String dashboardUrl; + String warningUrl; + + HTTPClient _http; + String parseDashboard(String jsonData); + String extractTagContent(String source, String tag); +}; +#endif \ No newline at end of file diff --git a/src/pocsag_encoder.cpp b/src/pocsag_encoder.cpp new file mode 100644 index 0000000..eddf827 --- /dev/null +++ b/src/pocsag_encoder.cpp @@ -0,0 +1,246 @@ +#include "pocsag_encoder.h" + +// encoder from here https://github.com/F5OEO/rpitx/blob/master/src/pocsag/pocsag.cpp + +/** + * Calculate the CRC error checking code for the given word. + * Messages use a 10 bit CRC computed from the 21 data bits. + * This is calculated through a binary polynomial long division, returning + * the remainder. + * See https://en.wikipedia.org/wiki/Cyclic_redundancy_check#Computation + * for more information. + */ +uint32_t crc(uint32_t inputMsg) +{ + // Align MSB of denominatorerator with MSB of message + uint32_t denominator = CRC_GENERATOR << 20; + // Message is right-padded with zeroes to the message length + crc length + uint32_t msg = inputMsg << CRC_BITS; + // We iterate until denominator has been right-shifted back to it's original value. + for (int column = 0; column <= 20; column++) + { + // Bit for the column we're aligned to + int msgBit = (msg >> (30 - column)) & 1; + // If the current bit is zero, we don't modify the message this iteration + if (msgBit != 0) + { + // While we would normally subtract in long division, we XOR here. + msg ^= denominator; + } + // Shift the denominator over to align with the next column + denominator >>= 1; + } + // At this point 'msg' contains the CRC value we've calculated + return msg & 0x3FF; +} + +/** + * Calculates the even parity bit for a message. + * If the number of bits in the message is even, return 0, else return 1. + */ +uint32_t parity(uint32_t x) +{ + // Our parity bit + uint32_t p = 0; + // We xor p with each bit of the input value. This works because + // xoring two one-bits will cancel out and leave a zero bit. Thus + // xoring any even number of one bits will result in zero, and xoring + // any odd number of one bits will result in one. + for (int i = 0; i < 32; i++) + { + p ^= (x & 1); + x >>= 1; + } + return p; +} + +/** + * Encodes a 21-bit message by calculating and adding a CRC code and parity bit. + */ +uint32_t encodeCodeword(uint32_t msg) +{ + uint32_t fullCRC = (msg << CRC_BITS) | crc(msg); + uint32_t p = parity(fullCRC); + return (fullCRC << 1) | p; +} + +/** + * ASCII encode a null-terminated string as a series of codewords, written + * to (*out). Returns the number of codewords written. Caller should ensure + * that enough memory is allocated in (*out) to contain the message + * + * initial_offset indicates which word in the current batch the function is + * beginning at, so that it can insert SYNC words at appropriate locations. + */ +uint32_t encodeASCII(uint32_t initial_offset, char *str, uint32_t *out) +{ + // Number of words written to *out + uint32_t numWordsWritten = 0; + + // Data for the current word we're writing + uint32_t currentWord = 0; + + // Nnumber of bits we've written so far to the current word + uint32_t currentNumBits = 0; + + // Position of current word in the current batch + uint32_t wordPosition = initial_offset; + + while (*str != 0) + { + unsigned char c = *str; + str++; + // Encode the character bits backwards + for (int i = 0; i < TEXT_BITS_PER_CHAR; i++) + { + currentWord <<= 1; + currentWord |= (c >> i) & 1; + currentNumBits++; + if (currentNumBits == TEXT_BITS_PER_WORD) + { + // Add the MESSAGE flag to our current word and encode it. + *out = encodeCodeword(currentWord | POCSAG_FLAG_MESSAGE); + out++; + currentWord = 0; + currentNumBits = 0; + numWordsWritten++; + + wordPosition++; + if (wordPosition == POCSAG_BATCH_SIZE) + { + // We've filled a full batch, time to insert a SYNC word + // and start a new one. + *out = POCSAG_SYNC; + out++; + numWordsWritten++; + wordPosition = 0; + } + } + } + } + + // Write remainder of message + if (currentNumBits > 0) + { + // Pad out the word to 20 bits with zeroes + currentWord <<= 20 - currentNumBits; + *out = encodeCodeword(currentWord | POCSAG_FLAG_MESSAGE); + out++; + numWordsWritten++; + + wordPosition++; + if (wordPosition == POCSAG_BATCH_SIZE) + { + // We've filled a full batch, time to insert a SYNC word + // and start a new one. + *out = POCSAG_SYNC; + out++; + numWordsWritten++; + wordPosition = 0; + } + } + return numWordsWritten; +} + +/** + * An address of 21 bits, but only 18 of those bits are encoded in the address + * word itself. The remaining 3 bits are derived from which frame in the batch + * is the address word. This calculates the number of words (not frames!) + * which must precede the address word so that it is in the right spot. These + * words will be filled with the idle value. + */ +int addressOffset(int address) +{ + return (address & 0x7) * POCSAG_FRAME_SIZE; +} + +/** + * Encode a full text POCSAG transmission addressed to (address). + * (*message) is a null terminated C string. + * (*out) is the destination to which the transmission will be written. + */ +void encodeTransmission(int repeatIndex, int address, int fb, char *message, uint32_t *out) +{ + // Encode preamble + // Alternating 1,0,1,0 bits for 576 bits, used for receiver to synchronize + // with transmitter + if (repeatIndex == 0) + for (int i = 0; i < POCSAG_PREAMBLE_LENGTH / 32; i++) + { + *out = 0xAAAAAAAA; + out++; + } + + uint32_t *start = out; + + // Sync + *out = POCSAG_SYNC; + out++; + + // Write out padding before adderss word + int prefixLength = addressOffset(address); + for (int i = 0; i < prefixLength; i++) + { + *out = POCSAG_IDLE; + out++; + } + + // Write address word. + // The last two bits of word's data contain the message type (function bits) + // The 3 least significant bits are dropped, as those are encoded by the + // word's location. + *out = encodeCodeword(((address >> 3) << 2) | fb); + out++; + + out += encodeASCII(addressOffset(address) + 1, message, out); + + // Finally, write an IDLE word indicating the end of the message + *out = POCSAG_IDLE; + out++; + + // Pad out the last batch with IDLE to write multiple of BATCH_SIZE + 1 + // words (+ 1 is there because of the SYNC words) + size_t written = out - start; + size_t padding = (POCSAG_BATCH_SIZE + 1) - written % (POCSAG_BATCH_SIZE + 1); + for (size_t i = 0; i < padding; i++) + { + *out = POCSAG_IDLE; + out++; + } +} + +/** + * Calculates the length in words of a text POCSAG message, given the address + * and the number of characters to be transmitted. + */ +size_t textMessageLength(int repeatIndex, int address, int numChars) +{ + size_t numWords = 0; + + // Padding before address word. + numWords += addressOffset(address); + + // Address word itself + numWords++; + + // numChars * 7 bits per character / 20 bits per word, rounding up + numWords += (numChars * TEXT_BITS_PER_CHAR + (TEXT_BITS_PER_WORD - 1)) / TEXT_BITS_PER_WORD; + + // Idle word representing end of message + numWords++; + + // Pad out last batch with idles + numWords += POCSAG_BATCH_SIZE - (numWords % POCSAG_BATCH_SIZE); + + // Batches consist of 16 words each and are preceded by a sync word. + // So we add one word for every 16 message words + numWords += numWords / POCSAG_BATCH_SIZE; + + // Preamble of 576 alternating 1,0,1,0 bits before the message + // Even though this comes first, we add it to the length last so it + // doesn't affect the other word-based calculations + if (repeatIndex == 0) + numWords += POCSAG_PREAMBLE_LENGTH / 32; + + return numWords; +} diff --git a/src/pocsag_encoder.h b/src/pocsag_encoder.h new file mode 100644 index 0000000..14c154d --- /dev/null +++ b/src/pocsag_encoder.h @@ -0,0 +1,29 @@ +#include +#include + +#define POCSAG_SYNC 0x7CD215D8 +#define POCSAG_IDLE 0x7A89C197 + +#define POCSAG_FRAME_SIZE 2 +#define POCSAG_BATCH_SIZE 16 + +#define POCSAG_PREAMBLE_LENGTH 576 + +#define POCSAG_FLAG_ADDRESS 0x000000 +#define POCSAG_FLAG_MESSAGE 0x100000 + +#define POCSAG_FLAG_TEXT_DATA 0x3 +#define POCSAG_FLAG_NUMERIC_DATA = 0x0 + +#define TEXT_BITS_PER_WORD 20 +#define TEXT_BITS_PER_CHAR 7 +#define CRC_BITS 10 +#define CRC_GENERATOR 0b11101101001 + +uint32_t crc(uint32_t inputMsg); +uint32_t parity(uint32_t x); +uint32_t encodeCodeword(uint32_t msg); +uint32_t encodeASCII(uint32_t initial_offset, char *str, uint32_t *out); +int addressOffset(int address); +void encodeTransmission(int repeatIndex, int address, int fb, char *message, uint32_t *out); +size_t textMessageLength(int repeatIndex, int address, int numChars); \ No newline at end of file diff --git a/src/pocsag_transmitter.cpp b/src/pocsag_transmitter.cpp new file mode 100644 index 0000000..8f060eb --- /dev/null +++ b/src/pocsag_transmitter.cpp @@ -0,0 +1,151 @@ +#include "pocsag_transmitter.h" +#include "pocsag_encoder.h" + +POCSAGTransmitter::POCSAGTransmitter() +{ + POCSAG_DEBUG_PRINTLN("malloc'ating and prefilling encodingBuffer"); + for (int i = 0; i < POCSAG_MAX_BUFFER_SIZE; i++) + transmitterData[i] = 0xFFFFFFFF; + for (int i = 0; i < POCSAG_MAX_ENCODING_BUFFER_SIZE; i++) + encodingBuffer[i] = 0xFFFFFFFF; +} + +void POCSAGTransmitter::begin(SX1278 *radio) +{ + _radio = radio; + _currentRadio = _radio; + + //_radio->setFrequencyDeviation(4.5); + // 512 baud testing + // uint16_t bitRate = 62500; //62500; //(SX127X_CRYSTAL_FREQ * 1000.0) / 0.512; + //_radio->_mod->SPIsetRegValue(SX127X_REG_BITRATE_MSB, (bitRate & 0xFF00) >> 8, 7, 0); + //_radio->_mod->SPIsetRegValue(SX127X_REG_BITRATE_LSB, bitRate & 0x00FF, 7, 0); + + _radio->setCRC(false); + _radio->setEncoding(RADIOLIB_ENCODING_NRZ); + _radio->setDataShaping(RADIOLIB_SHAPING_NONE); + _radio->setPreambleLength(0); + //_radio->setBitRate(1.2); + // pinz + pinMode(POCSAG_PIN_DIO1, INPUT); + pinMode(POCSAG_PIN_DIO2, OUTPUT); +} + +void test2(); + +void POCSAGTransmitter::clearQueue() +{ + queueCount = 0; + transmitterLength = 0; +} +int8_t POCSAGTransmitter::getQueueCount() +{ + return queueCount; +} +bool POCSAGTransmitter::isActive() +{ + return transmitterState; +} +uint16_t POCSAGTransmitter::getTransmitLength() +{ + return transmitterLength; +} +uint16_t POCSAGTransmitter::getTransmitPos() +{ + return transmitterOffset; +} +uint8_t POCSAGTransmitter::getBitOffset() +{ + return transmitterBitOffset; +} +uint32_t POCSAGTransmitter::getTransmitWord() +{ + return transmitterData[ transmitterOffset ]; +} +void POCSAGTransmitter::queuePage(uint32_t ric, uint8_t functionBit, char *text) +{ + size_t beforeLength = transmitterLength + 0; + size_t messageLength = textMessageLength(queueCount, ric, strlen(text)); + // uint32_t *transmission = (uint32_t *)malloc(sizeof(uint32_t) * messageLength); + uint32_t *encodingBufferPointer = encodingBuffer; + encodeTransmission(queueCount, ric, functionBit, text, encodingBufferPointer); + transmitterLength += messageLength; + +#ifdef POCSAG_DEBUG + POCSAG_DEBUG_PRINTLN(); + POCSAG_DEBUG_PRINT("RIC: "); + POCSAG_DEBUG_PRINT(ric, DEC); + POCSAG_DEBUG_PRINT(" F: "); + POCSAG_DEBUG_PRINTLN(functionBit, DEC); + POCSAG_DEBUG_PRINT("TEXT: "); + POCSAG_DEBUG_PRINTLN(text); + POCSAG_DEBUG_PRINTLN(); + POCSAG_DEBUG_PRINT("messageLength="); + POCSAG_DEBUG_PRINTLN(messageLength, DEC); + POCSAG_DEBUG_PRINTLN("MESSAGE encoded:"); + for (size_t i = 0; i < messageLength; i++) + POCSAG_DEBUG_PRINT(encodingBuffer[i], HEX); + POCSAG_DEBUG_PRINTLN(); +#endif + + // copy it to the correct place lol + for (size_t i = 0; i < messageLength; i++) + { + transmitterData[beforeLength + i] = encodingBuffer[i]; + } + // free(transmission); + queueCount++; +} +bool POCSAGTransmitter::transmitBatch() +{ + if (transmitterState > 0) + return false; // we already started + if (transmitterLength < 16) + return false; // dont start if we have less than 16 bytes + + _radio->standby(); +#ifdef POCSAG_DEBUG + POCSAG_DEBUG_PRINT(F("transmitterData: ")); + POCSAG_DEBUG_PRINTLN((unsigned long int)transmitterData, HEX); + + POCSAG_DEBUG_PRINT(F("transmitterData: ")); + POCSAG_DEBUG_PRINTLN((unsigned long int)transmitterData, HEX); + POCSAG_DEBUG_PRINTLN(); + POCSAG_DEBUG_PRINTLN("TX encoded in big buffer:"); + for (size_t i = 0; i < transmitterLength; i++) + POCSAG_DEBUG_PRINT(transmitterData[i], HEX); + POCSAG_DEBUG_PRINTLN(); + POCSAG_DEBUG_PRINT("transmitterLength="); + POCSAG_DEBUG_PRINTLN(transmitterLength, DEC); + + POCSAG_DEBUG_PRINT(F("transmitterData: ")); + POCSAG_DEBUG_PRINTLN((unsigned long int)transmitterData, HEX); + + POCSAG_DEBUG_PRINTLN("starting tx"); +#endif + transmitterState = true; + transmitterBitOffset = 32; + transmitterOffset = 0; + // attach DCLK interrupt + attachInterrupt(digitalPinToInterrupt(POCSAG_PIN_DIO1), onTransmitterClock, RISING); + delay(10); // giving it some time + _currentRadio->transmitDirect(); + return true; +} + +static void IRAM_ATTR onTransmitterClock() +{ + transmitterBitOffset--; + digitalWrite(POCSAG_PIN_DIO2, ((transmitterData[transmitterOffset] >> transmitterBitOffset) & 1) == 0); + if (transmitterBitOffset == 0) + { // lets shift to next byte + transmitterBitOffset = 32; + transmitterOffset++; + } + if (transmitterOffset > transmitterLength) + { + _currentRadio->standby(); + detachInterrupt(POCSAG_PIN_DIO1); + transmitterState = false; + } +} \ No newline at end of file diff --git a/src/pocsag_transmitter.h b/src/pocsag_transmitter.h new file mode 100644 index 0000000..60ea615 --- /dev/null +++ b/src/pocsag_transmitter.h @@ -0,0 +1,66 @@ +#if !defined(_POCSAG_TRANSMITTER_H) +#define _POCSAG_TRANSMITTER_H +#include + +#define POCSAG_MAX_ENCODING_BUFFER_SIZE 70 // 70 QBYTEs should be enough for max 80char Messages +#define POCSAG_MAX_BUFFER_SIZE 2000 // 2000 QBYTEs +#define POCSAG_PIN_DIO1 12 // DCLK +#define POCSAG_PIN_DIO2 14 // DATA + +// #define POCSAG_DEBUG +#define POCSAG_DEBUG_PORT Serial +#if defined(POCSAG_DEBUG) +#define POCSAG_DEBUG_PRINT(...) \ + { \ + POCSAG_DEBUG_PORT.print(__VA_ARGS__); \ + } +#define POCSAG_DEBUG_PRINTLN(...) \ + { \ + POCSAG_DEBUG_PORT.println(__VA_ARGS__); \ + } +#else +#define POCSAG_DEBUG_PRINT(...) \ + { \ + } +#define POCSAG_DEBUG_PRINTLN(...) \ + { \ + } +#endif + +/*! +* POCSAG Transmitter +- catSIXe, encoder is partly transformed from RPITX, with my old contributions(batch-encoding etc.) from the old github +*/ + +static SX1278 *_currentRadio; // we need to put this pointer static for the ISR +static uint32_t transmitterData[POCSAG_MAX_BUFFER_SIZE]; // complete transmission +static uint32_t encodingBuffer[POCSAG_MAX_ENCODING_BUFFER_SIZE]; // small static allocated memory, for storing a encoded chunk + +static uint16_t transmitterLength; +static uint16_t transmitterOffset; +static uint8_t transmitterBitOffset; +static bool transmitterState; +static void IRAM_ATTR onTransmitterClock(); + +class POCSAGTransmitter +{ +public: + SX1278 *_radio; + explicit POCSAGTransmitter(); + void begin(SX1278 *radio); + void clearQueue(); + int8_t getQueueCount(); + bool isActive(); + void queuePage(uint32_t ric, uint8_t functionBit, char *text); + bool transmitBatch(); + void test(); + + uint16_t getTransmitPos(); + uint16_t getTransmitLength(); + uint32_t getTransmitWord(); + uint8_t getBitOffset(); +private: + int8_t queueCount = 0; +}; + +#endif \ No newline at end of file diff --git a/src/utils.cpp b/src/utils.cpp new file mode 100644 index 0000000..4fe6cc5 --- /dev/null +++ b/src/utils.cpp @@ -0,0 +1,12 @@ +#include + +String replaceUmlauts(String msg) { + msg.replace("ä", "ae"); + msg.replace("ö", "oe"); + msg.replace("ü", "ue"); + msg.replace("Ä", "Ae"); + msg.replace("Ö", "Oe"); + msg.replace("Ü", "Ue"); + msg.replace("ß", "ss"); + return msg; +} \ No newline at end of file diff --git a/src/webserver.cpp b/src/webserver.cpp new file mode 100644 index 0000000..0d3a0c8 --- /dev/null +++ b/src/webserver.cpp @@ -0,0 +1,426 @@ +#include +#include +#include "main.h" + + +extern const uint8_t data_index_html_start[] asm("_binary_data_index_html_start"); +extern const uint8_t data_index_html_end[] asm("_binary_data_index_html_end"); +extern const uint8_t data_script_js_start[] asm("_binary_data_script_js_start"); +extern const uint8_t data_script_js_end[] asm("_binary_data_script_js_end"); +extern const uint8_t data_style_css_start[] asm("_binary_data_style_css_start"); +extern const uint8_t data_style_css_end[] asm("_binary_data_style_css_end"); + +AsyncWebServer server(80); +// static AsyncWebSocket ws("/ws"); +// static AsyncEventSource events("/events"); +// +void handleNotFound(AsyncWebServerRequest *request) { + request->send(404, "text/plain", "Not found"); +} +// +// void onEvent(AsyncWebSocket *server, AsyncWebSocketClient *client, AwsEventType type, void *arg, uint8_t *data, size_t len) { +// if (type == WS_EVT_CONNECT) { +// // client connected +// info("ws[%s][%u] connect\n", server->url(), client->id()); +// // String str = get_settings(); +// // client->printf("%s", str.c_str()); +// client->ping(); +// } else if (type == WS_EVT_DISCONNECT) { +// // client disconnected +// info("ws[%s][%u] disconnect: %u\n", server->url(), client->id()); +// } else if (type == WS_EVT_ERROR) { +// // error was received from the other end +// info("ws[%s][%u] error(%u): %s\n", server->url(), client->id(), +// *((uint16_t *)arg), (char *)data); +// } else if (type == WS_EVT_PONG) { +// // pong message was received (in response to a ping request maybe) +// info("ws[%s][%u] pong[%u]: %s\n", server->url(), client->id(), len, (len) ? (char *)data : ""); +// } else if (type == WS_EVT_DATA) { +// // data packet +// AwsFrameInfo *info = (AwsFrameInfo *)arg; +// if (info->final && info->index == 0 && info->len == len) { +// // the whole message is in a single frame and we got all of it's +// // data info("ws[%s][%u] %s-message[%llu]: ", server->url(), +// // client->id(), (info->opcode == WS_TEXT) ? "text" : "binary", +// // info->len); +// if (info->opcode == WS_TEXT) { +// data[len] = 0; +// info("data: %s\n", (char *)data); +// // parse_cmd((char *)data, client); +// } +// } +// } +// } +// +static void redirectHomeResponse(AsyncWebServerRequest *request, String location) { + AsyncWebServerResponse *response = request->beginResponse(303, "text/plain", ""); + response->addHeader("Location", location); + response->addHeader("Access-Control-Allow-Origin", "*"); + request->send(response); +} +// + static void insertPage(AsyncWebServerRequest *request) { + uint32_t address = 0; + int ric = -1; + int fun = 0; + String message; + // + if (request->hasArg("text")) { + message = request->arg("text"); + message = txHandleUmlauts(message); + } + if (request->hasArg("ric")) { + ric = request->arg("ric").toInt(); + address = ric + 0; + } + if (request->hasArg("fun")) { + fun = request->arg("fun").toInt(); + } + Serial.printf("RIC: %d -> %d MSG: %s\n\n", ric, address, message); + + if (ric > 0) { + char *messageText = new char[message.length() + 1]{}; + message.toCharArray(messageText, message.length() + 1); + // messageText[ message.length() ] = 0x20; + txControllerInsert(address, fun + 0, messageText); + delete []messageText; + + if (request->hasArg("addtx")) { + txControllerBatchStart(); + } + } + redirectHomeResponse(request, "/"); + } + // + static void triggerTimeBeacon(AsyncWebServerRequest *request) { + broadcastTriggerTimeBeacon(); + redirectHomeResponse(request, "/#time"); + } + + static void transmit(AsyncWebServerRequest *request) { + txControllerBatchStart(); + redirectHomeResponse(request, "/"); + } + static void clearQueue(AsyncWebServerRequest *request) { + redirectHomeResponse(request, "/"); + } + static void resetConfigReboot(AsyncWebServerRequest *request) { + redirectHomeResponse(request, "/"); + create_default_config(); + esp_cpu_reset(1); + esp_cpu_reset(0); + } + static void justReboot(AsyncWebServerRequest *request) { + redirectHomeResponse(request, "/"); + esp_cpu_reset(1); + esp_cpu_reset(0); + } + // + static void setAPCfg(AsyncWebServerRequest *request) { + String ssid, pass; + // + if (request->hasArg("ssid")) ssid = request->arg("ssid"); + if (request->hasArg("pass")) pass = request->arg("pass"); + cfg_startTransaction(); + cfg_adjust("ap_ssid", ssid); + cfg_adjust("ap_pass", pass); + cfg_write(); + redirectHomeResponse(request, "/#wifi"); + } + static void setWifi1Cfg(AsyncWebServerRequest *request) { + String ssid, pass; + // + if (request->hasArg("ssid")) ssid = request->arg("ssid"); + if (request->hasArg("pass")) pass = request->arg("pass"); + cfg_startTransaction(); + cfg_adjust("wifi1_ssid", ssid); + cfg_adjust("wifi1_pass", pass); + cfg_write(); + redirectHomeResponse(request, "/#wifi"); + } + static void setWifi2Cfg(AsyncWebServerRequest *request) { + String ssid, pass; + // + if (request->hasArg("ssid")) ssid = request->arg("ssid"); + if (request->hasArg("pass")) pass = request->arg("pass"); + cfg_startTransaction(); + cfg_adjust("wifi2_ssid", ssid); + cfg_adjust("wifi2_pass", pass); + cfg_write(); + redirectHomeResponse(request, "/#wifi"); + } + // + static void setTransmitterCfg(AsyncWebServerRequest *request) { + float tx_freq, tx_dev; + int tx_power, tx_baud; + bool tx_empty_queue, pocsag_german; + // + cfg_startTransaction(); + if (request->hasArg("tx_freq")) { + tx_freq = request->arg("tx_freq").toFloat(); + cfg_adjust("tx_freq", tx_freq); + } + if (request->hasArg("tx_baud")) { + tx_baud = request->arg("tx_baud").toInt(); + cfg_adjust("tx_baud", tx_baud); + } + if (request->hasArg("tx_dev")) { + tx_dev = request->arg("tx_dev").toFloat(); + cfg_adjust("tx_dev", tx_dev); + } + if (request->hasArg("tx_power")) { + tx_power = request->arg("tx_power").toInt(); + cfg_adjust("tx_power", tx_power); + } + if (request->hasArg("tx_empty_queue")) { + tx_empty_queue = request->arg("tx_empty_queue").equals("on"); + cfg_adjust("tx_empty_queue", tx_empty_queue); + } else { + cfg_adjust("tx_empty_queue", false); + } + if (request->hasArg("pocsag_german")) { + pocsag_german = request->arg("pocsag_german").equals("on"); + cfg_adjust("pocsag_german", pocsag_german); + } else { + cfg_adjust("pocsag_german", false); + } + cfg_write(); + redirectHomeResponse(request, "/#config"); + } + static void setMQTTCfg(AsyncWebServerRequest *request) { + String mqtt_host, mqtt_user, mqtt_pass, mqtt_topic; + int mqtt_port; + // + cfg_startTransaction(); + if (request->hasArg("mqtt_host")) { + mqtt_host = request->arg("mqtt_host"); + cfg_adjust("mqtt_host", mqtt_host); + } + if (request->hasArg("mqtt_topic")) { + mqtt_topic = request->arg("mqtt_topic"); + cfg_adjust("mqtt_topic", mqtt_topic); + } + if (request->hasArg("mqtt_user")) { + mqtt_user = request->arg("mqtt_user"); + cfg_adjust("mqtt_user", mqtt_user); + } + if (request->hasArg("mqtt_pass")) { + mqtt_pass = request->arg("mqtt_pass"); + cfg_adjust("mqtt_pass", mqtt_pass); + } + if (request->hasArg("mqtt_port")) { + mqtt_port = request->arg("mqtt_port").toInt(); + cfg_adjust("mqtt_port", mqtt_port); + } + cfg_write(); + redirectHomeResponse(request, "/#config"); + } + // + static void setDWDMoWaS(AsyncWebServerRequest *request) { + int broadcast_ric, broadcast_fun; + bool dwd_enable, mowas_enable; + int dwd_interval, mowas_interval; + int dwd_fun, mowas_fun; + String dwd_region, mowas_region; + cfg_startTransaction(); + + //broadcast + if (request->hasArg("broadcast_ric")) { + broadcast_ric = request->arg("broadcast_ric").toFloat(); + cfg_adjust("broadcast_ric", broadcast_ric); + } + if (request->hasArg("broadcast_fun")) { + broadcast_fun = request->arg("broadcast_fun").toInt(); + cfg_adjust("broadcast_fun", broadcast_fun); + } + + // dwd + if (request->hasArg("dwd_enable")) { + dwd_enable = request->arg("dwd_enable").equals("on"); + cfg_adjust("dwd_enable", dwd_enable); + } else { + cfg_adjust("dwd_enable", false); + } + if (request->hasArg("dwd_interval")) { + dwd_interval = request->arg("dwd_interval").toInt(); + cfg_adjust("dwd_interval", dwd_interval); + } + if (request->hasArg("dwd_fun")) { + dwd_fun = request->arg("dwd_fun").toInt(); + cfg_adjust("dwd_fun", dwd_fun); + } + if (request->hasArg("dwd_region")) { + dwd_region = request->arg("dwd_region"); + cfg_adjust("dwd_region", dwd_region); + } + // mowas + if (request->hasArg("mowas_enable")) { + mowas_enable = request->arg("mowas_enable").equals("on"); + cfg_adjust("mowas_enable", mowas_enable); + } else { + cfg_adjust("mowas_enable", false); + } + if (request->hasArg("mowas_interval")) { + mowas_interval = request->arg("mowas_interval").toInt(); + cfg_adjust("mowas_interval", mowas_interval); + } + if (request->hasArg("mowas_fun")) { + mowas_fun = request->arg("mowas_fun").toInt(); + cfg_adjust("mowas_fun", mowas_fun); + } + if (request->hasArg("mowas_region")) { + mowas_region = request->arg("mowas_region"); + cfg_adjust("mowas_region", mowas_region); + } + + cfg_write(); + redirectHomeResponse(request, "/#dwdmowas"); + } + // + static void setTimebeacon(AsyncWebServerRequest *request) { + int time_ric, time_fun; + bool time_enable; + int time_interval, time_mode; + String time_zone; + cfg_startTransaction(); + if (request->hasArg(CFG_TIME_RIC)) { + time_ric = request->arg(CFG_TIME_RIC).toFloat(); + cfg_adjust(CFG_TIME_RIC, time_ric); + } + if (request->hasArg("time_fun")) { + time_fun = request->arg("time_fun").toInt(); + cfg_adjust("time_fun", time_fun); + } + if (request->hasArg("time_enable")) { + time_enable = request->arg("time_enable").equals("on"); + cfg_adjust("time_enable", time_enable); + } else { + cfg_adjust("time_enable", false); + } + if (request->hasArg("time_interval")) { + time_interval = request->arg("time_interval").toInt(); + cfg_adjust("time_interval", time_interval); + } + if (request->hasArg("time_mode")) { + time_mode = request->arg("time_mode").toInt(); + cfg_adjust("time_mode", time_mode); + } + if (request->hasArg("time_zone")) { + time_zone = request->arg("time_zone"); + cfg_adjust("time_zone", time_zone); + } + cfg_write(); + redirectHomeResponse(request, "/#timebeacon"); + } + static void setIdlebeacon(AsyncWebServerRequest *request) { + bool idle_enable; + int idle_interval, idle_mode; + cfg_startTransaction(); + if (request->hasArg("idle_enable")) { + idle_enable = request->arg("idle_enable").equals("on"); + cfg_adjust("idle_enable", idle_enable); + } else { + cfg_adjust("idle_enable", false); + } + if (request->hasArg("idle_interval")) { + idle_interval = request->arg("idle_interval").toInt(); + cfg_adjust("idle_interval", idle_interval); + } + if (request->hasArg("idle_mode")) { + idle_mode = request->arg("idle_mode").toInt(); + cfg_adjust("idle_mode", idle_mode); + } + cfg_write(); + redirectHomeResponse(request, "/#idle"); + } + // + static void setDevCfg(AsyncWebServerRequest *request) { + int oled_timeout; + // + cfg_startTransaction(); + if (request->hasArg("oled_timeout")) { + oled_timeout = request->arg("oled_timeout").toInt(); + cfg_adjust("oled_timeout", oled_timeout); + } + if (request->hasArg("device_name")) { + String device_name = request->arg("device_name"); + cfg_adjust("device_name", device_name); + } + cfg_write(); + redirectHomeResponse(request, "/#config"); + } +// +void webserver_setup() { + // ws.onEvent(onEvent); + // server.addHandler(&ws); + + // // attach AsyncEventSource + // server.addHandler(&events); + server.on("/", HTTP_GET, [](AsyncWebServerRequest *request) + { + AsyncWebServerResponse *response = request->beginResponse_P( + 200, "text/html", data_index_html_start, + data_index_html_end - data_index_html_start - 1); + response->addHeader("Access-Control-Allow-Origin", "*"); + request->send(response); + }); + server.on("/script.js", HTTP_GET, [](AsyncWebServerRequest *request) + { + AsyncWebServerResponse *response = request->beginResponse_P( + 200, "application/javascript", data_script_js_start, + data_script_js_end - data_script_js_start - 1); + response->addHeader("Access-Control-Allow-Origin", "*"); + request->send(response); + }); + server.on("/style.css", HTTP_GET, [](AsyncWebServerRequest *request) + { + AsyncWebServerResponse *response = request->beginResponse_P( + 200, "text/css", data_style_css_start, + data_style_css_end - data_style_css_start - 1); + response->addHeader("Access-Control-Allow-Origin", "*"); + request->send(response); + }); + server.on("/config.json", HTTP_GET, [](AsyncWebServerRequest *request) { + String output = cfg_tostring(); + AsyncWebServerResponse *response = + request->beginResponse(200, "application/json", output); + response->addHeader("Access-Control-Allow-Origin", "*"); + request->send(response); + }); + server.on("/contacts.json", HTTP_GET, [](AsyncWebServerRequest *request) { + String output = contacts_tostring(); + AsyncWebServerResponse *response = + request->beginResponse(200, "application/json", output); + response->addHeader("Access-Control-Allow-Origin", "*"); + request->send(response); + }); + server.on("/contacts.json", HTTP_POST, [](AsyncWebServerRequest * request){ + if (request->hasParam("body", true)) { // This is important, otherwise the sketch will crash if there is no body + contacts_write(request->getParam("body", true)->value()); + request->send(200, "text/plain", "ok\n"); + } else { + Serial.println("No body?!"); + request->send(200, "text/plain", "No body?!\n"); + } + }); + + server.on("/setap", setAPCfg); + server.on("/setwifi1", setWifi1Cfg); + server.on("/setwifi2", setWifi2Cfg); + server.on("/settransmitter", setTransmitterCfg); + server.on("/setmqtt", setMQTTCfg); + server.on("/setdwdmowas", setDWDMoWaS); + server.on("/settimebeacon", setTimebeacon); + server.on("/setidlebeacon", setIdlebeacon); + server.on("/setdev", setDevCfg); + + server.on("/page", insertPage); + server.on("/trigger-time", triggerTimeBeacon); + server.on("/transmit", transmit); + server.on("/clear", clearQueue); + server.on("/rstcfgrbt", resetConfigReboot); + server.on("/reboot", justReboot); + + server.onNotFound(handleNotFound); + server.begin(); +} \ No newline at end of file diff --git a/src/webserver.h b/src/webserver.h new file mode 100644 index 0000000..6e220b4 --- /dev/null +++ b/src/webserver.h @@ -0,0 +1,25 @@ +#if !defined(_WEBSERVER_H) + #define _WEBSERVER_H + + static void redirectHomeResponse(AsyncWebServerRequest *request); + // + static void triggerTimeBeacon(AsyncWebServerRequest *request); + static void insertPage(AsyncWebServerRequest *request); + static void transmit(AsyncWebServerRequest *request); + static void clearQueue(AsyncWebServerRequest *request); + // + static void setAPCfg(AsyncWebServerRequest *request); + static void setWifi1Cfg(AsyncWebServerRequest *request); + static void setWifi2Cfg(AsyncWebServerRequest *request); + static void setTransmitterCfg(AsyncWebServerRequest *request); + static void setMQTTCfg(AsyncWebServerRequest *request); + static void setDWDMoWaS(AsyncWebServerRequest *request); + static void setTimebeacon(AsyncWebServerRequest *request); + static void setIdlebeacon(AsyncWebServerRequest *request); + static void setDevCfg(AsyncWebServerRequest *request); + // + static void justReboot(AsyncWebServerRequest *request); + static void resetConfigReboot(AsyncWebServerRequest *request); + void webserver_setup(); + +#endif \ No newline at end of file diff --git a/test/README b/test/README new file mode 100644 index 0000000..b94d089 --- /dev/null +++ b/test/README @@ -0,0 +1,11 @@ + +This directory is intended for PlatformIO Unit Testing and project tests. + +Unit Testing is a software testing method by which individual units of +source code, sets of one or more MCU program modules together with associated +control data, usage procedures, and operating procedures, are tested to +determine whether they are fit for use. Unit testing finds problems early +in the development cycle. + +More information about PlatformIO Unit Testing: +- https://docs.platformio.org/page/plus/unit-testing.html