Mercurial > gemma

annotate pkg/geoserver/boot.go @ 876:8b9bd9ccdd93 geo-style

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Upload style during boot. TODO: Connect with layer.
author Sascha L. Teichmann <teichmann@intevation.de>
date Sun, 30 Sep 2018 19:42:16 +0200
parents 371c756f0370
children 254cd247826d
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
868
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
1 package geoserver
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
2
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
3 import (
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
4 "bytes"
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
5 "encoding/json"
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
6 "encoding/xml"
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
7 "fmt"
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
8 "io"
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
9 "log"
868
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
10 "net"
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
11 "net/http"
868
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
12 "net/url"
417
ff26ffc18a04 Minor: Removed unnecessary byte slice conversion.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 414
diff changeset
13 "strings"
868
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
14 "time"
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
15
414
c1047fd04a3a Moved project specific Go packages to new pkg folder.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 398
diff changeset
16 "gemma.intevation.de/gemma/pkg/config"
444
c315885825e5 Publish WFS layers on GeoServer from database configuration.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 435
diff changeset
17 "gemma.intevation.de/gemma/pkg/models"
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
18 )
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
19
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
20 const (
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
21 workspaceName = "gemma"
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
22 datastoreName = "gemma"
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
23 databaseScheme = "waterway"
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
24 databaseType = "postgis"
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
25 )
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
26
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
27 const (
477
00b52d653039 It turns out that the GeoServer is happy with the lower privileged 'waterway_user'.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 476
diff changeset
28 startupSQL = `SELECT public.setrole('${user,'||encode('waterway_user', 'hex')||'}')`
431
7cd1536a6797 Replaced sys-admin db user with a metamorphic one.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 429
diff changeset
29 closeupSQL = `RESET ROLE`
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
30 )
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
31
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
32 func basicAuth(user, password string) func(req *http.Request) {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
33 return func(req *http.Request) {
559
f827dc4f3e95 Use stdlib for basic auth instead og home brew in GeoServer config.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 517
diff changeset
34 req.SetBasicAuth(user, password)
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
35 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
36 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
37
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
38 func asJSON(req *http.Request) {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
39 req.Header.Set("Content-Type", "application/json")
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
40 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
41
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
42 func asContentType(req *http.Request, contentType string) {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
43 req.Header.Set("Content-Type", contentType)
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
44 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
45
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
46 func ensureWorkspace() error {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
47 var (
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
48 geoURL = config.GeoServerURL()
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
49 user = config.GeoServerUser()
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
50 password = config.GeoServerPassword()
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
51 auth = basicAuth(user, password)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
52 )
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
53
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
54 // Probe workspace.
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
55 req, err := http.NewRequest(
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
56 http.MethodGet,
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
57 geoURL+"/rest/workspaces/"+workspaceName+".json",
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
58 nil)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
59 if err != nil {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
60 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
61 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
62 auth(req)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
63 resp, err := http.DefaultClient.Do(req)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
64 if err != nil {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
65 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
66 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
67
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
68 if resp.StatusCode != http.StatusNotFound {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
69 log.Println("info: workspace " + workspaceName + " already exists.")
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
70 return nil
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
71 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
72
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
73 // Create workspace
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
74
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
75 log.Println("info: creating workspace " + workspaceName)
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
76
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
77 const createJSON = `{"workspace":{"name":"` + workspaceName + `"}}`
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
78
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
79 req, err = http.NewRequest(
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
80 http.MethodPost,
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
81 geoURL+"/rest/workspaces",
417
ff26ffc18a04 Minor: Removed unnecessary byte slice conversion.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 414
diff changeset
82 strings.NewReader(createJSON))
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
83 if err != nil {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
84 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
85 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
86 auth(req)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
87 asJSON(req)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
88 if resp, err = http.DefaultClient.Do(req); err != nil {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
89 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
90 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
91
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
92 if resp.StatusCode != http.StatusCreated {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
93 err = fmt.Errorf("Status code '%s' (%d)",
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
94 http.StatusText(resp.StatusCode),
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
95 resp.StatusCode)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
96 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
97
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
98 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
99 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
100
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
101 func ensureDataStore() error {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
102 var (
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
103 geoURL = config.GeoServerURL()
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
104 user = config.GeoServerUser()
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
105 password = config.GeoServerPassword()
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
106 auth = basicAuth(user, password)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
107 )
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
108
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
109 // Probe datastore.
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
110 req, err := http.NewRequest(
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
111 http.MethodGet,
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
112 geoURL+"/rest/workspaces/"+workspaceName+"/datastores/"+datastoreName+".json",
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
113 nil)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
114 if err != nil {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
115 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
116 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
117 auth(req)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
118 resp, err := http.DefaultClient.Do(req)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
119 if err != nil {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
120 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
121 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
122
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
123 if resp.StatusCode != http.StatusNotFound {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
124 log.Println("info: datastore " + datastoreName + " already exists.")
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
125 return nil
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
126 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
127
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
128 // Create datastore.
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
129 log.Println("info: creating datastore " + datastoreName)
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
130
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
131 type entry struct {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
132 Key interface{} `json:"@key"`
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
133 Value interface{} `json:"$"`
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
134 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
135
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
136 // Create datastore.
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
137 ds := map[string]interface{}{
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
138 "dataStore": map[string]interface{}{
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
139 "name": datastoreName,
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
140 "connectionParameters": map[string]interface{}{
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
141 "entry": []entry{
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
142 {"host", config.DBHost()},
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
143 {"port", config.DBPort()},
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
144 {"database", config.DBName()},
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
145 {"schema", databaseScheme},
517
7e45aaec7081 Consolidate configuration parameters.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 477
diff changeset
146 {"user", config.DBUser()},
7e45aaec7081 Consolidate configuration parameters.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 477
diff changeset
147 {"passwd", config.DBPassword()},
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
148 {"dbtype", databaseType},
433
da05704e25c1 Removed templating from GeoServer startup SQL script.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 432
diff changeset
149 {"Session startup SQL", startupSQL},
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
150 {"Session close-up SQL", closeupSQL},
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
151 },
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
152 },
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
153 },
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
154 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
155 var out bytes.Buffer
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
156 enc := json.NewEncoder(&out)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
157 if err := enc.Encode(&ds); err != nil {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
158 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
159 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
160
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
161 req, err = http.NewRequest(
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
162 http.MethodPost,
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
163 geoURL+"/rest/workspaces/"+workspaceName+"/datastores",
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
164 bytes.NewReader(out.Bytes()))
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
165 if err != nil {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
166 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
167 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
168 auth(req)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
169 asJSON(req)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
170 resp, err = http.DefaultClient.Do(req)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
171 if err != nil {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
172 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
173 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
174
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
175 if resp.StatusCode != http.StatusCreated {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
176 err = fmt.Errorf("Status code '%s' (%d)",
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
177 http.StatusText(resp.StatusCode),
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
178 resp.StatusCode)
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
179 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
180
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
181 return err
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
182 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
183
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
184 func ensureFeatures() error {
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
185 var (
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
186 geoURL = config.GeoServerURL()
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
187 user = config.GeoServerUser()
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
188 password = config.GeoServerPassword()
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
189 auth = basicAuth(user, password)
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
190 )
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
191
474
11d80120ed3d Renamed published services to internal services to be more symmetrical to external services.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 467
diff changeset
192 tables := models.InternalServices.Filter(models.IntWFS)
398
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
193 if len(tables) == 0 {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
194 log.Println("info: no tables to publish")
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
195 return nil
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
196 }
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
197
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
198 log.Printf("info: number of tables to publish %d\n", len(tables))
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
199
398
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
200 var features struct {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
201 FeatureTypes struct {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
202 FeatureType []struct {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
203 Name string `json:"name"`
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
204 } `json:"featureType"`
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
205 } `json:"featureTypes"`
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
206 }
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
207
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
208 hasFeature := func(name string) bool {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
209 for _, ft := range features.FeatureTypes.FeatureType {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
210 if ft.Name == name {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
211 return true
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
212 }
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
213 }
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
214 return false
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
215 }
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
216
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
217 // Fetch all featuretypes.
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
218 req, err := http.NewRequest(
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
219 http.MethodGet,
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
220 geoURL+"/rest/workspaces/"+workspaceName+
398
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
221 "/datastores/"+datastoreName+
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
222 "/featuretypes.json",
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
223 nil)
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
224 if err != nil {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
225 return err
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
226 }
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
227 auth(req)
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
228 resp, err := http.DefaultClient.Do(req)
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
229 if err != nil {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
230 return err
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
231 }
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
232
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
233 err = json.NewDecoder(resp.Body).Decode(&features)
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
234 resp.Body.Close()
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
235 if err != nil {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
236 // XXX: Quirk in the JSON return by GeoServer:
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
237 // If there are no features in the datastore
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
238 // featureType deserializes to an empty string ""
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
239 // instead of an empty array *palmface*.
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
240 // So assume there no features.
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
241 hasFeature = func(string) bool { return false }
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
242 }
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
243
449
a74b8c2a4e75 Removed the command line option to publish tables with GeoServer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 444
diff changeset
244 for i := range tables {
a74b8c2a4e75 Removed the command line option to publish tables with GeoServer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 444
diff changeset
245 table := tables[i].Name
444
c315885825e5 Publish WFS layers on GeoServer from database configuration.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 435
diff changeset
246
398
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
247 if hasFeature(table) {
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
248 log.Printf("info: featuretype %s already exists.\n", table)
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
249 continue
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
250 }
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
251
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
252 // Create featuretype.
398
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
253 log.Printf("info: creating featuretype %s.\n", table)
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
254
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
255 // Create featuretype
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
256 ft := map[string]interface{}{
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
257 "featureType": map[string]interface{}{
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
258 "name": table,
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
259 "nativeName": table,
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
260 "title": table,
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
261 },
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
262 }
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
263
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
264 var out bytes.Buffer
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
265 enc := json.NewEncoder(&out)
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
266 if err := enc.Encode(&ft); err != nil {
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
267 return err
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
268 }
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
269
398
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
270 req, err := http.NewRequest(
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
271 http.MethodPost,
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
272 geoURL+"/rest/workspaces/"+workspaceName+
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
273 "/datastores/"+datastoreName+
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
274 "/featuretypes",
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
275 bytes.NewReader(out.Bytes()))
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
276 if err != nil {
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
277 return err
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
278 }
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
279 auth(req)
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
280 asJSON(req)
398
0b8921797064 To reduce the number of REST calls to the GeoServer when publishing gemma tables
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 395
diff changeset
281 resp, err := http.DefaultClient.Do(req)
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
282 if err != nil {
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
283 return err
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
284 }
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
285
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
286 if resp.StatusCode != http.StatusCreated {
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
287 return fmt.Errorf("Status code '%s' (%d)",
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
288 http.StatusText(resp.StatusCode),
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
289 resp.StatusCode)
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
290 }
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
291 }
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
292
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
293 return nil
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
294 }
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
295
874
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
296 func deleteWorkspace() error {
875
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
297
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
298 // Should we delete our workspace first?
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
299 if !config.GeoServerClean() {
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
300 return nil
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
301 }
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
302
874
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
303 log.Println("info: delete workspace " + workspaceName)
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
304 var (
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
305 geoURL = config.GeoServerURL()
874
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
306 user = config.GeoServerUser()
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
307 password = config.GeoServerPassword()
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
308 auth = basicAuth(user, password)
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
309 )
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
310
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
311 req, err := http.NewRequest(
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
312 http.MethodDelete,
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
313 geoURL+"/rest/workspaces/"+workspaceName+"?recurse=true",
874
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
314 nil)
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
315 if err != nil {
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
316 return err
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
317 }
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
318 auth(req)
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
319 _, err = http.DefaultClient.Do(req)
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
320 return err
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
321 }
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
322
875
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
323 func ensureStyles() error {
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
324 log.Println("info: creating styles")
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
325
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
326 var (
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
327 geoURL = config.GeoServerURL()
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
328 user = config.GeoServerUser()
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
329 password = config.GeoServerPassword()
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
330 auth = basicAuth(user, password)
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
331 )
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
332
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
333 type styles struct {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
334 Styles struct {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
335 Style []struct {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
336 Name string `json:"name"`
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
337 } `json:"style"`
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
338 } `json:"styles"`
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
339 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
340
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
341 var stls styles
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
342
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
343 hasStyle := func(name string) bool {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
344 for i := range stls.Styles.Style {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
345 if stls.Styles.Style[i].Name == name {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
346 return true
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
347 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
348 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
349 return false
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
350 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
351
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
352 req, err := http.NewRequest(
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
353 http.MethodGet,
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
354 geoURL+"/rest/workspaces/"+workspaceName+"/styles.json",
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
355 nil)
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
356 if err != nil {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
357 return err
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
358 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
359 auth(req)
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
360 resp, err := http.DefaultClient.Do(req)
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
361 if err != nil {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
362 return err
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
363 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
364
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
365 // Fetch all styles
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
366 if err := json.NewDecoder(resp.Body).Decode(&stls); err != nil {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
367 // XXX: Same quirk as with featuretypes.
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
368 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
369 resp.Body.Close()
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
370
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
371 entries := models.InternalServices.Filter(
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
372 models.IntAnd(models.IntWMS, models.IntWithStyle))
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
373
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
374 for i := range entries {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
375 if hasStyle(entries[i].Name) {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
376 log.Printf("already has style for %s\n", entries[i].Name)
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
377 continue
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
378 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
379
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
380 log.Printf("creating style %s\n", entries[i].Name)
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
381
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
382 req, err := http.NewRequest(
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
383 http.MethodPost,
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
384 geoURL+"/rest/workspaces/"+workspaceName+"/styles?name="+
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
385 url.QueryEscape(entries[i].Name),
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
386 strings.NewReader(entries[i].Style.String))
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
387 if err != nil {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
388 return err
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
389 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
390 auth(req)
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
391 if isSymbologyEncoding(entries[i].Style.String) {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
392 asContentType(req, "application/vnd.ogc.se+xml")
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
393 } else {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
394 asContentType(req, "application/vnd.ogc.sld+xml")
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
395 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
396 resp, err := http.DefaultClient.Do(req)
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
397 if err != nil {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
398 return err
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
399 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
400
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
401 if resp.StatusCode != http.StatusCreated {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
402 return fmt.Errorf("cannot create style %s (%s)",
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
403 entries[i].Name, http.StatusText(resp.StatusCode))
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
404 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
405
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
406 // TODO: Connect with feature.
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
407 }
875
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
408
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
409 return nil
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
410 }
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
411
876
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
412 // isSymbologyEncoding tries to figure out if its plain SLD or SE.
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
413 func isSymbologyEncoding(data string) bool {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
414 decoder := xml.NewDecoder(strings.NewReader(data))
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
415 for {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
416 tok, err := decoder.Token()
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
417 switch {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
418 case tok == nil && err == io.EOF:
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
419 return false
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
420 case err != nil:
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
421 log.Printf("warn: invalid XML: %v\n", err)
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
422 return false
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
423 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
424 if t, ok := tok.(xml.StartElement); ok &&
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
425 t.Name.Space == "http://www.opengis.net/se" {
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
426 return true
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
427 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
428 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
429 }
8b9bd9ccdd93 Upload style during boot. TODO: Connect with layer.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 875
diff changeset
430
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
431 func prepareGeoServer() error {
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
432
517
7e45aaec7081 Consolidate configuration parameters.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 477
diff changeset
433 if config.DBUser() == "" {
435
7d2afdc263b5 Don't panic if we have no metamorphic db user.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 433
diff changeset
434 log.Println("info: Need metamorphic db user to configure GeoServer")
432
5f5b3ca0c9fe Fixed wrong SQL startup script for GeoServer.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 431
diff changeset
435 return nil
5f5b3ca0c9fe Fixed wrong SQL startup script for GeoServer.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 431
diff changeset
436 }
5f5b3ca0c9fe Fixed wrong SQL startup script for GeoServer.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 431
diff changeset
437
395
272ed64a5053 Create feature layers in GeoServer via REST API.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 386
diff changeset
438 if config.GeoServerURL() == "" {
875
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
439 log.Println("info: No URL to GeoServer configured")
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
440 return nil
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
441 }
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
442
875
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
443 for _, ensure := range []func() error{
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
444 deleteWorkspace,
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
445 ensureWorkspace,
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
446 ensureDataStore,
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
447 ensureFeatures,
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
448 ensureStyles,
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
449 } {
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
450 if err := ensure(); err != nil {
874
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
451 return err
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
452 }
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
453 }
da526b58c9c4 Added a flag geoserver-clean to force deletion of the gemma workspace before configuring the GeoServer again.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents: 868
diff changeset
454
875
371c756f0370 Code simplification in geoserver boot configuration.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 874
diff changeset
455 return nil
386
999f4f83a072 Configure GeoServer via REST-API. TODO: Configure layers.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff changeset
456 }
868
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
457
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
458 func ConfigureBoot() {
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
459 log.Println("Configure GeoServer...")
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
460 const maxTries = 10
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
461 const sleep = time.Second * 5
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
462
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
463 for try := 1; try <= maxTries; try++ {
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
464 err := prepareGeoServer()
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
465 if err == nil {
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
466 break
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
467 }
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
468 if try < maxTries {
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
469 if uerr, ok := err.(*url.Error); ok {
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
470 if oerr, ok := uerr.Err.(*net.OpError); ok && oerr.Op == "dial" {
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
471 log.Printf("Failed attempt %d of %d to configure GeoServer. "+
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
472 "Will try again in %s...\n", try, maxTries, sleep)
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
473 time.Sleep(sleep)
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
474 continue
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
475 }
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
476 }
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
477 }
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
478 log.Printf("warn: configure GeoServer failed: %v\n", err)
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
479 break
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
480 }
aa8f30c1ed27 Moved GeoServer configuration to own package.
Sascha L. Teichmann <teichmann@intevation.de>
parents: 559
diff changeset
481 }