opensandbox-group--opensandbox/components/execd/pkg/jupyter/transport.go

// Copyright 2025 Alibaba Group Holding Ltd.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package jupyter

import (
	"net/http"
	"sync"
)

type AuthTransport struct {
	Token string
	Base  http.RoundTripper

	host   string
	scheme string
	mu     sync.Mutex
}

func (t *AuthTransport) RoundTrip(req *http.Request) (*http.Response, error) {
	reqClone := req.Clone(req.Context())
	allowAuth := true
	if reqClone.URL != nil {
		t.mu.Lock()
		if t.host == "" {
			t.host = reqClone.URL.Host
		}
		if t.scheme == "" {
			t.scheme = reqClone.URL.Scheme
		}
		allowAuth = reqClone.URL.Host == t.host && reqClone.URL.Scheme == t.scheme
		t.mu.Unlock()
	}
	if allowAuth {
		reqClone.Header.Set("Authorization", "Token "+t.Token)
	}
	return t.Base.RoundTrip(reqClone)
}