Mercurial > gemma

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

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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
comparison
equal deleted inserted replaced
1809:b16a6db0008f 1810:7ee9bdaac336
15 15
16 import ( 16 import (
17 "context" 17 "context"
18 "database/sql" 18 "database/sql"
19 "errors" 19 "errors"
20 "log"
20 21
21 "gemma.intevation.de/gemma/pkg/common" 22 "gemma.intevation.de/gemma/pkg/common"
23 "gemma.intevation.de/gemma/pkg/soap"
24 "gemma.intevation.de/gemma/pkg/soap/erdms"
22 ) 25 )
23 26
24 type WaterwayGauge struct { 27 type WaterwayGauge struct {
25 // URL is the URL of the SOAP service. 28 // URL is the URL of the SOAP service.
26 URL string `json:"url"` 29 URL string `json:"url"`
74 ctx context.Context, 77 ctx context.Context,
75 importID int64, 78 importID int64,
76 conn *sql.Conn, 79 conn *sql.Conn,
77 feedback Feedback, 80 feedback Feedback,
78 ) (interface{}, error) { 81 ) (interface{}, error) {
82
83 var auth *soap.BasicAuth
84 if wg.Username != "" {
85 auth = &soap.BasicAuth{
86 Login: wg.Username,
87 Password: wg.Password,
88 }
89 }
90
91 client := erdms.NewRefService(wg.URL, wg.Insecure, auth)
92
93 request := &erdms.GetRisDataXML{
94 GetRisDataXMLType: &erdms.GetRisDataXMLType{
95 Subcode: "AT%",
96 Funcode: "wtwgag",
97 },
98 }
99
100 log.Printf("user: %s password: %s\n", wg.Username, wg.Password)
101
102 data, err := client.GetRisDataXML(request)
103
104 if err != nil {
105 log.Printf("error: %v\n", err)
106 return nil, err
107 }
108
109 _ = data
110
79 // TODO: Implement me! 111 // TODO: Implement me!
80 return nil, errors.New("Not implemented, yet!") 112 return nil, errors.New("Not implemented, yet!")
81 } 113 }