Mercurial > gemma
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!") }