package apiserver import ( "bytes" "encoding/json" "fmt" "io/ioutil" "net/http" "net/url" "time" "github.com/up9inc/mizu/shared/kubernetes" "github.com/up9inc/mizu/cli/config" "github.com/up9inc/mizu/shared" "github.com/up9inc/mizu/shared/logger" core "k8s.io/api/core/v1" ) type Provider struct { url string retries int client *http.Client } const DefaultRetries = 20 const DefaultTimeout = 5 * time.Second func NewProvider(url string, retries int, timeout time.Duration) *Provider { return &Provider{ url: url, retries: config.GetIntEnvConfig(config.ApiServerRetries, retries), client: &http.Client{ Timeout: timeout, }, } } func NewProviderWithoutRetries(url string, timeout time.Duration) *Provider { return &Provider{ url: url, retries: 1, client: &http.Client{ Timeout: timeout, }, } } func (provider *Provider) TestConnection() error { retriesLeft := provider.retries for retriesLeft > 0 { if isReachable, err := provider.isReachable(); err != nil || !isReachable { logger.Log.Debugf("api server not ready yet %v", err) } else { logger.Log.Debugf("connection test to api server passed successfully") break } retriesLeft -= 1 time.Sleep(time.Second) } if retriesLeft == 0 { return fmt.Errorf("couldn't reach the api server after %v retries", provider.retries) } return nil } func (provider *Provider) isReachable() (bool, error) { echoUrl := fmt.Sprintf("%s/echo", provider.url) if response, err := provider.client.Get(echoUrl); err != nil { return false, err } else if response.StatusCode != 200 { return false, fmt.Errorf("invalid status code %v", response.StatusCode) } else { return true, nil } } func (provider *Provider) ReportTapperStatus(tapperStatus shared.TapperStatus) error { tapperStatusUrl := fmt.Sprintf("%s/status/tapperStatus", provider.url) if jsonValue, err := json.Marshal(tapperStatus); err != nil { return fmt.Errorf("failed Marshal the tapper status %w", err) } else { if response, err := provider.client.Post(tapperStatusUrl, "application/json", bytes.NewBuffer(jsonValue)); err != nil { return fmt.Errorf("failed sending to API server the tapped pods %w", err) } else if response.StatusCode != 200 { return fmt.Errorf("failed sending to API server the tapper status, response status code %v", response.StatusCode) } else { logger.Log.Debugf("Reported to server API about tapper status: %v", tapperStatus) return nil } } } func (provider *Provider) ReportTappedPods(pods []core.Pod) error { tappedPodsUrl := fmt.Sprintf("%s/status/tappedPods", provider.url) podInfos := kubernetes.GetPodInfosForPods(pods) if jsonValue, err := json.Marshal(podInfos); err != nil { return fmt.Errorf("failed Marshal the tapped pods %w", err) } else { if response, err := provider.client.Post(tappedPodsUrl, "application/json", bytes.NewBuffer(jsonValue)); err != nil { return fmt.Errorf("failed sending to API server the tapped pods %w", err) } else if response.StatusCode != 200 { return fmt.Errorf("failed sending to API server the tapped pods, response status code %v", response.StatusCode) } else { logger.Log.Debugf("Reported to server API about %d taped pods successfully", len(podInfos)) return nil } } } func (provider *Provider) GetGeneralStats() (map[string]interface{}, error) { generalStatsUrl := fmt.Sprintf("%s/status/general", provider.url) response, requestErr := provider.client.Get(generalStatsUrl) if requestErr != nil { return nil, fmt.Errorf("failed to get general stats for telemetry, err: %w", requestErr) } else if response.StatusCode != 200 { return nil, fmt.Errorf("failed to get general stats for telemetry, status code: %v", response.StatusCode) } defer response.Body.Close() data, readErr := ioutil.ReadAll(response.Body) if readErr != nil { return nil, fmt.Errorf("failed to read general stats for telemetry, err: %v", readErr) } var generalStats map[string]interface{} if parseErr := json.Unmarshal(data, &generalStats); parseErr != nil { return nil, fmt.Errorf("failed to parse general stats for telemetry, err: %v", parseErr) } return generalStats, nil } func (provider *Provider) GetVersion() (string, error) { versionUrl, _ := url.Parse(fmt.Sprintf("%s/metadata/version", provider.url)) req := &http.Request{ Method: http.MethodGet, URL: versionUrl, } statusResp, err := provider.client.Do(req) if err != nil { return "", err } defer statusResp.Body.Close() versionResponse := &shared.VersionResponse{} if err := json.NewDecoder(statusResp.Body).Decode(&versionResponse); err != nil { return "", err } return versionResponse.SemVer, nil }