diff pkg/imports/wg.go @ 1810:7ee9bdaac336

Waterway gauge import: Added support for username/password.
author Sascha L. Teichmann <sascha.teichmann@intevation.de>
date Tue, 15 Jan 2019 18:09:10 +0100
parents 77582da3adb0
children 4910bcfab319
line wrap: on
line diff
--- a/pkg/imports/wg.go	Tue Jan 15 17:02:51 2019 +0100
+++ b/pkg/imports/wg.go	Tue Jan 15 18:09:10 2019 +0100
@@ -17,8 +17,11 @@
 	"context"
 	"database/sql"
 	"errors"
+	"log"
 
 	"gemma.intevation.de/gemma/pkg/common"
+	"gemma.intevation.de/gemma/pkg/soap"
+	"gemma.intevation.de/gemma/pkg/soap/erdms"
 )
 
 type WaterwayGauge struct {
@@ -76,6 +79,35 @@
 	conn *sql.Conn,
 	feedback Feedback,
 ) (interface{}, error) {
+
+	var auth *soap.BasicAuth
+	if wg.Username != "" {
+		auth = &soap.BasicAuth{
+			Login:    wg.Username,
+			Password: wg.Password,
+		}
+	}
+
+	client := erdms.NewRefService(wg.URL, wg.Insecure, auth)
+
+	request := &erdms.GetRisDataXML{
+		GetRisDataXMLType: &erdms.GetRisDataXMLType{
+			Subcode: "AT%",
+			Funcode: "wtwgag",
+		},
+	}
+
+	log.Printf("user: %s password: %s\n", wg.Username, wg.Password)
+
+	data, err := client.GetRisDataXML(request)
+
+	if err != nil {
+		log.Printf("error: %v\n", err)
+		return nil, err
+	}
+
+	_ = data
+
 	// TODO: Implement me!
 	return nil, errors.New("Not implemented, yet!")
 }