ttnhabbridge/ttnhabbridge/src/main/java/nl/sikken/bertrik/hab/lorawan/HeliumUplinkMessage.java

package nl.sikken.bertrik.hab.lorawan;

import java.time.Instant;
import java.util.ArrayList;
import java.util.List;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;

import nl.sikken.bertrik.hab.lorawan.LoraWanUplinkMessage.ILoraWanUplink;

@JsonIgnoreProperties(ignoreUnknown = true)
public final class HeliumUplinkMessage implements ILoraWanUplink {

    @JsonProperty("fcnt")
    int fcnt;

    @JsonProperty("port")
    int port;

    @JsonProperty("name")
    String name = "";

    @JsonProperty("payload")
    byte[] payload = new byte[0];

    // milliseconds
    @JsonProperty("reported_at")
    long reportedAt;

    @JsonProperty("hotspots")
    List<HotSpot> hotSpots = new ArrayList<>();

    @JsonIgnoreProperties(ignoreUnknown = true)
    static final class HotSpot {
        @JsonProperty("name")
        String name = "";

        @JsonProperty("lat")
        double latitude;

        @JsonProperty("long")
        double longitude;

        @JsonProperty("rssi")
        double rssi;

        @JsonProperty("snr")
        double snr;
    }

    @Override
    public LoraWanUplinkMessage toLoraWanUplinkMessage() {
        LoraWanUplinkMessage uplink = new LoraWanUplinkMessage("Helium", Instant.ofEpochMilli(reportedAt), name, fcnt,
                port, payload);
        for (HotSpot hotSpot : hotSpots) {
            uplink.addGateway(hotSpot.name.trim(), hotSpot.latitude, hotSpot.longitude, Double.NaN);
        }
        return uplink;
    }

}