ASTERIX

README.md

@@ -275,9 +275,9 @@ Don't write recent(1), full(2), either(3) traces
  Establish connection, can be specified multiple
  times (e.g. 127.0.0.1,23004,beast_out) Protocols:
  beast_out, beast_in, raw_out, raw_in, sbs_in,
- sbs_in_jaero, sbs_out, sbs_out_jaero, vrs_out,
- json_out, gpsd_in (one failover ip/address,port
- can be specified:
+ sbs_in_jaero, sbs_out, sbs_out_jaero, sbs_out_prio 
+ vrs_out, json_out, asterix_out, asterix_in, 
+ gpsd_in (one failover ip/address,port can be specified:
  primary-address,primary-port,protocol,failover-address,failover-port)
  --net-connector-delay=<seconds>
  Outbound re-connection delay (default: 30)
@@ -319,6 +319,10 @@ TCP json position output: include aircraft without
  --net-sbs-port=<ports> TCP BaseStation output listen ports (default: 0)
  --net-sbs-reduce Apply beast reduce logic and interval to SBS
  outputs
+ --net-ao-port=<ports> TCP ASTERIX output listen ports (default: 0)
+ --net-ai-port=<ports> TCP ASTERIX input listen ports (default: 0)
+ --net-asterix-reduce Apply beast reduce logic and interval to ASTERIX
+ outputs
  --net-verbatim Forward messages unchanged
  --net-vrs-interval=<seconds>
  TCP VRS json output interval (default: 5.0)

comm_b.c

@@ -35,6 +35,7 @@ static int decodeBDS30(struct modesMessage *mm, bool store);
 static int decodeBDS40(struct modesMessage *mm, bool store);
 static int decodeBDS50(struct modesMessage *mm, bool store);
 static int decodeBDS60(struct modesMessage *mm, bool store);
+static int decodeBDS44(struct modesMessage *mm, bool store);
 
 static CommBDecoderFn comm_b_decoders[] = {
  &decodeEmptyResponse,
@@ -44,7 +45,8 @@ static CommBDecoderFn comm_b_decoders[] = {
  &decodeBDS17,
  &decodeBDS40,
  &decodeBDS50,
- &decodeBDS60
+ &decodeBDS60,
+ &decodeBDS44
 };
 
 void decodeCommB(struct modesMessage *mm) {
@@ -820,3 +822,140 @@ static int decodeBDS60(struct modesMessage *mm, bool store) {
 
  return score;
 }
+
+// BDS 4,4 Meteorological routine air report
+
+static int decodeBDS44(struct modesMessage *mm, bool store) {
+ unsigned char *msg = mm->MB;
+
+ unsigned source = getbits(msg, 1, 4);
+
+ unsigned wind_valid = getbit(msg, 5);
+ unsigned wind_speed_raw = getbits(msg, 6, 14);
+ unsigned wind_direction_raw = getbits(msg, 15, 23);
+
+ unsigned temperature_sign = getbit(msg, 24);
+ unsigned static_air_temperature_raw = getbits(msg, 25, 34);
+
+ unsigned pressure_valid = getbit(msg, 35);
+ unsigned static_pressure_raw = getbits(msg, 36, 46);
+
+ unsigned turbulence_valid = getbit(msg, 47);
+ unsigned turbulence_raw = getbits(msg, 48, 49);
+
+ unsigned humidity_valid = getbit(msg, 50);
+ unsigned humidity_raw = getbits(msg, 51, 56);
+
+/*
+ if (!wind_valid || !temperature_valid || !pressure_valid || !turbulence_valid && !humidity_valid){
+ return 0;
+ }
+*/
+ int met_source = source;
+ int score = 0;
+ int wind_speed = 0;
+ float wind_direction = 0;
+ float temperature = 0;
+ int static_pressure = 0;
+ int turbulence = 0;
+ float humidity = 0;
+ if (met_source >= 0 && met_source <= 6) {
+ score += 4;
+ }
+ else {
+ return 0;
+ }
+ if (wind_valid){
+ wind_speed = (int)wind_speed_raw;
+ if (wind_speed <= 511 && wind_speed >= 0){
+ score += 9;
+ }
+ else {
+ return 0;
+ }
+ wind_direction = wind_direction_raw * (180 / 256);
+ if (wind_direction >= 0 && wind_direction <= 360){
+ score += 9;
+ }
+ else {
+ return 0;
+ }
+ }
+ else if (wind_speed == 0) {
+ score += 2;
+ }
+ if (temperature_sign){
+ temperature = (static_air_temperature_raw - pow(2, 10)) * 0.25;
+ }
+ else {
+ temperature = static_air_temperature_raw * 0.25;
+ }
+ if (temperature >= -128 && temperature <= 128){
+ score += 10;
+ }
+ else {
+ return 0;
+ }
+ if (pressure_valid){
+ static_pressure = (int)static_pressure_raw;
+ if (static_pressure >= 0 && static_pressure <= 2048){
+ score += 11;
+ return 0;
+ }
+ else {
+ }
+ }
+ else if (static_pressure == 0) {
+ score += 1;
+ }
+ if (turbulence_valid){
+ turbulence = (int)turbulence_raw;
+ if (turbulence >= 0 && turbulence <= 3) {
+ score += 2;
+ }
+ else {
+ return 0;
+ }
+ }
+ else if (turbulence == 0) {
+ score += 1;
+ }
+ if (humidity_valid) {
+ humidity = humidity_raw * (100.0f / 64);
+ if (humidity >= 0 && humidity <= 100){
+ score += 6;
+ }
+ else {
+ return 0;
+ }
+ }
+ else if (humidity == 0) {
+ score += 1;
+ }
+ if (store) {
+ mm->commb_format = COMMB_METEOROLOGICAL_ROUTINE;
+ mm->met_source_valid = 1;
+ mm->met_source = met_source;
+ if (wind_valid) { 
+ mm->wind_valid = 1;
+ mm->wind_speed = wind_speed;
+ mm->wind_direction = wind_direction;
+ }
+ mm->oat_valid = 1;
+ mm->oat = temperature;
+ if (pressure_valid) {
+ mm->static_pressure_valid = 1;
+ mm->static_pressure = static_pressure;
+ }
+ if (turbulence_valid) {
+ mm->turbulence_valid = 1;
+ mm->turbulence = turbulence;
+ }
+ if (humidity_valid) {
+ mm->humidity_valid = 1;
+ mm->humidity = humidity;
+ }
+ }
+ return score;
+}
+

help.h

@@ -120,6 +120,9 @@ static struct argp_option optionsReadsb[] = {
  {"net-only", OptNetOnly, 0, 0, "Enable just networking, no RTL device or file used", 2},
  {"net-bind-address", OptNetBindAddr, "<ip>", 0, "IP address to bind to (default: Any; Use 127.0.0.1 for private)", 2},
  {"net-bo-port", OptNetBoPorts, "<ports>", 0, "TCP Beast output listen ports (default: 0)", 2},
+ {"net-ao-port", OptNetAsterixOutPorts, "<ports>", 0, "TCP Asterix output listen ports (default: 0)", 2},
+ {"net-ai-port", OptNetAsterixInPorts, "<ports>", 0, "TCP Asterix input listen ports (default: 0)", 2},
+ {"net-asterix-reduce", OptNetAsterixReduce, 0, 0, "Apply beast reduce logic and interval to ASTERIX outputs", 2},
  {"net-ri-port", OptNetRiPorts, "<ports>", 0, "TCP raw input listen ports (default: 0)", 2},
  {"net-ro-port", OptNetRoPorts, "<ports>", 0, "TCP raw output listen ports (default: 0)", 2},
  {"net-sbs-port", OptNetSbsPorts, "<ports>", 0, "TCP BaseStation output listen ports (default: 0)", 2},

mode_s.c

@@ -1645,6 +1645,8 @@ static const char *commb_format_to_string(commb_format_t format) {
  return "BDS5,0 Track and turn report";
  case COMMB_HEADING_SPEED:
  return "BDS6,0 Heading and speed report";
+ case COMMB_METEOROLOGICAL_ROUTINE:
+ return "BDS4,4 Meteorological routine air report";
  default:
  return "unknown format";
  }