register.go 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081
  1. package functions
  2. import (
  3. "bytes"
  4. "crypto/ed25519"
  5. "crypto/rand"
  6. "encoding/json"
  7. "errors"
  8. "log"
  9. "net/http"
  10. "os"
  11. "github.com/gravitl/netmaker/logger"
  12. "github.com/gravitl/netmaker/netclient/config"
  13. "github.com/gravitl/netmaker/netclient/ncutils"
  14. "github.com/gravitl/netmaker/tls"
  15. "github.com/kr/pretty"
  16. )
  17. func Register(cfg *config.ClientConfig) error {
  18. if cfg.Server.Server == "" {
  19. return errors.New("no server provided")
  20. }
  21. if cfg.Server.AccessKey == "" {
  22. return errors.New("no access key provided")
  23. }
  24. //create certificate request
  25. _, key, err := ed25519.GenerateKey(rand.Reader)
  26. if err != nil {
  27. return err
  28. }
  29. name := tls.NewCName(os.Getenv("HOSTNAME"))
  30. csr, err := tls.NewCSR(key, name)
  31. if err != nil {
  32. return err
  33. }
  34. data := config.RegisterRequest{
  35. Name: name,
  36. CSR: *csr,
  37. }
  38. pretty.Println(data.CSR.PublicKey)
  39. pretty.Println(data.CSR.RawSubjectPublicKeyInfo)
  40. pretty.Println("data\n", data)
  41. payload, err := json.Marshal(data)
  42. if err != nil {
  43. return err
  44. }
  45. os.WriteFile("/tmp/data", payload, os.ModePerm)
  46. url := cfg.Server.API + "/api/server/register"
  47. log.Println("registering at ", url)
  48. request, err := http.NewRequest(http.MethodPost, url, bytes.NewBuffer(payload))
  49. if err != nil {
  50. return err
  51. }
  52. request.Header.Set("Content-Type", "application/json")
  53. request.Header.Set("authorization", "Bearer "+cfg.Server.AccessKey)
  54. client := http.Client{}
  55. response, err := client.Do(request)
  56. if err != nil {
  57. return err
  58. }
  59. if response.StatusCode != http.StatusOK {
  60. return errors.New(response.Status)
  61. }
  62. var resp config.RegisterResponse
  63. if err := json.NewDecoder(response.Body).Decode(&resp); err != nil {
  64. return errors.New("unmarshal cert error " + err.Error())
  65. }
  66. if err := tls.SaveCert(ncutils.GetNetclientPath()+cfg.Server.Server, "root.cert", &resp.CA); err != nil {
  67. return err
  68. }
  69. if err := tls.SaveCert(ncutils.GetNetclientPath(), "client.cert", &resp.Cert); err != nil {
  70. return err
  71. }
  72. if err := tls.SaveKey(ncutils.GetNetclientPath(), "client.key", resp.Key); err != nil {
  73. return err
  74. }
  75. logger.Log(0, "certificates/key saved ")
  76. return nil
  77. }