Method getActionServiceInfo

util/github/scalesets/token.go:29–83

(ctx context.Context)

)

func (s *ScaleSetClient) getActionServiceInfo(ctx context.Context) (_ params.ActionsServiceAdminInfoResponse, err error) {
	s.recordOperation("GetActionServiceInfo")
	defer func() {
		if err != nil {
			s.recordFailedOperation("GetActionServiceInfo")
		}
	}()

	regPath := "/actions/runner-registration"
	baseURL := s.ghCli.GithubBaseURL()
	url, err := baseURL.Parse(regPath)
	if err != nil {
		return params.ActionsServiceAdminInfoResponse{}, fmt.Errorf("failed to parse url: %w", err)
	}

	entity := s.ghCli.GetEntity()
	body := params.ActionsServiceAdminInfoRequest{
		URL:         entity.ForgeURL(),
		RunnerEvent: "register",
	}

	buf := &bytes.Buffer{}
	enc := json.NewEncoder(buf)
	enc.SetEscapeHTML(false)

	if err := enc.Encode(body); err != nil {
		return params.ActionsServiceAdminInfoResponse{}, err
	}
	req, err := http.NewRequestWithContext(ctx, http.MethodPost, url.String(), buf)
	if err != nil {
		return params.ActionsServiceAdminInfoResponse{}, fmt.Errorf("failed to create request: %w", err)
	}

	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("Authorization", fmt.Sprintf("RemoteAuth %s", *s.runnerRegistrationToken.Token))

	resp, err := s.Do(req)
	if err != nil {
		return params.ActionsServiceAdminInfoResponse{}, fmt.Errorf("failed to get actions service admin info: %w", err)
	}
	defer resp.Body.Close()

	data, err := io.ReadAll(resp.Body)
	if err != nil {
		return params.ActionsServiceAdminInfoResponse{}, fmt.Errorf("failed to read response body: %w", err)
	}
	data = bytes.TrimPrefix(data, []byte("\xef\xbb\xbf"))

	var info params.ActionsServiceAdminInfoResponse
	if err := json.Unmarshal(data, &info); err != nil {
		return params.ActionsServiceAdminInfoResponse{}, fmt.Errorf("failed to decode response: %w", err)
	}

	return info, nil
}

func (s *ScaleSetClient) ensureAdminInfo(ctx context.Context) error {
	s.mux.Lock()