mirror of
https://github.com/taigrr/godns
synced 2025-01-18 04:03:25 -08:00
Compare commits
No commits in common. "master" and "V2.2" have entirely different histories.
4
.github/workflows/go.yml
vendored
4
.github/workflows/go.yml
vendored
@ -7,10 +7,10 @@ jobs:
|
|||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
|
|
||||||
- name: Set up Go 1.15.7
|
- name: Set up Go 1.13.6
|
||||||
uses: actions/setup-go@v1
|
uses: actions/setup-go@v1
|
||||||
with:
|
with:
|
||||||
go-version: 1.15.7
|
go-version: 1.13.6
|
||||||
id: go
|
id: go
|
||||||
|
|
||||||
- name: Check out code into the Go module directory
|
- name: Check out code into the Go module directory
|
||||||
|
|||||||
@ -1,76 +0,0 @@
|
|||||||
# Contributor Covenant Code of Conduct
|
|
||||||
|
|
||||||
## Our Pledge
|
|
||||||
|
|
||||||
In the interest of fostering an open and welcoming environment, we as
|
|
||||||
contributors and maintainers pledge to making participation in our project and
|
|
||||||
our community a harassment-free experience for everyone, regardless of age, body
|
|
||||||
size, disability, ethnicity, sex characteristics, gender identity and expression,
|
|
||||||
level of experience, education, socio-economic status, nationality, personal
|
|
||||||
appearance, race, religion, or sexual identity and orientation.
|
|
||||||
|
|
||||||
## Our Standards
|
|
||||||
|
|
||||||
Examples of behavior that contributes to creating a positive environment
|
|
||||||
include:
|
|
||||||
|
|
||||||
* Using welcoming and inclusive language
|
|
||||||
* Being respectful of differing viewpoints and experiences
|
|
||||||
* Gracefully accepting constructive criticism
|
|
||||||
* Focusing on what is best for the community
|
|
||||||
* Showing empathy towards other community members
|
|
||||||
|
|
||||||
Examples of unacceptable behavior by participants include:
|
|
||||||
|
|
||||||
* The use of sexualized language or imagery and unwelcome sexual attention or
|
|
||||||
advances
|
|
||||||
* Trolling, insulting/derogatory comments, and personal or political attacks
|
|
||||||
* Public or private harassment
|
|
||||||
* Publishing others' private information, such as a physical or electronic
|
|
||||||
address, without explicit permission
|
|
||||||
* Other conduct which could reasonably be considered inappropriate in a
|
|
||||||
professional setting
|
|
||||||
|
|
||||||
## Our Responsibilities
|
|
||||||
|
|
||||||
Project maintainers are responsible for clarifying the standards of acceptable
|
|
||||||
behavior and are expected to take appropriate and fair corrective action in
|
|
||||||
response to any instances of unacceptable behavior.
|
|
||||||
|
|
||||||
Project maintainers have the right and responsibility to remove, edit, or
|
|
||||||
reject comments, commits, code, wiki edits, issues, and other contributions
|
|
||||||
that are not aligned to this Code of Conduct, or to ban temporarily or
|
|
||||||
permanently any contributor for other behaviors that they deem inappropriate,
|
|
||||||
threatening, offensive, or harmful.
|
|
||||||
|
|
||||||
## Scope
|
|
||||||
|
|
||||||
This Code of Conduct applies both within project spaces and in public spaces
|
|
||||||
when an individual is representing the project or its community. Examples of
|
|
||||||
representing a project or community include using an official project e-mail
|
|
||||||
address, posting via an official social media account, or acting as an appointed
|
|
||||||
representative at an online or offline event. Representation of a project may be
|
|
||||||
further defined and clarified by project maintainers.
|
|
||||||
|
|
||||||
## Enforcement
|
|
||||||
|
|
||||||
Instances of abusive, harassing, or otherwise unacceptable behavior may be
|
|
||||||
reported by contacting the project team at i@xiaozhou.net. All
|
|
||||||
complaints will be reviewed and investigated and will result in a response that
|
|
||||||
is deemed necessary and appropriate to the circumstances. The project team is
|
|
||||||
obligated to maintain confidentiality with regard to the reporter of an incident.
|
|
||||||
Further details of specific enforcement policies may be posted separately.
|
|
||||||
|
|
||||||
Project maintainers who do not follow or enforce the Code of Conduct in good
|
|
||||||
faith may face temporary or permanent repercussions as determined by other
|
|
||||||
members of the project's leadership.
|
|
||||||
|
|
||||||
## Attribution
|
|
||||||
|
|
||||||
This Code of Conduct is adapted from the [Contributor Covenant][homepage], version 1.4,
|
|
||||||
available at https://www.contributor-covenant.org/version/1/4/code-of-conduct.html
|
|
||||||
|
|
||||||
[homepage]: https://www.contributor-covenant.org
|
|
||||||
|
|
||||||
For answers to common questions about this code of conduct, see
|
|
||||||
https://www.contributor-covenant.org/faq
|
|
||||||
13
Dockerfile
13
Dockerfile
@ -2,8 +2,13 @@ FROM golang:alpine AS builder
|
|||||||
RUN mkdir /godns
|
RUN mkdir /godns
|
||||||
ADD . /godns/
|
ADD . /godns/
|
||||||
WORKDIR /godns
|
WORKDIR /godns
|
||||||
RUN CGO_ENABLED=0 go build -o godns cmd/godns/godns.go
|
RUN go build -o godns cmd/godns/godns.go
|
||||||
|
|
||||||
FROM gcr.io/distroless/base
|
FROM alpine
|
||||||
COPY --from=builder /godns/godns /godns
|
RUN apk add --update ca-certificates
|
||||||
ENTRYPOINT ["/godns"]
|
RUN mkdir /usr/local/godns
|
||||||
|
COPY --from=builder /godns/godns /usr/local/godns
|
||||||
|
RUN chmod +x /usr/local/godns/godns
|
||||||
|
RUN rm -rf /var/cache/apk/*
|
||||||
|
WORKDIR /usr/local/godns
|
||||||
|
ENTRYPOINT ["./godns", "-c", "/usr/local/godns/config.json"]
|
||||||
|
|||||||
6
Makefile
6
Makefile
@ -2,15 +2,15 @@
|
|||||||
BINARY=godns
|
BINARY=godns
|
||||||
# Builds the project
|
# Builds the project
|
||||||
build:
|
build:
|
||||||
GO111MODULE=on go build -ldflags "-X main.Version=${VERSION}" -o ${BINARY} cmd/godns/godns.go
|
GO111MODULE=on go build cmd/godns/godns.go -o ${BINARY} -ldflags "-X main.Version=${VERSION}"
|
||||||
# Installs our project: copies binaries
|
# Installs our project: copies binaries
|
||||||
install:
|
install:
|
||||||
GO111MODULE=on go install
|
GO111MODULE=on go install
|
||||||
image:
|
image:
|
||||||
# Build docker image
|
# Build docker image
|
||||||
go clean
|
go clean
|
||||||
docker buildx build --platform linux/amd64,linux/arm64,linux/arm/v7 -t timothyye/godns:${VERSION} . --push
|
docker buildx build --platform linux/amd64,linux/386,linux/arm64,linux/arm/v7 -t timothyye/godns:${VERSION} . --push
|
||||||
docker buildx build --platform linux/amd64,linux/arm64,linux/arm/v7 -t timothyye/godns:latest . --push
|
docker buildx build --platform linux/amd64,linux/386,linux/arm64,linux/arm/v7 -t timothyye/godns:latest . --push
|
||||||
release:
|
release:
|
||||||
# Clean
|
# Clean
|
||||||
go clean
|
go clean
|
||||||
|
|||||||
487
README.md
487
README.md
@ -7,7 +7,7 @@
|
|||||||
╚═════╝ ╚═════╝ ╚═════╝ ╚═╝ ╚═══╝╚══════╝
|
╚═════╝ ╚═════╝ ╚═════╝ ╚═╝ ╚═══╝╚══════╝
|
||||||
```
|
```
|
||||||
|
|
||||||
[![Apache licensed][9]][10] [![Docker][3]][4] [![Go Report Card][11]][12] [![Cover.Run][15]][16] [![GoDoc][13]][14]
|
[![MIT licensed][9]][10] [-blue.svg)](https://github.com/996icu/996.ICU/blob/master/LICENSE) [![Docker][3]][4] [![Go Report Card][11]][12] [![Cover.Run][15]][16] [![GoDoc][13]][14]
|
||||||
|
|
||||||
[3]: https://images.microbadger.com/badges/image/timothyye/godns.svg
|
[3]: https://images.microbadger.com/badges/image/timothyye/godns.svg
|
||||||
[4]: https://microbadger.com/images/timothyye/godns
|
[4]: https://microbadger.com/images/timothyye/godns
|
||||||
@ -20,107 +20,69 @@
|
|||||||
[15]: https://img.shields.io/badge/cover.run-88.2%25-green.svg
|
[15]: https://img.shields.io/badge/cover.run-88.2%25-green.svg
|
||||||
[16]: https://cover.run/go/github.com/timothyye/godns
|
[16]: https://cover.run/go/github.com/timothyye/godns
|
||||||
|
|
||||||
[GoDNS](https://github.com/TimothyYe/godns) is a dynamic DNS (DDNS) client tool. It is a rewrite in [Go](https://golang.org) of my early [DynDNS](https://github.com/TimothyYe/DynDNS) open source project.
|
GoDNS is a dynamic DNS (DDNS) client tool, it is based on my early open source project: [DynDNS](https://github.com/TimothyYe/DynDNS).
|
||||||
|
|
||||||
Currently supports updating A records for subdomains. Doesn't support updating of root domains.
|
Now I rewrite [DynDNS](https://github.com/TimothyYe/DynDNS) by Golang and call it [GoDNS](https://github.com/TimothyYe/godns).
|
||||||
|
|
||||||
---
|
|
||||||
- [Supported DNS Providers](#supported-dns-providers)
|
|
||||||
- [Supported Platforms](#supported-platforms)
|
|
||||||
- [Pre-conditions](#pre-conditions)
|
|
||||||
- [Installation](#installation)
|
|
||||||
- [Usage](#usage)
|
|
||||||
- [Configuration](#configuration)
|
|
||||||
- [Overview](#overview)
|
|
||||||
- [Configuration properties](#configuration-properties)
|
|
||||||
- [Configuration examples](#configuration-examples)
|
|
||||||
- [Cloudflare](#cloudflare)
|
|
||||||
- [DNSPod](#dnspod)
|
|
||||||
- [Dreamhost](#dreamhost)
|
|
||||||
- [Google Domains](#google-domains)
|
|
||||||
- [AliDNS](#alidns)
|
|
||||||
- [DuckDNS](#duckdns)
|
|
||||||
- [No-IP](#no-ip)
|
|
||||||
- [HE.net](#henet)
|
|
||||||
- [Notifications](#notifications)
|
|
||||||
- [Email](#email)
|
|
||||||
- [Telegram](#telegram)
|
|
||||||
- [Slack](#slack)
|
|
||||||
- [Miscellaneous topics](#miscellaneous-topics)
|
|
||||||
- [IPv6 support](#ipv6-support)
|
|
||||||
- [Network interface IP address](#network-interface-ip-address)
|
|
||||||
- [SOCKS5 proxy support](#socks5-proxy-support)
|
|
||||||
- [Running GoDNS](#running-godns)
|
|
||||||
- [As a manual daemon](#as-a-manual-daemon)
|
|
||||||
- [As a managed daemon (with upstart)](#as-a-managed-daemon-with-upstart)
|
|
||||||
- [As a managed daemon (with systemd)](#as-a-managed-daemon-with-systemd)
|
|
||||||
- [As a Docker container](#as-a-docker-container)
|
|
||||||
- [As a Windows service](#as-a-windows-service)
|
|
||||||
- [Special Thanks](#special-thanks)
|
|
||||||
|
|
||||||
---
|
|
||||||
## Supported DNS Providers
|
## Supported DNS Providers
|
||||||
|
|
||||||
| Provider | IPv4 support | IPv6 support | Root Domain | Subdomains |
|
* Cloudflare ([https://cloudflare.com](https://cloudflare.com))
|
||||||
| ------------------------------------- | :----------------: | :----------------: | :----------------: | :----------------: |
|
* Google Domains ([https://domains.google](https://domains.google))
|
||||||
| [Cloudflare][cloudflare] | :white_check_mark: | :white_check_mark: | :white_check_mark: | :white_check_mark: |
|
* DNSPod ([https://www.dnspod.cn/](https://www.dnspod.cn/))
|
||||||
| [Google Domains][google.domains] | :white_check_mark: | :white_check_mark: | :x: | :white_check_mark: |
|
* HE.net (Hurricane Electric) ([https://dns.he.net/](https://dns.he.net/))
|
||||||
| [DNSPod][dnspod] | :white_check_mark: | :white_check_mark: | :x: | :white_check_mark: |
|
* AliDNS ([https://help.aliyun.com/product/29697.html](https://help.aliyun.com/product/29697.html))
|
||||||
| [HE.net (Hurricane Electric)][he.net] | :white_check_mark: | :white_check_mark: | :x: | :white_check_mark: |
|
* DuckDNS ([https://www.duckdns.org](https://www.duckdns.org))
|
||||||
| [AliDNS][alidns] | :white_check_mark: | :x: | :x: | :white_check_mark: |
|
* Dreamhost ([https://www.dreamhost.com](https://www.dreamhost.com))
|
||||||
| [DuckDNS][duckdns] | :white_check_mark: | :white_check_mark: | :x: | :white_check_mark: |
|
|
||||||
| [Dreamhost][dreamhost] | :white_check_mark: | :white_check_mark: | :x: | :white_check_mark: |
|
|
||||||
| [No-IP][no-ip] | :white_check_mark: | :white_check_mark: | :x: | :white_check_mark: |
|
|
||||||
|
|
||||||
[cloudflare]: https://cloudflare.com
|
|
||||||
[google.domains]: https://domains.google
|
|
||||||
[dnspod]: https://www.dnspod.cn
|
|
||||||
[he.net]: https://dns.he.net
|
|
||||||
[alidns]: https://help.aliyun.com/product/29697.html
|
|
||||||
[duckdns]: https://www.duckdns.org
|
|
||||||
[dreamhost]: https://www.dreamhost.com
|
|
||||||
[no-ip]: https://www.noip.com
|
|
||||||
|
|
||||||
Tip: You can follow this [issue](https://github.com/TimothyYe/godns/issues/76) to view the current status of DDNS for root domains.
|
|
||||||
|
|
||||||
## Supported Platforms
|
## Supported Platforms
|
||||||
|
|
||||||
* Linux
|
* Linux
|
||||||
* MacOS
|
* MacOS
|
||||||
* ARM Linux (Raspberry Pi, etc.)
|
* ARM Linux (Raspberry Pi, etc...)
|
||||||
* Windows
|
* Windows
|
||||||
* MIPS32 platform
|
* MIPS32 platform
|
||||||
|
|
||||||
To compile binaries for MIPS (mips or mipsle), run:
|
## MIPS32 platform
|
||||||
|
|
||||||
```bash
|
To compile binaries for MIPS (mips or mipsle):
|
||||||
GOOS=linux GOARCH=mips/mipsle GOMIPS=softfloat go build -a
|
|
||||||
```
|
|
||||||
|
|
||||||
The binary can run on routers as well.
|
|
||||||
|
|
||||||
## Pre-conditions
|
|
||||||
|
|
||||||
To use GoDNS, it is assumed:
|
|
||||||
* You registered (now own) a domain
|
|
||||||
* Domain was delegated to a supported [DNS provider](#supported-dns-providers) (i.e. it has nameserver `NS` records pointing at a supported provider)
|
|
||||||
|
|
||||||
Alternatively, you can sign in to [DuckDNS](https://www.duckdns.org) (with a social account) and get a subdomain on the duckdns.org domain for free.
|
|
||||||
|
|
||||||
## Installation
|
|
||||||
|
|
||||||
Build GoDNS by running (from the root of the repository):
|
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
cd cmd/godns # go to the GoDNS directory
|
GOOS=linux GOARCH=mips/mipsle GOMIPS=softfloat go build -a
|
||||||
go get -v # get dependencies
|
|
||||||
go build # build
|
|
||||||
```
|
```
|
||||||
|
|
||||||
You can also download a compiled binary from the [releases](https://github.com/TimothyYe/godns/releases).
|
And the binary can run well on routers.
|
||||||
## Usage
|
|
||||||
|
|
||||||
Print usage/help by running:
|
## Pre-condition
|
||||||
|
|
||||||
|
* Register and own a domain.
|
||||||
|
|
||||||
|
* Domain's nameserver points to [DNSPod](https://www.dnspod.cn/) or [HE.net](https://dns.he.net/) or [Cloudflare](https://www.cloudflare.com/) or [Google Domains](https://domains.google) or [AliDNS](https://dc.console.aliyun.com).
|
||||||
|
|
||||||
|
* Or just register an account from [DuckDNS](https://www.duckdns.org/).
|
||||||
|
|
||||||
|
## Get it
|
||||||
|
|
||||||
|
### Build it from source code
|
||||||
|
|
||||||
|
* Get source code from Github:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
git clone https://github.com/timothyye/godns.git
|
||||||
|
```
|
||||||
|
|
||||||
|
* Go into the godns directory, get related library and then build it:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
cd cmd/godns
|
||||||
|
go get -v
|
||||||
|
go build
|
||||||
|
```
|
||||||
|
|
||||||
|
### Download from releases
|
||||||
|
|
||||||
|
Download compiled binaries from [releases](https://github.com/TimothyYe/godns/releases)
|
||||||
|
|
||||||
|
## Get help
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
$ ./godns -h
|
$ ./godns -h
|
||||||
@ -130,37 +92,65 @@ Usage of ./godns:
|
|||||||
-h Show help
|
-h Show help
|
||||||
```
|
```
|
||||||
|
|
||||||
## Configuration
|
## Config it
|
||||||
|
|
||||||
### Overview
|
* Get [config_sample.json](https://github.com/timothyye/godns/blob/master/config_sample.json) from Github.
|
||||||
|
* Rename it to **config.json**.
|
||||||
|
* Configure your provider, domain/subdomain info, username and password, etc.
|
||||||
|
* Configure the SMTP options if you want, a mail notification will sent to your mailbox once the IP is changed.
|
||||||
|
* Save it in the same directory of GoDNS, or use -c=your_conf_path command.
|
||||||
|
|
||||||
* Make a copy of [config_sample.json](./config_sample.json) and name it `config.json`
|
## Config fields
|
||||||
* Configure your provider, domain/subdomain info, credentials, etc.
|
|
||||||
* Configure a notification medium (e.g. SMTP to receive emails) to get notified when your IP address changes
|
|
||||||
* Place the file in the same directory of GoDNS or use the `-c=path/to/your/file.json` option
|
|
||||||
|
|
||||||
### Configuration properties
|
* provider: The providers that GoDNS supports, available values are: `Cloudflare`, `Google`, `DNSPod`, `AliDNS`, `HE`, `DuckDNS`, `Dreamhost`.
|
||||||
|
* email: Email or account name of your DNS provider.
|
||||||
|
* password: Password of your account.
|
||||||
|
* login_token: API token of your account.
|
||||||
|
* domains: Domains list, with your sub domains.
|
||||||
|
* ip_url: A site helps you to get your public IPv4 IP address.
|
||||||
|
* ipv6_url: A site helps you to get your public IPv6 address.
|
||||||
|
* ip_type: To configure GoDNS under IPv4 mode or IPv6 mode, available values are: `IPv4`, `IPv6`.
|
||||||
|
* interval: The interval `seconds` that GoDNS check your public IP.
|
||||||
|
* socks5_proxy: Socks5 proxy server.
|
||||||
|
* resolver: The address of the public DNS server. For example, to run GoDNS in `IPv4` mode, you can set resolver as `8.8.8.8`, to GoDNS in `IPv6` mode, you can set resolver as `2001:4860:4860::8888`.
|
||||||
|
|
||||||
* `provider` — One of the [supported provider to use](#supported-dns-providers): `Cloudflare`, `Google`, `DNSPod`, `AliDNS`, `HE`, `DuckDNS` or `Dreamhost`.
|
## IPv6 support
|
||||||
* `email` — Email or account name of the DNS provider.
|
|
||||||
* `password` — Password of the DNS provider.
|
|
||||||
* `login_token` — API token of the DNS provider.
|
|
||||||
* `domains` — Domains list, with your sub domains.
|
|
||||||
* `ip_url` — A URL for fetching one's public IPv4 address.
|
|
||||||
* `ipv6_url` — A URL for fetching one's public IPv6 address.
|
|
||||||
* `ip_type` — Switch deciding if IPv4 or IPv6 should be used (when [supported](#supported-dns-providers)). Available values: `IPv4` or `IPv6`.
|
|
||||||
* `interval` — How often (in seconds) the public IP should be updated.
|
|
||||||
* `socks5_proxy` — Socks5 proxy server.
|
|
||||||
* `resolver` — Address of a public DNS server to use. For instance to use [Google's public DNS](https://developers.google.com/speed/public-dns/docs/using), you can set `8.8.8.8` when using GoDNS in IPv4 mode or `2001:4860:4860::8888` in IPv6 mode.
|
|
||||||
|
|
||||||
### Configuration examples
|
Supported provider(s):
|
||||||
|
* Cloudflare
|
||||||
|
* DNSPod
|
||||||
|
* Dreamhost
|
||||||
|
* DuckDNS
|
||||||
|
* Google Domains
|
||||||
|
* HE.net
|
||||||
|
|
||||||
#### Cloudflare
|
To enable the `IPv6` mode of GoDNS, you only need two steps:
|
||||||
|
* Set the `ip_type` as `IPv6`, and make sure the `ipv6_url` is configured.
|
||||||
|
* Add one `AAAA` record to your provider.
|
||||||
|
|
||||||
|
For example:
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"domains": [
|
||||||
|
{
|
||||||
|
"domain_name": "example.com",
|
||||||
|
"sub_domains": [
|
||||||
|
"ipv6"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
],
|
||||||
|
"resolver": "2001:4860:4860::8888",
|
||||||
|
"ipv6_url": "https://api-ipv6.ip.sb/ip",
|
||||||
|
"ip_type": "IPv6"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
### Config example for Cloudflare
|
||||||
|
|
||||||
For Cloudflare, you need to provide the email & Global API Key as password (or to use the API token) and config all the domains & subdomains.
|
For Cloudflare, you need to provide the email & Global API Key as password (or to use the API token) and config all the domains & subdomains.
|
||||||
|
|
||||||
<details>
|
* Using email & Global API Key
|
||||||
<summary>Using email & Global API Key</summary>
|
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
@ -181,10 +171,8 @@ For Cloudflare, you need to provide the email & Global API Key as password (or t
|
|||||||
"socks5_proxy": ""
|
"socks5_proxy": ""
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
</details>
|
|
||||||
|
|
||||||
<details>
|
* Using the API Token
|
||||||
<summary>Using the API Token</summary>
|
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
@ -204,15 +192,11 @@ For Cloudflare, you need to provide the email & Global API Key as password (or t
|
|||||||
"socks5_proxy": ""
|
"socks5_proxy": ""
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
</details>
|
|
||||||
|
|
||||||
#### DNSPod
|
### Config example for DNSPod
|
||||||
|
|
||||||
For DNSPod, you need to provide your API Token(you can create it [here](https://www.dnspod.cn/console/user/security)), and config all the domains & subdomains.
|
For DNSPod, you need to provide your API Token(you can create it [here](https://www.dnspod.cn/console/user/security)), and config all the domains & subdomains.
|
||||||
|
|
||||||
<details>
|
|
||||||
<summary>Example</summary>
|
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"provider": "DNSPod",
|
"provider": "DNSPod",
|
||||||
@ -232,15 +216,11 @@ For DNSPod, you need to provide your API Token(you can create it [here](https://
|
|||||||
"socks5_proxy": ""
|
"socks5_proxy": ""
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
</details>
|
|
||||||
|
|
||||||
#### Dreamhost
|
### Config example for Dreamhost
|
||||||
|
|
||||||
For Dreamhost, you need to provide your API Token(you can create it [here](https://panel.dreamhost.com/?tree=home.api)), and config all the domains & subdomains.
|
For Dreamhost, you need to provide your API Token(you can create it [here](https://panel.dreamhost.com/?tree=home.api)), and config all the domains & subdomains.
|
||||||
|
|
||||||
<details>
|
|
||||||
<summary>Example</summary>
|
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"provider": "Dreamhost",
|
"provider": "Dreamhost",
|
||||||
@ -261,15 +241,11 @@ For Dreamhost, you need to provide your API Token(you can create it [here](https
|
|||||||
"socks5_proxy": ""
|
"socks5_proxy": ""
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
</details>
|
|
||||||
|
|
||||||
#### Google Domains
|
### Config example for Google Domains
|
||||||
|
|
||||||
For Google Domains, you need to provide email & password, and config all the domains & subdomains.
|
For Google Domains, you need to provide email & password, and config all the domains & subdomains.
|
||||||
|
|
||||||
<details>
|
|
||||||
<summary>Example</summary>
|
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"provider": "Google",
|
"provider": "Google",
|
||||||
@ -289,15 +265,11 @@ For Google Domains, you need to provide email & password, and config all the dom
|
|||||||
"socks5_proxy": ""
|
"socks5_proxy": ""
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
</details>
|
|
||||||
|
|
||||||
#### AliDNS
|
### Config example for AliDNS
|
||||||
|
|
||||||
For AliDNS, you need to provide `AccessKeyID` & `AccessKeySecret` as `email` & `password`, and config all the domains & subdomains.
|
For AliDNS, you need to provide `AccessKeyID` & `AccessKeySecret` as `email` & `password`, and config all the domains & subdomains.
|
||||||
|
|
||||||
<details>
|
|
||||||
<summary>Example</summary>
|
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"provider": "AliDNS",
|
"provider": "AliDNS",
|
||||||
@ -318,15 +290,11 @@ For AliDNS, you need to provide `AccessKeyID` & `AccessKeySecret` as `email` & `
|
|||||||
"socks5_proxy": ""
|
"socks5_proxy": ""
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
</details>
|
|
||||||
|
|
||||||
#### DuckDNS
|
### Config example for DuckDNS
|
||||||
|
|
||||||
For DuckDNS, only need to provide the `token`, config 1 default domain & subdomains.
|
For DuckDNS, only need to provide the `token`, config 1 default domain & subdomains.
|
||||||
|
|
||||||
<details>
|
|
||||||
<summary>Example</summary>
|
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"provider": "DuckDNS",
|
"provider": "DuckDNS",
|
||||||
@ -346,40 +314,11 @@ For DuckDNS, only need to provide the `token`, config 1 default domain & subdoma
|
|||||||
"socks5_proxy": ""
|
"socks5_proxy": ""
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
</details>
|
|
||||||
|
|
||||||
#### No-IP
|
### Config example for HE.net
|
||||||
|
|
||||||
<details>
|
|
||||||
<summary>Example</summary>
|
|
||||||
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"provider": "NoIP",
|
|
||||||
"email": "mail@example.com",
|
|
||||||
"password": "YourPassword",
|
|
||||||
"domains": [
|
|
||||||
{
|
|
||||||
"domain_name": "ddns.net",
|
|
||||||
"sub_domains": ["timothyye6"]
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"ip_type": "IPv4",
|
|
||||||
"ip_url": "https://myip.biturl.top",
|
|
||||||
"resolver": "8.8.8.8",
|
|
||||||
"interval": 300,
|
|
||||||
"socks5_proxy": ""
|
|
||||||
}
|
|
||||||
```
|
|
||||||
</details>
|
|
||||||
|
|
||||||
#### HE.net
|
|
||||||
|
|
||||||
For HE, email is not needed, just fill DDNS key to password, and config all the domains & subdomains.
|
For HE, email is not needed, just fill DDNS key to password, and config all the domains & subdomains.
|
||||||
|
|
||||||
<details>
|
|
||||||
<summary>Example</summary>
|
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"provider": "HE",
|
"provider": "HE",
|
||||||
@ -399,31 +338,38 @@ For HE, email is not needed, just fill DDNS key to password, and config all the
|
|||||||
"socks5_proxy": ""
|
"socks5_proxy": ""
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
</details>
|
|
||||||
|
|
||||||
<details>
|
### HE.net DDNS configuration
|
||||||
<summary>Provider configuration</summary>
|
|
||||||
|
|
||||||
Add a new "A record" and make sure that "Enable entry for dynamic dns" is checked:
|
Add a new "A record", make sure that "Enable entry for dynamic dns" is checked:
|
||||||
|
|
||||||
<img src="./snapshots/he1.png" width="640" />
|
<img src="https://github.com/TimothyYe/godns/blob/master/snapshots/he1.png?raw=true" width="640" />
|
||||||
|
|
||||||
Fill in your own DDNS key or generate a random DDNS key for this new created "A record":
|
Fill your own DDNS key or generate a random DDNS key for this new created "A record":
|
||||||
|
|
||||||
<img src="./snapshots/he2.png" width="640" />
|
<img src="https://github.com/TimothyYe/godns/blob/master/snapshots/he2.png?raw=true" width="640" />
|
||||||
|
|
||||||
Remember the DDNS key and set it in the `password` property in the configuration file.
|
Remember the DDNS key and fill it as password to the config.json.
|
||||||
|
|
||||||
__NOTICE__: If you have multiple domains or subdomains, make sure their DDNS key are the same.
|
__NOTICE__: If you have multiple domains or subdomains, make sure their DDNS key are the same.
|
||||||
</details>
|
|
||||||
|
|
||||||
### Notifications
|
### Get an IP address from the interface
|
||||||
|
|
||||||
GoDNS can send a notification each time the IP changes.
|
For some reasons if you want to get an IP directly from the interface, say `eth0` for Linux or `Local Area Connection` for Windows, update config file like this:
|
||||||
|
|
||||||
#### Email
|
```json
|
||||||
|
"ip_url": "",
|
||||||
|
"ip_interface": "eth0",
|
||||||
|
```
|
||||||
|
|
||||||
Emails are sent over [SMTP](https://en.wikipedia.org/wiki/Simple_Mail_Transfer_Protocol). Update your configuration with the following snippet:
|
If you set both `ip_url` and `ip_interface`, it first tries to get an IP address online, and if not succeed, gets
|
||||||
|
an IP address from the interface as a fallback.
|
||||||
|
|
||||||
|
Note that IPv6 address will be ignored currently.
|
||||||
|
|
||||||
|
### Email notification support
|
||||||
|
|
||||||
|
Update config file and provide your SMTP options, a notification mail will be sent to your mailbox once the IP is changed and updated.
|
||||||
|
|
||||||
```json
|
```json
|
||||||
"notify": {
|
"notify": {
|
||||||
@ -438,13 +384,13 @@ Emails are sent over [SMTP](https://en.wikipedia.org/wiki/Simple_Mail_Transfer_P
|
|||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
Each time the IP changes, you will receive an email like that:
|
Notification mail example:
|
||||||
|
|
||||||
<img src="https://github.com/TimothyYe/godns/blob/master/snapshots/mail.png?raw=true" />
|
<img src="https://github.com/TimothyYe/godns/blob/master/snapshots/mail.png?raw=true" />
|
||||||
|
|
||||||
#### Telegram
|
### Telegram notification support
|
||||||
|
|
||||||
To receive a [Telegram](https://telegram.org/) message each time the IP changes, update your configuration with the following snippet:
|
Update config file and provide your Telegram options, a notification message will be sent to your telegram channel once the IP is changed and updated.
|
||||||
|
|
||||||
```json
|
```json
|
||||||
"notify": {
|
"notify": {
|
||||||
@ -452,168 +398,81 @@ To receive a [Telegram](https://telegram.org/) message each time the IP changes,
|
|||||||
"enabled": true,
|
"enabled": true,
|
||||||
"bot_api_key": "11111:aaaa-bbbb",
|
"bot_api_key": "11111:aaaa-bbbb",
|
||||||
"chat_id": "-123456",
|
"chat_id": "-123456",
|
||||||
"message_template": "Domain *{{ .Domain }}* is updated to %0A{{ .CurrentIP }}",
|
"message_template": "Domain *{{ .Domain }}* is updated to %0A{{ .CurrentIP }}"
|
||||||
"use_proxy": false
|
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
Markdown is supported in message template, and use `%0A` for newline.
|
||||||
|
|
||||||
The `message_template` property supports [markdown](https://www.markdownguide.org). New lines needs to be escaped with `%0A`.
|
### SOCKS5 proxy support
|
||||||
|
|
||||||
#### Slack
|
You can also use SOCKS5 proxy, just fill SOCKS5 address to the ```socks5_proxy``` item:
|
||||||
|
|
||||||
To receive a [Slack](https://slack.com) message each time the IP changes, update your configuration with the following snippet:
|
|
||||||
|
|
||||||
```json
|
```json
|
||||||
"notify": {
|
|
||||||
"slack": {
|
|
||||||
"enabled": true,
|
|
||||||
"bot_api_token": "xoxb-xxx",
|
|
||||||
"channel": "your_channel",
|
|
||||||
"message_template": "Domain *{{ .Domain }}* is updated to \n{{ .CurrentIP }}",
|
|
||||||
"use_proxy": false
|
|
||||||
},
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
The `message_template` property supports [markdown](https://www.markdownguide.org). New lines needs to be escaped with `\n`.
|
|
||||||
|
|
||||||
### Miscellaneous topics
|
|
||||||
|
|
||||||
#### IPv6 support
|
|
||||||
|
|
||||||
Most of the [providers](#supported-dns-providers) support IPv6.
|
|
||||||
|
|
||||||
To enable the `IPv6` support of GoDNS, there are two solutions to choose from:
|
|
||||||
|
|
||||||
1. Use an online service to lookup the external IPv6
|
|
||||||
|
|
||||||
For that:
|
|
||||||
|
|
||||||
- Set the `ip_type` as `IPv6`, and make sure the `ipv6_url` is configured
|
|
||||||
- Create an `AAAA` record instead of an `A` record in your DNS provider
|
|
||||||
|
|
||||||
<details>
|
|
||||||
<summary>Configuration example</summary>
|
|
||||||
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"domains": [
|
|
||||||
{
|
|
||||||
"domain_name": "example.com",
|
|
||||||
"sub_domains": [
|
|
||||||
"ipv6"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"resolver": "2001:4860:4860::8888",
|
|
||||||
"ipv6_url": "https://api-ipv6.ip.sb/ip",
|
|
||||||
"ip_type": "IPv6"
|
|
||||||
}
|
|
||||||
```
|
|
||||||
</details>
|
|
||||||
|
|
||||||
|
|
||||||
2. Let GoDNS find the IPv6 of the network interface of the machine it is running on (more on that [later](#network-interface-ip-address)).
|
|
||||||
|
|
||||||
For this to happen, just leave `ip_url` and `ipv6_url` empty.
|
|
||||||
|
|
||||||
Note that the network interface must be configured with an IPv6 for this to work.
|
|
||||||
|
|
||||||
#### Network interface IP address
|
|
||||||
|
|
||||||
For some reasons if you want to get the IP address associated to a network interface (instead of performing an online lookup), you can specify it in the configuration file this way:
|
|
||||||
|
|
||||||
```json
|
|
||||||
...
|
|
||||||
"ip_url": "",
|
|
||||||
"ip_interface": "interface-name",
|
|
||||||
...
|
|
||||||
```
|
|
||||||
|
|
||||||
With `interface-name` replaced by the name of the network interface, e.g. `eth0` on Linux or `Local Area Connection` on Windows.
|
|
||||||
|
|
||||||
Note: If `ip_url` is also specified, it will be used to perform an online lookup first and the network interface IP will be used as a fallback in case of failure.
|
|
||||||
|
|
||||||
#### SOCKS5 proxy support
|
|
||||||
|
|
||||||
You can make all remote calls go through a [SOCKS5 proxy](https://en.wikipedia.org/wiki/SOCKS#SOCKS5) by specifying it in the configuration file this way:
|
|
||||||
|
|
||||||
```json
|
|
||||||
...
|
|
||||||
"socks5_proxy": "127.0.0.1:7070"
|
"socks5_proxy": "127.0.0.1:7070"
|
||||||
"use_proxy": true
|
|
||||||
...
|
|
||||||
```
|
```
|
||||||
|
|
||||||
## Running GoDNS
|
Now all the queries will go through the specified SOCKS5 proxy.
|
||||||
|
|
||||||
There are few ways to run GoDNS.
|
## Run it as a daemon manually
|
||||||
|
|
||||||
### As a manual daemon
|
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
nohup ./godns &
|
nohup ./godns &
|
||||||
```
|
```
|
||||||
|
|
||||||
Note: when the program stops, it will not be restarted.
|
## Run it as a daemon, manage it via Upstart
|
||||||
|
|
||||||
### As a managed daemon (with upstart)
|
* Install `upstart` first
|
||||||
|
* Copy `./upstart/godns.conf` to `/etc/init`
|
||||||
1. Install `upstart` first (if not available already)
|
* Start it as a system service:
|
||||||
2. Copy `./upstart/godns.conf` to `/etc/init` (and tweak it to your needs)
|
|
||||||
3. Start the service:
|
|
||||||
|
|
||||||
```bash
|
|
||||||
sudo start godns
|
|
||||||
```
|
|
||||||
|
|
||||||
### As a managed daemon (with systemd)
|
|
||||||
|
|
||||||
1. Install `systemd` first (it not available already)
|
|
||||||
2. Copy `./systemd/godns.service` to `/lib/systemd/system` (and tweak it to your needs)
|
|
||||||
3. Start the service:
|
|
||||||
|
|
||||||
```bash
|
|
||||||
sudo systemctl enable godns
|
|
||||||
sudo systemctl start godns
|
|
||||||
```
|
|
||||||
|
|
||||||
### As a Docker container
|
|
||||||
|
|
||||||
With `/path/to/config.json` your local configuration file, run:
|
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
docker run \
|
sudo start godns
|
||||||
-d --name godns --restart=always \
|
|
||||||
-v /path/to/config.json:/config.json \
|
|
||||||
timothyye/godns:latest
|
|
||||||
```
|
```
|
||||||
|
|
||||||
### As a Windows service
|
## Run it as a daemon, manage it via Systemd
|
||||||
|
|
||||||
1. Download the latest version of [NSSM](https://nssm.cc/download)
|
* Modify `./systemd/godns.service` and config it.
|
||||||
|
* Copy `./systemd/godns.service` to `/lib/systemd/system`
|
||||||
|
* Start it as a systemd service:
|
||||||
|
|
||||||
2. In an administrative prompt, from the folder where NSSM was downloaded, e.g. `C:\Downloads\nssm\` **win64**, run:
|
```bash
|
||||||
|
sudo systemctl enable godns
|
||||||
|
sudo systemctl start godns
|
||||||
|
```
|
||||||
|
|
||||||
```
|
## Run it with docker
|
||||||
nssm install YOURSERVICENAME
|
|
||||||
```
|
|
||||||
|
|
||||||
3. Follow the interface to configure the service. In the "Application" tab just indicate where the `godns.exe` file is. Optionally you can also define a description on the "Details" tab and define a log file on the "I/O" tab. Finish by clicking on the "Install service" button.
|
Now godns supports to run in docker.
|
||||||
|
|
||||||
4. The service will now start along Windows.
|
* Get [config_sample.json](https://github.com/timothyye/godns/blob/master/config_sample.json) from Github.
|
||||||
|
* Rename it to **config.json**.
|
||||||
|
* Run GoDNS with docker:
|
||||||
|
|
||||||
Note: you can uninstall the service by running:
|
```bash
|
||||||
|
docker run -d --name godns --restart=always \
|
||||||
|
-v /path/to/config.json:/usr/local/godns/config.json timothyye/godns:latest
|
||||||
|
```
|
||||||
|
|
||||||
|
## Run it as a Windows service
|
||||||
|
|
||||||
|
After creating your config.json file:
|
||||||
|
|
||||||
|
* Get the latest [NSSM](https://nssm.cc/download) for create a windows service.
|
||||||
|
* Open the command prompt (as administrator) in the folder where you downloaded NSSM (e.g. C:\Downloads\nssm\ **win64**) and run:
|
||||||
|
|
||||||
|
```
|
||||||
|
nssm install YOURSERVICENAME
|
||||||
|
```
|
||||||
|
|
||||||
|
You will have an interface to configure your service, it is very simple in the "Application" tab just indicate where your `godns.exe` file is. Optionally you can also define a description on the "Details" tab and define a log file on the "I/O" tab.
|
||||||
|
|
||||||
|
* Finish using the "Install service" button.
|
||||||
|
* Done. Now whenever windows start your service will be loaded.
|
||||||
|
* To uninstall:
|
||||||
|
|
||||||
```
|
```
|
||||||
nssm remove YOURSERVICENAME
|
nssm remove YOURSERVICENAME
|
||||||
```
|
```
|
||||||
|
|
||||||
## Special Thanks
|
## Enjoy it!
|
||||||
|
|
||||||
<img src="https://i.imgur.com/xhe5RLZ.jpg" width="80px" align="right" />
|
|
||||||
|
|
||||||
Thanks JetBrains for sponsoring this project with [free open source license](https://www.jetbrains.com/community/opensource/).
|
|
||||||
|
|
||||||
> I like GoLand, it is an amazing and productive tool.
|
|
||||||
|
|||||||
@ -50,17 +50,17 @@ func dnsLoop() {
|
|||||||
panicChan := make(chan godns.Domain)
|
panicChan := make(chan godns.Domain)
|
||||||
|
|
||||||
log.Println("Creating DNS handler with provider:", configuration.Provider)
|
log.Println("Creating DNS handler with provider:", configuration.Provider)
|
||||||
h := handler.CreateHandler(configuration.Provider)
|
handler := handler.CreateHandler(configuration.Provider)
|
||||||
h.SetConfiguration(&configuration)
|
handler.SetConfiguration(&configuration)
|
||||||
for i := range configuration.Domains {
|
for i := range configuration.Domains {
|
||||||
go h.DomainLoop(&configuration.Domains[i], panicChan)
|
go handler.DomainLoop(&configuration.Domains[i], panicChan)
|
||||||
}
|
}
|
||||||
|
|
||||||
panicCount := 0
|
panicCount := 0
|
||||||
for {
|
for {
|
||||||
failDomain := <-panicChan
|
failDomain := <-panicChan
|
||||||
log.Println("Got panic in goroutine, will start a new one... :", panicCount)
|
log.Println("Got panic in goroutine, will start a new one... :", panicCount)
|
||||||
go h.DomainLoop(&failDomain, panicChan)
|
go handler.DomainLoop(&failDomain, panicChan)
|
||||||
|
|
||||||
panicCount++
|
panicCount++
|
||||||
if panicCount >= godns.PanicMax {
|
if panicCount >= godns.PanicMax {
|
||||||
|
|||||||
@ -26,14 +26,12 @@
|
|||||||
"user_agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_10_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/38.0.2125.111 Safari/537.36",
|
"user_agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_10_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/38.0.2125.111 Safari/537.36",
|
||||||
"ip_interface": "eth0",
|
"ip_interface": "eth0",
|
||||||
"socks5_proxy": "",
|
"socks5_proxy": "",
|
||||||
"use_proxy": false,
|
|
||||||
"notify": {
|
"notify": {
|
||||||
"telegram": {
|
"telegram": {
|
||||||
"enabled": false,
|
"enabled": false,
|
||||||
"bot_api_key": "",
|
"bot_api_key": "",
|
||||||
"chat_id": "",
|
"chat_id": "",
|
||||||
"message_template": "",
|
"message_template": ""
|
||||||
"use_proxy": false
|
|
||||||
},
|
},
|
||||||
"mail": {
|
"mail": {
|
||||||
"enabled": false,
|
"enabled": false,
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
// Package resolver is a simple dns resolver
|
// Package dns_resolver is a simple dns resolver
|
||||||
// based on miekg/dns
|
// based on miekg/dns
|
||||||
package resolver
|
package dns_resolver
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
@ -13,47 +13,42 @@ import (
|
|||||||
"github.com/miekg/dns"
|
"github.com/miekg/dns"
|
||||||
)
|
)
|
||||||
|
|
||||||
// DNSResolver represents a dns resolver
|
// DnsResolver represents a dns resolver
|
||||||
type DNSResolver struct {
|
type DnsResolver struct {
|
||||||
Servers []string
|
Servers []string
|
||||||
RetryTimes int
|
RetryTimes int
|
||||||
r *rand.Rand
|
r *rand.Rand
|
||||||
}
|
}
|
||||||
|
|
||||||
// New initializes DnsResolver.
|
// New initializes DnsResolver.
|
||||||
func New(servers []string) *DNSResolver {
|
func New(servers []string) *DnsResolver {
|
||||||
for i := range servers {
|
for i := range servers {
|
||||||
servers[i] = net.JoinHostPort(servers[i], "53")
|
servers[i] = net.JoinHostPort(servers[i], "53")
|
||||||
}
|
}
|
||||||
|
|
||||||
return &DNSResolver{servers, len(servers) * 2, rand.New(rand.NewSource(time.Now().UnixNano()))}
|
return &DnsResolver{servers, len(servers) * 2, rand.New(rand.NewSource(time.Now().UnixNano()))}
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewFromResolvConf initializes DnsResolver from resolv.conf like file.
|
// NewFromResolvConf initializes DnsResolver from resolv.conf like file.
|
||||||
func NewFromResolvConf(path string) (*DNSResolver, error) {
|
func NewFromResolvConf(path string) (*DnsResolver, error) {
|
||||||
if _, err := os.Stat(path); os.IsNotExist(err) {
|
if _, err := os.Stat(path); os.IsNotExist(err) {
|
||||||
return &DNSResolver{}, errors.New("no such file or directory: " + path)
|
return &DnsResolver{}, errors.New("no such file or directory: " + path)
|
||||||
}
|
}
|
||||||
|
|
||||||
config, err := dns.ClientConfigFromFile(path)
|
config, err := dns.ClientConfigFromFile(path)
|
||||||
if err != nil {
|
servers := []string{}
|
||||||
return &DNSResolver{}, err
|
|
||||||
}
|
|
||||||
|
|
||||||
var servers []string
|
|
||||||
for _, ipAddress := range config.Servers {
|
for _, ipAddress := range config.Servers {
|
||||||
servers = append(servers, net.JoinHostPort(ipAddress, "53"))
|
servers = append(servers, net.JoinHostPort(ipAddress, "53"))
|
||||||
}
|
}
|
||||||
return &DNSResolver{servers, len(servers) * 2, rand.New(rand.NewSource(time.Now().UnixNano()))}, err
|
return &DnsResolver{servers, len(servers) * 2, rand.New(rand.NewSource(time.Now().UnixNano()))}, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// LookupHost returns IP addresses of provied host.
|
// LookupHost returns IP addresses of provied host.
|
||||||
// In case of timeout retries query RetryTimes times.
|
// In case of timeout retries query RetryTimes times.
|
||||||
func (r *DNSResolver) LookupHost(host string, dnsType uint16) ([]net.IP, error) {
|
func (r *DnsResolver) LookupHost(host string, dnsType uint16) ([]net.IP, error) {
|
||||||
return r.lookupHost(host, dnsType, r.RetryTimes)
|
return r.lookupHost(host, dnsType, r.RetryTimes)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *DNSResolver) lookupHost(host string, dnsType uint16, triesLeft int) ([]net.IP, error) {
|
func (r *DnsResolver) lookupHost(host string, dnsType uint16, triesLeft int) ([]net.IP, error) {
|
||||||
m1 := new(dns.Msg)
|
m1 := new(dns.Msg)
|
||||||
m1.Id = dns.Id()
|
m1.Id = dns.Id()
|
||||||
m1.RecursionDesired = true
|
m1.RecursionDesired = true
|
||||||
@ -61,14 +56,14 @@ func (r *DNSResolver) lookupHost(host string, dnsType uint16, triesLeft int) ([]
|
|||||||
|
|
||||||
switch dnsType {
|
switch dnsType {
|
||||||
case dns.TypeA:
|
case dns.TypeA:
|
||||||
m1.Question[0] = dns.Question{Name: dns.Fqdn(host), Qtype: dns.TypeA, Qclass: dns.ClassINET}
|
m1.Question[0] = dns.Question{dns.Fqdn(host), dns.TypeA, dns.ClassINET}
|
||||||
case dns.TypeAAAA:
|
case dns.TypeAAAA:
|
||||||
m1.Question[0] = dns.Question{Name: dns.Fqdn(host), Qtype: dns.TypeAAAA, Qclass: dns.ClassINET}
|
m1.Question[0] = dns.Question{dns.Fqdn(host), dns.TypeAAAA, dns.ClassINET}
|
||||||
}
|
}
|
||||||
|
|
||||||
in, err := dns.Exchange(m1, r.Servers[r.r.Intn(len(r.Servers))])
|
in, err := dns.Exchange(m1, r.Servers[r.r.Intn(len(r.Servers))])
|
||||||
|
|
||||||
var result []net.IP
|
result := []net.IP{}
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if strings.HasSuffix(err.Error(), "i/o timeout") && triesLeft > 0 {
|
if strings.HasSuffix(err.Error(), "i/o timeout") && triesLeft > 0 {
|
||||||
@ -83,26 +78,18 @@ func (r *DNSResolver) lookupHost(host string, dnsType uint16, triesLeft int) ([]
|
|||||||
}
|
}
|
||||||
|
|
||||||
if dnsType == dns.TypeA {
|
if dnsType == dns.TypeA {
|
||||||
if len(in.Answer) > 0 {
|
for _, record := range in.Answer {
|
||||||
for _, record := range in.Answer {
|
if t, ok := record.(*dns.A); ok {
|
||||||
if t, ok := record.(*dns.A); ok {
|
result = append(result, t.A)
|
||||||
result = append(result, t.A)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
return result, errors.New("empty result")
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if dnsType == dns.TypeAAAA {
|
if dnsType == dns.TypeAAAA {
|
||||||
if len(in.Answer) > 0 {
|
for _, record := range in.Answer {
|
||||||
for _, record := range in.Answer {
|
if t, ok := record.(*dns.AAAA); ok {
|
||||||
if t, ok := record.(*dns.AAAA); ok {
|
result = append(result, t.AAAA)
|
||||||
result = append(result, t.AAAA)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
return result, errors.New("Cannot resolve this domain, please make sure the IP type is right")
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package resolver
|
package dns_resolver
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
@ -40,6 +40,6 @@ func TestLookupHostIPv6_ValidServer(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if result[0].String() != "2001:4860:4860::8888" {
|
if result[0].String() != "2001:4860:4860::8888" {
|
||||||
t.Error("result should be: 2001:4860:4860::8888")
|
t.Error("result shoudl be: 2001:4860:4860::8888")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -74,7 +74,7 @@ func getHTTPBody(url string) ([]byte, error) {
|
|||||||
if resp.StatusCode == http.StatusOK {
|
if resp.StatusCode == http.StatusOK {
|
||||||
return body, err
|
return body, err
|
||||||
}
|
}
|
||||||
return nil, fmt.Errorf("status %d, Error:%s", resp.StatusCode, body)
|
return nil, fmt.Errorf("Status %d, Error:%s", resp.StatusCode, body)
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewAliDNS function creates instance of AliDNS and return
|
// NewAliDNS function creates instance of AliDNS and return
|
||||||
@ -92,8 +92,9 @@ func NewAliDNS(key, secret string) *AliDNS {
|
|||||||
func (d *AliDNS) GetDomainRecords(domain, rr string) []DomainRecord {
|
func (d *AliDNS) GetDomainRecords(domain, rr string) []DomainRecord {
|
||||||
resp := &domainRecordsResp{}
|
resp := &domainRecordsResp{}
|
||||||
parms := map[string]string{
|
parms := map[string]string{
|
||||||
"Action": "DescribeSubDomainRecords",
|
"Action": "DescribeDomainRecords",
|
||||||
"SubDomain": fmt.Sprintf("%s.%s", rr, domain),
|
"DomainName": domain,
|
||||||
|
"RRKeyWord": rr,
|
||||||
}
|
}
|
||||||
urlPath := d.genRequestURL(parms)
|
urlPath := d.genRequestURL(parms)
|
||||||
body, err := getHTTPBody(urlPath)
|
body, err := getHTTPBody(urlPath)
|
||||||
@ -123,7 +124,7 @@ func (d *AliDNS) UpdateDomainRecord(r DomainRecord) error {
|
|||||||
|
|
||||||
urlPath := d.genRequestURL(parms)
|
urlPath := d.genRequestURL(parms)
|
||||||
if urlPath == "" {
|
if urlPath == "" {
|
||||||
return errors.New("failed to generate request URL")
|
return errors.New("Failed to generate request URL")
|
||||||
}
|
}
|
||||||
_, err := getHTTPBody(urlPath)
|
_, err := getHTTPBody(urlPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -133,7 +134,7 @@ func (d *AliDNS) UpdateDomainRecord(r DomainRecord) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (d *AliDNS) genRequestURL(parms map[string]string) string {
|
func (d *AliDNS) genRequestURL(parms map[string]string) string {
|
||||||
var pArr []string
|
pArr := []string{}
|
||||||
ps := map[string]string{}
|
ps := map[string]string{}
|
||||||
for k, v := range publicParm {
|
for k, v := range publicParm {
|
||||||
ps[k] = v
|
ps[k] = v
|
||||||
|
|||||||
@ -28,17 +28,9 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
looping := false
|
|
||||||
aliDNS := NewAliDNS(handler.Configuration.Email, handler.Configuration.Password)
|
aliDNS := NewAliDNS(handler.Configuration.Email, handler.Configuration.Password)
|
||||||
|
|
||||||
for {
|
for {
|
||||||
if looping {
|
|
||||||
// Sleep with interval
|
|
||||||
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
|
||||||
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
|
||||||
}
|
|
||||||
|
|
||||||
looping = true
|
|
||||||
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -48,11 +40,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
log.Println("currentIP is:", currentIP)
|
log.Println("currentIP is:", currentIP)
|
||||||
for _, subDomain := range domain.SubDomains {
|
for _, subDomain := range domain.SubDomains {
|
||||||
hostname := subDomain + "." + domain.DomainName
|
hostname := subDomain + "." + domain.DomainName
|
||||||
lastIP, err := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
lastIP := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
||||||
if err != nil {
|
|
||||||
log.Println(err)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
//check against currently known IP, if no change, skip update
|
//check against currently known IP, if no change, skip update
|
||||||
if currentIP == lastIP {
|
if currentIP == lastIP {
|
||||||
log.Printf("IP is the same as cached one. Skip update.\n")
|
log.Printf("IP is the same as cached one. Skip update.\n")
|
||||||
@ -80,6 +68,9 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
// Sleep with interval
|
||||||
|
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
||||||
|
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -77,15 +77,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}()
|
}()
|
||||||
|
|
||||||
var lastIP string
|
var lastIP string
|
||||||
looping := false
|
|
||||||
for {
|
for {
|
||||||
if looping {
|
|
||||||
// Sleep with interval
|
|
||||||
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
|
||||||
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
|
||||||
}
|
|
||||||
looping = true
|
|
||||||
|
|
||||||
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println("Error in GetCurrentIP:", err)
|
log.Println("Error in GetCurrentIP:", err)
|
||||||
@ -96,6 +88,8 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
if currentIP == lastIP {
|
if currentIP == lastIP {
|
||||||
log.Printf("IP is the same as cached one. Skip update.\n")
|
log.Printf("IP is the same as cached one. Skip update.\n")
|
||||||
} else {
|
} else {
|
||||||
|
lastIP = currentIP
|
||||||
|
|
||||||
log.Println("Checking IP for domain", domain.DomainName)
|
log.Println("Checking IP for domain", domain.DomainName)
|
||||||
zoneID := handler.getZone(domain.DomainName)
|
zoneID := handler.getZone(domain.DomainName)
|
||||||
if zoneID != "" {
|
if zoneID != "" {
|
||||||
@ -109,7 +103,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
if rec.IP != currentIP {
|
if rec.IP != currentIP {
|
||||||
log.Printf("IP mismatch: Current(%+v) vs Cloudflare(%+v)\r\n", currentIP, rec.IP)
|
log.Printf("IP mismatch: Current(%+v) vs Cloudflare(%+v)\r\n", currentIP, rec.IP)
|
||||||
lastIP = handler.updateRecord(rec, currentIP)
|
handler.updateRecord(rec, currentIP)
|
||||||
|
|
||||||
// Send notification
|
// Send notification
|
||||||
if err := godns.SendNotify(handler.Configuration, rec.Name, currentIP); err != nil {
|
if err := godns.SendNotify(handler.Configuration, rec.Name, currentIP); err != nil {
|
||||||
@ -123,14 +117,14 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
log.Println("Failed to find zone for domain:", domain.DomainName)
|
log.Println("Failed to find zone for domain:", domain.DomainName)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
// Sleep with interval
|
||||||
|
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
||||||
|
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Check if record is present in domain conf
|
// Check if record is present in domain conf
|
||||||
func recordTracked(domain *godns.Domain, record *DNSRecord) bool {
|
func recordTracked(domain *godns.Domain, record *DNSRecord) bool {
|
||||||
if record.Name == domain.DomainName {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
for _, subDomain := range domain.SubDomains {
|
for _, subDomain := range domain.SubDomains {
|
||||||
sd := fmt.Sprintf("%s.%s", subDomain, domain.DomainName)
|
sd := fmt.Sprintf("%s.%s", subDomain, domain.DomainName)
|
||||||
if record.Name == sd {
|
if record.Name == sd {
|
||||||
@ -143,7 +137,7 @@ func recordTracked(domain *godns.Domain, record *DNSRecord) bool {
|
|||||||
|
|
||||||
// Create a new request with auth in place and optional proxy
|
// Create a new request with auth in place and optional proxy
|
||||||
func (handler *Handler) newRequest(method, url string, body io.Reader) (*http.Request, *http.Client) {
|
func (handler *Handler) newRequest(method, url string, body io.Reader) (*http.Request, *http.Client) {
|
||||||
client := godns.GetHttpClient(handler.Configuration, handler.Configuration.UseProxy)
|
client := godns.GetHttpClient(handler.Configuration)
|
||||||
if client == nil {
|
if client == nil {
|
||||||
log.Println("cannot create HTTP client")
|
log.Println("cannot create HTTP client")
|
||||||
}
|
}
|
||||||
@ -166,7 +160,7 @@ func (handler *Handler) getZone(domain string) string {
|
|||||||
|
|
||||||
var z ZoneResponse
|
var z ZoneResponse
|
||||||
|
|
||||||
req, client := handler.newRequest("GET", fmt.Sprintf("/zones?name=%s", domain), nil)
|
req, client := handler.newRequest("GET", "/zones", nil)
|
||||||
resp, err := client.Do(req)
|
resp, err := client.Do(req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println("Request error:", err.Error())
|
log.Println("Request error:", err.Error())
|
||||||
@ -207,7 +201,7 @@ func (handler *Handler) getDNSRecords(zoneID string) []DNSRecord {
|
|||||||
}
|
}
|
||||||
|
|
||||||
log.Println("Querying records with type:", recordType)
|
log.Println("Querying records with type:", recordType)
|
||||||
req, client := handler.newRequest("GET", fmt.Sprintf("/zones/"+zoneID+"/dns_records?type=%s&page=1&per_page=500", recordType), nil)
|
req, client := handler.newRequest("GET", fmt.Sprintf("/zones/"+zoneID+"/dns_records?type=%s", recordType), nil)
|
||||||
resp, err := client.Do(req)
|
resp, err := client.Do(req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println("Request error:", err.Error())
|
log.Println("Request error:", err.Error())
|
||||||
@ -231,11 +225,10 @@ func (handler *Handler) getDNSRecords(zoneID string) []DNSRecord {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Update DNS A Record with new IP
|
// Update DNS A Record with new IP
|
||||||
func (handler *Handler) updateRecord(record DNSRecord, newIP string) string {
|
func (handler *Handler) updateRecord(record DNSRecord, newIP string) {
|
||||||
|
|
||||||
var r DNSRecordUpdateResponse
|
var r DNSRecordUpdateResponse
|
||||||
record.SetIP(newIP)
|
record.SetIP(newIP)
|
||||||
var lastIP string
|
|
||||||
|
|
||||||
j, _ := json.Marshal(record)
|
j, _ := json.Marshal(record)
|
||||||
req, client := handler.newRequest("PUT",
|
req, client := handler.newRequest("PUT",
|
||||||
@ -245,7 +238,7 @@ func (handler *Handler) updateRecord(record DNSRecord, newIP string) string {
|
|||||||
resp, err := client.Do(req)
|
resp, err := client.Do(req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println("Request error:", err.Error())
|
log.Println("Request error:", err.Error())
|
||||||
return ""
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
body, _ := ioutil.ReadAll(resp.Body)
|
body, _ := ioutil.ReadAll(resp.Body)
|
||||||
@ -253,14 +246,12 @@ func (handler *Handler) updateRecord(record DNSRecord, newIP string) string {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
log.Printf("Decoder error: %+v\n", err)
|
log.Printf("Decoder error: %+v\n", err)
|
||||||
log.Printf("Response body: %+v\n", string(body))
|
log.Printf("Response body: %+v\n", string(body))
|
||||||
return ""
|
return
|
||||||
}
|
}
|
||||||
if r.Success != true {
|
if r.Success != true {
|
||||||
body, _ := ioutil.ReadAll(resp.Body)
|
body, _ := ioutil.ReadAll(resp.Body)
|
||||||
log.Printf("Response failed: %+v\n", string(body))
|
log.Printf("Response failed: %+v\n", string(body))
|
||||||
} else {
|
} else {
|
||||||
log.Printf("Record updated: %+v - %+v", record.Name, record.IP)
|
log.Printf("Record updated: %+v - %+v", record.Name, record.IP)
|
||||||
lastIP = record.IP
|
|
||||||
}
|
}
|
||||||
return lastIP
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -14,7 +14,7 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/TimothyYe/godns"
|
"github.com/TimothyYe/godns"
|
||||||
"github.com/bitly/go-simplejson"
|
simplejson "github.com/bitly/go-simplejson"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Handler struct definition
|
// Handler struct definition
|
||||||
@ -36,16 +36,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
looping := false
|
|
||||||
for {
|
for {
|
||||||
if looping {
|
|
||||||
// Sleep with interval
|
|
||||||
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
|
||||||
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
|
||||||
}
|
|
||||||
|
|
||||||
looping = true
|
|
||||||
|
|
||||||
log.Printf("Checking IP for domain %s \r\n", domain.DomainName)
|
log.Printf("Checking IP for domain %s \r\n", domain.DomainName)
|
||||||
domainID := handler.GetDomain(domain.DomainName)
|
domainID := handler.GetDomain(domain.DomainName)
|
||||||
|
|
||||||
@ -63,12 +54,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
|
|
||||||
for _, subDomain := range domain.SubDomains {
|
for _, subDomain := range domain.SubDomains {
|
||||||
hostname := subDomain + "." + domain.DomainName
|
hostname := subDomain + "." + domain.DomainName
|
||||||
lastIP, err := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
lastIP := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
||||||
if err != nil {
|
|
||||||
log.Println(err)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
//check against currently known IP, if no change, skip update
|
//check against currently known IP, if no change, skip update
|
||||||
if currentIP == lastIP {
|
if currentIP == lastIP {
|
||||||
log.Printf("IP is the same as cached one. Skip update.\n")
|
log.Printf("IP is the same as cached one. Skip update.\n")
|
||||||
@ -96,6 +82,9 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
// Sleep with interval
|
||||||
|
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
||||||
|
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -177,15 +166,6 @@ func (handler *Handler) GetSubDomain(domainID int64, name string) (string, strin
|
|||||||
value.Add("length", "1")
|
value.Add("length", "1")
|
||||||
value.Add("sub_domain", name)
|
value.Add("sub_domain", name)
|
||||||
|
|
||||||
if handler.Configuration.IPType == "" || strings.ToUpper(handler.Configuration.IPType) == godns.IPV4 {
|
|
||||||
value.Add("record_type", "A")
|
|
||||||
} else if strings.ToUpper(handler.Configuration.IPType) == godns.IPV6 {
|
|
||||||
value.Add("record_type", "AAAA")
|
|
||||||
} else {
|
|
||||||
log.Println("Error: must specify \"ip_type\" in config for DNSPod.")
|
|
||||||
return "", ""
|
|
||||||
}
|
|
||||||
|
|
||||||
response, err := handler.PostData("/Record.List", value)
|
response, err := handler.PostData("/Record.List", value)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -265,7 +245,7 @@ func (handler *Handler) UpdateIP(domainID int64, subDomainID string, subDomainNa
|
|||||||
|
|
||||||
// PostData post data and invoke DNSPod API
|
// PostData post data and invoke DNSPod API
|
||||||
func (handler *Handler) PostData(url string, content url.Values) (string, error) {
|
func (handler *Handler) PostData(url string, content url.Values) (string, error) {
|
||||||
client := godns.GetHttpClient(handler.Configuration, handler.Configuration.UseProxy)
|
client := godns.GetHttpClient(handler.Configuration)
|
||||||
|
|
||||||
if client == nil {
|
if client == nil {
|
||||||
return "", errors.New("failed to create HTTP client")
|
return "", errors.New("failed to create HTTP client")
|
||||||
|
|||||||
@ -38,15 +38,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
looping := false
|
|
||||||
for {
|
for {
|
||||||
if looping {
|
|
||||||
// Sleep with interval
|
|
||||||
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
|
||||||
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
|
||||||
}
|
|
||||||
looping = true
|
|
||||||
|
|
||||||
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -57,12 +49,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
|
|
||||||
for _, subDomain := range domain.SubDomains {
|
for _, subDomain := range domain.SubDomains {
|
||||||
hostname := subDomain + "." + domain.DomainName
|
hostname := subDomain + "." + domain.DomainName
|
||||||
lastIP, err := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
lastIP := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
||||||
if err != nil {
|
|
||||||
log.Println(err)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
//check against currently known IP, if no change, skip update
|
//check against currently known IP, if no change, skip update
|
||||||
if currentIP == lastIP {
|
if currentIP == lastIP {
|
||||||
log.Printf("IP is the same as cached one. Skip update.\n")
|
log.Printf("IP is the same as cached one. Skip update.\n")
|
||||||
@ -76,6 +63,10 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Sleep with interval
|
||||||
|
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
||||||
|
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@ -115,7 +106,7 @@ func (handler *Handler) updateDNS(dns, ip, hostname, action string) {
|
|||||||
log.Fatalf("Unknown action %s\n", action)
|
log.Fatalf("Unknown action %s\n", action)
|
||||||
}
|
}
|
||||||
|
|
||||||
client := godns.GetHttpClient(handler.Configuration, handler.Configuration.UseProxy)
|
client := godns.GetHttpClient(handler.Configuration)
|
||||||
req, _ := http.NewRequest("POST", DreamhostURL, strings.NewReader(values.Encode()))
|
req, _ := http.NewRequest("POST", DreamhostURL, strings.NewReader(values.Encode()))
|
||||||
req.SetBasicAuth(handler.Configuration.Email, handler.Configuration.Password)
|
req.SetBasicAuth(handler.Configuration.Email, handler.Configuration.Password)
|
||||||
|
|
||||||
|
|||||||
@ -35,25 +35,18 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
looping := false
|
|
||||||
|
|
||||||
for {
|
for {
|
||||||
if looping {
|
|
||||||
// Sleep with interval
|
|
||||||
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
|
||||||
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
|
||||||
}
|
|
||||||
|
|
||||||
looping = true
|
|
||||||
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println("get_currentIP:", err)
|
log.Println("get_currentIP:", err)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Println("currentIP is:", currentIP)
|
log.Println("currentIP is:", currentIP)
|
||||||
client := godns.GetHttpClient(handler.Configuration, handler.Configuration.UseProxy)
|
|
||||||
|
//check against locally cached IP, if no change, skip update
|
||||||
|
|
||||||
|
client := godns.GetHttpClient(handler.Configuration)
|
||||||
var ip string
|
var ip string
|
||||||
|
|
||||||
if strings.ToUpper(handler.Configuration.IPType) == godns.IPV4 {
|
if strings.ToUpper(handler.Configuration.IPType) == godns.IPV4 {
|
||||||
@ -64,12 +57,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
|
|
||||||
for _, subDomain := range domain.SubDomains {
|
for _, subDomain := range domain.SubDomains {
|
||||||
hostname := subDomain + "." + domain.DomainName
|
hostname := subDomain + "." + domain.DomainName
|
||||||
lastIP, err := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
lastIP := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
||||||
if err != nil {
|
|
||||||
log.Println(err)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
//check against currently known IP, if no change, skip update
|
//check against currently known IP, if no change, skip update
|
||||||
if currentIP == lastIP {
|
if currentIP == lastIP {
|
||||||
log.Printf("IP is the same as cached one. Skip update.\n")
|
log.Printf("IP is the same as cached one. Skip update.\n")
|
||||||
@ -98,5 +86,9 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Sleep with interval
|
||||||
|
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
||||||
|
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -36,16 +36,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
looping := false
|
|
||||||
|
|
||||||
for {
|
for {
|
||||||
if looping {
|
|
||||||
// Sleep with interval
|
|
||||||
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
|
||||||
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
|
||||||
}
|
|
||||||
|
|
||||||
looping = true
|
|
||||||
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println("get_currentIP:", err)
|
log.Println("get_currentIP:", err)
|
||||||
@ -54,12 +45,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
log.Println("currentIP is:", currentIP)
|
log.Println("currentIP is:", currentIP)
|
||||||
for _, subDomain := range domain.SubDomains {
|
for _, subDomain := range domain.SubDomains {
|
||||||
hostname := subDomain + "." + domain.DomainName
|
hostname := subDomain + "." + domain.DomainName
|
||||||
lastIP, err := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
lastIP := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
||||||
if err != nil {
|
|
||||||
log.Println(err)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
//check against currently known IP, if no change, skip update
|
//check against currently known IP, if no change, skip update
|
||||||
if currentIP == lastIP {
|
if currentIP == lastIP {
|
||||||
log.Printf("IP is the same as cached one. Skip update.\n")
|
log.Printf("IP is the same as cached one. Skip update.\n")
|
||||||
@ -73,13 +59,16 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
// Sleep with interval
|
||||||
|
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
||||||
|
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// UpdateIP update subdomain with current IP
|
// UpdateIP update subdomain with current IP
|
||||||
func (handler *Handler) UpdateIP(domain, subDomain, currentIP string) {
|
func (handler *Handler) UpdateIP(domain, subDomain, currentIP string) {
|
||||||
client := godns.GetHttpClient(handler.Configuration, handler.Configuration.UseProxy)
|
client := godns.GetHttpClient(handler.Configuration)
|
||||||
resp, err := client.Get(fmt.Sprintf(GoogleURL,
|
resp, err := client.Get(fmt.Sprintf(GoogleURL,
|
||||||
handler.Configuration.Email,
|
handler.Configuration.Email,
|
||||||
handler.Configuration.Password,
|
handler.Configuration.Password,
|
||||||
@ -90,7 +79,6 @@ func (handler *Handler) UpdateIP(domain, subDomain, currentIP string) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
// handle error
|
// handle error
|
||||||
log.Print("Failed to update sub domain:", subDomain)
|
log.Print("Failed to update sub domain:", subDomain)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
|
|
||||||
defer resp.Body.Close()
|
defer resp.Body.Close()
|
||||||
|
|||||||
@ -9,7 +9,6 @@ import (
|
|||||||
"github.com/TimothyYe/godns/handler/duck"
|
"github.com/TimothyYe/godns/handler/duck"
|
||||||
"github.com/TimothyYe/godns/handler/google"
|
"github.com/TimothyYe/godns/handler/google"
|
||||||
"github.com/TimothyYe/godns/handler/he"
|
"github.com/TimothyYe/godns/handler/he"
|
||||||
"github.com/TimothyYe/godns/handler/noip"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// IHandler is the interface for all DNS handlers
|
// IHandler is the interface for all DNS handlers
|
||||||
@ -37,8 +36,6 @@ func CreateHandler(provider string) IHandler {
|
|||||||
handler = IHandler(&google.Handler{})
|
handler = IHandler(&google.Handler{})
|
||||||
case godns.DUCK:
|
case godns.DUCK:
|
||||||
handler = IHandler(&duck.Handler{})
|
handler = IHandler(&duck.Handler{})
|
||||||
case godns.NOIP:
|
|
||||||
handler = IHandler(&noip.Handler{})
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return handler
|
return handler
|
||||||
|
|||||||
@ -37,15 +37,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
looping := false
|
|
||||||
for {
|
for {
|
||||||
if looping {
|
|
||||||
// Sleep with interval
|
|
||||||
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
|
||||||
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
|
||||||
}
|
|
||||||
looping = true
|
|
||||||
|
|
||||||
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -58,12 +50,7 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
|
|
||||||
for _, subDomain := range domain.SubDomains {
|
for _, subDomain := range domain.SubDomains {
|
||||||
hostname := subDomain + "." + domain.DomainName
|
hostname := subDomain + "." + domain.DomainName
|
||||||
lastIP, err := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
lastIP := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
||||||
if err != nil {
|
|
||||||
log.Println(err)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
//check against currently known IP, if no change, skip update
|
//check against currently known IP, if no change, skip update
|
||||||
if currentIP == lastIP {
|
if currentIP == lastIP {
|
||||||
log.Printf("IP is the same as cached one. Skip update.\n")
|
log.Printf("IP is the same as cached one. Skip update.\n")
|
||||||
@ -77,6 +64,10 @@ func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Sleep with interval
|
||||||
|
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
||||||
|
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@ -88,7 +79,7 @@ func (handler *Handler) UpdateIP(domain, subDomain, currentIP string) {
|
|||||||
values.Add("password", handler.Configuration.Password)
|
values.Add("password", handler.Configuration.Password)
|
||||||
values.Add("myip", currentIP)
|
values.Add("myip", currentIP)
|
||||||
|
|
||||||
client := godns.GetHttpClient(handler.Configuration, handler.Configuration.UseProxy)
|
client := godns.GetHttpClient(handler.Configuration)
|
||||||
|
|
||||||
req, _ := http.NewRequest("POST", HEUrl, strings.NewReader(values.Encode()))
|
req, _ := http.NewRequest("POST", HEUrl, strings.NewReader(values.Encode()))
|
||||||
resp, err := client.Do(req)
|
resp, err := client.Do(req)
|
||||||
|
|||||||
@ -1,114 +0,0 @@
|
|||||||
package noip
|
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
"io/ioutil"
|
|
||||||
"log"
|
|
||||||
"net/http"
|
|
||||||
"runtime/debug"
|
|
||||||
"strings"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"github.com/TimothyYe/godns"
|
|
||||||
)
|
|
||||||
|
|
||||||
var (
|
|
||||||
// NoIPUrl the API address for NoIP
|
|
||||||
NoIPUrl = "https://%s:%s@dynupdate.no-ip.com/nic/update?hostname=%s&%s"
|
|
||||||
)
|
|
||||||
|
|
||||||
// Handler struct
|
|
||||||
type Handler struct {
|
|
||||||
Configuration *godns.Settings
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetConfiguration pass dns settings and store it to handler instance
|
|
||||||
func (handler *Handler) SetConfiguration(conf *godns.Settings) {
|
|
||||||
handler.Configuration = conf
|
|
||||||
}
|
|
||||||
|
|
||||||
// DomainLoop the main logic loop
|
|
||||||
func (handler *Handler) DomainLoop(domain *godns.Domain, panicChan chan<- godns.Domain) {
|
|
||||||
defer func() {
|
|
||||||
if err := recover(); err != nil {
|
|
||||||
log.Printf("Recovered in %v: %v\n", err, debug.Stack())
|
|
||||||
panicChan <- *domain
|
|
||||||
}
|
|
||||||
}()
|
|
||||||
|
|
||||||
looping := false
|
|
||||||
|
|
||||||
for {
|
|
||||||
if looping {
|
|
||||||
// Sleep with interval
|
|
||||||
log.Printf("Going to sleep, will start next checking in %d seconds...\r\n", handler.Configuration.Interval)
|
|
||||||
time.Sleep(time.Second * time.Duration(handler.Configuration.Interval))
|
|
||||||
}
|
|
||||||
|
|
||||||
looping = true
|
|
||||||
currentIP, err := godns.GetCurrentIP(handler.Configuration)
|
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
log.Println("get_currentIP:", err)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Println("currentIP is:", currentIP)
|
|
||||||
client := godns.GetHttpClient(handler.Configuration, handler.Configuration.UseProxy)
|
|
||||||
|
|
||||||
var ip string
|
|
||||||
if strings.ToUpper(handler.Configuration.IPType) == godns.IPV4 {
|
|
||||||
ip = fmt.Sprintf("myip=%s", currentIP)
|
|
||||||
} else if strings.ToUpper(handler.Configuration.IPType) == godns.IPV6 {
|
|
||||||
ip = fmt.Sprintf("myipv6=%s", currentIP)
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, subDomain := range domain.SubDomains {
|
|
||||||
hostname := subDomain + "." + domain.DomainName
|
|
||||||
lastIP, err := godns.ResolveDNS(hostname, handler.Configuration.Resolver, handler.Configuration.IPType)
|
|
||||||
if err != nil {
|
|
||||||
log.Println(err)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
//check against currently known IP, if no change, skip update
|
|
||||||
if currentIP == lastIP {
|
|
||||||
log.Printf("IP is the same as cached one. Skip update.\n")
|
|
||||||
} else {
|
|
||||||
req, _ := http.NewRequest("GET", fmt.Sprintf(
|
|
||||||
NoIPUrl,
|
|
||||||
handler.Configuration.Email,
|
|
||||||
handler.Configuration.Password,
|
|
||||||
hostname,
|
|
||||||
ip), nil)
|
|
||||||
|
|
||||||
if handler.Configuration.UserAgent != "" {
|
|
||||||
req.Header.Add("User-Agent", handler.Configuration.UserAgent)
|
|
||||||
}
|
|
||||||
|
|
||||||
// update IP with HTTP GET request
|
|
||||||
resp, err := client.Do(req)
|
|
||||||
if err != nil {
|
|
||||||
// handle error
|
|
||||||
log.Print("Failed to update sub domain:", subDomain)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
defer resp.Body.Close()
|
|
||||||
|
|
||||||
body, err := ioutil.ReadAll(resp.Body)
|
|
||||||
if err != nil || !strings.Contains(string(body), "good") {
|
|
||||||
log.Println("Failed to update the IP")
|
|
||||||
continue
|
|
||||||
} else {
|
|
||||||
log.Print("IP updated to:", currentIP)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Send notification
|
|
||||||
if err := godns.SendNotify(handler.Configuration, fmt.Sprintf("%s.%s", subDomain, domain.DomainName), currentIP); err != nil {
|
|
||||||
log.Println("Failed to send notification")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
12
settings.go
12
settings.go
@ -12,22 +12,12 @@ type Domain struct {
|
|||||||
SubDomains []string `json:"sub_domains"`
|
SubDomains []string `json:"sub_domains"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// Notify struct for slack notification
|
|
||||||
type SlackNotify struct {
|
|
||||||
Enabled bool `json:"enabled"`
|
|
||||||
BotApiToken string `json:"bot_api_token"`
|
|
||||||
Channel string `json:"channel"`
|
|
||||||
MsgTemplate string `json:"message_template"`
|
|
||||||
UseProxy bool `json:"use_proxy"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// Notify struct for telegram notification
|
// Notify struct for telegram notification
|
||||||
type TelegramNotify struct {
|
type TelegramNotify struct {
|
||||||
Enabled bool `json:"enabled"`
|
Enabled bool `json:"enabled"`
|
||||||
BotApiKey string `json:"bot_api_key"`
|
BotApiKey string `json:"bot_api_key"`
|
||||||
ChatId string `json:"chat_id"`
|
ChatId string `json:"chat_id"`
|
||||||
MsgTemplate string `json:"message_template"`
|
MsgTemplate string `json:"message_template"`
|
||||||
UseProxy bool `json:"use_proxy"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Notify struct for SMTP notification
|
// Notify struct for SMTP notification
|
||||||
@ -44,7 +34,6 @@ type MailNotify struct {
|
|||||||
type Notify struct {
|
type Notify struct {
|
||||||
Telegram TelegramNotify `json:"telegram"`
|
Telegram TelegramNotify `json:"telegram"`
|
||||||
Mail MailNotify `json:"mail"`
|
Mail MailNotify `json:"mail"`
|
||||||
Slack SlackNotify `json:"slack"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Settings struct
|
// Settings struct
|
||||||
@ -64,7 +53,6 @@ type Settings struct {
|
|||||||
IPInterface string `json:"ip_interface"`
|
IPInterface string `json:"ip_interface"`
|
||||||
IPType string `json:"ip_type"`
|
IPType string `json:"ip_type"`
|
||||||
Resolver string `json:"resolver"`
|
Resolver string `json:"resolver"`
|
||||||
UseProxy bool `json:"use_proxy"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// LoadSettings -- Load settings from config file
|
// LoadSettings -- Load settings from config file
|
||||||
|
|||||||
115
utils.go
115
utils.go
@ -10,14 +10,12 @@ import (
|
|||||||
"log"
|
"log"
|
||||||
"net"
|
"net"
|
||||||
"net/http"
|
"net/http"
|
||||||
"net/url"
|
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
dnsResolver "github.com/TimothyYe/godns/resolver"
|
"github.com/TimothyYe/godns/dns_resolver"
|
||||||
|
|
||||||
"github.com/miekg/dns"
|
"github.com/miekg/dns"
|
||||||
"golang.org/x/net/proxy"
|
"golang.org/x/net/proxy"
|
||||||
"gopkg.in/gomail.v2"
|
gomail "gopkg.in/gomail.v2"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
@ -54,8 +52,6 @@ const (
|
|||||||
DUCK = "DuckDNS"
|
DUCK = "DuckDNS"
|
||||||
// DREAMHOST for Dreamhost
|
// DREAMHOST for Dreamhost
|
||||||
DREAMHOST = "Dreamhost"
|
DREAMHOST = "Dreamhost"
|
||||||
// NOIP for NoIP
|
|
||||||
NOIP = "NoIP"
|
|
||||||
// IPV4 for IPV4 mode
|
// IPV4 for IPV4 mode
|
||||||
IPV4 = "IPV4"
|
IPV4 = "IPV4"
|
||||||
// IPV6 for IPV6 mode
|
// IPV6 for IPV6 mode
|
||||||
@ -99,7 +95,7 @@ func GetIPFromInterface(configuration *Settings) (string, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if isIPv4(ip.String()) {
|
if isIPv4(ip.String()) {
|
||||||
if strings.ToUpper(configuration.IPType) != IPV4 {
|
if strings.ToUpper(configuration.IPType) == IPV4 {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
@ -120,10 +116,10 @@ func isIPv4(ip string) bool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// GetHttpClient creates the HTTP client and return it
|
// GetHttpClient creates the HTTP client and return it
|
||||||
func GetHttpClient(configuration *Settings, useProxy bool) *http.Client {
|
func GetHttpClient(configuration *Settings) *http.Client {
|
||||||
client := &http.Client{}
|
client := &http.Client{}
|
||||||
|
|
||||||
if useProxy && configuration.Socks5Proxy != "" {
|
if configuration.Socks5Proxy != "" {
|
||||||
log.Println("use socks5 proxy:" + configuration.Socks5Proxy)
|
log.Println("use socks5 proxy:" + configuration.Socks5Proxy)
|
||||||
dialer, err := proxy.SOCKS5("tcp", configuration.Socks5Proxy, nil, proxy.Direct)
|
dialer, err := proxy.SOCKS5("tcp", configuration.Socks5Proxy, nil, proxy.Direct)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -220,8 +216,6 @@ func CheckSettings(config *Settings) error {
|
|||||||
return errors.New("login token cannot be empty")
|
return errors.New("login token cannot be empty")
|
||||||
}
|
}
|
||||||
case GOOGLE:
|
case GOOGLE:
|
||||||
fallthrough
|
|
||||||
case NOIP:
|
|
||||||
if config.Email == "" {
|
if config.Email == "" {
|
||||||
return errors.New("email cannot be empty")
|
return errors.New("email cannot be empty")
|
||||||
}
|
}
|
||||||
@ -255,21 +249,21 @@ func SendTelegramNotify(configuration *Settings, domain, currentIP string) error
|
|||||||
return errors.New("chat id cannot be empty")
|
return errors.New("chat id cannot be empty")
|
||||||
}
|
}
|
||||||
|
|
||||||
client := GetHttpClient(configuration, configuration.Notify.Telegram.UseProxy)
|
client := GetHttpClient(configuration)
|
||||||
tpl := configuration.Notify.Telegram.MsgTemplate
|
tpl := configuration.Notify.Telegram.MsgTemplate
|
||||||
if tpl == "" {
|
if tpl == "" {
|
||||||
tpl = "_Your IP address is changed to_%0A%0A*{{ .CurrentIP }}*%0A%0ADomain *{{ .Domain }}* is updated"
|
tpl = "_Your IP address is changed to_%0A%0A*{{ .CurrentIP }}*%0A%0ADomain *{{ .Domain }}* is updated"
|
||||||
}
|
}
|
||||||
|
|
||||||
msg := buildTemplate(currentIP, domain, tpl)
|
msg := buildTemplate(currentIP, domain, tpl)
|
||||||
reqURL := fmt.Sprintf("https://api.telegram.org/bot%s/sendMessage?chat_id=%s&parse_mode=Markdown&text=%s",
|
url := fmt.Sprintf("https://api.telegram.org/bot%s/sendMessage?chat_id=%s&parse_mode=Markdown&text=%s",
|
||||||
configuration.Notify.Telegram.BotApiKey,
|
configuration.Notify.Telegram.BotApiKey,
|
||||||
configuration.Notify.Telegram.ChatId,
|
configuration.Notify.Telegram.ChatId,
|
||||||
msg)
|
msg)
|
||||||
var response *http.Response
|
var response *http.Response
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
response, err = client.Get(reqURL)
|
response, err = client.Get(url)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
@ -290,10 +284,10 @@ func SendTelegramNotify(configuration *Settings, domain, currentIP string) error
|
|||||||
Parameters *ResponseParameters `json:"parameters"`
|
Parameters *ResponseParameters `json:"parameters"`
|
||||||
}
|
}
|
||||||
var resp APIResponse
|
var resp APIResponse
|
||||||
err = json.Unmarshal(body, &resp)
|
err = json.Unmarshal([]byte(body), &resp)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Println("error:", err)
|
fmt.Println("error:", err)
|
||||||
return errors.New("failed to parse response")
|
return errors.New("Failed to parse response")
|
||||||
}
|
}
|
||||||
if !resp.Ok {
|
if !resp.Ok {
|
||||||
return errors.New(resp.Description)
|
return errors.New(resp.Description)
|
||||||
@ -317,7 +311,7 @@ func SendMailNotify(configuration *Settings, domain, currentIP string) error {
|
|||||||
log.Println("domain:", domain)
|
log.Println("domain:", domain)
|
||||||
m.SetBody("text/html", buildTemplate(currentIP, domain, mailTemplate))
|
m.SetBody("text/html", buildTemplate(currentIP, domain, mailTemplate))
|
||||||
|
|
||||||
d := gomail.NewDialer(configuration.Notify.Mail.SMTPServer, configuration.Notify.Mail.SMTPPort, configuration.Notify.Mail.SMTPUsername, configuration.Notify.Mail.SMTPPassword)
|
d := gomail.NewPlainDialer(configuration.Notify.Mail.SMTPServer, configuration.Notify.Mail.SMTPPort, configuration.Notify.Mail.SMTPUsername, configuration.Notify.Mail.SMTPPassword)
|
||||||
|
|
||||||
// Send the email config by sendlist .
|
// Send the email config by sendlist .
|
||||||
if err := d.DialAndSend(m); err != nil {
|
if err := d.DialAndSend(m); err != nil {
|
||||||
@ -326,69 +320,6 @@ func SendMailNotify(configuration *Settings, domain, currentIP string) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// SendSlack sends slack if IP is changed
|
|
||||||
func SendSlackNotify(configuration *Settings, domain, currentIP string) error {
|
|
||||||
if !configuration.Notify.Slack.Enabled {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
if configuration.Notify.Slack.BotApiToken == "" {
|
|
||||||
return errors.New("bot api token cannot be empty")
|
|
||||||
}
|
|
||||||
|
|
||||||
if configuration.Notify.Slack.Channel == "" {
|
|
||||||
return errors.New("channel cannot be empty")
|
|
||||||
}
|
|
||||||
client := GetHttpClient(configuration, configuration.Notify.Slack.UseProxy)
|
|
||||||
tpl := configuration.Notify.Slack.MsgTemplate
|
|
||||||
if tpl == "" {
|
|
||||||
tpl = "_Your IP address is changed to_\n\n*{{ .CurrentIP }}*\n\nDomain *{{ .Domain }}* is updated"
|
|
||||||
}
|
|
||||||
|
|
||||||
msg := buildTemplate(currentIP, domain, tpl)
|
|
||||||
|
|
||||||
var response *http.Response
|
|
||||||
var err error
|
|
||||||
|
|
||||||
formData := url.Values{
|
|
||||||
"token": {configuration.Notify.Slack.BotApiToken},
|
|
||||||
"channel": {configuration.Notify.Slack.Channel},
|
|
||||||
"text": {msg},
|
|
||||||
}
|
|
||||||
|
|
||||||
response, err = client.PostForm("https://slack.com/api/chat.postMessage", formData)
|
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
defer response.Body.Close()
|
|
||||||
|
|
||||||
body, _ := ioutil.ReadAll(response.Body)
|
|
||||||
type ResponseParameters struct {
|
|
||||||
MigrateToChatID int64 `json:"migrate_to_chat_id"` // optional
|
|
||||||
RetryAfter int `json:"retry_after"` // optional
|
|
||||||
}
|
|
||||||
type APIResponse struct {
|
|
||||||
Ok bool `json:"ok"`
|
|
||||||
Result json.RawMessage `json:"result"`
|
|
||||||
ErrorCode int `json:"error_code"`
|
|
||||||
Description string `json:"description"`
|
|
||||||
Parameters *ResponseParameters `json:"parameters"`
|
|
||||||
}
|
|
||||||
var resp APIResponse
|
|
||||||
err = json.Unmarshal(body, &resp)
|
|
||||||
if err != nil {
|
|
||||||
fmt.Println("error:", err)
|
|
||||||
return errors.New("failed to parse response")
|
|
||||||
}
|
|
||||||
if !resp.Ok {
|
|
||||||
return errors.New(resp.Description)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// SendNotify sends notify if IP is changed
|
// SendNotify sends notify if IP is changed
|
||||||
func SendNotify(configuration *Settings, domain, currentIP string) error {
|
func SendNotify(configuration *Settings, domain, currentIP string) error {
|
||||||
err := SendTelegramNotify(configuration, domain, currentIP)
|
err := SendTelegramNotify(configuration, domain, currentIP)
|
||||||
@ -399,10 +330,6 @@ func SendNotify(configuration *Settings, domain, currentIP string) error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println("Send email notification with error:", err.Error())
|
log.Println("Send email notification with error:", err.Error())
|
||||||
}
|
}
|
||||||
err = SendSlackNotify(configuration, domain, currentIP)
|
|
||||||
if err != nil {
|
|
||||||
log.Println("Send slack notification with error:", err.Error())
|
|
||||||
}
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -431,7 +358,7 @@ func buildTemplate(currentIP, domain string, tplsrc string) string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// ResolveDNS will query DNS for a given hostname.
|
// ResolveDNS will query DNS for a given hostname.
|
||||||
func ResolveDNS(hostname, resolver, ipType string) (string, error) {
|
func ResolveDNS(hostname, resolver, ipType string) string {
|
||||||
var dnsType uint16
|
var dnsType uint16
|
||||||
if ipType == "" || strings.ToUpper(ipType) == IPV4 {
|
if ipType == "" || strings.ToUpper(ipType) == IPV4 {
|
||||||
dnsType = dns.TypeA
|
dnsType = dns.TypeA
|
||||||
@ -443,20 +370,24 @@ func ResolveDNS(hostname, resolver, ipType string) (string, error) {
|
|||||||
if resolver == "" {
|
if resolver == "" {
|
||||||
dnsAdress, err := net.LookupHost(hostname)
|
dnsAdress, err := net.LookupHost(hostname)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "<nil>", err
|
if strings.HasSuffix(err.Error(), "no such host") {
|
||||||
|
return "<nil>"
|
||||||
|
}
|
||||||
|
log.Fatalf(err.Error())
|
||||||
}
|
}
|
||||||
|
return dnsAdress[0]
|
||||||
return dnsAdress[0], nil
|
|
||||||
}
|
}
|
||||||
res := dnsResolver.New([]string{resolver})
|
res := dns_resolver.New([]string{resolver})
|
||||||
// In case of i/o timeout
|
// In case of i/o timeout
|
||||||
res.RetryTimes = 5
|
res.RetryTimes = 5
|
||||||
|
|
||||||
ip, err := res.LookupHost(hostname, dnsType)
|
ip, err := res.LookupHost(hostname, dnsType)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "<nil>", err
|
if strings.HasSuffix(err.Error(), "NXDOMAIN") {
|
||||||
|
return "<nil>"
|
||||||
|
}
|
||||||
|
log.Fatalf(err.Error())
|
||||||
}
|
}
|
||||||
|
return ip[0].String()
|
||||||
return ip[0].String(), nil
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user