# HG changeset patch
# User Sascha L. Teichmann <sascha.teichmann@intevation.de>
# Date 1537801818 -7200
# Node ID e6f8d58434f45afefd3d78beddaa1d3e0738faa9
# Parent  f09cbe80a864ab65840ac7a219c052f8c4f7609f
Added stub for octree based cross sections.

diff -r f09cbe80a864 -r e6f8d58434f4 pkg/controllers/octreecross.go
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/pkg/controllers/octreecross.go	Mon Sep 24 17:10:18 2018 +0200
@@ -0,0 +1,87 @@
+package controllers
+
+import (
+	"context"
+	"database/sql"
+	"log"
+	"net/http"
+	"time"
+
+	"gemma.intevation.de/gemma/pkg/models"
+	"gemma.intevation.de/gemma/pkg/octree"
+)
+
+const (
+	reprojectSQL = `
+SELECT ST_X(p), ST_Y(p)
+FROM ST_Transform(ST_SetSRID(ST_MakePoint($1, $2), $3::integer), $4::integer) AS p`
+)
+
+func reproject(
+	conn *sql.Conn,
+	ctx context.Context,
+	src models.GeoJSONLineCoordinates,
+	fromEPSG, toEPSG uint32,
+) (models.GeoJSONLineCoordinates, error) {
+
+	stmt, err := conn.PrepareContext(ctx, reprojectSQL)
+	if err != nil {
+		return nil, err
+	}
+	defer stmt.Close()
+
+	dst := make(models.GeoJSONLineCoordinates, len(src))
+	for i, s := range src {
+		d := &dst[i]
+		if err := stmt.QueryRowContext(
+			ctx,
+			s.Lat, s.Lon,
+			fromEPSG, toEPSG,
+		).Scan(&d.Lat, &d.Lon); err != nil {
+			return nil, err
+		}
+	}
+	return dst, nil
+}
+
+func octreeCrossSection(
+	input interface{},
+	req *http.Request,
+	conn *sql.Conn,
+) (jr JSONResult, err error) {
+
+	csi := input.(*models.CrossSectionInput)
+
+	start := time.Now()
+
+	tree, err := octree.Cache.Get(
+		csi.Properties.Bottleneck, csi.Properties.Date.Time,
+		conn, req.Context())
+
+	log.Printf("loading octree took: %s\n", time.Since(start))
+	if err != nil {
+		return
+	}
+
+	// The coordinate system of the octree is an UTM projection.
+	// The input coordinates are in WGS84.
+	// So we need to reproject them.
+
+	start = time.Now()
+
+	coords, err := reproject(
+		conn, req.Context(),
+		csi.Geometry.Coordinates,
+		4326, tree.EPSG)
+
+	log.Printf("transforming input coords took: %s\n", time.Since(start))
+	if err != nil {
+		return
+	}
+
+	for i := 0; i < len(coords)-1; i++ {
+		// TODO: Query segmentwise (i, i+1).
+	}
+
+	return
+}
diff -r f09cbe80a864 -r e6f8d58434f4 pkg/controllers/routes.go
--- a/pkg/controllers/routes.go	Mon Sep 24 16:40:54 2018 +0200
+++ b/pkg/controllers/routes.go	Mon Sep 24 17:10:18 2018 +0200
@@ -105,6 +105,11 @@
 
 	// Cross sections
 
+	api.Handle("/octcross", any(&JSONHandler{
+		Input:  func() interface{} { return new(models.CrossSectionInput) },
+		Handle: octreeCrossSection,
+	})).Methods(http.MethodPost)
+
 	api.Handle("/cross", any(&JSONHandler{
 		Input:  func() interface{} { return new(models.CrossSectionInput) },
 		Handle: crossSection,