Add files via upload

examples/simple_pppos_with_mqtt/simple_pppos_with_mqtt.ino

@@ -0,0 +1,182 @@
+#include <PPPOS.h>
+#include <PPPOSClient.h>
+#include <PubSubClient.h>
+
+#define SERIAL_BR           115200
+#define GSM_SERIAL          1
+#define GSM_RX              16
+#define GSM_TX              17
+#define GSM_BR              115200
+
+char* server = "example.com";
+char* ppp_user = "";
+char* ppp_pass = "";
+String APN = "internet";
+
+#define WEB_SERVER "www.w3.org"
+#define WEB_URL "https://www.w3.org/TR/PNG/iso_8859-1.txt"
+static const char *REQUEST = "GET " WEB_URL "\ HTTP/1.1\r\n"
+    "Host: "WEB_SERVER"\r\n"
+    "Connection: keep-alive\r\n"
+    "User-Agent: esp/1.0 esp32\r\n"
+    "\r\n";
+
+String buffer = "";
+char *data = (char *) malloc(1024); 
+bool atMode = true;
+
+void callback(char* topic, byte* payload, unsigned int length) {
+  Serial.print("Message arrived [");
+  Serial.print(topic);
+  Serial.print("] ");
+  for (int i=0;i<length;i++) {
+    Serial.print((char)payload[i]);
+  }
+  Serial.println();
+}
+
+PPPOSClient ppposClient;
+PubSubClient client(ppposClient);
+
+bool sendCommandWithAnswer(String cmd, String ans){
+         PPPOS_write((char *)cmd.c_str());
+         unsigned long _tg = millis();
+         while(true){
+          data = PPPOS_read();
+          if (data != NULL){
+            char* command = strtok(data, "\n");
+            while (command != 0)
+            {
+              buffer = String(command);
+              buffer.replace("\r", "");
+              command = strtok(0, "\n");
+              if (buffer != "") { Serial.println(buffer); }
+              if (buffer == ans) {buffer = ""; return true; }
+              buffer = "";
+            } 
+          }
+            if (millis() > (_tg + 5000)) { buffer = ""; return false; } 
+         }
+         buffer = "";
+         return false;
+}
+
+bool startPPPOS(){  
+      String apnSet = "AT+CGDCONT=1,\"IP\",\"" + APN + "\"\n";
+      if (!sendCommandWithAnswer(apnSet, "OK")) { return false; }
+      if (!sendCommandWithAnswer("AT+CGDATA=\"PPP\",1\n", "CONNECT")) { return false; }
+      atMode = false;
+      PPPOS_start(); 
+      unsigned long _tg = millis();
+      while(!PPPOS_isConnected()) {
+        if (millis() > (_tg + 10000)) { PPPOS_stop();  atMode = true; return false; }
+      }
+      Serial.println("PPPOS Started");
+      return true;
+}
+
+bool enterATModePPPOS(){
+      if (PPPOS_isConnected() && !atMode){
+        if (sendCommandWithAnswer("+++", "OK")) { atMode = true; return true;}
+      }
+      return false;
+}
+
+bool cancelATModePPPOS(){
+      if (PPPOS_isConnected() && atMode){
+        if (sendCommandWithAnswer("ATO\n", "CONNECT")) { atMode = false; return true;}
+      }
+      return false;
+}
+
+void simpleGetRequest(){
+  if (!ppposClient.connected() ) {
+          Serial.println("Connecting...");
+           ppposClient.connect(WEB_SERVER, 80);
+  }
+  if (ppposClient.connected() ) {
+           Serial.println("Connected");
+           Serial.println(ppposClient.write(REQUEST, strlen(REQUEST)));
+           while(ppposClient.available()){
+            Serial.print((char)ppposClient.read());
+           }
+  }
+}
+
+void reconnect() {
+  // Loop until we're reconnected
+  while (!client.connected()) {
+    Serial.print("Attempting MQTT connection...");
+    // Attempt to connect
+    if (client.connect("arduinoClient")) {
+      Serial.println("connected");
+      // Once connected, publish an announcement...
+      client.publish("outTopic","hello world");
+      // ... and resubscribe
+      client.subscribe("inTopic");
+    } else {
+      Serial.print("failed, rc=");
+      Serial.print(client.state());
+      Serial.println(" try again in 5 seconds");
+      // Wait 5 seconds before retrying
+      delay(5000);
+    }
+  }
+}
+
+void setup()
+{
+  Serial.begin(SERIAL_BR);
+  PPPOS_init(GSM_TX, GSM_RX, GSM_BR, GSM_SERIAL, ppp_user, ppp_pass);
+  client.setServer(server, 1883);
+  client.setCallback(callback);
+
+  Serial.println("1) Start GSM Communication: AT\\n");
+  Serial.println("2) Start PPP Protocol: ppp\\n");
+  Serial.println("3) Test GET Request: get\\n");
+  Serial.println("4) Switch to AT Mode: +++\\n");
+  Serial.println("5) Switch to Data Mode: ATO\\n");
+  Serial.println("6) Stop PPP Protocol: stop\\n");
+}
+
+void loop()
+{ 
+  if (!PPPOS_isConnected() || atMode){
+    data = PPPOS_read();
+    if (data != NULL){
+      Serial.println(data);  
+    }
+  }
+  
+  if (Serial.available()){
+    char c = Serial.read();
+    if (c == '\n'){
+      if (buffer == "ppp") {          
+        Serial.println("Starting PPPOS...");
+        if (startPPPOS()) { Serial.println("Starting PPPOS... OK"); } else { Serial.println("Starting PPPOS... Failed"); }
+      } else if (buffer == "stop") {
+        PPPOS_stop(); 
+      } else if (buffer == "+++") {
+        if (enterATModePPPOS()) { Serial.println("Entering ATMode... OK"); } else { Serial.println("Entering ATMode... Failed"); }
+      } else if (buffer == "ATO") {
+        if (cancelATModePPPOS()) { Serial.println("Canceling ATMode... OK"); } else { Serial.println("Canceling ATMode... Failed"); }
+      } else if (buffer == "get") {
+        simpleGetRequest();
+      } else { 
+        buffer += "\n";
+        PPPOS_write((char *)buffer.c_str());
+        Serial.println(buffer);
+      }
+      buffer = "";
+    } else {
+      buffer += c;
+    }
+  }
+
+  if (PPPOS_isConnected() && !atMode) {
+    if (!client.connected()) {
+      reconnect();
+    }
+    client.loop();
+  }
+}