1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
// Copyright 2013 Canonical Ltd. This software is licensed under the
// GNU Lesser General Public License version 3 (see the file COPYING).
package gwacl
import (
"fmt"
"net/http"
"net/url"
"strings"
)
type x509Session struct {
subscriptionId string
certFile string
}
// newX509Session creates and returns a new x509Session based on credentials
// and X509 certificate files.
func newX509Session(subscriptionId string, certFile string) (*x509Session, error) {
return &x509Session{subscriptionId: subscriptionId, certFile: certFile}, nil
}
var AZURE_URL = "https://management.core.windows.net/"
// composeURL puts together a URL for an item on the Azure API based on
// the starting point used by the session, and a given relative path from
// there.
func (session *x509Session) composeURL(path string) string {
if strings.HasPrefix(path, "/") {
panic(fmt.Errorf("got absolute API path '%s' instead of relative one", path))
}
azure_url, err := url.Parse(AZURE_URL)
if err != nil {
panic(err)
}
path = fmt.Sprintf("___/%s", path)
path_url, err := url.Parse(path)
if err != nil {
panic(err)
}
return interpolateURL(
azure_url.ResolveReference(path_url).String(),
session.subscriptionId)
}
// _X509Dispatcher is the function used to dispatch requests. We call the
// function through this pointer, not directly, so that tests can inject
// fakes.
var _X509Dispatcher = performX509CurlRequest
// getServerError returns a ServerError matching the given server response
// status, or nil if the server response indicates success.
func (session *x509Session) getServerError(status int, body []byte, description string) error {
if status < http.StatusOK || status >= http.StatusMultipleChoices {
return newHTTPError(status, body, description)
}
return nil
}
// get performs a GET request to the Azure management API.
// It returns the response body and/or an error. If the error is a
// ServerError, the returned body will be the one received from the server.
// For any other kind of error, the returned body will be nil.
func (session *x509Session) get(path string) (*x509Response, error) {
request := newX509RequestGET(session.composeURL(path))
response, err := _X509Dispatcher(session, request)
if err != nil {
return nil, err
}
err = session.getServerError(response.StatusCode, response.Body, "GET request failed")
return response, err
}
// post performs a POST request to the Azure management API.
// It returns the response body and/or an error. If the error is a
// ServerError, the returned body will be the one received from the server.
// For any other kind of error, the returned body will be nil.
// Be aware that Azure may perform POST operations asynchronously. If you are
// not sure, call blockUntilCompleted() on the response.
func (session *x509Session) post(path string, body []byte, contentType string) (*x509Response, error) {
request := newX509RequestPOST(session.composeURL(path), body, contentType)
response, err := _X509Dispatcher(session, request)
if err != nil {
return nil, err
}
err = session.getServerError(response.StatusCode, response.Body, "POST request failed")
return response, err
}
// delete performs a DELETE request to the Azure management API.
// Be aware that Azure may perform DELETE operations asynchronously. If you
// are not sure, call blockUntilCompleted() on the response.
func (session *x509Session) delete(path string) (*x509Response, error) {
request := newX509RequestDELETE(session.composeURL(path))
response, err := _X509Dispatcher(session, request)
if err != nil {
return response, err
}
err = session.getServerError(response.StatusCode, response.Body, "DELETE request failed")
return response, err
}
// put performs a PUT request to the Azure management API.
// Be aware that Azure may perform PUT operations asynchronously. If you are
// not sure, call blockUntilCompleted() on the response.
func (session *x509Session) put(path string, body []byte) (*x509Response, error) {
request := newX509RequestPUT(session.composeURL(path), body)
response, err := _X509Dispatcher(session, request)
if err != nil {
return nil, err
}
err = session.getServerError(response.StatusCode, response.Body, "POST request failed")
return response, err
}
|