Update for latest wkt

Cargo.toml

@@ -7,7 +7,10 @@ resolver = "2"
 [workspace.package]
 # This version should match the version in [workspace.dependencies] below
 version = "0.13.0"
-authors = ["Pirmin Kalberer <pka@sourcepole.ch>", "Yuri Astrakhan <YuriAstrakhan@gmail.com>"]
+authors = [
+    "Pirmin Kalberer <pka@sourcepole.ch>",
+    "Yuri Astrakhan <YuriAstrakhan@gmail.com>",
+]
 edition = "2021"
 homepage = "https://github.com/georust/geozero"
 repository = "https://github.com/georust/geozero"
@@ -27,7 +30,9 @@ clap = { version = "4.3", features = ["derive"] }
 criterion = "0.5.1"
 csv = "1.2.2"
 dbase = "0.4"
-diesel = { version = "2.1.0", default-features = false, features = ["postgres"] }
+diesel = { version = "2.1.0", default-features = false, features = [
+    "postgres",
+] }
 dup-indexer = "0.3"
 env_logger = "0.10.0"
 flatgeobuf = "4.0.0"
@@ -56,7 +61,7 @@ serde_json = "1.0.104"
 sqlx = { version = "0.7", default-features = false }
 thiserror = "1.0"
 tokio = { version = "1.30.0", default-features = false }
-wkt = "0.10.3"
+wkt = "0.11"
 
 [patch.crates-io]
 geozero = { path = "./geozero" }

geozero/src/csv/csv_reader.rs

@@ -132,14 +132,12 @@ pub fn process_csv_geom(
             processor.geometrycollection_begin(1, 0)?;
         }
 
-        crate::wkt::wkt_reader::process_wkt_geom_n(&wkt.item, record_idx, processor).map_err(
-            |e| {
-                // +2 to start at line 1 and to account for the header row
-                let line = record_idx + 2;
-                log::warn!("line {line}: invalid WKT: '{geometry_field}', record: {record:?}");
-                e
-            },
-        )?;
+        crate::wkt::wkt_reader::process_wkt_geom_n(&wkt, record_idx, processor).map_err(|e| {
+            // +2 to start at line 1 and to account for the header row
+            let line = record_idx + 2;
+            log::warn!("line {line}: invalid WKT: '{geometry_field}', record: {record:?}");
+            e
+        })?;
     }
 
     if !collection_started {

geozero/src/wkt/wkt_reader.rs

@@ -4,7 +4,6 @@ use crate::{FeatureProcessor, GeomProcessor, GeozeroDatasource, GeozeroGeometry}
 use std::io::Read;
 use std::str::FromStr;
 use wkt::types::{Coord, LineString, Polygon};
-use wkt::Geometry;
 
 /// A wrapper around a WKT String or String slice.
 #[derive(Debug)]
@@ -85,22 +84,22 @@ pub fn read_wkt<R: Read, P: GeomProcessor>(reader: &mut R, processor: &mut P) ->
     let mut wkt_string = String::new();
     reader.read_to_string(&mut wkt_string)?;
     let wkt = wkt::Wkt::from_str(&wkt_string).map_err(|e| GeozeroError::Geometry(e.to_string()))?;
-    process_wkt_geom(&wkt.item, processor)
+    process_wkt_geom(&wkt, processor)
 }
 
 /// Process WKT geometry
-fn process_wkt_geom<P: GeomProcessor>(geometry: &Geometry<f64>, processor: &mut P) -> Result<()> {
+fn process_wkt_geom<P: GeomProcessor>(geometry: &wkt::Wkt<f64>, processor: &mut P) -> Result<()> {
     process_wkt_geom_n(geometry, 0, processor)
 }
 
 pub(crate) fn process_wkt_geom_n<P: GeomProcessor>(
-    geometry: &Geometry<f64>,
+    geometry: &wkt::Wkt<f64>,
     idx: usize,
     processor: &mut P,
 ) -> Result<()> {
     let multi_dim = processor.multi_dim();
     match geometry {
-        Geometry::Point(g) => {
+        wkt::Wkt::Point(g) => {
             if let Some(ref coord) = g.0 {
                 processor.point_begin(idx)?;
                 process_coord(coord, multi_dim, 0, processor)?;
@@ -109,7 +108,7 @@ pub(crate) fn process_wkt_geom_n<P: GeomProcessor>(
                 processor.empty_point(idx)
             }
         }
-        Geometry::MultiPoint(g) => {
+        wkt::Wkt::MultiPoint(g) => {
             processor.multipoint_begin(g.0.len(), idx)?;
             let multi_dim1 = processor.multi_dim();
             for (idxc, point) in g.0.iter().enumerate() {
@@ -123,23 +122,23 @@ pub(crate) fn process_wkt_geom_n<P: GeomProcessor>(
             }
             processor.multipoint_end(idx)
         }
-        Geometry::LineString(g) => process_linestring(g, true, idx, processor),
-        Geometry::MultiLineString(g) => {
+        wkt::Wkt::LineString(g) => process_linestring(g, true, idx, processor),
+        wkt::Wkt::MultiLineString(g) => {
             processor.multilinestring_begin(g.0.len(), idx)?;
             for (idxc, linestring) in g.0.iter().enumerate() {
                 process_linestring(linestring, false, idxc, processor)?;
             }
             processor.multilinestring_end(idx)
         }
-        Geometry::Polygon(g) => process_polygon(g, true, idx, processor),
-        Geometry::MultiPolygon(g) => {
+        wkt::Wkt::Polygon(g) => process_polygon(g, true, idx, processor),
+        wkt::Wkt::MultiPolygon(g) => {
             processor.multipolygon_begin(g.0.len(), idx)?;
             for (idx2, polygon) in g.0.iter().enumerate() {
                 process_polygon(polygon, false, idx2, processor)?;
             }
             processor.multipolygon_end(idx)
         }
-        Geometry::GeometryCollection(g) => {
+        wkt::Wkt::GeometryCollection(g) => {
             processor.geometrycollection_begin(g.0.len(), idx)?;
             for (idx2, geometry) in g.0.iter().enumerate() {
                 process_wkt_geom_n(geometry, idx2, processor)?;