Skip to content

Commit ccb8bfa

Browse files
committed
fix
1 parent 52e2a35 commit ccb8bfa

File tree

1 file changed

+21
-9
lines changed

1 file changed

+21
-9
lines changed

pkg/vpcmodel/externalNetwork.go

Lines changed: 21 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ package vpcmodel
88

99
import (
1010
"errors"
11+
"fmt"
1112
"sync"
1213

1314
"github.com/np-guard/models/pkg/netset"
@@ -28,15 +29,17 @@ var once sync.Once
2829

2930
// singleton struct
3031
type NetworkAddressLists struct {
31-
publicInternetAddressList []string
32-
serviceNetworkAddressList []string
32+
publicInternetAddressList []*netset.IPBlock
33+
serviceNetworkAddressList []*netset.IPBlock
3334
}
3435

3536
var networkAddressList = &NetworkAddressLists{}
3637

3738
func InitNetworkAddressLists(publicInternetAddressList, serviceNetworkAddressList []string) {
3839
once.Do(func() {
39-
networkAddressList = &NetworkAddressLists{publicInternetAddressList, serviceNetworkAddressList}
40+
ipbListPI, _, _ := ipStringsToIPblocks(publicInternetAddressList)
41+
ipbListSN, _, _ := ipStringsToIPblocks(serviceNetworkAddressList)
42+
networkAddressList = &NetworkAddressLists{ipbListPI, ipbListSN}
4043
})
4144
}
4245

@@ -66,17 +69,26 @@ func GetDefaultPublicInternetAddressList() []string {
6669
}
6770
}
6871

69-
func (n *NetworkAddressLists) GetPublicInternetIPblocksList() (internetIPblocksList []*netset.IPBlock,
70-
allInternetRagnes *netset.IPBlock, err error) {
72+
func (n *NetworkAddressLists) GetPublicInternetIPblocksList() ([]*netset.IPBlock, *netset.IPBlock, error) {
7173
if len(n.publicInternetAddressList) == 0 {
7274
return ipStringsToIPblocks(GetDefaultPublicInternetAddressList())
7375
}
74-
return ipStringsToIPblocks(n.publicInternetAddressList)
76+
allInternetRanges := netset.NewIPBlock()
77+
for _, ipRange := range n.publicInternetAddressList {
78+
fmt.Printf("ipRange.String(): %v\n", ipRange.String())
79+
allInternetRanges = allInternetRanges.Union(ipRange)
80+
}
81+
fmt.Printf("allInternetRanges.String(): %v\n", allInternetRanges.String())
82+
return n.publicInternetAddressList, allInternetRanges, nil
7583
}
7684

77-
func (n *NetworkAddressLists) GetServiceNetworkIPblocksList() (serviceNetworkIPblocksList []*netset.IPBlock,
78-
serviceNetworkRagnes *netset.IPBlock, err error) {
79-
return ipStringsToIPblocks(n.serviceNetworkAddressList)
85+
func (n *NetworkAddressLists) GetServiceNetworkIPblocksList() ([]*netset.IPBlock, *netset.IPBlock, error) {
86+
allServiceNetworkRanges := netset.NewIPBlock()
87+
for _, ipRange := range n.serviceNetworkAddressList {
88+
allServiceNetworkRanges = allServiceNetworkRanges.Union(ipRange)
89+
}
90+
fmt.Printf("allServiceNetworkRanges.String(): %v\n", allServiceNetworkRanges.String())
91+
return n.serviceNetworkAddressList, allServiceNetworkRanges, nil
8092
}
8193

8294
// ExternalNetwork implements Node interface

0 commit comments

Comments
 (0)