MMDVM/MMDVMHost
1
0
Fork 0
mirror of https://github.com/g4klx/MMDVMHost synced 2025-12-24 09:35:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add AX.25 to JSON/MQTT.

Browse Source
This commit is contained in:
Jonathan Naylor
2023-01-18 20:56:37 +00:00
parent 72f249b12e
commit d6fe3f0cac
4 changed files with 282 additions and 103 deletions
Download Patch File Download Diff File Expand all files Collapse all files

375
AX25Control.cpp
View File

@@ -21,6 +21,8 @@
#include <cstring>
#include <ctime>
#include <nlohmann/json.hpp>
// #define DUMP_AX25
const unsigned char BIT_MASK_TABLE[] = { 0x80U, 0x40U, 0x20U, 0x10U, 0x08U, 0x04U, 0x02U, 0x01U };
@@ -47,33 +49,37 @@ bool CAX25Control::writeModem(unsigned char *data, unsigned int len)
if (!m_enabled)
return false;
if (m_trace)
decode(data, len);
if (m_trace)
decode(data, len);
CUtils::dump(1U, "AX.25 received packet", data, len);
decodeJSON("rf", data, len);
if (m_network == NULL)
return true;
CUtils::dump(1U, "AX.25 received packet", data, len);
return m_network->write(data, len);
if (m_network == NULL)
return true;
return m_network->write(data, len);
}
unsigned int CAX25Control::readModem(unsigned char* data)
{
assert(data != NULL);
assert(data != NULL);
if (m_network == NULL)
return 0U;
if (m_network == NULL)
return 0U;
if (!m_enabled)
return 0U;
if (!m_enabled)
return 0U;
unsigned int length = m_network->read(data, 500U);
unsigned int length = m_network->read(data, 500U);
if (length > 0U)
CUtils::dump(1U, "AX.25 transmitted packet", data, length);
decodeJSON("network", data, length);
return length;
if (length > 0U)
CUtils::dump(1U, "AX.25 transmitted packet", data, length);
return length;
}
bool CAX25Control::openFile()
@@ -124,101 +130,240 @@ void CAX25Control::enable(bool enabled)
void CAX25Control::decode(const unsigned char* data, unsigned int length)
{
assert(data != NULL);
assert(length >= 15U);
assert(data != NULL);
assert(length >= 15U);
std::string text;
std::string text;
bool more = decodeAddress(data + 7U, text);
bool more = decodeAddress(data + 7U, text);
text += '>';
text += '>';
decodeAddress(data + 0U, text);
decodeAddress(data + 0U, text);
unsigned int n = 14U;
while (more && n < length) {
text += ',';
more = decodeAddress(data + n, text, true);
n += 7U;
}
unsigned int n = 14U;
while (more && n < length) {
text += ',';
more = decodeAddress(data + n, text, true);
n += 7U;
}
text += ' ';
text += ' ';
if ((data[n] & 0x01U) == 0x00U) {
// I frame
char t[20U];
::sprintf(t, "<I S%u R%u>", (data[n] >> 1) & 0x07U, (data[n] >> 5) & 0x07U);
text += t;
} else {
if ((data[n] & 0x02U) == 0x00U) {
// S frame
char t[20U];
switch (data[n] & 0x0FU) {
case 0x01U:
sprintf(t, "<RR R%u>", (data[n] >> 5) & 0x07U);
break;
case 0x05U:
sprintf(t, "<RNR R%u>", (data[n] >> 5) & 0x07U);
break;
case 0x09U:
sprintf(t, "<REJ R%u>", (data[n] >> 5) & 0x07U);
break;
case 0x0DU:
sprintf(t, "<SREJ R%u>", (data[n] >> 5) & 0x07U);
break;
default:
sprintf(t, "<Unknown R%u>", (data[n] >> 5) & 0x07U);
break;
}
if ((data[n] & 0x01U) == 0x00U) {
// I frame
char t[20U];
::sprintf(t, "<I S%u R%u>", (data[n] >> 1) & 0x07U, (data[n] >> 5) & 0x07U);
text += t;
} else {
if ((data[n] & 0x02U) == 0x00U) {
// S frame
char t[20U];
switch (data[n] & 0x0FU) {
case 0x01U:
::sprintf(t, "<RR R%u>", (data[n] >> 5) & 0x07U);
break;
case 0x05U:
::sprintf(t, "<RNR R%u>", (data[n] >> 5) & 0x07U);
break;
case 0x09U:
::sprintf(t, "<REJ R%u>", (data[n] >> 5) & 0x07U);
break;
case 0x0DU:
::sprintf(t, "<SREJ R%u>", (data[n] >> 5) & 0x07U);
break;
default:
::sprintf(t, "<Unknown R%u>", (data[n] >> 5) & 0x07U);
break;
}
text += t;
LogMessage("AX.25, %s", text.c_str());
return;
} else {
// U frame
switch (data[n] & 0xEFU) {
case 0x6FU:
text += "<SABME>";
break;
case 0x2FU:
text += "<SABM>";
break;
case 0x43U:
text += "<DISC>";
break;
case 0x0FU:
text += "<DM>";
break;
case 0x63U:
text += "<UA>";
break;
case 0x87U:
text += "<FRMR>";
break;
case 0x03U:
text += "<UI>";
break;
case 0xAFU:
text += "<XID>";
break;
case 0xE3U:
text += "<TEST>";
break;
default:
text += "<Unknown>";
break;
}
text += t;
LogMessage("AX.25, %s", text.c_str());
return;
} else {
// U frame
switch (data[n] & 0xEFU) {
case 0x6FU:
text += "<SABME>";
break;
case 0x2FU:
text += "<SABM>";
break;
case 0x43U:
text += "<DISC>";
break;
case 0x0FU:
text += "<DM>";
break;
case 0x63U:
text += "<UA>";
break;
case 0x87U:
text += "<FRMR>";
break;
case 0x03U:
text += "<UI>";
break;
case 0xAFU:
text += "<XID>";
break;
case 0xE3U:
text += "<TEST>";
break;
default:
text += "<Unknown>";
break;
}
if ((data[n] & 0xEFU) != 0x03U) {
LogMessage("AX.25, %s", text.c_str());
return;
}
}
}
if ((data[n] & 0xEFU) != 0x03U) {
LogMessage("AX.25, %s", text.c_str());
return;
}
}
}
n += 2U;
n += 2U;
LogMessage("AX.25, %s %.*s", text.c_str(), length - n, data + n);
LogMessage("AX.25, %s %.*s", text.c_str(), length - n, data + n);
}
void CAX25Control::decodeJSON(const char* source, const unsigned char* data, unsigned int length)
{
assert(source != NULL);
assert(data != NULL);
assert(length >= 15U);
nlohmann::json json;
json["timestamp"] = CUtils::createTimestamp();
std::string text;
bool isDigi;
bool more = decodeAddressJSON(data + 7U, text, isDigi);
json["source"] = text;
decodeAddressJSON(data + 0U, text, isDigi);
json["destination"] = text;
unsigned int n = 14U;
if (more) {
while (more && n < length) {
nlohmann::json digi;
more = decodeAddressJSON(data + n, text, isDigi);
n += 7U;
digi["callsign"] = text;
digi["repeated"] = isDigi;
json["digipeaters"] = digi;
}
}
if ((data[n] & 0x01U) == 0x00U) {
// I frame
char t[20U];
::sprintf(t, "I S%u R%u", (data[n] >> 1) & 0x07U, (data[n] >> 5) & 0x07U);
json["type"] = t;
} else {
if ((data[n] & 0x02U) == 0x00U) {
// S frame
char t[20U];
switch (data[n] & 0x0FU) {
case 0x01U:
::sprintf(t, "RR R%u", (data[n] >> 5) & 0x07U);
break;
case 0x05U:
::sprintf(t, "RNR R%u", (data[n] >> 5) & 0x07U);
break;
case 0x09U:
::sprintf(t, "REJ R%u", (data[n] >> 5) & 0x07U);
break;
case 0x0DU:
::sprintf(t, "SREJ R%u", (data[n] >> 5) & 0x07U);
break;
default:
::sprintf(t, "Unknown R%u", (data[n] >> 5) & 0x07U);
break;
}
json["type"] = t;
WriteJSON("AX.25", json);
return;
} else {
// U frame
switch (data[n] & 0xEFU) {
case 0x6FU:
text = "SABME";
break;
case 0x2FU:
text = "SABM";
break;
case 0x43U:
text = "DISC";
break;
case 0x0FU:
text = "DM";
break;
case 0x63U:
text = "UA";
break;
case 0x87U:
text = "FRMR";
break;
case 0x03U:
text = "UI";
break;
case 0xAFU:
text = "XID";
break;
case 0xE3U:
text = "TEST";
break;
default:
text = "Unknown>";
break;
}
json["type"] = text;
if ((data[n] & 0xEFU) != 0x03U) {
WriteJSON("AX.25", json);
return;
}
}
}
n++;
char buffer[5U];
::sprintf(buffer, "%02X", data[n]);
json["pid"] = buffer;
n++;
text.clear();
for (unsigned int i = 0U; i < (length - n); i++) {
char buffer[5U];
::sprintf(buffer, "%02X ", data[n + i]);
text += buffer;
}
for (unsigned int i = 0U; i < (length - n); i++) {
char c = data[n + i];
if (::isprint(c) || c == ' ')
text += c;
else
text += '.';
}
json["data"] = text;
WriteJSON("AX.25", json);
}
bool CAX25Control::decodeAddress(const unsigned char* data, std::string& text, bool isDigi) const
@@ -237,8 +382,7 @@ bool CAX25Control::decodeAddress(const unsigned char* data, std::string& text, b
if (ssid >= 10U) {
text += '1';
text += '0' + ssid - 10U;
}
else {
} else {
text += '0' + ssid;
}
}
@@ -250,3 +394,32 @@ bool CAX25Control::decodeAddress(const unsigned char* data, std::string& text, b
return (data[6U] & 0x01U) == 0x00U;
}
bool CAX25Control::decodeAddressJSON(const unsigned char* data, std::string& text, bool& isDigi) const
{
assert(data != NULL);
text.clear();
for (unsigned int i = 0U; i < 6U; i++) {
char c = data[i] >> 1;
if (c != ' ')
text += c;
}
unsigned char ssid = (data[6U] >> 1) & 0x0FU;
if (ssid > 0U) {
text += '-';
if (ssid >= 10U) {
text += '1';
text += '0' + ssid - 10U;
} else {
text += '0' + ssid;
}
}
isDigi = (data[6U] & 0x80U) == 0x80U;
return (data[6U] & 0x01U) == 0x00U;
}