Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -2,3 +2,4 @@ tmp
*.o
*.sh
*.txt
/config.yaml
1 change: 1 addition & 0 deletions Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -16,5 +16,6 @@ RUN apt-get update \
&& rm -rf /var/lib/apt/lists/*

COPY --from=corebuilder /work/hyperproxy /usr/local/bin
COPY ./config.yaml.sample /etc/hyperproxy/config.yaml

CMD ["hyperproxy"]
1 change: 1 addition & 0 deletions config.yaml.sample
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
whitelist:
1 change: 1 addition & 0 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,7 @@ require (
google.golang.org/genproto/googleapis/rpc v0.0.0-20241104194629-dd2ea8efbc28 // indirect
google.golang.org/grpc v1.67.1 // indirect
google.golang.org/protobuf v1.35.1 // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect
)

replace github.com/chai2010/webp => github.com/totegamma/webp v0.0.0
1 change: 1 addition & 0 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -88,5 +88,6 @@ google.golang.org/grpc v1.67.1 h1:zWnc1Vrcno+lHZCOofnIMvycFcc0QRGIzm9dhnDX68E=
google.golang.org/grpc v1.67.1/go.mod h1:1gLDyUQU7CTLJI90u3nXZ9ekeghjeM7pTDZlqFNg2AA=
google.golang.org/protobuf v1.35.1 h1:m3LfL6/Ca+fqnjnlqQXNpFPABW1UD7mjh8KO2mKFytA=
google.golang.org/protobuf v1.35.1/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
37 changes: 31 additions & 6 deletions image.go
Original file line number Diff line number Diff line change
Expand Up @@ -205,15 +205,40 @@ func ImageHandler(c echo.Context) error {
return c.String(400, err.Error())
}

for _, denyIP := range denyIps {
_, ipnet, err := net.ParseCIDR(denyIP)
if err != nil {
fmt.Println("Error parsing CIDR: ", err)
span.RecordError(err)
whiteListMap := make(map[string]bool)
var whiteListCIDRs []*net.IPNet
for _, entry := range IpsWhiteList {
if _, ipNet, err := net.ParseCIDR(entry); err == nil {
whiteListCIDRs = append(whiteListCIDRs, ipNet)
} else {
whiteListMap[entry] = true
}
}

for _, targetIP := range targetIPs {

if whiteListMap[targetIP.String()] {
continue
}
inWhiteList := false
for _, cidr := range whiteListCIDRs {
if cidr.Contains(targetIP) {
inWhiteList = true
break
}
}
if inWhiteList {
continue
}

for _, denyIP := range denyIps {
_, ipnet, err := net.ParseCIDR(denyIP)
if err != nil {
fmt.Println("Error parsing CIDR: ", err)
span.RecordError(err)
continue
}

for _, targetIP := range targetIPs {
if ipnet.Contains(targetIP) {
err := errors.New("IP is in deny list")
span.RecordError(err)
Expand Down
33 changes: 33 additions & 0 deletions main.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,8 @@ package main
import (
"context"
"fmt"
"gopkg.in/yaml.v3"
"io/ioutil"
"net/http"
"os"
"time"
Expand Down Expand Up @@ -30,6 +32,27 @@ var denyIps = []string{
"fc00::/7",
}

var IpsWhiteList []string

type Config struct {
Whitelist []string `yaml:"whitelist"`
}

func LoadWhitelist(filePath string) ([]string, error) {
data, err := ioutil.ReadFile(filePath)
if err != nil {
return nil, err
}

var config Config
err = yaml.Unmarshal(data, &config)
if err != nil {
return nil, err
}

return config.Whitelist, nil
}

var (
mc *memcache.Client
client = &http.Client{
Expand All @@ -44,6 +67,16 @@ const (

func main() {

whitelistFile := "/etc/hyperproxy/config.yaml"
loadedWhitelist, err := LoadWhitelist(whitelistFile)
if err != nil {
fmt.Println("Error loading whitelist:", err)
os.Exit(1)
}

IpsWhiteList = loadedWhitelist
fmt.Println("Loaded whitelist:", IpsWhiteList)

mc = memcache.New(os.Getenv("MEMCACHED_HOST"))
defer mc.Close()

Expand Down