mirror of
https://github.com/opentofu/opentofu.git
synced 2025-02-25 18:45:20 -06:00
015e96d0dd
* Initial checkin for PR request * Added an argument to provider to allow control over whether or not TLS Certs will skip verification. Controllable via provider or env variable being set * Initial check-in to use refactored module * Checkin of very MVP for creating/deleting host test which works and validates basic host creation and deletion * Check in with support for creating hosts with variables working * Checking in work to date * Remove code that causes travis CI to fail while I debug * Adjust create to accept multivale * Back on track. Working basic tests. go-icinga2-api needs more test too * Squashing * Back on track. Working basic tests. go-icinga2-api needs more test too * Check in refactored hostgroup support * Check in refactored check_command, hosts, and hsotgroup with a few test * Checking in service code * Add in dependency for icinga2 provider * Add documentation. Refactor, fix and extend based on feedback from Hashicorp * Added checking and validation around invalid URL and unavailable server
135 lines
3.1 KiB
Go
135 lines
3.1 KiB
Go
// Package iapi provides a client for interacting with an Icinga2 Server
|
|
package iapi
|
|
|
|
import (
|
|
"bytes"
|
|
"crypto/tls"
|
|
"encoding/json"
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
// Server ... Use to be ClientConfig
|
|
type Server struct {
|
|
Username string
|
|
Password string
|
|
BaseURL string
|
|
AllowUnverifiedSSL bool
|
|
httpClient *http.Client
|
|
}
|
|
|
|
// func New ...
|
|
func New(username, password, url string, allowUnverifiedSSL bool) (*Server, error) {
|
|
return &Server{username, password, url, allowUnverifiedSSL, nil}, nil
|
|
}
|
|
|
|
// func Config ...
|
|
func (server *Server) Config(username, password, url string, allowUnverifiedSSL bool) (*Server, error) {
|
|
|
|
// TODO : Add code to verify parameters
|
|
return &Server{username, password, url, allowUnverifiedSSL, nil}, nil
|
|
|
|
}
|
|
|
|
func (server *Server) Connect() error {
|
|
|
|
t := &http.Transport{
|
|
TLSClientConfig: &tls.Config{
|
|
InsecureSkipVerify: server.AllowUnverifiedSSL,
|
|
},
|
|
}
|
|
|
|
server.httpClient = &http.Client{
|
|
Transport: t,
|
|
Timeout: time.Second * 60,
|
|
}
|
|
|
|
request, err := http.NewRequest("GET", server.BaseURL, nil)
|
|
if err != nil {
|
|
server.httpClient = nil
|
|
}
|
|
|
|
request.SetBasicAuth(server.Username, server.Password)
|
|
request.Header.Set("Accept", "application/json")
|
|
request.Header.Set("Content-Type", "application/json")
|
|
|
|
response, err := server.httpClient.Do(request)
|
|
|
|
if (err != nil) || (response == nil) {
|
|
server.httpClient = nil
|
|
return err
|
|
}
|
|
|
|
defer response.Body.Close()
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
// NewAPIRequest ...
|
|
func (server *Server) NewAPIRequest(method, APICall string, jsonString []byte) (*APIResult, error) {
|
|
|
|
var results APIResult
|
|
|
|
fullURL := server.BaseURL + APICall
|
|
|
|
t := &http.Transport{
|
|
TLSClientConfig: &tls.Config{
|
|
InsecureSkipVerify: server.AllowUnverifiedSSL,
|
|
},
|
|
}
|
|
|
|
server.httpClient = &http.Client{
|
|
Transport: t,
|
|
Timeout: time.Second * 60,
|
|
}
|
|
|
|
request, requestErr := http.NewRequest(method, fullURL, bytes.NewBuffer(jsonString))
|
|
if requestErr != nil {
|
|
return nil, requestErr
|
|
}
|
|
|
|
request.SetBasicAuth(server.Username, server.Password)
|
|
request.Header.Set("Accept", "application/json")
|
|
request.Header.Set("Content-Type", "application/json")
|
|
|
|
response, doErr := server.httpClient.Do(request)
|
|
if doErr != nil {
|
|
results.Code = 0
|
|
results.Status = "Error : Request to server failed : " + doErr.Error()
|
|
results.ErrorString = doErr.Error()
|
|
return &results, doErr
|
|
}
|
|
|
|
defer response.Body.Close()
|
|
|
|
if decodeErr := json.NewDecoder(response.Body).Decode(&results); decodeErr != nil {
|
|
return nil, decodeErr
|
|
}
|
|
|
|
if results.Code == 0 { // results.Code has default value so set it.
|
|
results.Code = response.StatusCode
|
|
}
|
|
|
|
if results.Status == "" { // results.Status has default value, so set it.
|
|
results.Status = response.Status
|
|
}
|
|
|
|
switch results.Code {
|
|
case 0:
|
|
results.ErrorString = "Did not get a response code."
|
|
case 404:
|
|
results.ErrorString = results.Status
|
|
case 200:
|
|
results.ErrorString = results.Status
|
|
default:
|
|
theError := strings.Replace(results.Results.([]interface{})[0].(map[string]interface{})["errors"].([]interface{})[0].(string), "\n", " ", -1)
|
|
results.ErrorString = strings.Replace(theError, "Error: ", "", -1)
|
|
|
|
}
|
|
|
|
return &results, nil
|
|
|
|
}
|