Scaffold modular architecture and entry sketch
This commit is contained in:
@ -1,260 +1,9 @@
|
|||||||
#include <HardwareSerial.h>
|
#include "src/app/App.hpp"
|
||||||
|
|
||||||
// Pins
|
|
||||||
#define LTE_RX_PIN 16 // ESP32 RX <- SIM7080 TX
|
|
||||||
#define LTE_TX_PIN 17 // ESP32 TX -> SIM7080 RX
|
|
||||||
#define PWRKEY_PIN 4 // SIM7080 PWRKEY
|
|
||||||
|
|
||||||
// Network and endpoint
|
|
||||||
const char* APN = "hologram";
|
|
||||||
const char* BASE_URL = "http://laravel-server.lab.audasmedia.com.au";
|
|
||||||
const char* PATH = "/api/gps";
|
|
||||||
|
|
||||||
// -------- Utilities --------
|
|
||||||
String sendAT(const String& cmd, uint32_t timeoutMs) {
|
|
||||||
Serial.print(">> "); Serial.println(cmd);
|
|
||||||
while (Serial2.available()) (void)Serial2.read();
|
|
||||||
Serial2.println(cmd);
|
|
||||||
|
|
||||||
String resp;
|
|
||||||
uint32_t t0 = millis();
|
|
||||||
while (millis() - t0 < timeoutMs) {
|
|
||||||
while (Serial2.available()) {
|
|
||||||
char c = (char)Serial2.read();
|
|
||||||
resp += c;
|
|
||||||
Serial.print(c);
|
|
||||||
t0 = millis(); // extend timeout on input
|
|
||||||
}
|
|
||||||
}
|
|
||||||
resp.trim();
|
|
||||||
Serial.println("\n[Resp]\n" + resp);
|
|
||||||
return resp;
|
|
||||||
}
|
|
||||||
|
|
||||||
void powerOnSIM7080() {
|
|
||||||
pinMode(PWRKEY_PIN, OUTPUT);
|
|
||||||
digitalWrite(PWRKEY_PIN, LOW);
|
|
||||||
delay(2000);
|
|
||||||
digitalWrite(PWRKEY_PIN, HIGH);
|
|
||||||
delay(1000);
|
|
||||||
digitalWrite(PWRKEY_PIN, LOW);
|
|
||||||
delay(30000); // full boot
|
|
||||||
}
|
|
||||||
|
|
||||||
bool waitLTE(uint32_t ms = 120000) {
|
|
||||||
uint32_t t0 = millis();
|
|
||||||
while (millis() - t0 < ms) {
|
|
||||||
String r = sendAT("AT+CEREG?", 4000);
|
|
||||||
if (r.indexOf("+CEREG: 0,1") != -1 || r.indexOf("+CEREG: 0,5") != -1) return true;
|
|
||||||
delay(3000);
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Simple reusable HTTP POST via SH client
|
|
||||||
bool httpPostSH(const String& baseUrl, const String& path, const String& jsonBody) {
|
|
||||||
// Configure HTTP client
|
|
||||||
sendAT("AT+SHCONF=\"URL\",\"" + baseUrl + "\"", 5000);
|
|
||||||
sendAT("AT+SHCONF=\"BODYLEN\",1024", 2000);
|
|
||||||
sendAT("AT+SHCONF=\"HEADERLEN\",350", 2000);
|
|
||||||
|
|
||||||
// Connect (no micromanagement; rely on OK)
|
|
||||||
String r = sendAT("AT+SHCONN", 15000);
|
|
||||||
if (r.indexOf("OK") == -1) {
|
|
||||||
Serial.println("SHCONN failed");
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Clear and set headers
|
|
||||||
sendAT("AT+SHCHEAD", 2000);
|
|
||||||
sendAT("AT+SHAHEAD=\"Content-Type\",\"application/json\"", 2000);
|
|
||||||
|
|
||||||
// Send body
|
|
||||||
String cmd = "AT+SHBOD=" + String(jsonBody.length()) + ",10000";
|
|
||||||
sendAT(cmd, 2000);
|
|
||||||
Serial2.print(jsonBody);
|
|
||||||
delay(200);
|
|
||||||
|
|
||||||
// POST (3 = POST)
|
|
||||||
r = sendAT("AT+SHREQ=\"" + path + "\",3", 20000);
|
|
||||||
// Expect URC like: +SHREQ: "POST",<HTTP_CODE>,<len>
|
|
||||||
// Print status line if present
|
|
||||||
int p = r.indexOf("+SHREQ:");
|
|
||||||
if (p != -1) {
|
|
||||||
Serial.println("Status/URC: " + r.substring(p));
|
|
||||||
}
|
|
||||||
|
|
||||||
// If there is a body, try to read (non-fatal if none)
|
|
||||||
sendAT("AT+SHREAD=0,2048", 4000);
|
|
||||||
|
|
||||||
// Disconnect
|
|
||||||
sendAT("AT+SHDISC", 3000);
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
// -------- Arduino setup/loop --------
|
|
||||||
void setup() {
|
void setup() {
|
||||||
Serial.begin(115200);
|
App::instance().setup();
|
||||||
Serial2.begin(9600, SERIAL_8N1, LTE_RX_PIN, LTE_TX_PIN);
|
|
||||||
Serial.println("--- SIM7080: Simple Connect + HTTP POST ---");
|
|
||||||
|
|
||||||
powerOnSIM7080();
|
|
||||||
|
|
||||||
// Basic checks
|
|
||||||
sendAT("AT", 2000);
|
|
||||||
sendAT("AT+CMEE=1", 2000);
|
|
||||||
sendAT("AT+CPIN?", 2000);
|
|
||||||
sendAT("AT+CSQ", 2000);
|
|
||||||
|
|
||||||
// Force Cat‑M1 + APN attach
|
|
||||||
sendAT("AT+CNMP=38", 5000);
|
|
||||||
sendAT("AT+CMNB=1", 5000);
|
|
||||||
sendAT("AT+CGDCONT=1,\"IP\",\"" + String(APN) + "\"", 5000);
|
|
||||||
sendAT("AT+CGATT=1", 10000);
|
|
||||||
|
|
||||||
// Wait for LTE registration
|
|
||||||
if (!waitLTE()) {
|
|
||||||
Serial.println("No LTE registration; stopping.");
|
|
||||||
while (true) delay(1000);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Activate SIM7080 APP PDP (required for HTTP)
|
|
||||||
sendAT("AT+CNCFG=0,1,\"" + String(APN) + "\"", 5000);
|
|
||||||
sendAT("AT+CNACT=0,1", 45000);
|
|
||||||
sendAT("AT+CNACT?", 3000);
|
|
||||||
|
|
||||||
smsSetup();
|
|
||||||
|
|
||||||
// Optional DNS
|
|
||||||
sendAT("AT+CDNSCFG=\"8.8.8.8\",\"1.1.1.1\"", 3000);
|
|
||||||
|
|
||||||
// Build your JSON (adjust as needed)
|
|
||||||
String json = "{\"device_id\":\"sim7080g-01\",\"lat\":-33.865143,"
|
|
||||||
"\"lng\":151.2099,\"speed\":12.5,\"altitude\":30.2}";
|
|
||||||
|
|
||||||
// Do the POST
|
|
||||||
bool ok = httpPostSH(BASE_URL, PATH, json);
|
|
||||||
Serial.println(ok ? "HTTP POST sent (see status above)" : "HTTP POST failed");
|
|
||||||
|
|
||||||
Serial.println("--- Done ---");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void loop() {
|
void loop() {
|
||||||
// Non-blocking read to capture unsolicited lines like +CMTI
|
App::instance().loop();
|
||||||
static String urc;
|
|
||||||
while (Serial2.available()) {
|
|
||||||
char c = (char)Serial2.read();
|
|
||||||
urc += c;
|
|
||||||
if (c == '\n') {
|
|
||||||
urc.trim();
|
|
||||||
if (urc.startsWith("+CMTI:")) {
|
|
||||||
// +CMTI: "SM",<idx>
|
|
||||||
int comma = urc.lastIndexOf(',');
|
|
||||||
if (comma != -1) {
|
|
||||||
int idx = urc.substring(comma + 1).toInt();
|
|
||||||
String body = smsReadAndDelete(idx);
|
|
||||||
Serial.println("SMS (URC): " + body);
|
|
||||||
handleSmsCommand(body);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
urc = "";
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Optional periodic poll in case URC was missed
|
|
||||||
static uint32_t lastPoll = 0;
|
|
||||||
if (millis() - lastPoll > 60000) { // every 60 s
|
|
||||||
smsPollUnread();
|
|
||||||
lastPoll = millis();
|
|
||||||
}
|
|
||||||
|
|
||||||
// Your normal work here...
|
|
||||||
}
|
|
||||||
|
|
||||||
// Call once after PDP is active (or right after registration)
|
|
||||||
void smsSetup() {
|
|
||||||
sendAT("AT+CMGF=1", 2000); // text mode
|
|
||||||
sendAT("AT+CPMS=\"SM\",\"SM\",\"SM\"", 2000); // SIM storage
|
|
||||||
sendAT("AT+CNMI=2,1,0,0,0", 2000); // new SMS URC: +CMTI: "SM",<idx>
|
|
||||||
// Optional: show extended text params
|
|
||||||
// sendAT("AT+CSDH=1", 2000);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Read & delete one SMS by index; returns the body
|
|
||||||
String smsReadAndDelete(int idx) {
|
|
||||||
String r = sendAT("AT+CMGR=" + String(idx), 4000);
|
|
||||||
// Extract last non-empty line before OK
|
|
||||||
int okPos = r.lastIndexOf("\nOK");
|
|
||||||
String s = (okPos>0) ? r.substring(0, okPos) : r;
|
|
||||||
int lastLf = s.lastIndexOf('\n');
|
|
||||||
if (lastLf != -1) s = s.substring(lastLf + 1);
|
|
||||||
s.trim();
|
|
||||||
|
|
||||||
sendAT("AT+CMGD=" + String(idx), 2000);
|
|
||||||
return s;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Optional: poll unread SMS (if you want to scan periodically)
|
|
||||||
void smsPollUnread() {
|
|
||||||
String list = sendAT("AT+CMGL=\"REC UNREAD\"", 5000);
|
|
||||||
// list may contain many entries like:
|
|
||||||
// +CMGL: <idx>,"REC UNREAD",...
|
|
||||||
int pos = 0;
|
|
||||||
while (true) {
|
|
||||||
int p = list.indexOf("+CMGL:", pos);
|
|
||||||
if (p == -1) break;
|
|
||||||
int comma = list.indexOf(',', p);
|
|
||||||
if (comma == -1) break;
|
|
||||||
// Extract index after "+CMGL: "
|
|
||||||
int idxStart = list.indexOf(' ', p);
|
|
||||||
if (idxStart == -1 || idxStart > comma) break;
|
|
||||||
int idx = list.substring(idxStart + 1, comma).toInt();
|
|
||||||
String body = smsReadAndDelete(idx);
|
|
||||||
Serial.println("SMS (polled): " + body);
|
|
||||||
handleSmsCommand(body);
|
|
||||||
pos = comma + 1;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void handleSmsCommand(String msg) {
|
|
||||||
Serial.println("Command received via SMS: " + msg);
|
|
||||||
|
|
||||||
msg.trim();
|
|
||||||
if (msg.isEmpty()) {
|
|
||||||
Serial.println("Empty body");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Very simple JSON extraction: look for device_id and speed keys
|
|
||||||
auto extract = [&](const String& key)->String {
|
|
||||||
String pat = String("\"") + key + "\":";
|
|
||||||
int k = msg.indexOf(pat);
|
|
||||||
if (k < 0) return "";
|
|
||||||
k += pat.length();
|
|
||||||
|
|
||||||
// Skip quotes/spaces
|
|
||||||
while (k < (int)msg.length() && (msg[k]==' ' || msg[k]=='\"')) k++;
|
|
||||||
|
|
||||||
// If quoted value
|
|
||||||
if (k < (int)msg.length() && msg[k-1] == '\"') {
|
|
||||||
int end = msg.indexOf('\"', k);
|
|
||||||
if (end > k) return msg.substring(k, end);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Numeric value
|
|
||||||
int end = k;
|
|
||||||
while (end < (int)msg.length() && (isDigit(msg[end]) || msg[end]=='.' || msg[end]=='-' )) end++;
|
|
||||||
return msg.substring(k, end);
|
|
||||||
};
|
|
||||||
|
|
||||||
String deviceId = extract("device_id");
|
|
||||||
String speed = extract("speed");
|
|
||||||
|
|
||||||
Serial.println("Parsed device_id=" + deviceId + " speed=" + speed);
|
|
||||||
|
|
||||||
// Example action: if speed present
|
|
||||||
if (speed.length()) {
|
|
||||||
Serial.println("Action: set speed to " + speed);
|
|
||||||
// TODO: apply speed to your app logic
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
0
src/app/App.cpp
Normal file
0
src/app/App.cpp
Normal file
0
src/app/App.hpp
Normal file
0
src/app/App.hpp
Normal file
0
src/app/AppConfig.cpp
Normal file
0
src/app/AppConfig.cpp
Normal file
0
src/app/AppConfig.hpp
Normal file
0
src/app/AppConfig.hpp
Normal file
0
src/core/CommandMgr.cpp
Normal file
0
src/core/CommandMgr.cpp
Normal file
0
src/core/CommandMgr.hpp
Normal file
0
src/core/CommandMgr.hpp
Normal file
0
src/core/HttpClient.cpp
Normal file
0
src/core/HttpClient.cpp
Normal file
0
src/core/HttpClient.hpp
Normal file
0
src/core/HttpClient.hpp
Normal file
0
src/core/Modem.cpp
Normal file
0
src/core/Modem.cpp
Normal file
0
src/core/Modem.hpp
Normal file
0
src/core/Modem.hpp
Normal file
0
src/core/NetMgr.cpp
Normal file
0
src/core/NetMgr.cpp
Normal file
0
src/core/NetMgr.hpp
Normal file
0
src/core/NetMgr.hpp
Normal file
0
src/core/OTAMgr.cpp
Normal file
0
src/core/OTAMgr.cpp
Normal file
0
src/core/OTAMgr.hpp
Normal file
0
src/core/OTAMgr.hpp
Normal file
0
src/core/SmsMgr.cpp
Normal file
0
src/core/SmsMgr.cpp
Normal file
0
src/core/SmsMgr.hpp
Normal file
0
src/core/SmsMgr.hpp
Normal file
0
src/core/Telemetry.cpp
Normal file
0
src/core/Telemetry.cpp
Normal file
0
src/core/Telemetry.hpp
Normal file
0
src/core/Telemetry.hpp
Normal file
0
src/domain/Geofence.cpp
Normal file
0
src/domain/Geofence.cpp
Normal file
0
src/domain/Geofence.hpp
Normal file
0
src/domain/Geofence.hpp
Normal file
0
src/domain/Presence.cpp
Normal file
0
src/domain/Presence.cpp
Normal file
0
src/domain/Presence.hpp
Normal file
0
src/domain/Presence.hpp
Normal file
0
src/hw/EspNowMgr.cpp
Normal file
0
src/hw/EspNowMgr.cpp
Normal file
0
src/hw/EspNowMgr.hpp
Normal file
0
src/hw/EspNowMgr.hpp
Normal file
0
src/hw/GNSS.cpp
Normal file
0
src/hw/GNSS.cpp
Normal file
0
src/hw/GNSS.hpp
Normal file
0
src/hw/GNSS.hpp
Normal file
0
src/hw/GpioCtrl.cpp
Normal file
0
src/hw/GpioCtrl.cpp
Normal file
0
src/hw/GpioCtrl.hpp
Normal file
0
src/hw/GpioCtrl.hpp
Normal file
0
src/hw/PowerMgr.cpp
Normal file
0
src/hw/PowerMgr.cpp
Normal file
0
src/hw/PowerMgr.hpp
Normal file
0
src/hw/PowerMgr.hpp
Normal file
0
src/hw/WiFiMgr.cpp
Normal file
0
src/hw/WiFiMgr.cpp
Normal file
0
src/hw/WiFiMgr.hpp
Normal file
0
src/hw/WiFiMgr.hpp
Normal file
Reference in New Issue
Block a user