Method doBotRequest

backend/plugin/webhook/teams/app.go:548–600

(ctx context.Context, method, apiURL string, data []byte)

}

func (p *provider) doBotRequest(ctx context.Context, method, apiURL string, data []byte) ([]byte, error) {
	const maxRetries = 3

	for i := 0; i < maxRetries; i++ {
		if ctx.Err() != nil {
			return nil, ctx.Err()
		}

		b, retry, err := func() ([]byte, bool, error) {
			req, err := http.NewRequestWithContext(ctx, method, apiURL, bytes.NewReader(data))
			if err != nil {
				return nil, false, errors.Wrapf(err, "failed to construct request")
			}

			req.Header.Set("Authorization", "Bearer "+p.botToken)
			req.Header.Set("Content-Type", "application/json")

			resp, err := p.c.Do(req)
			if err != nil {
				return nil, false, errors.Wrapf(err, "request failed")
			}
			defer resp.Body.Close()

			respBody, err := io.ReadAll(resp.Body)
			if err != nil {
				return nil, false, errors.Wrapf(err, "failed to read response")
			}

			if resp.StatusCode == http.StatusUnauthorized {
				if err := p.refreshBotToken(ctx); err != nil {
					return nil, false, errors.Wrapf(err, "failed to refresh token")
				}
				return nil, true, nil
			}

			if resp.StatusCode < 200 || resp.StatusCode >= 300 {
				return nil, false, errors.Errorf("request failed with status %d: %s", resp.StatusCode, string(respBody))
			}

			return respBody, false, nil
		}()

		if err != nil {
			return nil, err
		}
		if retry {
			continue
		}
		return b, nil
	}

	return nil, errors.Errorf("exceeded max retries for %s %s", method, apiURL)
}

// Validate validates the Teams configuration by attempting to get a token and look up a user.
func Validate(ctx context.Context, tenantID, clientID, clientSecret, email string) error {