From 6fa10cbc543847125ca25cdc1cfbe3f504ae32ca Mon Sep 17 00:00:00 2001
From: simonpoole <simon@poole.ch>
Date: Thu, 14 Feb 2019 11:11:25 +0100
Subject: [PATCH] If @id is present save json for @ref in PointReader

---
 .../de/komoot/photon/elasticsearch/Replicatior.java    | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/src/main/java/de/komoot/photon/elasticsearch/Replicatior.java b/src/main/java/de/komoot/photon/elasticsearch/Replicatior.java
index 8a30d4b03..9f2a6bb5e 100644
--- a/src/main/java/de/komoot/photon/elasticsearch/Replicatior.java
+++ b/src/main/java/de/komoot/photon/elasticsearch/Replicatior.java
@@ -99,6 +99,7 @@ public void run() {
                     InputStream in = new BufferedInputStream(new GZIPInputStream(urlConnection.getInputStream()));
                     JsonReader reader = new JsonReader(in);
                     reader.addReader(com.vividsolutions.jts.geom.Point.class, new PointReader());
+
                     List<PhotonAction> actions = (List<PhotonAction>) reader.readObject();
                     int deletions = 0;
                     int updates = 0;
@@ -166,7 +167,14 @@ public Point read(Object jOb, Deque<JsonObject<String, Object>> stack, Map<Strin
             } else { // crash and burn
                 throw new IllegalArgumentException("PointReader unknown serialisation " + c.getClass().getCanonicalName() + " " + c.toString());
             }
-            return factory.createPoint(new Coordinate(coords[0], coords[1]));
+            if (coords[0] != null && coords[1] != null) {
+                if (((JsonObject) jOb).hasId()) {
+                    // this isn't done automatically
+                    Support.getReader(args).getObjectsRead().put(((JsonObject) jOb).getId(), coordinates);
+                }
+                return factory.createPoint(new Coordinate(coords[0], coords[1]));
+            }
+            throw new IllegalArgumentException("PointReader invlaid coordinates " + c.getClass().getCanonicalName() + " " + c.toString());
         }
     }
 }