ext_client.go 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. package functions
  2. import (
  3. "fmt"
  4. "io"
  5. "log"
  6. "net/http"
  7. "github.com/gravitl/netmaker/cli/config"
  8. "github.com/gravitl/netmaker/models"
  9. )
  10. // GetAllExtClients - fetch all external clients
  11. func GetAllExtClients() *[]models.ExtClient {
  12. return request[[]models.ExtClient](http.MethodGet, "/api/extclients", nil)
  13. }
  14. // GetNetworkExtClients - fetch external clients associated with a network
  15. func GetNetworkExtClients(networkName string) *[]models.ExtClient {
  16. return request[[]models.ExtClient](http.MethodGet, "/api/extclients/"+networkName, nil)
  17. }
  18. // GetExtClient - fetch a single external client
  19. func GetExtClient(networkName, clientID string) *models.ExtClient {
  20. return request[models.ExtClient](http.MethodGet, fmt.Sprintf("/api/extclients/%s/%s", networkName, clientID), nil)
  21. }
  22. // GetExtClientConfig - fetch a wireguard config of an external client
  23. func GetExtClientConfig(networkName, clientID string) string {
  24. _, ctx := config.GetCurrentContext()
  25. req, err := http.NewRequest(http.MethodGet, fmt.Sprintf("%s/api/extclients/%s/%s/file", ctx.Endpoint, networkName, clientID), nil)
  26. if err != nil {
  27. log.Fatal(err)
  28. }
  29. if ctx.MasterKey != "" {
  30. req.Header.Set("Authorization", "Bearer "+ctx.MasterKey)
  31. } else {
  32. req.Header.Set("Authorization", "Bearer "+getAuthToken(ctx, true))
  33. }
  34. res, err := http.DefaultClient.Do(req)
  35. if err != nil {
  36. log.Fatal(err)
  37. }
  38. bodyBytes, err := io.ReadAll(res.Body)
  39. if err != nil {
  40. log.Fatal(err)
  41. }
  42. return string(bodyBytes)
  43. }
  44. // CreateExtClient - create an external client
  45. func CreateExtClient(networkName, nodeID, extClientID string) {
  46. if extClientID != "" {
  47. request[any](http.MethodPost, fmt.Sprintf("/api/extclients/%s/%s", networkName, nodeID), &models.CustomExtClient{
  48. ClientID: extClientID,
  49. })
  50. } else {
  51. request[any](http.MethodPost, fmt.Sprintf("/api/extclients/%s/%s", networkName, nodeID), nil)
  52. }
  53. }
  54. // DeleteExtClient - delete an external client
  55. func DeleteExtClient(networkName, clientID string) *models.SuccessResponse {
  56. return request[models.SuccessResponse](http.MethodDelete, fmt.Sprintf("/api/extclients/%s/%s", networkName, clientID), nil)
  57. }
  58. // UpdateExtClient - update an external client
  59. func UpdateExtClient(networkName, clientID string, payload *models.ExtClient) *models.ExtClient {
  60. return request[models.ExtClient](http.MethodPut, fmt.Sprintf("/api/extclients/%s/%s", networkName, clientID), payload)
  61. }