Method Refresh

util/github/scalesets/message_sessions.go:113–146

(ctx context.Context)

}

func (m *MessageSession) Refresh(ctx context.Context) (err error) {
	m.ssCli.recordOperation("RefreshMessageSession")
	defer func() {
		if err != nil {
			m.ssCli.recordFailedOperation("RefreshMessageSession")
		}
	}()

	slog.DebugContext(ctx, "refreshing message session token", "session_id", m.session.SessionID.String())
	m.mux.Lock()
	defer m.mux.Unlock()

	relPath, err := m.SessionsRelativeURL()
	if err != nil {
		return fmt.Errorf("failed to get session URL: %w", err)
	}
	req, err := m.ssCli.newActionsRequest(ctx, http.MethodPatch, relPath, nil)
	if err != nil {
		return fmt.Errorf("failed to create message delete request: %w", err)
	}
	resp, err := m.ssCli.Do(req)
	if err != nil {
		return fmt.Errorf("failed to delete message session: %w", err)
	}
	defer resp.Body.Close()

	var refreshedSession params.RunnerScaleSetSession
	if err := json.NewDecoder(resp.Body).Decode(&refreshedSession); err != nil {
		return fmt.Errorf("failed to decode response: %w", err)
	}
	slog.DebugContext(ctx, "refreshed message session token")
	m.session = &refreshedSession
	return nil
}

func (m *MessageSession) maybeRefreshToken(ctx context.Context) error {
	if m.session == nil {