Compare commits
1 commit
main
...
set-contai
| Author | SHA1 | Date | |
|---|---|---|---|
| d2a6de86b4 |
6 changed files with 7 additions and 367 deletions
2
.gitignore
vendored
2
.gitignore
vendored
|
|
@ -1,2 +0,0 @@
|
|||
.env
|
||||
/.idea/
|
||||
|
|
@ -5,10 +5,16 @@
|
|||
# Container Scanning customization: https://docs.gitlab.com/ee/user/application_security/container_scanning/#customizing-the-container-scanning-settings
|
||||
# Note that environment variables can be set in several places
|
||||
# See https://docs.gitlab.com/ee/ci/variables/#cicd-variable-precedence
|
||||
|
||||
# container_scanning:
|
||||
# variables:
|
||||
# DOCKER_IMAGE: ...
|
||||
# DOCKER_USER: ...
|
||||
# DOCKER_PASSWORD: ...
|
||||
stages:
|
||||
- test
|
||||
sast:
|
||||
stage: test
|
||||
include:
|
||||
- template: Security/SAST.gitlab-ci.yml
|
||||
- template: Security/Secret-Detection.gitlab-ci.yml
|
||||
- template: Jobs/Container-Scanning.gitlab-ci.yml
|
||||
|
|
|
|||
16
go.mod
16
go.mod
|
|
@ -1,16 +0,0 @@
|
|||
module gitlab.com/durfy/durpdns
|
||||
|
||||
go 1.24.1
|
||||
|
||||
require (
|
||||
github.com/caarlos0/env/v6 v6.10.1
|
||||
github.com/cloudflare/cloudflare-go/v4 v4.1.0
|
||||
github.com/joho/godotenv v1.5.1
|
||||
)
|
||||
|
||||
require (
|
||||
github.com/tidwall/gjson v1.14.4 // indirect
|
||||
github.com/tidwall/match v1.1.1 // indirect
|
||||
github.com/tidwall/pretty v1.2.1 // indirect
|
||||
github.com/tidwall/sjson v1.2.5 // indirect
|
||||
)
|
||||
16
go.sum
16
go.sum
|
|
@ -1,16 +0,0 @@
|
|||
github.com/caarlos0/env/v6 v6.10.1 h1:t1mPSxNpei6M5yAeu1qtRdPAK29Nbcf/n3G7x+b3/II=
|
||||
github.com/caarlos0/env/v6 v6.10.1/go.mod h1:hvp/ryKXKipEkcuYjs9mI4bBCg+UI0Yhgm5Zu0ddvwc=
|
||||
github.com/cloudflare/cloudflare-go/v4 v4.1.0 h1:1SjQZaPbUe23fSoCuMuN7EblVo+RIldNGd4pfkPCpW4=
|
||||
github.com/cloudflare/cloudflare-go/v4 v4.1.0/go.mod h1:XcYpLe7Mf6FN87kXzEWVnJ6z+vskW/k6eUqgqfhFE9k=
|
||||
github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
|
||||
github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
|
||||
github.com/tidwall/gjson v1.14.2/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk=
|
||||
github.com/tidwall/gjson v1.14.4 h1:uo0p8EbA09J7RQaflQ1aBRffTR7xedD2bcIVSYxLnkM=
|
||||
github.com/tidwall/gjson v1.14.4/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk=
|
||||
github.com/tidwall/match v1.1.1 h1:+Ho715JplO36QYgwN9PGYNhgZvoUSc9X2c80KVTi+GA=
|
||||
github.com/tidwall/match v1.1.1/go.mod h1:eRSPERbgtNPcGhD8UCthc6PmLEQXEWd3PRB5JTxsfmM=
|
||||
github.com/tidwall/pretty v1.2.0/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU=
|
||||
github.com/tidwall/pretty v1.2.1 h1:qjsOFOWWQl+N3RsoF5/ssm1pHmJJwhjlSbZ51I6wMl4=
|
||||
github.com/tidwall/pretty v1.2.1/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU=
|
||||
github.com/tidwall/sjson v1.2.5 h1:kLy8mja+1c9jlljvWTlSazM7cKDRfJuR/bOJhcY5NcY=
|
||||
github.com/tidwall/sjson v1.2.5/go.mod h1:Fvgq9kS/6ociJEDnK0Fk1cpYF4FIW6ZF7LAe+6jwd28=
|
||||
329
main.go
329
main.go
|
|
@ -1,329 +0,0 @@
|
|||
package main
|
||||
|
||||
import (
|
||||
"context"
|
||||
"encoding/json"
|
||||
"errors"
|
||||
"fmt"
|
||||
"github.com/caarlos0/env/v6"
|
||||
"github.com/cloudflare/cloudflare-go/v4"
|
||||
"github.com/cloudflare/cloudflare-go/v4/dns"
|
||||
"github.com/cloudflare/cloudflare-go/v4/option"
|
||||
"github.com/joho/godotenv"
|
||||
"io"
|
||||
"log"
|
||||
"net/http"
|
||||
"regexp"
|
||||
"time"
|
||||
)
|
||||
|
||||
var ipPattern = `^((25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.){3}(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)$`
|
||||
|
||||
type WTFIPResponse struct {
|
||||
IP string `json:"YourFuckingIPAddress"`
|
||||
Location string `json:"YourFuckingLocation"`
|
||||
Hostname string `json:"YourFuckingHostname"`
|
||||
ISP string `json:"YourFuckingISP"`
|
||||
TorExit bool `json:"YourFuckingTorExit"`
|
||||
City string `json:"YourFuckingCity"`
|
||||
Country string `json:"YourFuckingCountry"`
|
||||
CountryCode string `json:"YourFuckingCountryCode"`
|
||||
}
|
||||
|
||||
type IpifyResponse struct {
|
||||
IP string `json:"ip"`
|
||||
}
|
||||
|
||||
type IpInfoResponse struct {
|
||||
IP string `json:"ip"`
|
||||
Hostname string `json:"hostname"`
|
||||
City string `json:"city"`
|
||||
Region string `json:"region"`
|
||||
Country string `json:"country"`
|
||||
Loc string `json:"loc"`
|
||||
Org string `json:"org"`
|
||||
Postal string `json:"postal"`
|
||||
Timezone string `json:"timezone"`
|
||||
Readme string `json:"readme"`
|
||||
}
|
||||
type Response struct {
|
||||
IPAddress string
|
||||
}
|
||||
|
||||
type ResponseInterface interface {
|
||||
getIP() Response
|
||||
}
|
||||
|
||||
func (r *WTFIPResponse) getIP() Response {
|
||||
return Response{IPAddress: r.IP}
|
||||
}
|
||||
func (r *IpInfoResponse) getIP() Response {
|
||||
return Response{IPAddress: r.IP}
|
||||
}
|
||||
func (r *IpifyResponse) getIP() Response {
|
||||
return Response{IPAddress: r.IP}
|
||||
}
|
||||
|
||||
func NewIpifyProvider() *IpProvider {
|
||||
return &IpProvider{
|
||||
url: "https://api.ipify.org?format=json",
|
||||
resp: new(IpifyResponse),
|
||||
client: http.Client{
|
||||
Timeout: 5 * time.Second,
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
func NewIpInfoProvider() *IpProvider {
|
||||
return &IpProvider{
|
||||
url: "https://ipinfo.io/json",
|
||||
resp: new(IpInfoResponse),
|
||||
client: http.Client{
|
||||
Timeout: 5 * time.Second,
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
func NewWTFProvider() *IpProvider {
|
||||
return &IpProvider{
|
||||
url: "https://myip.wtf/json",
|
||||
resp: new(WTFIPResponse),
|
||||
client: http.Client{
|
||||
Timeout: 5 * time.Second,
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
type IpProvider struct {
|
||||
url string
|
||||
resp interface{}
|
||||
client http.Client
|
||||
}
|
||||
|
||||
func (p *IpProvider) get() *Response {
|
||||
|
||||
body, err := p.client.Get(p.url)
|
||||
if err != nil {
|
||||
return nil
|
||||
}
|
||||
defer body.Body.Close()
|
||||
|
||||
data, err := io.ReadAll(body.Body)
|
||||
if err != nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &p.resp)
|
||||
if err != nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
resp := p.resp.(ResponseInterface).getIP()
|
||||
pattern := regexp.MustCompile(ipPattern)
|
||||
|
||||
if !pattern.MatchString(resp.IPAddress) {
|
||||
return nil
|
||||
}
|
||||
|
||||
return &resp
|
||||
}
|
||||
|
||||
type Config struct {
|
||||
CloudflareZoneID string `env:"CLOUDFLARE_ZONE_ID"`
|
||||
CloudFlareAPIKey string `env:"CLOUDFLARE_API_KEY"`
|
||||
CloudflareEmail string `env:"CLOUDFLARE_EMAIL"`
|
||||
IpProviders []*IpProvider
|
||||
Client *cloudflare.Client
|
||||
Timeout time.Duration
|
||||
}
|
||||
|
||||
func main() {
|
||||
|
||||
err := godotenv.Load(".env")
|
||||
if err != nil {
|
||||
log.Fatal("Failed to load env file")
|
||||
return
|
||||
}
|
||||
|
||||
config := &Config{
|
||||
Timeout: 5 * time.Second,
|
||||
}
|
||||
err = env.Parse(config)
|
||||
if err != nil {
|
||||
log.Fatal("Failed to load env file")
|
||||
return
|
||||
}
|
||||
|
||||
if config.CloudflareEmail == "" || config.CloudFlareAPIKey == "" || config.CloudflareZoneID == "" {
|
||||
log.Fatal("Email, API and ZoneID need to be set")
|
||||
return
|
||||
}
|
||||
|
||||
config.Client = cloudflare.NewClient(
|
||||
option.WithAPIKey(config.CloudFlareAPIKey),
|
||||
option.WithAPIEmail(config.CloudflareEmail),
|
||||
)
|
||||
|
||||
config.IpProviders = append(
|
||||
config.IpProviders,
|
||||
NewWTFProvider(),
|
||||
)
|
||||
config.IpProviders = append(
|
||||
config.IpProviders,
|
||||
NewIpifyProvider(),
|
||||
)
|
||||
config.IpProviders = append(
|
||||
config.IpProviders,
|
||||
NewIpInfoProvider(),
|
||||
)
|
||||
|
||||
ExistingIP, err := GetIPAddress(config)
|
||||
|
||||
fmt.Printf("The current IP address is: %s\n", ExistingIP)
|
||||
|
||||
err = updateDNSRecords(
|
||||
config,
|
||||
ExistingIP,
|
||||
)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
|
||||
do:
|
||||
for {
|
||||
CurrentIP, err := GetIPAddress(config)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
continue do
|
||||
}
|
||||
|
||||
if ExistingIP == CurrentIP {
|
||||
time.Sleep(config.Timeout)
|
||||
continue do
|
||||
}
|
||||
|
||||
ExistingIP = CurrentIP
|
||||
fmt.Printf(
|
||||
"Your IP address has changed: %s\n",
|
||||
CurrentIP,
|
||||
)
|
||||
|
||||
err = updateDNSRecords(
|
||||
config,
|
||||
CurrentIP,
|
||||
)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
|
||||
time.Sleep(config.Timeout)
|
||||
continue do
|
||||
}
|
||||
}
|
||||
|
||||
func GetIPAddress(config *Config) (string, error) {
|
||||
|
||||
responses := []*Response{}
|
||||
|
||||
for _, provider := range config.IpProviders {
|
||||
resp := provider.get()
|
||||
responses = append(responses, resp)
|
||||
}
|
||||
|
||||
// Count the occurrences of each IPAddress
|
||||
counts := map[string]int{}
|
||||
for _, r := range responses {
|
||||
if r != nil {
|
||||
IP := r.IPAddress
|
||||
if count, ok := counts[IP]; ok {
|
||||
counts[IP] = count + 1
|
||||
} else {
|
||||
counts[IP] = 1
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Find the IPAddress that repeats the most
|
||||
maxCount := 0
|
||||
CurrentIP := ""
|
||||
for IP, count := range counts {
|
||||
if count > maxCount {
|
||||
maxCount = count
|
||||
CurrentIP = IP
|
||||
}
|
||||
}
|
||||
|
||||
pattern := regexp.MustCompile(ipPattern)
|
||||
|
||||
if !pattern.MatchString(CurrentIP) {
|
||||
return "", errors.New("Did not find a valid IP")
|
||||
}
|
||||
|
||||
return CurrentIP, nil
|
||||
}
|
||||
|
||||
func getDNSRecords(
|
||||
client *cloudflare.Client,
|
||||
zoneID string,
|
||||
) (*[]dns.RecordResponse, error) {
|
||||
dnslist, err := client.DNS.Records.List(
|
||||
context.TODO(),
|
||||
dns.RecordListParams{
|
||||
ZoneID: cloudflare.F(zoneID),
|
||||
},
|
||||
)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
var records []dns.RecordResponse
|
||||
for _, item := range dnslist.Result {
|
||||
|
||||
if item.Type == "A" {
|
||||
records = append(records, item)
|
||||
}
|
||||
}
|
||||
return &records, nil
|
||||
}
|
||||
|
||||
func updateDNSRecords(
|
||||
config *Config,
|
||||
ipAddress string,
|
||||
) error {
|
||||
records, err := getDNSRecords(
|
||||
config.Client,
|
||||
config.CloudflareZoneID,
|
||||
)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
for _, record := range *records {
|
||||
|
||||
if record.Content == ipAddress {
|
||||
continue
|
||||
}
|
||||
|
||||
NewDNS := dns.ARecordParam{
|
||||
Comment: cloudflare.F(record.Comment),
|
||||
Content: cloudflare.F(ipAddress),
|
||||
Name: cloudflare.F(record.Name),
|
||||
Proxied: cloudflare.F(record.Proxied),
|
||||
TTL: cloudflare.F(record.TTL),
|
||||
Type: cloudflare.F(dns.ARecordTypeA),
|
||||
}
|
||||
|
||||
_, err = config.Client.DNS.Records.Edit(
|
||||
context.TODO(), record.ID, dns.RecordEditParams{
|
||||
ZoneID: cloudflare.F(config.CloudflareZoneID),
|
||||
Record: NewDNS,
|
||||
},
|
||||
)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
fmt.Printf("Updated IP address for %s\n", record.Name)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
|
@ -1,3 +0,0 @@
|
|||
{
|
||||
"$schema": "https://docs.renovatebot.com/renovate-schema.json"
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue