// Copyright 2021 The casbin Authors. All Rights Reserved. // // 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 object import ( "fmt" "net" "net/http" "time" "github.com/casbin/casnode/conf" "golang.org/x/net/proxy" ) var httpClient *http.Client func InitHttpClient() { httpClient = getProxyHttpClient() } func isAddressOpen(address string) bool { timeout := time.Millisecond * 100 conn, err := net.DialTimeout("tcp", address, timeout) if err != nil { // cannot connect to address, proxy is not active return false } if conn != nil { defer conn.Close() fmt.Printf("Socks5 proxy enabled: %s\n", address) return true } return false } func getProxyHttpClient() *http.Client { httpProxy := conf.GetConfigString("httpProxy") if httpProxy == "" { return &http.Client{} } if !isAddressOpen(httpProxy) { return &http.Client{} } // https://stackoverflow.com/questions/33585587/creating-a-go-socks5-client dialer, err := proxy.SOCKS5("tcp", httpProxy, nil, proxy.Direct) if err != nil { panic(err) } tr := &http.Transport{Dial: dialer.Dial} return &http.Client{ Transport: tr, } }