added station database

Author: TomBlock

core/src/main/java/com/bc/fiduceo/reader/insitu/ndbc/NdbcInsituReader.java

@@ -25,12 +25,12 @@ class NdbcInsituReader implements Reader {
     private static final String REG_EX_CW = "\\w{5}c\\d{4}.txt";
     private static final String REG_EX_SM = "\\w{5}h\\d{4}.txt";
 
-    private final HashMap<String, GeoPos> buoyLocations;
+    private static StationDatabase stationDatabase;
+
     private final MeasurementType type;
 
     public NdbcInsituReader(MeasurementType type) {
         this.type = type;
-        this.buoyLocations = new HashMap<>();
     }
 
     @Override
@@ -111,4 +111,10 @@ public String getLongitudeVariableName() {
     public String getLatitudeVariableName() {
         throw new RuntimeException("not implemented");
     }
+
+    private void ensureStationDatabase() {
+        if (stationDatabase == null) {
+
+        }
+    }
 }

core/src/main/java/com/bc/fiduceo/reader/insitu/ndbc/Station.java

@@ -3,36 +3,88 @@
 class Station {
 
     private final String id;
+    private final MeasurementType measurementType;
     private float lon;
     private float lat;
     private float anHeight;
+    private float airTempHeight;
+    private float barHeight;
+    private float sstDepth;
     private StationType type;
 
-    Station(String id) {
+    public Station(String id, MeasurementType measurementType) {
         this.id = id;
+        this.measurementType = measurementType;
 
         lon = Float.NaN;
         lat = Float.NaN;
         anHeight = Float.NaN;
+        airTempHeight = Float.NaN;
+        barHeight = Float.NaN;
+        sstDepth = Float.NaN;
     }
 
     String getId() {
         return id;
     }
 
-     float getLon() {
+    float getLon() {
         return lon;
     }
 
-     float getLat() {
+    void setLon(float lon) {
+        this.lon = lon;
+    }
+
+    float getLat() {
         return lat;
     }
 
-    public StationType getType() {
+    void setLat(float lat) {
+        this.lat = lat;
+    }
+
+    StationType getType() {
         return type;
     }
 
-    public float getAnemometerHeight() {
+    void setType(StationType stationType) {
+        this.type = stationType;
+    }
+
+    float getAnemometerHeight() {
         return anHeight;
     }
+
+    void setAnemometerHeight(float anHeight) {
+        this.anHeight = anHeight;
+    }
+
+    float getAirTemperatureHeight() {
+        return airTempHeight;
+    }
+
+    void setAirTemperatureHeight(float airTempHeight) {
+        this.airTempHeight = airTempHeight;
+    }
+
+    float getBarometerHeight() {
+        return barHeight;
+    }
+
+    void setBarometerHeight(float barHeight) {
+        this.barHeight = barHeight;
+    }
+
+    float getSSTDepth() {
+        return sstDepth;
+    }
+
+    void setSSTDepth(float sstDepth) {
+        this.sstDepth = sstDepth;
+    }
+
+    MeasurementType getMeasurementType() {
+        return measurementType;
+    }
 }

core/src/main/java/com/bc/fiduceo/reader/insitu/ndbc/StationDatabase.java

@@ -9,6 +9,9 @@
 import java.util.ArrayList;
 import java.util.HashMap;
 
+import static com.bc.fiduceo.reader.insitu.ndbc.MeasurementType.CONSTANT_WIND;
+import static com.bc.fiduceo.reader.insitu.ndbc.MeasurementType.STANDARD_METEOROLOGICAL;
+
 class StationDatabase {
 
     private static final int CW_STATION_TOKENS = 5;
@@ -36,11 +39,41 @@ void load(InputStream inputStream) throws IOException {
     }
 
     private void parseSmStations(ArrayList<String> lineList) {
+        for (final String line : lineList) {
+            final String[] tokens = StringUtils.split(line, new char[]{'|'}, true);
+            final String stationId = tokens[0];
+
+            final Station station = new Station(stationId, STANDARD_METEOROLOGICAL);
+            parseBasicProperties(tokens, station);
+
+            station.setAirTemperatureHeight(Float.parseFloat(tokens[5]));
+            station.setBarometerHeight(Float.parseFloat(tokens[6]));
+            station.setSSTDepth(Float.parseFloat(tokens[7]));
 
+            stationMap.put(stationId, station);
+        }
     }
 
     private void parseCwStation(ArrayList<String> lineList) {
+        for (final String line : lineList) {
+            final String[] tokens = StringUtils.split(line, new char[]{'|'}, true);
+            final String stationId = tokens[0];
+
+            final Station station = new Station(stationId, CONSTANT_WIND);
+            parseBasicProperties(tokens, station);
+
+            stationMap.put(tokens[0], station);
+        }
+    }
+
+    private static void parseBasicProperties(String[] tokens, Station station) {
+        station.setLat(Float.parseFloat(tokens[1]));
+        station.setLon(Float.parseFloat(tokens[2]));
+
+        final StationType stationType = StationType.valueOf(tokens[3]);
+        station.setType(stationType);
 
+        station.setAnemometerHeight(Float.parseFloat(tokens[4]));
     }
 
     private static ArrayList<String> readInputLines(InputStream inputStream) throws IOException {
@@ -58,6 +91,6 @@ private static ArrayList<String> readInputLines(InputStream inputStream) throws
     }
 
     Station get(String id) {
-        return new Station(id);
+        return stationMap.get(id);
     }
 }

core/src/main/resources/com/bc/fiduceo/reader.nbdc/buoy_locations_sm.txt

@@ -379,4 +379,15 @@ PILA2     | 59.742   | -149.47   | COAST_STATION  | 6.6               | 6.4
 PILM4     | 48.223   | -88.366   | LAKE_STATION   | 15.5              | 9.8             | 230.4            | NaN
 PLSF1     | 24.693   | -82.773   | OCEAN_STATION  | 17.7              | 17.4            | 15.8             | 1.5
 PLXA2     | 56.247   | -134.647  | COAST_STATION  | 8.5               | 7.9             | 5.6              | 4.0
-PMOA2     | 55.99    | -160.562  | COAST_STATION  | 13.2              | 7.3             | 5.4              | 1.9
+PMOA2     | 55.99    | -160.562  | COAST_STATION  | 13.2              | 7.3             | 5.4              | 1.9
+PNGW3     | 46.792   | -91.386   | LAKE_STATION   | 10.0              | 3.0             | 185.9            | NaN
+PNLM4     | 45.968   | -85.869   | LAKE_STATION   | 10.3              | 6.5             | 180.2            | 4.6
+PORO3     | 42.739   | -124.498  | COAST_STATION  | 9.1               | 8.7             | 8.0              | 1.3
+PRDA2     | 70.4     | -148.527  | COAST_STATION  | NaN               | 23.68           | 4.8              | 3.3
+PSCM4     | 43.42    | -82.54    | LAKE_STATION   | 10.0              | 3.3             | 191.8            | NaN
+PSLC1     | 35.169   | -120.754  | COAST_STATION  | 13.6              | 12.7            | 11.6             | 3.5
+PSTL1     | 28.932   | -89.407   | COAST_STATION  | 20.3              | 2.5             | 4.7              | 5.7
+PTAT2     | 27.826   | -97.051   | COAST_STATION  | 14.9              | 9.1             | 6.4              | 1.0
+PTAW1     | 48.125   | -123.441  | COAST_STATION  | 12.2              | 4.6             | 5.5              | 2.9
+PTBM6     | 30.213   | -88.505   | COAST_STATION  | 4.6               | 2.5             | 1.5              | NaN
+PTGC1     | 34.577   | -120.648  | COAST_STATION  | 9.4               | 9.1             | 33.5             | NaN

core/src/test/java/com/bc/fiduceo/reader/insitu/ndbc/StationDatabaseTest.java

@@ -5,6 +5,10 @@
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
 
+import static com.bc.fiduceo.reader.insitu.ndbc.MeasurementType.CONSTANT_WIND;
+import static com.bc.fiduceo.reader.insitu.ndbc.MeasurementType.STANDARD_METEOROLOGICAL;
+import static com.bc.fiduceo.reader.insitu.ndbc.StationType.COAST_STATION;
+import static com.bc.fiduceo.reader.insitu.ndbc.StationType.OCEAN_BUOY;
 import static org.junit.Assert.assertEquals;
 
 public class StationDatabaseTest {
@@ -24,10 +28,44 @@ public void testLoadAndGet_CW() throws IOException {
 
         Station station = stationDatabase.get("41002");
         assertEquals("41002", station.getId());
-        // @todo 1 tb/tb continue here 2023-02-22
-        //assertEquals(31.759f, station.getLat(), 1e-8);
+        assertEquals(31.759f, station.getLat(), 1e-8);
+        assertEquals(-74.936f, station.getLon(), 1e-8);
+        assertEquals(OCEAN_BUOY, station.getType());
+        assertEquals(CONSTANT_WIND, station.getMeasurementType());
+        assertEquals(4.1f, station.getAnemometerHeight(), 1e-8);
 
         station = stationDatabase.get("41004");
         assertEquals("41004", station.getId());
+        assertEquals(32.502f, station.getLat(), 1e-8);
+        assertEquals(-79.099f, station.getLon(), 1e-8);
+        assertEquals(OCEAN_BUOY, station.getType());
+        assertEquals(CONSTANT_WIND, station.getMeasurementType());
+        assertEquals(4.1f, station.getAnemometerHeight(), 1e-8);
+    }
+
+    @Test
+    public void testLoadANdGet_SM() throws IOException {
+        final String resourceFile = "AAMC1     | 37.772   | -122.3    | COAST_STATION  | 6.9               | 4.3             | 5.3              | 1.2\n" +
+                "ADKA2     | 51.861   | -176.637  | COAST_STATION  | 7.0               | 6.3             | 7.0              | 2.8\n" +
+                "AGMW3     | 44.608   | -87.433   | LAKE_STATION   | 9.0               | 9.0             | NaN              | NaN\n" +
+                "AGXC1     | 33.716   | -118.246  | COAST_STATION  | 20.0              | NaN             | NaN              | NaN\n" +
+                "AJXA2     | 58.287   | -134.398  | COAST_STATION  | 3.0               | 3.0             | 7.6              | NaN\n" +
+                "ALIA2     | 56.898   | -154.247  | COAST_STATION  | 10.3              | 9.7             | 6.5              | 2.2";
+
+        final ByteArrayInputStream inputStream = new ByteArrayInputStream(resourceFile.getBytes());
+
+        final StationDatabase stationDatabase = new StationDatabase();
+        stationDatabase.load(inputStream);
+
+        Station station = stationDatabase.get("ADKA2");
+        assertEquals("ADKA2", station.getId());
+        assertEquals(51.861f, station.getLat(), 1e-8);
+        assertEquals(-176.637f, station.getLon(), 1e-8);
+        assertEquals(COAST_STATION, station.getType());
+        assertEquals(STANDARD_METEOROLOGICAL, station.getMeasurementType());
+        assertEquals(7.0f, station.getAnemometerHeight(), 1e-8);
+        assertEquals(6.3f, station.getAirTemperatureHeight(), 1e-8);
+        assertEquals(7.0f, station.getBarometerHeight(), 1e-8);
+        assertEquals(2.8f, station.getSSTDepth(), 1e-8);
     }
 }

core/src/test/java/com/bc/fiduceo/reader/insitu/ndbc/StationTest.java

@@ -1,20 +1,74 @@
 package com.bc.fiduceo.reader.insitu.ndbc;
 
+import org.junit.Before;
 import org.junit.Test;
 
+import static com.bc.fiduceo.reader.insitu.ndbc.MeasurementType.STANDARD_METEOROLOGICAL;
+import static com.bc.fiduceo.reader.insitu.ndbc.StationType.OCEAN_STATION;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNull;
 
 public class StationTest {
 
+    private Station station;
+
+    @Before
+    public void setUp() {
+        station = new Station("abgdzt", STANDARD_METEOROLOGICAL);
+    }
+
     @Test
     public void testConstruction() {
-        final Station station = new Station("abgdzt");
-
         assertEquals("abgdzt", station.getId());
         assertEquals(Float.NaN, station.getLon(), 1e-8);
         assertEquals(Float.NaN, station.getLat(), 1e-8);
         assertNull(station.getType());
+        assertEquals(STANDARD_METEOROLOGICAL, station.getMeasurementType());
         assertEquals(Float.NaN, station.getAnemometerHeight(), 1e-8);
+        assertEquals(Float.NaN, station.getAirTemperatureHeight(), 1e-8);
+        assertEquals(Float.NaN, station.getBarometerHeight(), 1e-8);
+        assertEquals(Float.NaN, station.getSSTDepth(), 1e-8);
+    }
+
+    @Test
+    public void testSetGetLat() {
+        station.setLat(23.56f);
+        assertEquals(23.56f, station.getLat(), 1e-8);
+    }
+
+    @Test
+    public void testSetGetLon() {
+        station.setLon(34.56f);
+        assertEquals(34.56f, station.getLon(), 1e-8);
+    }
+
+    @Test
+    public void testSetGetType() {
+        station.setType(OCEAN_STATION);
+        assertEquals(OCEAN_STATION, station.getType());
+    }
+
+    @Test
+    public void testSetGetAnemometerHeight() {
+        station.setAnemometerHeight(2.8f);
+        assertEquals(2.8f, station.getAnemometerHeight(), 1e-8);
+    }
+
+    @Test
+    public void testSetGetAirTemperatureHeight() {
+        station.setAirTemperatureHeight(3.9f);
+        assertEquals(3.9f, station.getAirTemperatureHeight(), 1e-8);
+    }
+
+    @Test
+    public void testSetGetBarometerHeight() {
+        station.setBarometerHeight(4.0f);
+        assertEquals(4.0f, station.getBarometerHeight(), 1e-8);
+    }
+
+    @Test
+    public void testSetGetSSTDepth() {
+        station.setSSTDepth(5.1f);
+        assertEquals(5.1f, station.getSSTDepth(), 1e-8);
     }
 }