mirror of
https://github.com/cmur2/dyndnsd.git
synced 2025-08-08 08:33:56 +02:00
Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
fad04a8a2e | |||
e96a918a81 | |||
591c0fe89a | |||
ac9bdfb6db |
@@ -1,9 +0,0 @@
|
|||||||
root = true
|
|
||||||
|
|
||||||
[*]
|
|
||||||
indent_style = space
|
|
||||||
indent_size = 2
|
|
||||||
end_of_line = lf
|
|
||||||
charset = utf-8
|
|
||||||
trim_trailing_whitespace = true
|
|
||||||
insert_final_newline = true
|
|
26
.github/workflows/cd.yml
vendored
26
.github/workflows/cd.yml
vendored
@@ -1,26 +0,0 @@
|
|||||||
---
|
|
||||||
name: cd
|
|
||||||
|
|
||||||
on:
|
|
||||||
push:
|
|
||||||
tags:
|
|
||||||
- 'v*.*.*'
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
release-dockerimage:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- uses: actions/checkout@v2
|
|
||||||
- name: Extract dyndnsd version from tag name
|
|
||||||
run: |
|
|
||||||
echo ::set-env name=DYNDNSD_VERSION::${GITHUB_REF#refs/*/v}
|
|
||||||
# https://github.com/marketplace/actions/build-and-push-docker-images
|
|
||||||
- name: Build and push Docker image for dyndnsd ${{ env.DYNDNSD_VERSION }}
|
|
||||||
uses: docker/build-push-action@v1
|
|
||||||
with:
|
|
||||||
username: cmur2
|
|
||||||
password: ${{ secrets.DOCKER_TOKEN }}
|
|
||||||
repository: cmur2/dyndnsd
|
|
||||||
path: docker
|
|
||||||
build_args: DYNDNSD_VERSION=${{ env.DYNDNSD_VERSION }}
|
|
||||||
tag_with_ref: true
|
|
33
.github/workflows/ci.yml
vendored
33
.github/workflows/ci.yml
vendored
@@ -1,33 +0,0 @@
|
|||||||
---
|
|
||||||
name: ci
|
|
||||||
|
|
||||||
on:
|
|
||||||
push:
|
|
||||||
branches: [master]
|
|
||||||
pull_request:
|
|
||||||
branches: [master]
|
|
||||||
workflow_dispatch:
|
|
||||||
schedule:
|
|
||||||
- cron: '35 4 * * 4' # weekly on thursday morning
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
build:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
strategy:
|
|
||||||
matrix:
|
|
||||||
ruby-version:
|
|
||||||
- '2.5'
|
|
||||||
- '2.6'
|
|
||||||
- '2.7'
|
|
||||||
steps:
|
|
||||||
- uses: actions/checkout@v2
|
|
||||||
- name: Set up Ruby ${{ matrix.ruby-version }}
|
|
||||||
uses: ruby/setup-ruby@v1
|
|
||||||
with:
|
|
||||||
ruby-version: ${{ matrix.ruby-version }}
|
|
||||||
- name: Install dependencies
|
|
||||||
run: |
|
|
||||||
bundle
|
|
||||||
- name: Test
|
|
||||||
run: |
|
|
||||||
bundle exec rake ci
|
|
19
.github/workflows/dockerhub.yml
vendored
19
.github/workflows/dockerhub.yml
vendored
@@ -1,19 +0,0 @@
|
|||||||
---
|
|
||||||
name: dockerhub
|
|
||||||
|
|
||||||
on:
|
|
||||||
schedule:
|
|
||||||
- cron: '7 4 * * 4' # weekly on thursday morning
|
|
||||||
workflow_dispatch:
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
pull-released-dockerimages:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Avoid stale tags by pulling
|
|
||||||
run: |
|
|
||||||
ALL_IMAGES="$(curl -s https://hub.docker.com/v2/repositories/cmur2/dyndnsd/tags?page_size=1000 | jq -r '.results[].name | "cmur2/dyndnsd:" + .' | grep -e 'cmur2/dyndnsd:v')"
|
|
||||||
for image in $ALL_IMAGES; do
|
|
||||||
echo "Pulling $image to avoid staleness..."
|
|
||||||
docker pull "$image"
|
|
||||||
done
|
|
46
.github/workflows/vulnscan.yml
vendored
46
.github/workflows/vulnscan.yml
vendored
@@ -1,46 +0,0 @@
|
|||||||
---
|
|
||||||
name: vulnscan
|
|
||||||
|
|
||||||
on:
|
|
||||||
schedule:
|
|
||||||
- cron: '7 4 * * 4' # weekly on thursday morning
|
|
||||||
workflow_dispatch:
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
scan-released-dockerimages:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
env:
|
|
||||||
TRIVY_LIGHT: 'true'
|
|
||||||
TRIVY_IGNORE_UNFIXED: 'true'
|
|
||||||
TRIVY_REMOVED_PKGS: 'true'
|
|
||||||
steps:
|
|
||||||
- name: Install Trivy
|
|
||||||
run: |
|
|
||||||
mkdir -p $GITHUB_WORKSPACE/bin
|
|
||||||
echo "$GITHUB_WORKSPACE/bin" >> "$GITHUB_PATH"
|
|
||||||
curl -sfL https://raw.githubusercontent.com/aquasecurity/trivy/master/contrib/install.sh | sh -s -- -b $GITHUB_WORKSPACE/bin
|
|
||||||
- name: Download Trivy DB
|
|
||||||
run: |
|
|
||||||
trivy image --download-db-only
|
|
||||||
- name: Scan vulnerabilities using Trivy
|
|
||||||
env:
|
|
||||||
TRIVY_SKIP_DIRS: 'usr/lib/ruby/gems/2.7.0/gems/jaeger-client-0.10.0/crossdock,usr/lib/ruby/gems/2.7.0/gems/jaeger-client-1.0.0/crossdock,usr/lib/ruby/gems/2.7.0/gems/jaeger-client-1.1.0/crossdock'
|
|
||||||
run: |
|
|
||||||
trivy --version
|
|
||||||
|
|
||||||
# semver sorting as per https://stackoverflow.com/a/40391207/2148786
|
|
||||||
ALL_IMAGES="$(curl -s https://hub.docker.com/v2/repositories/cmur2/dyndnsd/tags?page_size=1000 | jq -r '.results[].name | "cmur2/dyndnsd:" + .' | grep -e 'cmur2/dyndnsd:v' | sed '/-/!{s/$/_/}' | sort -r -V | sed 's/_$//')"
|
|
||||||
EXIT_CODE=0
|
|
||||||
set -e
|
|
||||||
for major_version in $(seq 1 10); do
|
|
||||||
for image in $ALL_IMAGES; do
|
|
||||||
if [[ "$image" = cmur2/dyndnsd:v$major_version.* ]]; then
|
|
||||||
echo -e "\nScanning newest patch release $image of major v$major_version...\n"
|
|
||||||
if ! trivy image --skip-update --exit-code 1 "$image"; then
|
|
||||||
EXIT_CODE=1
|
|
||||||
fi
|
|
||||||
break
|
|
||||||
fi
|
|
||||||
done
|
|
||||||
done
|
|
||||||
exit "$EXIT_CODE"
|
|
2
.gitignore
vendored
2
.gitignore
vendored
@@ -1,4 +1,6 @@
|
|||||||
.DS_Store
|
.DS_Store
|
||||||
*.lock
|
*.lock
|
||||||
|
doc/*
|
||||||
pkg/*
|
pkg/*
|
||||||
.yardoc
|
.yardoc
|
||||||
|
sorbet/rbi/hidden-definitions/errors.txt
|
||||||
|
15
.rubocop.yml
15
.rubocop.yml
@@ -1,6 +1,8 @@
|
|||||||
AllCops:
|
AllCops:
|
||||||
TargetRubyVersion: '2.5'
|
TargetRubyVersion: '2.3'
|
||||||
NewCops: enable
|
|
||||||
|
Gemspec/OrderedDependencies:
|
||||||
|
Enabled: false
|
||||||
|
|
||||||
Layout/EmptyLineAfterGuardClause:
|
Layout/EmptyLineAfterGuardClause:
|
||||||
Enabled: false
|
Enabled: false
|
||||||
@@ -54,6 +56,9 @@ Style/Documentation:
|
|||||||
Style/FormatStringToken:
|
Style/FormatStringToken:
|
||||||
Enabled: false
|
Enabled: false
|
||||||
|
|
||||||
|
Style/FrozenStringLiteralComment:
|
||||||
|
Enabled: false
|
||||||
|
|
||||||
Style/GuardClause:
|
Style/GuardClause:
|
||||||
Enabled: false
|
Enabled: false
|
||||||
|
|
||||||
@@ -69,9 +74,6 @@ Style/HashTransformValues:
|
|||||||
Style/IdenticalConditionalBranches:
|
Style/IdenticalConditionalBranches:
|
||||||
Enabled: false
|
Enabled: false
|
||||||
|
|
||||||
Style/IfUnlessModifier:
|
|
||||||
Enabled: false
|
|
||||||
|
|
||||||
Style/InverseMethods:
|
Style/InverseMethods:
|
||||||
Enabled: false
|
Enabled: false
|
||||||
|
|
||||||
@@ -83,6 +85,3 @@ Style/RescueModifier:
|
|||||||
|
|
||||||
Style/SymbolArray:
|
Style/SymbolArray:
|
||||||
Enabled: false
|
Enabled: false
|
||||||
|
|
||||||
Style/TrailingCommaInArrayLiteral:
|
|
||||||
Enabled: false
|
|
||||||
|
9
.travis.yml
Normal file
9
.travis.yml
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
---
|
||||||
|
os: linux
|
||||||
|
language: ruby
|
||||||
|
rvm:
|
||||||
|
- 2.7
|
||||||
|
- 2.6
|
||||||
|
- 2.5
|
||||||
|
- 2.4
|
||||||
|
- 2.3
|
58
CHANGELOG.md
58
CHANGELOG.md
@@ -1,63 +1,11 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
## 3.1.2 (December 20, 2020)
|
## 2.1.0
|
||||||
|
|
||||||
OTHER:
|
|
||||||
|
|
||||||
- fixes vulnerabilities in Docker image by using updated Alpine base image
|
|
||||||
- start using Github Actions CI for tests and drop Travis CI
|
|
||||||
|
|
||||||
## 3.1.1 (October 3, 2020)
|
|
||||||
|
|
||||||
IMPROVEMENTS:
|
|
||||||
|
|
||||||
- Use webrick gem which contains fixes against [CVE-2020-25613](https://www.ruby-lang.org/en/news/2020/09/29/http-request-smuggling-cve-2020-25613/)
|
|
||||||
|
|
||||||
## 3.1.0 (August 19, 2020)
|
|
||||||
|
|
||||||
IMPROVEMENTS:
|
|
||||||
|
|
||||||
- Add officially maintained [Docker image for dyndnsd](https://hub.docker.com/r/cmur2/dyndnsd)
|
|
||||||
|
|
||||||
## 3.0.0 (July 29, 2020)
|
|
||||||
|
|
||||||
IMPROVEMENTS:
|
|
||||||
|
|
||||||
- Drop EOL Ruby 2.4 and lower support, now minimum version supported is Ruby 2.5
|
|
||||||
|
|
||||||
## 2.3.1 (July 27, 2020)
|
|
||||||
|
|
||||||
IMPROVEMENTS:
|
|
||||||
|
|
||||||
- Fix annoying error message `log writing failed. can't be called from trap context` on shutdown by not attempting to log redundant information there
|
|
||||||
|
|
||||||
## 2.3.0 (July 20, 2020)
|
|
||||||
|
|
||||||
IMPROVEMENTS:
|
|
||||||
|
|
||||||
- Allow enabling debug logging
|
|
||||||
- Add updater that uses [DNS zone transfers via AXFR (RFC5936)](https://tools.ietf.org/html/rfc5936) to allow any secondary nameserver(s) to fetch the zone contents after (optionally) receiving a [DNS NOTIFY (RFC1996)](https://tools.ietf.org/html/rfc1996) request
|
|
||||||
|
|
||||||
## 2.2.0 (March 6, 2020)
|
|
||||||
|
|
||||||
IMPROVEMENTS:
|
|
||||||
|
|
||||||
- Refactor gemspec based on [recommendations](https://piotrmurach.com/articles/writing-a-ruby-gem-specification/) so tests are now excluded from gem and binaries move to `./exe` directory
|
|
||||||
- Adopt Ruby 2.3 frozen string literals for source code potentially reducing memory consumption
|
|
||||||
|
|
||||||
## 2.1.1 (March 1, 2020)
|
|
||||||
|
|
||||||
IMPROVEMENTS:
|
|
||||||
|
|
||||||
- Fix potential `nil` cases detected by [Sorbet](https://sorbet.org) including refactorings
|
|
||||||
|
|
||||||
## 2.1.0 (March 1, 2020)
|
|
||||||
|
|
||||||
IMPROVEMENTS:
|
IMPROVEMENTS:
|
||||||
|
|
||||||
- Add Ruby 2.7 support
|
- Add Ruby 2.7 support
|
||||||
- Add [solargraph](https://github.com/castwide/solargraph) to dev tooling as Ruby Language Server usable e.g. for IDEs (used solargraph version not compatible with Ruby 2.7 as bundler-audit 0.6.x requires old `thor` gem)
|
- Add experimental [Sorbet](https://sorbet.org) support to development tools, fix surfaced problems
|
||||||
- Document code using YARD tags, e.g. for type information and better code completion
|
|
||||||
|
|
||||||
## 2.0.0 (January 25, 2019)
|
## 2.0.0 (January 25, 2019)
|
||||||
|
|
||||||
@@ -68,7 +16,7 @@ IMPROVEMENTS:
|
|||||||
- Better code maintainability by refactorings
|
- Better code maintainability by refactorings
|
||||||
- Update dependencies, mainly `rack` to new major version 2
|
- Update dependencies, mainly `rack` to new major version 2
|
||||||
- Add Ruby 2.5 and Ruby 2.6 support
|
- Add Ruby 2.5 and Ruby 2.6 support
|
||||||
- Add experimental [OpenTracing](https://opentracing.io/) support with [CNCF Jaeger](https://github.com/jaegertracing/jaeger)
|
- Add experimental [OpenTracing](http://opentracing.io/) support with [CNCF Jaeger](https://github.com/jaegertracing/jaeger)
|
||||||
- Support host offlining by deleting the associated DNS records
|
- Support host offlining by deleting the associated DNS records
|
||||||
- Add textfile reporter to write Graphite-style metrics (also compatible with [Prometheus](https://prometheus.io/)) into a file
|
- Add textfile reporter to write Graphite-style metrics (also compatible with [Prometheus](https://prometheus.io/)) into a file
|
||||||
|
|
||||||
|
4
Gemfile
4
Gemfile
@@ -1,7 +1,3 @@
|
|||||||
# frozen_string_literal: true
|
|
||||||
|
|
||||||
source 'https://rubygems.org'
|
source 'https://rubygems.org'
|
||||||
|
|
||||||
gemspec
|
gemspec
|
||||||
|
|
||||||
gem 'solargraph', git: 'https://github.com/zaratan/solargraph.git', branch: 'fix_rubocop_1_0'
|
|
||||||
|
137
README.md
137
README.md
@@ -1,23 +1,19 @@
|
|||||||
# dyndnsd.rb
|
# dyndnsd.rb
|
||||||
|
|
||||||
 [](https://depfu.com/github/cmur2/dyndnsd)
|
[](https://travis-ci.org/cmur2/dyndnsd) [](https://depfu.com/github/cmur2/dyndnsd)
|
||||||
|
|
||||||
A small, lightweight and extensible DynDNS server written with Ruby and Rack.
|
A small, lightweight and extensible DynDNS server written with Ruby and Rack.
|
||||||
|
|
||||||
|
|
||||||
## Description
|
## Description
|
||||||
|
|
||||||
dyndnsd.rb aims to implement a small [DynDNS-compliant](https://help.dyn.com/remote-access-api/) server in Ruby supporting IPv4 and IPv6 addresses. It has an integrated user and hostname database in its configuration file that is used for authentication and authorization. Besides talking the DynDNS protocol it is able to invoke a so-called *updater*, a small Ruby module that takes care of supplying the current hostname => ip mapping to a DNS server.
|
dyndnsd.rb aims to implement a small [DynDNS-compliant](https://help.dyn.com/remote-access-api/) server in Ruby supporting IPv4 and IPv6 addresses. It has an integrated user and hostname database in it's configuration file that is used for authentication and authorization. Besides talking the DynDNS protocol it is able to invoke a so-called *updater*, a small Ruby module that takes care of supplying the current hostname => ip mapping to a DNS server.
|
||||||
|
|
||||||
There are currently two updaters shipped with dyndnsd.rb:
|
There is currently one updater shipped with dyndnsd.rb `command_with_bind_zone` that writes out a zone file in BIND syntax onto the current system and invokes a user-supplied command afterwards that is assumed to trigger the DNS server (not necessarily BIND since it's zone files are read by other DNS servers, too) to reload it's zone configuration.
|
||||||
- `zone_transfer_server` that uses [DNS zone transfers via AXFR (RFC5936)](https://tools.ietf.org/html/rfc5936) to allow any secondary nameserver(s) to fetch the zone contents after (optionally) receiving a [DNS NOTIFY (RFC1996)](https://tools.ietf.org/html/rfc1996) request
|
|
||||||
- `command_with_bind_zone` that writes out a zone file in BIND syntax onto the current system and invokes a user-supplied command afterwards that is assumed to trigger the DNS server (not necessarily BIND since its zone files are read by other DNS servers, too) to reload its zone configuration
|
|
||||||
|
|
||||||
Because of the mechanisms used, dyndnsd.rb is known to work only on \*nix systems.
|
Because of the mechanisms used, dyndnsd.rb is known to work only on \*nix systems.
|
||||||
|
|
||||||
See the [changelog](CHANGELOG.md) before upgrading. The older version 1.x of dyndnsd.rb is still available on [branch dyndnsd-1.x](https://github.com/cmur2/dyndnsd/tree/dyndnsd-1.x).
|
See the [changelog](CHANGELOG.md) before upgrading. The older version 1.x of dyndnsd.rb is still available on [branch dyndnsd-1.x](https://github.com/cmur2/dyndnsd/tree/dyndnsd-1.x).
|
||||||
|
|
||||||
|
|
||||||
## General Usage
|
## General Usage
|
||||||
|
|
||||||
Install the gem:
|
Install the gem:
|
||||||
@@ -29,16 +25,14 @@ Create a configuration file in YAML format somewhere:
|
|||||||
```yaml
|
```yaml
|
||||||
# listen address and port
|
# listen address and port
|
||||||
host: "0.0.0.0"
|
host: "0.0.0.0"
|
||||||
port: 80
|
port: "80"
|
||||||
# optional: drop privileges in case you want to but you may need sudo for external commands
|
# optional: drop priviliges in case you want to but you may need sudo for external commands
|
||||||
user: "nobody"
|
user: "nobody"
|
||||||
group: "nogroup"
|
group: "nogroup"
|
||||||
# logfile is optional, logs to STDOUT otherwise
|
# logfile is optional, logs to STDOUT else
|
||||||
logfile: "dyndnsd.log"
|
logfile: "dyndnsd.log"
|
||||||
# internal database file
|
# interal database file
|
||||||
db: "db.json"
|
db: "db.json"
|
||||||
# enable debug mode?
|
|
||||||
debug: false
|
|
||||||
# all hostnames are required to be cool-name.example.org
|
# all hostnames are required to be cool-name.example.org
|
||||||
domain: "example.org"
|
domain: "example.org"
|
||||||
# configure the updater, here we use command_with_bind_zone, params are updater-specific
|
# configure the updater, here we use command_with_bind_zone, params are updater-specific
|
||||||
@@ -64,98 +58,17 @@ users:
|
|||||||
|
|
||||||
Run dyndnsd.rb by:
|
Run dyndnsd.rb by:
|
||||||
|
|
||||||
```bash
|
dyndnsd /path/to/config.yaml
|
||||||
dyndnsd /path/to/config.yml
|
|
||||||
```
|
|
||||||
|
|
||||||
|
## Using dyndnsd.rb with [NSD](https://www.nlnetlabs.nl/nsd/)
|
||||||
|
|
||||||
### Docker image
|
NSD is a nice opensource, authoritative-only, low-memory DNS server that reads BIND-style zone files (and converts them into it's own database) and has a simple config file.
|
||||||
|
|
||||||
There is an officially maintained [Docker image for dyndnsd](https://hub.docker.com/r/cmur2/dyndnsd) available at Dockerhub. The goal is to have a minimal secured image available (currently based on Alpine) that works well for the `zone_transfer_server` updater use case.
|
A feature NSD is lacking is the [Dynamic DNS update](https://tools.ietf.org/html/rfc2136) functionality BIND offers but one can fake it using the following dyndnsd.rb config:
|
||||||
|
|
||||||
Users can make extensions by deriving from the official Docker image or building their own.
|
|
||||||
|
|
||||||
The Docker image consumes the same configuration file in YAML format as the gem, inside the container it needs to be mounted/available as `/etc/dyndnsd/config.yml`. the following YAML should be used as a base and extended with user's settings:
|
|
||||||
|
|
||||||
```yaml
|
```yaml
|
||||||
host: "0.0.0.0"
|
host: "0.0.0.0"
|
||||||
port: 8080
|
port: "8245" # the DynDNS.com alternative HTTP port
|
||||||
# omit the logfile: option so logging to STDOUT will happen automatically
|
|
||||||
db: "/var/lib/dyndnsd/db.json"
|
|
||||||
|
|
||||||
# User's settings for updater and permissions follow here!
|
|
||||||
```
|
|
||||||
|
|
||||||
more ports might be needed depending on if DNS zone transfer is needed
|
|
||||||
|
|
||||||
Run the Docker image exposing the DynDNS-API on host port 8080 via:
|
|
||||||
|
|
||||||
```bash
|
|
||||||
docker run -d --name dyndnsd \
|
|
||||||
-p 8080:8080 \
|
|
||||||
-v /host/path/to/dyndnsd/config.yml:/etc/dyndnsd/config.yml \
|
|
||||||
-v /host/ptherpath/to/dyndnsd/datadir:/var/lib/dyndnsd \
|
|
||||||
cmur2/dyndnsd:vX.Y.Z
|
|
||||||
```
|
|
||||||
|
|
||||||
*Note*: You may need to expose more then just port 8080 e.g. if you use the `zone_transfer_server` which can be done by appending additional `-p 5353:5353` flags to the `docker run` command.
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
## Using dyndnsd.rb with any nameserver via DNS zone transfers (AXFR)
|
|
||||||
|
|
||||||
By using [DNS zone transfers via AXFR (RFC5936)](https://tools.ietf.org/html/rfc5936) any secondary nameserver can retrieve the DNS zone contents from dyndnsd.rb and serve them to clients.
|
|
||||||
To speedup propagation after changes dyndnsd.rb can issue a [DNS NOTIFY (RFC1996)](https://tools.ietf.org/html/rfc1996) to inform the nameserver that the DNS zone contents changed and should be fetched even before the time indicated in the SOA record is up.
|
|
||||||
Currently dyndnsd.rb does not support any authentication for incoming DNS zone transfer requests so it should be isolated from the internet on these ports.
|
|
||||||
|
|
||||||
This approach has several advantages:
|
|
||||||
- dyndnsd.rb can be used in *hidden primary* fashion isolated from client's DNS traffic and does not need to implement full nameserver features
|
|
||||||
- any existing, production-grade, caching, geo-replicated nameserver setup can be used to pull DNS zone contents from the *hidden primary* dyndnsd.rb and serve it to clients
|
|
||||||
- any nameserver(s) and dyndnsd.rb do not need to be located on the same host
|
|
||||||
|
|
||||||
Example dyndnsd.rb configuration:
|
|
||||||
|
|
||||||
```yaml
|
|
||||||
host: "0.0.0.0"
|
|
||||||
port: 8245 # the DynDNS.com alternative HTTP port
|
|
||||||
db: "/opt/dyndnsd/db.json"
|
|
||||||
domain: "dyn.example.org"
|
|
||||||
updater:
|
|
||||||
name: "zone_transfer_server"
|
|
||||||
params:
|
|
||||||
# endpoint(s) to listen for incoming zone transfer (AXFR) requests, default 0.0.0.0@53
|
|
||||||
server_listens:
|
|
||||||
- 127.0.0.1@5300
|
|
||||||
# where to send DNS NOTIFY request(s) to on zone content change
|
|
||||||
send_notifies:
|
|
||||||
- '127.0.0.1'
|
|
||||||
# TTL for all records in the zone (in seconds)
|
|
||||||
zone_ttl: 300 # 5m
|
|
||||||
# zone's NS record(s) (at least one)
|
|
||||||
zone_nameservers:
|
|
||||||
- "dns.example.org."
|
|
||||||
# info for zone's SOA record
|
|
||||||
zone_email_address: "admin.example.org."
|
|
||||||
# zone's additional A/AAAA records
|
|
||||||
zone_additional_ips:
|
|
||||||
- "127.0.0.1"
|
|
||||||
users:
|
|
||||||
foo:
|
|
||||||
password: "secret"
|
|
||||||
hosts:
|
|
||||||
- foo.example.org
|
|
||||||
```
|
|
||||||
|
|
||||||
|
|
||||||
## Using dyndnsd.rb with [NSD](https://www.nlnetlabs.nl/projects/nsd/about/)
|
|
||||||
|
|
||||||
NSD is a nice, open source, authoritative-only, low-memory DNS server that reads BIND-style zone files (and converts them into its own database) and has a simple configuration file.
|
|
||||||
|
|
||||||
A feature NSD is lacking is the [Dynamic DNS update (RFC2136)](https://tools.ietf.org/html/rfc2136) functionality BIND offers but one can fake it using the following dyndnsd.rb configuration:
|
|
||||||
|
|
||||||
```yaml
|
|
||||||
host: "0.0.0.0"
|
|
||||||
port: 8245 # the DynDNS.com alternative HTTP port
|
|
||||||
db: "/opt/dyndnsd/db.json"
|
db: "/opt/dyndnsd/db.json"
|
||||||
domain: "dyn.example.org"
|
domain: "dyn.example.org"
|
||||||
updater:
|
updater:
|
||||||
@@ -180,15 +93,12 @@ users:
|
|||||||
|
|
||||||
Start dyndnsd.rb before NSD to make sure the zone file exists else NSD complains.
|
Start dyndnsd.rb before NSD to make sure the zone file exists else NSD complains.
|
||||||
|
|
||||||
|
|
||||||
## Using dyndnsd.rb with X
|
## Using dyndnsd.rb with X
|
||||||
|
|
||||||
Please provide ideas if you are using dyndnsd.rb with other DNS servers :)
|
Please provide ideas if you are using dyndnsd.rb with other DNS servers :)
|
||||||
|
|
||||||
|
|
||||||
## Advanced topics
|
## Advanced topics
|
||||||
|
|
||||||
|
|
||||||
### Update URL
|
### Update URL
|
||||||
|
|
||||||
The update URL you want to tell your clients (humans or scripts ^^) consists of the following
|
The update URL you want to tell your clients (humans or scripts ^^) consists of the following
|
||||||
@@ -201,11 +111,10 @@ where:
|
|||||||
* USER and PASSWORD are needed for HTTP Basic Auth and valid combinations are defined in your config.yaml
|
* USER and PASSWORD are needed for HTTP Basic Auth and valid combinations are defined in your config.yaml
|
||||||
* DOMAIN should match what you defined in your config.yaml as domain but may be anything else when using a webserver as proxy
|
* DOMAIN should match what you defined in your config.yaml as domain but may be anything else when using a webserver as proxy
|
||||||
* PORT depends on your (webserver/proxy) settings
|
* PORT depends on your (webserver/proxy) settings
|
||||||
* HOSTNAMES is a required list of comma-separated FQDNs (they all have to end with your config.yaml domain) the user wants to update
|
* HOSTNAMES is a required list of comma separated FQDNs (they all have to end with your config.yaml domain) the user wants to update
|
||||||
* MYIP is optional and the HTTP client's IP address will be used if missing
|
* MYIP is optional and the HTTP client's IP address will be used if missing
|
||||||
* MYIP6 is optional but if present also requires presence of MYIP
|
* MYIP6 is optional but if present also requires presence of MYIP
|
||||||
|
|
||||||
|
|
||||||
### IP address determination
|
### IP address determination
|
||||||
|
|
||||||
The following rules apply:
|
The following rules apply:
|
||||||
@@ -214,20 +123,15 @@ The following rules apply:
|
|||||||
* use any IP address provided via the X-Real-IP header e.g. when used behind HTTP reverse proxy such as nginx, or
|
* use any IP address provided via the X-Real-IP header e.g. when used behind HTTP reverse proxy such as nginx, or
|
||||||
* use any IP address used by the connecting HTTP client
|
* use any IP address used by the connecting HTTP client
|
||||||
|
|
||||||
If you want to provide an additional IPv6 address as myip6 parameter, the myip parameter containing an IPv4 address has to be present, too! No automatism is applied then.
|
If you want to provide an additional IPv6 address as myip6 parameter the myip parameter containing an IPv4 address has to be present, too! No automatism is applied then.
|
||||||
|
|
||||||
|
|
||||||
### SSL, multiple listen ports
|
### SSL, multiple listen ports
|
||||||
|
|
||||||
Use a webserver as a proxy to handle SSL and/or multiple listen addresses and ports. DynDNS.com provides HTTP on port 80 and 8245 and HTTPS on port 443.
|
Use a webserver as a proxy to handle SSL and/or multiple listen addresses and ports. DynDNS.com provides HTTP on port 80 and 8245 and HTTPS on port 443.
|
||||||
|
|
||||||
|
### Init scripts
|
||||||
|
|
||||||
### Startup
|
The [Debian 6 init.d script](init.d/debian-6-dyndnsd) assumes that dyndnsd.rb is installed into the system ruby (no RVM support) and the config.yaml is at /opt/dyndnsd/config.yaml. Modify to your needs.
|
||||||
|
|
||||||
There is a [Dockerfile](docs/Dockerfile) that can be used to build a Docker image for running dyndnsd.rb.
|
|
||||||
|
|
||||||
The [Debian 6 init.d script](docs/debian-6-init-dyndnsd) assumes that dyndnsd.rb is installed into the system ruby (no RVM support) and the config.yaml is at /opt/dyndnsd/config.yaml. Modify to your needs.
|
|
||||||
|
|
||||||
|
|
||||||
### Monitoring
|
### Monitoring
|
||||||
|
|
||||||
@@ -235,7 +139,7 @@ For monitoring dyndnsd.rb uses the [metriks](https://github.com/eric/metriks) fr
|
|||||||
|
|
||||||
```yaml
|
```yaml
|
||||||
host: "0.0.0.0"
|
host: "0.0.0.0"
|
||||||
port: 8245 # the DynDNS.com alternative HTTP port
|
port: "8245" # the DynDNS.com alternative HTTP port
|
||||||
db: "/opt/dyndnsd/db.json"
|
db: "/opt/dyndnsd/db.json"
|
||||||
domain: "dyn.example.org"
|
domain: "dyn.example.org"
|
||||||
# configure the Graphite backend to be used instead of proctitle
|
# configure the Graphite backend to be used instead of proctitle
|
||||||
@@ -268,16 +172,14 @@ users:
|
|||||||
password: "ihavenohosts"
|
password: "ihavenohosts"
|
||||||
```
|
```
|
||||||
|
|
||||||
|
|
||||||
### Tracing (experimental)
|
### Tracing (experimental)
|
||||||
|
|
||||||
For tracing, dyndnsd.rb is instrumented using the [OpenTracing](http://opentracing.io/) framework and will emit span tracing data for the most important operations happening during the request/response cycle. Using a middleware for Rack allows handling incoming OpenTracing span information properly.
|
For tracing dyndnsd.rb is instrumented using the [OpenTracing](http://opentracing.io/) framework and will emit span tracing data for the most important operations happening during the request/response cycle. Using a middleware for Rack allows handling incoming OpenTracing span information properly.
|
||||||
|
|
||||||
Currently only one OpenTracing-compatible tracer implementation named [CNCF Jaeger](https://github.com/jaegertracing/jaeger) can be configured to use with dyndnsd.rb.
|
Currently only one OpenTracing-compatible tracer implementation named [CNCF Jaeger](https://github.com/jaegertracing/jaeger) can be configured to use with dyndnsd.rb.
|
||||||
|
|
||||||
```yaml
|
```yaml
|
||||||
host: "0.0.0.0"
|
host: "0.0.0.0"
|
||||||
port: 8245 # the DynDNS.com alternative HTTP port
|
port: "8245" # the DynDNS.com alternative HTTP port
|
||||||
db: "/opt/dyndnsd/db.json"
|
db: "/opt/dyndnsd/db.json"
|
||||||
domain: "dyn.example.org"
|
domain: "dyn.example.org"
|
||||||
# enable and configure tracing using the (currently only) tracer jaeger
|
# enable and configure tracing using the (currently only) tracer jaeger
|
||||||
@@ -308,7 +210,6 @@ users:
|
|||||||
password: "ihavenohosts"
|
password: "ihavenohosts"
|
||||||
```
|
```
|
||||||
|
|
||||||
|
|
||||||
## License
|
## License
|
||||||
|
|
||||||
dyndnsd.rb is licensed under the Apache License, Version 2.0. See LICENSE for more information.
|
dyndnsd.rb is licensed under the Apache License, Version 2.0. See LICENSE for more information.
|
||||||
|
19
Rakefile
19
Rakefile
@@ -1,5 +1,3 @@
|
|||||||
# frozen_string_literal: true
|
|
||||||
|
|
||||||
require 'bundler/gem_tasks'
|
require 'bundler/gem_tasks'
|
||||||
require 'rspec/core/rake_task'
|
require 'rspec/core/rake_task'
|
||||||
require 'rubocop/rake_task'
|
require 'rubocop/rake_task'
|
||||||
@@ -9,23 +7,12 @@ RSpec::Core::RakeTask.new(:spec)
|
|||||||
RuboCop::RakeTask.new
|
RuboCop::RakeTask.new
|
||||||
Bundler::Audit::Task.new
|
Bundler::Audit::Task.new
|
||||||
|
|
||||||
desc 'Run experimental solargraph type checker'
|
|
||||||
task :solargraph do
|
task :solargraph do
|
||||||
sh 'solargraph typecheck'
|
sh 'solargraph typecheck'
|
||||||
end
|
end
|
||||||
|
|
||||||
namespace :solargraph do
|
task :sorbet do
|
||||||
desc 'Should be run by developer once to prepare initial solargraph usage (fill caches etc.)'
|
sh 'srb typecheck'
|
||||||
task :init do
|
|
||||||
sh 'solargraph download-core'
|
|
||||||
end
|
|
||||||
end
|
end
|
||||||
|
|
||||||
desc 'Run hadolint for Dockerfile linting'
|
task default: [:rubocop, :sorbet, :spec, 'bundle:audit']
|
||||||
task :hadolint do
|
|
||||||
sh 'docker run --rm -i hadolint/hadolint:v1.18.0 hadolint --ignore DL3018 - < docker/Dockerfile'
|
|
||||||
end
|
|
||||||
|
|
||||||
task default: [:rubocop, :spec, 'bundle:audit', :solargraph]
|
|
||||||
|
|
||||||
task ci: ['solargraph:init', :default, :hadolint]
|
|
||||||
|
4
bin/dyndnsd
Executable file
4
bin/dyndnsd
Executable file
@@ -0,0 +1,4 @@
|
|||||||
|
|
||||||
|
require 'dyndnsd'
|
||||||
|
|
||||||
|
Dyndnsd::Daemon.run!
|
@@ -1,15 +0,0 @@
|
|||||||
FROM alpine:3.12
|
|
||||||
|
|
||||||
EXPOSE 5353 8080
|
|
||||||
|
|
||||||
ARG DYNDNSD_VERSION=3.0.0
|
|
||||||
|
|
||||||
RUN apk --no-cache add openssl ca-certificates && \
|
|
||||||
apk --no-cache add ruby ruby-etc ruby-io-console ruby-json ruby-webrick && \
|
|
||||||
apk --no-cache add --virtual .build-deps ruby-dev build-base tzdata && \
|
|
||||||
gem install --no-document dyndnsd -v ${DYNDNSD_VERSION} && \
|
|
||||||
# set timezone to Berlin
|
|
||||||
cp /usr/share/zoneinfo/Europe/Berlin /etc/localtime && \
|
|
||||||
apk del .build-deps
|
|
||||||
|
|
||||||
ENTRYPOINT ["dyndnsd", "/etc/dyndnsd/config.yml"]
|
|
@@ -1,6 +1,7 @@
|
|||||||
# frozen_string_literal: true
|
|
||||||
|
|
||||||
require_relative 'lib/dyndnsd/version'
|
$LOAD_PATH.push File.expand_path('lib', __dir__)
|
||||||
|
|
||||||
|
require 'dyndnsd/version'
|
||||||
|
|
||||||
Gem::Specification.new do |s|
|
Gem::Specification.new do |s|
|
||||||
s.name = 'dyndnsd'
|
s.name = 'dyndnsd'
|
||||||
@@ -8,38 +9,32 @@ Gem::Specification.new do |s|
|
|||||||
s.summary = 'dyndnsd.rb'
|
s.summary = 'dyndnsd.rb'
|
||||||
s.description = 'A small, lightweight and extensible DynDNS server written with Ruby and Rack.'
|
s.description = 'A small, lightweight and extensible DynDNS server written with Ruby and Rack.'
|
||||||
s.author = 'Christian Nicolai'
|
s.author = 'Christian Nicolai'
|
||||||
|
s.email = 'chrnicolai@gmail.com'
|
||||||
s.homepage = 'https://github.com/cmur2/dyndnsd'
|
s.homepage = 'https://github.com/cmur2/dyndnsd'
|
||||||
s.license = 'Apache-2.0'
|
s.license = 'Apache-2.0'
|
||||||
s.metadata = {
|
|
||||||
'bug_tracker_uri' => "#{s.homepage}/issues",
|
|
||||||
'changelog_uri' => "#{s.homepage}/blob/master/CHANGELOG.md",
|
|
||||||
'source_code_uri' => s.homepage
|
|
||||||
}
|
|
||||||
|
|
||||||
s.files = `git ls-files -z`.split("\x0").select do |f|
|
s.files = `git ls-files`.split($INPUT_RECORD_SEPARATOR)
|
||||||
f.match(%r{^(init.d|lib)/})
|
s.test_files = s.files.grep(%r{^(test|spec|features)/})
|
||||||
end
|
|
||||||
s.require_paths = ['lib']
|
s.require_paths = ['lib']
|
||||||
s.bindir = 'exe'
|
|
||||||
s.executables = ['dyndnsd']
|
s.executables = ['dyndnsd']
|
||||||
s.extra_rdoc_files = Dir['README.md', 'CHANGELOG.md', 'LICENSE']
|
|
||||||
|
|
||||||
s.required_ruby_version = '>= 2.5'
|
s.required_ruby_version = '>= 2.3'
|
||||||
|
|
||||||
s.add_runtime_dependency 'async-dns', '~> 1.2.0'
|
s.add_runtime_dependency 'rack', '~> 2.0'
|
||||||
s.add_runtime_dependency 'jaeger-client', '~> 1.1.0'
|
s.add_runtime_dependency 'json'
|
||||||
s.add_runtime_dependency 'metriks'
|
s.add_runtime_dependency 'metriks'
|
||||||
s.add_runtime_dependency 'opentracing', '~> 0.5.0'
|
s.add_runtime_dependency 'opentracing', '~> 0.5.0'
|
||||||
s.add_runtime_dependency 'rack', '~> 2.0'
|
|
||||||
s.add_runtime_dependency 'rack-tracer', '~> 0.9.0'
|
s.add_runtime_dependency 'rack-tracer', '~> 0.9.0'
|
||||||
s.add_runtime_dependency 'webrick', '>= 1.6.1'
|
s.add_runtime_dependency 'jaeger-client', '~> 0.10.0'
|
||||||
|
s.add_runtime_dependency 'sorbet-runtime', '~> 0.5.0'
|
||||||
|
|
||||||
s.add_development_dependency 'bundler'
|
s.add_development_dependency 'bundler'
|
||||||
s.add_development_dependency 'bundler-audit', '~> 0.7.0'
|
|
||||||
s.add_development_dependency 'rack-test'
|
|
||||||
s.add_development_dependency 'rake'
|
s.add_development_dependency 'rake'
|
||||||
s.add_development_dependency 'rspec'
|
s.add_development_dependency 'rspec'
|
||||||
s.add_development_dependency 'rubocop', '~> 1.6.1'
|
s.add_development_dependency 'rack-test'
|
||||||
# s.add_development_dependency 'solargraph', '~> 0.39.0'
|
s.add_development_dependency 'rubocop', '~> 0.80.0'
|
||||||
|
s.add_development_dependency 'bundler-audit', '~> 0.6.0'
|
||||||
|
s.add_development_dependency 'solargraph'
|
||||||
|
s.add_development_dependency 'sorbet', '~> 0.5.0'
|
||||||
|
s.add_development_dependency 'sord'
|
||||||
end
|
end
|
||||||
|
@@ -1,6 +0,0 @@
|
|||||||
#!/usr/bin/env ruby
|
|
||||||
# frozen_string_literal: true
|
|
||||||
|
|
||||||
require 'dyndnsd'
|
|
||||||
|
|
||||||
Dyndnsd::Daemon.run!
|
|
0
docs/debian-6-init-dyndnsd → init.d/debian-6-dyndnsd
Executable file → Normal file
0
docs/debian-6-init-dyndnsd → init.d/debian-6-dyndnsd
Executable file → Normal file
33
lib/dyndnsd.rb
Normal file → Executable file
33
lib/dyndnsd.rb
Normal file → Executable file
@@ -1,6 +1,6 @@
|
|||||||
# frozen_string_literal: true
|
#!/usr/bin/env ruby
|
||||||
|
# typed: true
|
||||||
|
|
||||||
require 'date'
|
|
||||||
require 'etc'
|
require 'etc'
|
||||||
require 'logger'
|
require 'logger'
|
||||||
require 'ipaddr'
|
require 'ipaddr'
|
||||||
@@ -14,7 +14,6 @@ require 'rack/tracer'
|
|||||||
|
|
||||||
require 'dyndnsd/generator/bind'
|
require 'dyndnsd/generator/bind'
|
||||||
require 'dyndnsd/updater/command_with_bind_zone'
|
require 'dyndnsd/updater/command_with_bind_zone'
|
||||||
require 'dyndnsd/updater/zone_transfer_server'
|
|
||||||
require 'dyndnsd/responder/dyndns_style'
|
require 'dyndnsd/responder/dyndns_style'
|
||||||
require 'dyndnsd/responder/rest_style'
|
require 'dyndnsd/responder/rest_style'
|
||||||
require 'dyndnsd/database'
|
require 'dyndnsd/database'
|
||||||
@@ -58,9 +57,9 @@ module Dyndnsd
|
|||||||
@db.load
|
@db.load
|
||||||
@db['serial'] ||= 1
|
@db['serial'] ||= 1
|
||||||
@db['hosts'] ||= {}
|
@db['hosts'] ||= {}
|
||||||
@updater.update(@db)
|
|
||||||
if @db.changed?
|
if @db.changed?
|
||||||
@db.save
|
@db.save
|
||||||
|
@updater.update(@db)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
@@ -81,7 +80,7 @@ module Dyndnsd
|
|||||||
end
|
end
|
||||||
|
|
||||||
# @param env [Hash{String => String}]
|
# @param env [Hash{String => String}]
|
||||||
# @return [Array{Integer,Hash{String => String},Array<String>}]
|
# @return [Array{Integer,Hash{String => String},Array{String}}]
|
||||||
def call(env)
|
def call(env)
|
||||||
return [422, {'X-DynDNS-Response' => 'method_forbidden'}, []] if env['REQUEST_METHOD'] != 'GET'
|
return [422, {'X-DynDNS-Response' => 'method_forbidden'}, []] if env['REQUEST_METHOD'] != 'GET'
|
||||||
return [422, {'X-DynDNS-Response' => 'not_found'}, []] if env['PATH_INFO'] != '/nic/update'
|
return [422, {'X-DynDNS-Response' => 'not_found'}, []] if env['PATH_INFO'] != '/nic/update'
|
||||||
@@ -135,7 +134,7 @@ module Dyndnsd
|
|||||||
private
|
private
|
||||||
|
|
||||||
# @param params [Hash{String => String}]
|
# @param params [Hash{String => String}]
|
||||||
# @return [Array<String>]
|
# @return [Array{String}]
|
||||||
def extract_v4_and_v6_address(params)
|
def extract_v4_and_v6_address(params)
|
||||||
return [] if !(params['myip'])
|
return [] if !(params['myip'])
|
||||||
begin
|
begin
|
||||||
@@ -149,7 +148,7 @@ module Dyndnsd
|
|||||||
|
|
||||||
# @param env [Hash{String => String}]
|
# @param env [Hash{String => String}]
|
||||||
# @param params [Hash{String => String}]
|
# @param params [Hash{String => String}]
|
||||||
# @return [Array<String>]
|
# @return [Array{String}]
|
||||||
def extract_myips(env, params)
|
def extract_myips(env, params)
|
||||||
# require presence of myip parameter as valid IPAddr (v4) and valid myip6
|
# require presence of myip parameter as valid IPAddr (v4) and valid myip6
|
||||||
return extract_v4_and_v6_address(params) if params.key?('myip6')
|
return extract_v4_and_v6_address(params) if params.key?('myip6')
|
||||||
@@ -165,8 +164,8 @@ module Dyndnsd
|
|||||||
end
|
end
|
||||||
|
|
||||||
# @param hostnames [String]
|
# @param hostnames [String]
|
||||||
# @param myips [Array<String>]
|
# @param myips [Array{String}]
|
||||||
# @return [Array<Symbol>]
|
# @return [Array{Symbol}]
|
||||||
def process_changes(hostnames, myips)
|
def process_changes(hostnames, myips)
|
||||||
changes = []
|
changes = []
|
||||||
Helper.span('process_changes') do |span|
|
Helper.span('process_changes') do |span|
|
||||||
@@ -195,13 +194,13 @@ module Dyndnsd
|
|||||||
def update_db
|
def update_db
|
||||||
@db['serial'] += 1
|
@db['serial'] += 1
|
||||||
Dyndnsd.logger.info "Committing update ##{@db['serial']}"
|
Dyndnsd.logger.info "Committing update ##{@db['serial']}"
|
||||||
@updater.update(@db)
|
|
||||||
@db.save
|
@db.save
|
||||||
|
@updater.update(@db)
|
||||||
Metriks.meter('updates.committed').mark
|
Metriks.meter('updates.committed').mark
|
||||||
end
|
end
|
||||||
|
|
||||||
# @param env [Hash{String => String}]
|
# @param env [Hash{String => String}]
|
||||||
# @return [Array{Integer,Hash{String => String},Array<String>}]
|
# @return [Array{Integer,Hash{String => String},Array{String}}]
|
||||||
def handle_dyndns_request(env)
|
def handle_dyndns_request(env)
|
||||||
params = Rack::Utils.parse_query(env['QUERY_STRING'])
|
params = Rack::Utils.parse_query(env['QUERY_STRING'])
|
||||||
|
|
||||||
@@ -246,20 +245,21 @@ module Dyndnsd
|
|||||||
if config['logfile']
|
if config['logfile']
|
||||||
Dyndnsd.logger = Logger.new(config['logfile'])
|
Dyndnsd.logger = Logger.new(config['logfile'])
|
||||||
else
|
else
|
||||||
Dyndnsd.logger = Logger.new($stdout)
|
Dyndnsd.logger = Logger.new(STDOUT)
|
||||||
end
|
end
|
||||||
|
|
||||||
Dyndnsd.logger.progname = 'dyndnsd'
|
Dyndnsd.logger.progname = 'dyndnsd'
|
||||||
Dyndnsd.logger.formatter = LogFormatter.new
|
Dyndnsd.logger.formatter = LogFormatter.new
|
||||||
Dyndnsd.logger.level = config['debug'] ? Logger::DEBUG : Logger::INFO
|
|
||||||
end
|
end
|
||||||
|
|
||||||
# @return [void]
|
# @return [void]
|
||||||
private_class_method def self.setup_traps
|
private_class_method def self.setup_traps
|
||||||
Signal.trap('INT') do
|
Signal.trap('INT') do
|
||||||
|
Dyndnsd.logger.info 'Quitting...'
|
||||||
Rack::Handler::WEBrick.shutdown
|
Rack::Handler::WEBrick.shutdown
|
||||||
end
|
end
|
||||||
Signal.trap('TERM') do
|
Signal.trap('TERM') do
|
||||||
|
Dyndnsd.logger.info 'Quitting...'
|
||||||
Rack::Handler::WEBrick.shutdown
|
Rack::Handler::WEBrick.shutdown
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
@@ -314,12 +314,7 @@ module Dyndnsd
|
|||||||
private_class_method def self.setup_rack(config)
|
private_class_method def self.setup_rack(config)
|
||||||
# configure daemon
|
# configure daemon
|
||||||
db = Database.new(config['db'])
|
db = Database.new(config['db'])
|
||||||
case config.dig('updater', 'name')
|
updater = Updater::CommandWithBindZone.new(config['domain'], config.dig('updater', 'params')) if config.dig('updater', 'name') == 'command_with_bind_zone'
|
||||||
when 'command_with_bind_zone'
|
|
||||||
updater = Updater::CommandWithBindZone.new(config['domain'], config.dig('updater', 'params'))
|
|
||||||
when 'zone_transfer_server'
|
|
||||||
updater = Updater::ZoneTransferServer.new(config['domain'], config.dig('updater', 'params'))
|
|
||||||
end
|
|
||||||
daemon = Daemon.new(config, db, updater)
|
daemon = Daemon.new(config, db, updater)
|
||||||
|
|
||||||
# configure rack
|
# configure rack
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
# frozen_string_literal: true
|
# typed: true
|
||||||
|
|
||||||
require 'forwardable'
|
require 'forwardable'
|
||||||
|
|
||||||
|
@@ -1,16 +1,16 @@
|
|||||||
# frozen_string_literal: true
|
# typed: true
|
||||||
|
|
||||||
module Dyndnsd
|
module Dyndnsd
|
||||||
module Generator
|
module Generator
|
||||||
class Bind
|
class Bind
|
||||||
# @param domain [String]
|
# @param domain [String]
|
||||||
# @param updater_params [Hash{String => Object}]
|
# @param config [Hash{String => Object}]
|
||||||
def initialize(domain, updater_params)
|
def initialize(domain, config)
|
||||||
@domain = domain
|
@domain = domain
|
||||||
@ttl = updater_params['ttl']
|
@ttl = config['ttl']
|
||||||
@dns = updater_params['dns']
|
@dns = config['dns']
|
||||||
@email_addr = updater_params['email_addr']
|
@email_addr = config['email_addr']
|
||||||
@additional_zone_content = updater_params['additional_zone_content']
|
@additional_zone_content = config['additional_zone_content']
|
||||||
end
|
end
|
||||||
|
|
||||||
# @param db [Dyndnsd::Database]
|
# @param db [Dyndnsd::Database]
|
||||||
@@ -27,7 +27,7 @@ module Dyndnsd
|
|||||||
ips.each do |ip|
|
ips.each do |ip|
|
||||||
ip = IPAddr.new(ip).native
|
ip = IPAddr.new(ip).native
|
||||||
type = ip.ipv6? ? 'AAAA' : 'A'
|
type = ip.ipv6? ? 'AAAA' : 'A'
|
||||||
name = hostname.chomp(".#{@domain}")
|
name = hostname.chomp('.' + @domain)
|
||||||
out << "#{name} IN #{type} #{ip}"
|
out << "#{name} IN #{type} #{ip}"
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
# frozen_string_literal: true
|
# typed: true
|
||||||
|
|
||||||
require 'ipaddr'
|
require 'ipaddr'
|
||||||
|
|
||||||
@@ -60,7 +60,7 @@ module Dyndnsd
|
|||||||
message: e.message,
|
message: e.message,
|
||||||
stack: e.backtrace&.join("\n") || ''
|
stack: e.backtrace&.join("\n") || ''
|
||||||
)
|
)
|
||||||
raise e
|
raise
|
||||||
ensure
|
ensure
|
||||||
scope.close
|
scope.close
|
||||||
end
|
end
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
# frozen_string_literal: true
|
# typed: true
|
||||||
|
|
||||||
module Dyndnsd
|
module Dyndnsd
|
||||||
module Responder
|
module Responder
|
||||||
@@ -9,7 +9,7 @@ module Dyndnsd
|
|||||||
end
|
end
|
||||||
|
|
||||||
# @param env [Hash{String => String}]
|
# @param env [Hash{String => String}]
|
||||||
# @return [Array{Integer,Hash{String => String},Array<String>}]
|
# @return [Array{Integer,Hash{String => String},Array{String}}]
|
||||||
def call(env)
|
def call(env)
|
||||||
@app.call(env).tap do |status_code, headers, body|
|
@app.call(env).tap do |status_code, headers, body|
|
||||||
if headers.key?('X-DynDNS-Response')
|
if headers.key?('X-DynDNS-Response')
|
||||||
@@ -24,32 +24,30 @@ module Dyndnsd
|
|||||||
|
|
||||||
# @param status_code [Integer]
|
# @param status_code [Integer]
|
||||||
# @param headers [Hash{String => String}]
|
# @param headers [Hash{String => String}]
|
||||||
# @param body [Array<String>]
|
# @param body [Array{String}]
|
||||||
# @return [Array{Integer,Hash{String => String},Array<String>}]
|
# @return [Array{Integer,Hash{String => String},Array{String}}]
|
||||||
def decorate_dyndnsd_response(status_code, headers, body)
|
def decorate_dyndnsd_response(status_code, headers, body)
|
||||||
case status_code
|
if status_code == 200
|
||||||
when 200
|
|
||||||
[200, {'Content-Type' => 'text/plain'}, [get_success_body(body[0], body[1])]]
|
[200, {'Content-Type' => 'text/plain'}, [get_success_body(body[0], body[1])]]
|
||||||
when 422
|
elsif status_code == 422
|
||||||
error_response_map[headers['X-DynDNS-Response']]
|
error_response_map[headers['X-DynDNS-Response']]
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
# @param status_code [Integer]
|
# @param status_code [Integer]
|
||||||
# @param headers [Hash{String => String}]
|
# @param headers [Hash{String => String}]
|
||||||
# @param _body [Array<String>]
|
# @param _body [Array{String}]
|
||||||
# @return [Array{Integer,Hash{String => String},Array<String>}]
|
# @return [Array{Integer,Hash{String => String},Array{String}}]
|
||||||
def decorate_other_response(status_code, headers, _body)
|
def decorate_other_response(status_code, headers, _body)
|
||||||
case status_code
|
if status_code == 400
|
||||||
when 400
|
|
||||||
[status_code, headers, ['Bad Request']]
|
[status_code, headers, ['Bad Request']]
|
||||||
when 401
|
elsif status_code == 401
|
||||||
[status_code, headers, ['badauth']]
|
[status_code, headers, ['badauth']]
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
# @param changes [Array<Symbol>]
|
# @param changes [Array{Symbol}]
|
||||||
# @param myips [Array<String>]
|
# @param myips [Array{String}]
|
||||||
# @return [String]
|
# @return [String]
|
||||||
def get_success_body(changes, myips)
|
def get_success_body(changes, myips)
|
||||||
changes.map { |change| "#{change} #{myips.join(' ')}" }.join("\n")
|
changes.map { |change| "#{change} #{myips.join(' ')}" }.join("\n")
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
# frozen_string_literal: true
|
# typed: true
|
||||||
|
|
||||||
module Dyndnsd
|
module Dyndnsd
|
||||||
module Responder
|
module Responder
|
||||||
@@ -9,7 +9,7 @@ module Dyndnsd
|
|||||||
end
|
end
|
||||||
|
|
||||||
# @param env [Hash{String => String}]
|
# @param env [Hash{String => String}]
|
||||||
# @return [Array{Integer,Hash{String => String},Array<String>}]
|
# @return [Array{Integer,Hash{String => String},Array{String}}]
|
||||||
def call(env)
|
def call(env)
|
||||||
@app.call(env).tap do |status_code, headers, body|
|
@app.call(env).tap do |status_code, headers, body|
|
||||||
if headers.key?('X-DynDNS-Response')
|
if headers.key?('X-DynDNS-Response')
|
||||||
@@ -24,32 +24,30 @@ module Dyndnsd
|
|||||||
|
|
||||||
# @param status_code [Integer]
|
# @param status_code [Integer]
|
||||||
# @param headers [Hash{String => String}]
|
# @param headers [Hash{String => String}]
|
||||||
# @param body [Array<String>]
|
# @param body [Array{String}]
|
||||||
# @return [Array{Integer,Hash{String => String},Array<String>}]
|
# @return [Array{Integer,Hash{String => String},Array{String}}]
|
||||||
def decorate_dyndnsd_response(status_code, headers, body)
|
def decorate_dyndnsd_response(status_code, headers, body)
|
||||||
case status_code
|
if status_code == 200
|
||||||
when 200
|
|
||||||
[200, {'Content-Type' => 'text/plain'}, [get_success_body(body[0], body[1])]]
|
[200, {'Content-Type' => 'text/plain'}, [get_success_body(body[0], body[1])]]
|
||||||
when 422
|
elsif status_code == 422
|
||||||
error_response_map[headers['X-DynDNS-Response']]
|
error_response_map[headers['X-DynDNS-Response']]
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
# @param status_code [Integer]
|
# @param status_code [Integer]
|
||||||
# @param headers [Hash{String => String}]
|
# @param headers [Hash{String => String}]
|
||||||
# @param _body [Array<String>]
|
# @param _body [Array{String}]
|
||||||
# @return [Array{Integer,Hash{String => String},Array<String>}]
|
# @return [Array{Integer,Hash{String => String},Array{String}}]
|
||||||
def decorate_other_response(status_code, headers, _body)
|
def decorate_other_response(status_code, headers, _body)
|
||||||
case status_code
|
if status_code == 400
|
||||||
when 400
|
|
||||||
[status_code, headers, ['Bad Request']]
|
[status_code, headers, ['Bad Request']]
|
||||||
when 401
|
elsif status_code == 401
|
||||||
[status_code, headers, ['Unauthorized']]
|
[status_code, headers, ['Unauthorized']]
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
# @param changes [Array<Symbol>]
|
# @param changes [Array{Symbol}]
|
||||||
# @param myips [Array<String>]
|
# @param myips [Array{String}]
|
||||||
# @return [String]
|
# @return [String]
|
||||||
def get_success_body(changes, myips)
|
def get_success_body(changes, myips)
|
||||||
changes.map { |change| change == :good ? "Changed to #{myips.join(' ')}" : "No change needed for #{myips.join(' ')}" }.join("\n")
|
changes.map { |change| change == :good ? "Changed to #{myips.join(' ')}" : "No change needed for #{myips.join(' ')}" }.join("\n")
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
# frozen_string_literal: true
|
# typed: true
|
||||||
|
|
||||||
# Adapted from https://github.com/eric/metriks-graphite/blob/master/lib/metriks/reporter/graphite.rb
|
# Adapted from https://github.com/eric/metriks-graphite/blob/master/lib/metriks/reporter/graphite.rb
|
||||||
|
|
||||||
@@ -18,7 +18,7 @@ module Dyndnsd
|
|||||||
|
|
||||||
@registry = options[:registry] || Metriks::Registry.default
|
@registry = options[:registry] || Metriks::Registry.default
|
||||||
@interval = options[:interval] || 60
|
@interval = options[:interval] || 60
|
||||||
@on_error = options[:on_error] || proc { |ex| } # default: ignore errors
|
@on_error = options[:on_error] || proc { |ex| }
|
||||||
end
|
end
|
||||||
|
|
||||||
# @return [void]
|
# @return [void]
|
||||||
@@ -28,6 +28,7 @@ module Dyndnsd
|
|||||||
sleep @interval
|
sleep @interval
|
||||||
|
|
||||||
Thread.new do
|
Thread.new do
|
||||||
|
begin
|
||||||
write
|
write
|
||||||
rescue StandardError => e
|
rescue StandardError => e
|
||||||
@on_error[e] rescue nil
|
@on_error[e] rescue nil
|
||||||
@@ -35,6 +36,7 @@ module Dyndnsd
|
|||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
end
|
||||||
|
|
||||||
# @return [void]
|
# @return [void]
|
||||||
def stop
|
def stop
|
||||||
@@ -94,8 +96,8 @@ module Dyndnsd
|
|||||||
# @param file [String]
|
# @param file [String]
|
||||||
# @param base_name [String]
|
# @param base_name [String]
|
||||||
# @param metric [Object]
|
# @param metric [Object]
|
||||||
# @param keys [Array<Symbol>]
|
# @param keys [Array{Symbol}]
|
||||||
# @param snapshot_keys [Array<Symbol>]
|
# @param snapshot_keys [Array{Symbol}]
|
||||||
# @return [void]
|
# @return [void]
|
||||||
def write_metric(file, base_name, metric, keys, snapshot_keys = [])
|
def write_metric(file, base_name, metric, keys, snapshot_keys = [])
|
||||||
time = Time.now.to_i
|
time = Time.now.to_i
|
||||||
|
@@ -1,22 +1,19 @@
|
|||||||
# frozen_string_literal: true
|
# typed: true
|
||||||
|
|
||||||
module Dyndnsd
|
module Dyndnsd
|
||||||
module Updater
|
module Updater
|
||||||
class CommandWithBindZone
|
class CommandWithBindZone
|
||||||
# @param domain [String]
|
# @param domain [String]
|
||||||
# @param updater_params [Hash{String => Object}]
|
# @param config [Hash{String => Object}]
|
||||||
def initialize(domain, updater_params)
|
def initialize(domain, config)
|
||||||
@zone_file = updater_params['zone_file']
|
@zone_file = config['zone_file']
|
||||||
@command = updater_params['command']
|
@command = config['command']
|
||||||
@generator = Generator::Bind.new(domain, updater_params)
|
@generator = Generator::Bind.new(domain, config)
|
||||||
end
|
end
|
||||||
|
|
||||||
# @param db [Dyndnsd::Database]
|
# @param db [Dyndnsd::Database]
|
||||||
# @return [void]
|
# @return [void]
|
||||||
def update(db)
|
def update(db)
|
||||||
# do not regenerate zone file (assumed to be persistent) if DB did not change
|
|
||||||
return if !db.changed?
|
|
||||||
|
|
||||||
Helper.span('updater_update') do |span|
|
Helper.span('updater_update') do |span|
|
||||||
span.set_tag('dyndnsd.updater.name', self.class.name&.split('::')&.last || 'None')
|
span.set_tag('dyndnsd.updater.name', self.class.name&.split('::')&.last || 'None')
|
||||||
|
|
||||||
|
@@ -1,158 +0,0 @@
|
|||||||
# frozen_string_literal: true
|
|
||||||
|
|
||||||
require 'resolv'
|
|
||||||
require 'securerandom'
|
|
||||||
|
|
||||||
require 'async/dns'
|
|
||||||
|
|
||||||
module Dyndnsd
|
|
||||||
module Updater
|
|
||||||
class ZoneTransferServer
|
|
||||||
DEFAULT_SERVER_LISTENS = ['0.0.0.0@53'].freeze
|
|
||||||
|
|
||||||
# @param domain [String]
|
|
||||||
# @param updater_params [Hash{String => Object}]
|
|
||||||
def initialize(domain, updater_params)
|
|
||||||
@domain = domain
|
|
||||||
|
|
||||||
@server_listens = self.class.parse_endpoints(updater_params['server_listens'] || DEFAULT_SERVER_LISTENS)
|
|
||||||
@notify_targets = (updater_params['send_notifies'] || []).map { |e| self.class.parse_endpoints([e]) }
|
|
||||||
|
|
||||||
@zone_rr_ttl = updater_params['zone_ttl']
|
|
||||||
@zone_nameservers = updater_params['zone_nameservers'].map { |n| Resolv::DNS::Name.create(n) }
|
|
||||||
@zone_email_address = Resolv::DNS::Name.create(updater_params['zone_email_address'])
|
|
||||||
@zone_additional_ips = updater_params['zone_additional_ips'] || []
|
|
||||||
|
|
||||||
@server = ZoneTransferServerHelper.new(@server_listens, @domain)
|
|
||||||
|
|
||||||
# run Async::DNS server in background thread
|
|
||||||
Thread.new do
|
|
||||||
@server.run
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
# @param db [Dyndnsd::Database]
|
|
||||||
# @return [void]
|
|
||||||
def update(db)
|
|
||||||
Helper.span('updater_update') do |span|
|
|
||||||
span.set_tag('dyndnsd.updater.name', self.class.name&.split('::')&.last || 'None')
|
|
||||||
|
|
||||||
soa_rr = Resolv::DNS::Resource::IN::SOA.new(
|
|
||||||
@zone_nameservers[0], @zone_email_address,
|
|
||||||
db['serial'],
|
|
||||||
10_800, # 3h
|
|
||||||
300, # 5m
|
|
||||||
604_800, # 1w
|
|
||||||
3_600 # 1h
|
|
||||||
)
|
|
||||||
|
|
||||||
default_options = {ttl: @zone_rr_ttl}
|
|
||||||
|
|
||||||
# array containing all resource records for an AXFR request in the right order
|
|
||||||
rrs = []
|
|
||||||
# AXFR responses need to start with zone's SOA RR
|
|
||||||
rrs << [soa_rr, default_options]
|
|
||||||
|
|
||||||
# return RRs for all of the zone's nameservers
|
|
||||||
@zone_nameservers.each do |ns|
|
|
||||||
rrs << [Resolv::DNS::Resource::IN::NS.new(ns), default_options]
|
|
||||||
end
|
|
||||||
|
|
||||||
# return A/AAAA RRs for all additional IPv4s/IPv6s for the domain itself
|
|
||||||
@zone_additional_ips.each do |ip|
|
|
||||||
rrs << [create_addr_rr_for_ip(ip), default_options]
|
|
||||||
end
|
|
||||||
|
|
||||||
# return A/AAAA RRs for the dyndns hostnames
|
|
||||||
db['hosts'].each do |hostname, ips|
|
|
||||||
ips.each do |ip|
|
|
||||||
rrs << [create_addr_rr_for_ip(ip), default_options.merge({name: hostname})]
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
# AXFR responses need to end with zone's SOA RR again
|
|
||||||
rrs << [soa_rr, default_options]
|
|
||||||
|
|
||||||
# point Async::DNS server thread's variable to this new RR array
|
|
||||||
@server.axfr_rrs = rrs
|
|
||||||
|
|
||||||
# only send DNS NOTIFY if there really was a change
|
|
||||||
if db.changed?
|
|
||||||
send_dns_notify
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
# converts into suitable parameter form for Async::DNS::Resolver or Async::DNS::Server
|
|
||||||
#
|
|
||||||
# @param endpoint_list [Array<String>]
|
|
||||||
# @return [Array{Array{Object}}]
|
|
||||||
def self.parse_endpoints(endpoint_list)
|
|
||||||
endpoint_list.map { |addr_string| addr_string.split('@') }
|
|
||||||
.map { |addr_parts| [addr_parts[0], addr_parts[1].to_i || 53] }
|
|
||||||
.map { |addr| [:tcp, :udp].map { |type| [type] + addr } }
|
|
||||||
.flatten(1)
|
|
||||||
end
|
|
||||||
|
|
||||||
private
|
|
||||||
|
|
||||||
# creates correct Resolv::DNS::Resource object for IP address type
|
|
||||||
#
|
|
||||||
# @param ip_string [String]
|
|
||||||
# @return [Resolv::DNS::Resource::IN::A,Resolv::DNS::Resource::IN::AAAA]
|
|
||||||
def create_addr_rr_for_ip(ip_string)
|
|
||||||
ip = IPAddr.new(ip_string).native
|
|
||||||
|
|
||||||
if ip.ipv6?
|
|
||||||
Resolv::DNS::Resource::IN::AAAA.new(ip.to_s)
|
|
||||||
else
|
|
||||||
Resolv::DNS::Resource::IN::A.new(ip.to_s)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
# https://tools.ietf.org/html/rfc1996
|
|
||||||
#
|
|
||||||
# @return [void]
|
|
||||||
def send_dns_notify
|
|
||||||
Async::Reactor.run do
|
|
||||||
@notify_targets.each do |notify_target|
|
|
||||||
target = Async::DNS::Resolver.new(notify_target)
|
|
||||||
|
|
||||||
# assemble DNS NOTIFY message
|
|
||||||
request = Resolv::DNS::Message.new(SecureRandom.random_number(2**16))
|
|
||||||
request.opcode = Resolv::DNS::OpCode::Notify
|
|
||||||
request.add_question("#{@domain}.", Resolv::DNS::Resource::IN::SOA)
|
|
||||||
|
|
||||||
_response = target.dispatch_request(request)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
class ZoneTransferServerHelper < Async::DNS::Server
|
|
||||||
attr_accessor :axfr_rrs
|
|
||||||
|
|
||||||
def initialize(endpoints, domain)
|
|
||||||
super(endpoints, logger: Dyndnsd.logger)
|
|
||||||
@domain = domain
|
|
||||||
end
|
|
||||||
|
|
||||||
# @param name [String]
|
|
||||||
# @param resource_class [Resolv::DNS::Resource]
|
|
||||||
# Since solargraph cannot parse this: param transaction [Async::DNS::Transaction]
|
|
||||||
# @return [void]
|
|
||||||
def process(name, resource_class, transaction)
|
|
||||||
if name != @domain || resource_class != Resolv::DNS::Resource::Generic::Type252_Class1
|
|
||||||
transaction.fail!(:NXDomain)
|
|
||||||
return
|
|
||||||
end
|
|
||||||
|
|
||||||
# https://tools.ietf.org/html/rfc5936
|
|
||||||
transaction.append_question!
|
|
||||||
@axfr_rrs.each do |rr|
|
|
||||||
transaction.add([rr[0]], rr[1])
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
@@ -1,5 +1,5 @@
|
|||||||
# frozen_string_literal: true
|
# typed: true
|
||||||
|
|
||||||
module Dyndnsd
|
module Dyndnsd
|
||||||
VERSION = '3.1.2'
|
VERSION = '2.0.0'.freeze
|
||||||
end
|
end
|
||||||
|
2
sorbet/config
Normal file
2
sorbet/config
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
--dir
|
||||||
|
.
|
36571
sorbet/rbi/hidden-definitions/hidden.rbi
Normal file
36571
sorbet/rbi/hidden-definitions/hidden.rbi
Normal file
File diff suppressed because it is too large
Load Diff
5
sorbet/rbi/jaeger-client.rbi
Normal file
5
sorbet/rbi/jaeger-client.rbi
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
# typed: strong
|
||||||
|
|
||||||
|
module Jaeger::Client
|
||||||
|
def self.build(*args); end
|
||||||
|
end
|
5
sorbet/rbi/rack.rbi
Normal file
5
sorbet/rbi/rack.rbi
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
# typed: strong
|
||||||
|
|
||||||
|
class Rack::Auth::Basic
|
||||||
|
def initialize(app, *args); end
|
||||||
|
end
|
8684
sorbet/rbi/sorbet-typed/lib/bundler/all/bundler.rbi
Normal file
8684
sorbet/rbi/sorbet-typed/lib/bundler/all/bundler.rbi
Normal file
File diff suppressed because it is too large
Load Diff
276
sorbet/rbi/sorbet-typed/lib/rainbow/all/rainbow.rbi
Normal file
276
sorbet/rbi/sorbet-typed/lib/rainbow/all/rainbow.rbi
Normal file
@@ -0,0 +1,276 @@
|
|||||||
|
# This file is autogenerated. Do not edit it by hand. Regenerate it with:
|
||||||
|
# srb rbi sorbet-typed
|
||||||
|
#
|
||||||
|
# If you would like to make changes to this file, great! Please upstream any changes you make here:
|
||||||
|
#
|
||||||
|
# https://github.com/sorbet/sorbet-typed/edit/master/lib/rainbow/all/rainbow.rbi
|
||||||
|
#
|
||||||
|
# typed: strong
|
||||||
|
|
||||||
|
module Rainbow
|
||||||
|
sig { returns(T::Boolean) }
|
||||||
|
attr_accessor :enabled
|
||||||
|
|
||||||
|
class Color
|
||||||
|
sig { returns(Symbol) }
|
||||||
|
attr_reader :ground
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
ground: Symbol,
|
||||||
|
values: T.any([Integer], [Integer, Integer, Integer])
|
||||||
|
).returns(Color)
|
||||||
|
end
|
||||||
|
def self.build(ground, values); end
|
||||||
|
|
||||||
|
sig { params(hex: String).returns([Integer, Integer, Integer]) }
|
||||||
|
def self.parse_hex_color(hex); end
|
||||||
|
|
||||||
|
class Indexed < Color
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :num
|
||||||
|
|
||||||
|
sig { params(ground: Symbol, num: Integer).returns(Indexed) }
|
||||||
|
def initialize(ground, num); end
|
||||||
|
|
||||||
|
sig { returns(T::Array[Integer]) }
|
||||||
|
def codes; end
|
||||||
|
end
|
||||||
|
|
||||||
|
class Named < Indexed
|
||||||
|
NAMES = T.let(nil, T::Hash[Symbol, Integer])
|
||||||
|
|
||||||
|
sig { returns(T::Array[Symbol]) }
|
||||||
|
def self.color_names; end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
def self.valid_names; end
|
||||||
|
|
||||||
|
sig { params(ground: Symbol, name: Symbol).returns(Named) }
|
||||||
|
def initialize(ground, name); end
|
||||||
|
end
|
||||||
|
|
||||||
|
class RGB < Indexed
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_accessor :r, :g, :b
|
||||||
|
|
||||||
|
sig { params(value: Numeric).returns(Integer) }
|
||||||
|
def to_ansi_domain(value); end
|
||||||
|
|
||||||
|
sig { params(ground: Symbol, values: Integer).returns(RGB) }
|
||||||
|
def initialize(ground, *values); end
|
||||||
|
|
||||||
|
sig { returns(T::Array[Integer]) }
|
||||||
|
def codes; end
|
||||||
|
end
|
||||||
|
|
||||||
|
class X11Named < RGB
|
||||||
|
include X11ColorNames
|
||||||
|
|
||||||
|
sig { returns(T::Array[Symbol]) }
|
||||||
|
def self.color_names; end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
def self.valid_names; end
|
||||||
|
|
||||||
|
sig { params(ground: Symbol, name: Symbol).returns(X11Named) }
|
||||||
|
def initialize(ground, name); end
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(Wrapper) }
|
||||||
|
def self.global; end
|
||||||
|
|
||||||
|
sig { returns(T::Boolean) }
|
||||||
|
def self.enabled; end
|
||||||
|
|
||||||
|
sig { params(value: T::Boolean).returns(T::Boolean) }
|
||||||
|
def self.enabled=(value); end
|
||||||
|
|
||||||
|
sig { params(string: String).returns(String) }
|
||||||
|
def self.uncolor(string); end
|
||||||
|
|
||||||
|
class NullPresenter < String
|
||||||
|
sig { params(values: T.any([Integer], [Integer, Integer, Integer])).returns(NullPresenter) }
|
||||||
|
def color(*values); end
|
||||||
|
|
||||||
|
sig { params(values: T.any([Integer], [Integer, Integer, Integer])).returns(NullPresenter) }
|
||||||
|
def foreground(*values); end
|
||||||
|
|
||||||
|
sig { params(values: T.any([Integer], [Integer, Integer, Integer])).returns(NullPresenter) }
|
||||||
|
def fg(*values); end
|
||||||
|
|
||||||
|
sig { params(values: T.any([Integer], [Integer, Integer, Integer])).returns(NullPresenter) }
|
||||||
|
def background(*values); end
|
||||||
|
|
||||||
|
sig { params(values: T.any([Integer], [Integer, Integer, Integer])).returns(NullPresenter) }
|
||||||
|
def bg(*values); end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def reset; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def bright; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def faint; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def italic; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def underline; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def blink; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def inverse; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def hide; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def cross_out; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def black; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def red; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def green; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def yellow; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def blue; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def magenta; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def cyan; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def white; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def bold; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def dark; end
|
||||||
|
|
||||||
|
sig { returns(NullPresenter) }
|
||||||
|
def strike; end
|
||||||
|
end
|
||||||
|
|
||||||
|
class Presenter < String
|
||||||
|
TERM_EFFECTS = T.let(nil, T::Hash[Symbol, Integer])
|
||||||
|
|
||||||
|
sig { params(values: T.any([Integer], [Integer, Integer, Integer])).returns(Presenter) }
|
||||||
|
def color(*values); end
|
||||||
|
|
||||||
|
sig { params(values: T.any([Integer], [Integer, Integer, Integer])).returns(Presenter) }
|
||||||
|
def foreground(*values); end
|
||||||
|
|
||||||
|
sig { params(values: T.any([Integer], [Integer, Integer, Integer])).returns(Presenter) }
|
||||||
|
def fg(*values); end
|
||||||
|
|
||||||
|
sig { params(values: T.any([Integer], [Integer, Integer, Integer])).returns(Presenter) }
|
||||||
|
def background(*values); end
|
||||||
|
|
||||||
|
sig { params(values: T.any([Integer], [Integer, Integer, Integer])).returns(Presenter) }
|
||||||
|
def bg(*values); end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def reset; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def bright; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def faint; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def italic; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def underline; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def blink; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def inverse; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def hide; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def cross_out; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def black; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def red; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def green; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def yellow; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def blue; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def magenta; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def cyan; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def white; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def bold; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def dark; end
|
||||||
|
|
||||||
|
sig { returns(Presenter) }
|
||||||
|
def strike; end
|
||||||
|
end
|
||||||
|
|
||||||
|
class StringUtils
|
||||||
|
sig { params(string: String, codes: T::Array[Integer]).returns(String) }
|
||||||
|
def self.wrap_with_sgr(string, codes); end
|
||||||
|
|
||||||
|
sig { params(string: String).returns(String) }
|
||||||
|
def uncolor(string); end
|
||||||
|
end
|
||||||
|
|
||||||
|
VERSION = T.let(nil, String)
|
||||||
|
|
||||||
|
class Wrapper
|
||||||
|
sig { returns(T::Boolean) }
|
||||||
|
attr_accessor :enabled
|
||||||
|
|
||||||
|
sig { params(enabled: T::Boolean).returns(Wrapper) }
|
||||||
|
def initialize(enabled = true); end
|
||||||
|
|
||||||
|
sig { params(string: String).returns(T.any(Rainbow::Presenter, Rainbow::NullPresenter)) }
|
||||||
|
def wrap(string); end
|
||||||
|
end
|
||||||
|
|
||||||
|
module X11ColorNames
|
||||||
|
NAMES = T.let(nil, T::Hash[Symbol, [Integer, Integer, Integer]])
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { params(string: String).returns(Rainbow::Presenter) }
|
||||||
|
def Rainbow(string); end
|
4222
sorbet/rbi/sorbet-typed/lib/ruby/all/gem.rbi
Normal file
4222
sorbet/rbi/sorbet-typed/lib/ruby/all/gem.rbi
Normal file
File diff suppressed because it is too large
Load Diff
111
sorbet/rbi/sorbet-typed/lib/ruby/all/open3.rbi
Normal file
111
sorbet/rbi/sorbet-typed/lib/ruby/all/open3.rbi
Normal file
@@ -0,0 +1,111 @@
|
|||||||
|
# This file is autogenerated. Do not edit it by hand. Regenerate it with:
|
||||||
|
# srb rbi sorbet-typed
|
||||||
|
#
|
||||||
|
# If you would like to make changes to this file, great! Please upstream any changes you make here:
|
||||||
|
#
|
||||||
|
# https://github.com/sorbet/sorbet-typed/edit/master/lib/ruby/all/open3.rbi
|
||||||
|
#
|
||||||
|
# typed: strong
|
||||||
|
|
||||||
|
module Open3
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmd: T.any(String, T::Array[String]),
|
||||||
|
opts: T.untyped,
|
||||||
|
block: T.nilable(T.proc.params(stdin: IO, stdout: IO, stderr: IO, wait_thr: Process::Waiter).void)
|
||||||
|
).returns([IO, IO, IO, Process::Waiter])
|
||||||
|
end
|
||||||
|
def self.popen3(*cmd, **opts, &block); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmd: T.any(String, T::Array[String]),
|
||||||
|
opts: T.untyped,
|
||||||
|
block: T.nilable(T.proc.params(stdin: IO, stdout: IO, wait_thr: Process::Waiter).void)
|
||||||
|
).returns([IO, IO, Process::Waiter])
|
||||||
|
end
|
||||||
|
def self.popen2(*cmd, **opts, &block); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmd: T.any(String, T::Array[String]),
|
||||||
|
opts: T.untyped,
|
||||||
|
block: T.nilable(T.proc.params(stdin: IO, stdout_and_stderr: IO, wait_thr: Process::Waiter).void)
|
||||||
|
).returns([IO, IO, Process::Waiter])
|
||||||
|
end
|
||||||
|
def self.popen2e(*cmd, **opts, &block); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmd: T.any(String, T::Array[String]),
|
||||||
|
stdin_data: T.nilable(String),
|
||||||
|
binmode: T.any(FalseClass, TrueClass),
|
||||||
|
opts: T::Hash[Symbol, T.untyped]
|
||||||
|
).returns([String, String, Process::Status])
|
||||||
|
end
|
||||||
|
def self.capture3(*cmd, stdin_data: '', binmode: false, **opts); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmd: T.any(String, T::Array[String]),
|
||||||
|
stdin_data: T.nilable(String),
|
||||||
|
binmode: T.any(FalseClass, TrueClass),
|
||||||
|
opts: T::Hash[Symbol, T.untyped]
|
||||||
|
).returns([String, Process::Status])
|
||||||
|
end
|
||||||
|
def self.capture2(*cmd, stdin_data: nil, binmode: false, **opts); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmd: T.any(String, T::Array[String]),
|
||||||
|
stdin_data: T.nilable(String),
|
||||||
|
binmode: T.any(FalseClass, TrueClass),
|
||||||
|
opts: T::Hash[Symbol, T.untyped]
|
||||||
|
).returns([String, Process::Status])
|
||||||
|
end
|
||||||
|
def self.capture2e(*cmd, stdin_data: nil, binmode: false, **opts); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmds: T.any(String, T::Array[String]),
|
||||||
|
opts: T.untyped,
|
||||||
|
block: T.nilable(T.proc.params(first_stdin: IO, last_stdout: IO, wait_threads: T::Array[Process::Waiter]).void)
|
||||||
|
).returns([IO, IO, T::Array[Process::Waiter]])
|
||||||
|
end
|
||||||
|
def self.pipeline_rw(*cmds, **opts, &block); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmds: T.any(String, T::Array[String]),
|
||||||
|
opts: T.untyped,
|
||||||
|
block: T.nilable(T.proc.params(last_stdout: IO, wait_threads: T::Array[Process::Waiter]).void)
|
||||||
|
).returns([IO, T::Array[Process::Waiter]])
|
||||||
|
end
|
||||||
|
def self.pipeline_r(*cmds, **opts, &block); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmds: T.any(String, T::Array[String]),
|
||||||
|
opts: T.untyped,
|
||||||
|
block: T.nilable(T.proc.params(first_stdin: IO, wait_threads: T::Array[Process::Waiter]).void)
|
||||||
|
).returns([IO, T::Array[Process::Waiter]])
|
||||||
|
end
|
||||||
|
def self.pipeline_w(*cmds, **opts, &block); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmds: T.any(String, T::Array[String]),
|
||||||
|
opts: T.untyped,
|
||||||
|
block: T.nilable(T.proc.params(wait_threads: T::Array[Process::Waiter]).void)
|
||||||
|
).returns(T::Array[Process::Waiter])
|
||||||
|
end
|
||||||
|
def self.pipeline_start(*cmds, **opts, &block); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
cmds: T.any(String, T::Array[String]),
|
||||||
|
opts: T.untyped
|
||||||
|
).returns(T::Array[Process::Status])
|
||||||
|
end
|
||||||
|
def self.pipeline(*cmds, **opts); end
|
||||||
|
end
|
543
sorbet/rbi/sorbet-typed/lib/ruby/all/resolv.rbi
Normal file
543
sorbet/rbi/sorbet-typed/lib/ruby/all/resolv.rbi
Normal file
@@ -0,0 +1,543 @@
|
|||||||
|
# This file is autogenerated. Do not edit it by hand. Regenerate it with:
|
||||||
|
# srb rbi sorbet-typed
|
||||||
|
#
|
||||||
|
# If you would like to make changes to this file, great! Please upstream any changes you make here:
|
||||||
|
#
|
||||||
|
# https://github.com/sorbet/sorbet-typed/edit/master/lib/ruby/all/resolv.rbi
|
||||||
|
#
|
||||||
|
# typed: strong
|
||||||
|
|
||||||
|
class Resolv
|
||||||
|
sig { params(name: String).returns(String) }
|
||||||
|
def self.getaddress(name); end
|
||||||
|
|
||||||
|
sig { params(name: String).returns(T::Array[String]) }
|
||||||
|
def self.getaddresses(name); end
|
||||||
|
|
||||||
|
sig { params(name: String, block: T.proc.params(address: String).void).void }
|
||||||
|
def self.each_address(name, &block); end
|
||||||
|
|
||||||
|
sig { params(address: String).returns(String) }
|
||||||
|
def self.getname(address); end
|
||||||
|
|
||||||
|
sig { params(address: String).returns(T::Array[String]) }
|
||||||
|
def self.getnames(address); end
|
||||||
|
|
||||||
|
sig { params(address: String, proc: T.proc.params(name: String).void).void }
|
||||||
|
def self.each_name(address, &proc); end
|
||||||
|
|
||||||
|
sig { params(resolvers: [Hosts, DNS]).void }
|
||||||
|
def initialize(resolvers=[Hosts.new, DNS.new]); end
|
||||||
|
|
||||||
|
sig { params(name: String).returns(String) }
|
||||||
|
def getaddress(name); end
|
||||||
|
|
||||||
|
sig { params(name: String).returns(T::Array[String]) }
|
||||||
|
def getaddresses(name); end
|
||||||
|
|
||||||
|
sig { params(name: String, block: T.proc.params(address: String).void).void }
|
||||||
|
def each_address(name, &block); end
|
||||||
|
|
||||||
|
sig { params(address: String).returns(String) }
|
||||||
|
def getname(address); end
|
||||||
|
|
||||||
|
sig { params(address: String).returns(T::Array[String]) }
|
||||||
|
def getnames(address); end
|
||||||
|
|
||||||
|
sig { params(address: String, proc: T.proc.params(name: String).void).void }
|
||||||
|
def each_name(address, &proc); end
|
||||||
|
|
||||||
|
class ResolvError < StandardError; end
|
||||||
|
class ResolvTimeout < Timeout::Error; end
|
||||||
|
|
||||||
|
class Hosts
|
||||||
|
DefaultFileName = T.let(T.unsafe(nil), String)
|
||||||
|
|
||||||
|
sig { params(filename: String).void }
|
||||||
|
def initialize(filename = DefaultFileName); end
|
||||||
|
|
||||||
|
sig { params(name: String).returns(String) }
|
||||||
|
def getaddress(name); end
|
||||||
|
|
||||||
|
sig { params(name: String).returns(T::Array[String]) }
|
||||||
|
def getaddresses(name); end
|
||||||
|
|
||||||
|
sig { params(name: String, block: T.proc.params(address: String).void).void }
|
||||||
|
def each_address(name, &block); end
|
||||||
|
|
||||||
|
sig { params(address: String).returns(String) }
|
||||||
|
def getname(address); end
|
||||||
|
|
||||||
|
sig { params(address: String).returns(T::Array[String]) }
|
||||||
|
def getnames(address); end
|
||||||
|
|
||||||
|
sig { params(address: String, proc: T.proc.params(name: String).void).void }
|
||||||
|
def each_name(address, &proc); end
|
||||||
|
end
|
||||||
|
|
||||||
|
class DNS
|
||||||
|
Port = T.let(T.unsafe(nil), Integer)
|
||||||
|
|
||||||
|
UDPSize = T.let(T.unsafe(nil), Integer)
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
config_info: T.any(
|
||||||
|
NilClass,
|
||||||
|
String,
|
||||||
|
{ nameserver: T.any(String, T::Array[String]), search: T::Array[String], ndots: Integer },
|
||||||
|
{ nameserver_port: T::Array[[String, Integer]], search: T::Array[String], ndots: Integer }
|
||||||
|
)
|
||||||
|
).returns(Resolv::DNS)
|
||||||
|
end
|
||||||
|
def self.open(config_info = nil); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
config_info: T.any(
|
||||||
|
NilClass,
|
||||||
|
String,
|
||||||
|
{ nameserver: T.any(String, T::Array[String]), search: T::Array[String], ndots: Integer },
|
||||||
|
{ nameserver_port: T::Array[[String, Integer]], search: T::Array[String], ndots: Integer }
|
||||||
|
)
|
||||||
|
).void
|
||||||
|
end
|
||||||
|
def initialize(config_info = nil); end
|
||||||
|
|
||||||
|
sig { params(values: T.any(NilClass, Integer, T::Array[Integer])).void }
|
||||||
|
def timeouts=(values); end
|
||||||
|
|
||||||
|
sig { void }
|
||||||
|
def close; end
|
||||||
|
|
||||||
|
sig { params(name: String).returns(String) }
|
||||||
|
def getaddress(name); end
|
||||||
|
|
||||||
|
sig { params(name: String).returns(T::Array[String]) }
|
||||||
|
def getaddresses(name); end
|
||||||
|
|
||||||
|
sig { params(name: String, block: T.proc.params(address: String).void).void }
|
||||||
|
def each_address(name, &block); end
|
||||||
|
|
||||||
|
sig { params(address: String).returns(String) }
|
||||||
|
def getname(address); end
|
||||||
|
|
||||||
|
sig { params(address: String).returns(T::Array[String]) }
|
||||||
|
def getnames(address); end
|
||||||
|
|
||||||
|
sig { params(address: String, proc: T.proc.params(name: String).void).void }
|
||||||
|
def each_name(address, &proc); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
name: T.any(String, Resolv::DNS::Name),
|
||||||
|
typeclass: T.class_of(Resolv::DNS::Resource)
|
||||||
|
).returns(Resolv::DNS::Resource)
|
||||||
|
end
|
||||||
|
def getresource(name, typeclass); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
name: T.any(String, Resolv::DNS::Name),
|
||||||
|
typeclass: T.class_of(Resolv::DNS::Resource)
|
||||||
|
).returns(T::Array[Resolv::DNS::Resource])
|
||||||
|
end
|
||||||
|
def getresources(name, typeclass); end
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
name: T.any(String, Resolv::DNS::Name),
|
||||||
|
typeclass: T.class_of(Resolv::DNS::Resource),
|
||||||
|
proc: T.proc.params(resource: Resolv::DNS::Resource).void
|
||||||
|
).void
|
||||||
|
end
|
||||||
|
def each_resource(name, typeclass, &proc); end
|
||||||
|
|
||||||
|
class DecodeError < StandardError; end
|
||||||
|
class EncodeError < StandardError; end
|
||||||
|
|
||||||
|
class Name
|
||||||
|
sig { params(arg: T.any(String, Resolv::DNS::Name)).returns(Resolv::DNS::Name) }
|
||||||
|
def self.create(arg); end
|
||||||
|
|
||||||
|
sig { params(labels: T::Array[String], absolute: T.any(FalseClass, TrueClass)).void }
|
||||||
|
def initialize(labels, absolute=true); end
|
||||||
|
|
||||||
|
sig { returns(T.any(FalseClass, TrueClass)) }
|
||||||
|
def absolute?; end
|
||||||
|
|
||||||
|
sig { params(other: Resolv::DNS::Name).returns(T.any(FalseClass, TrueClass)) }
|
||||||
|
def subdomain_of?(other); end
|
||||||
|
end
|
||||||
|
|
||||||
|
class Query; end
|
||||||
|
|
||||||
|
class Resource < Query
|
||||||
|
sig { returns(T.nilable(Integer)) }
|
||||||
|
attr_reader :ttl
|
||||||
|
|
||||||
|
sig { void }
|
||||||
|
def initialize
|
||||||
|
@ttl = T.let(T.unsafe(nil), T.nilable(Integer))
|
||||||
|
end
|
||||||
|
|
||||||
|
class Generic < Resource
|
||||||
|
sig { params(data: T.untyped).void }
|
||||||
|
def initialize(data)
|
||||||
|
@data = T.let(T.unsafe(nil), T.untyped)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(T.untyped) }
|
||||||
|
attr_reader :data
|
||||||
|
end
|
||||||
|
|
||||||
|
class DomainName < Resource
|
||||||
|
sig { params(name: String).void }
|
||||||
|
def initialize(name)
|
||||||
|
@name = T.let(T.unsafe(nil), String)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :name
|
||||||
|
end
|
||||||
|
|
||||||
|
class NS < DomainName; end
|
||||||
|
|
||||||
|
class CNAME < DomainName; end
|
||||||
|
|
||||||
|
class SOA < Resource
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
mname: String,
|
||||||
|
rname: String,
|
||||||
|
serial: Integer,
|
||||||
|
refresh: Integer,
|
||||||
|
retry_: Integer,
|
||||||
|
expire: Integer,
|
||||||
|
minimum: Integer
|
||||||
|
).void
|
||||||
|
end
|
||||||
|
def initialize(mname, rname, serial, refresh, retry_, expire, minimum)
|
||||||
|
@mname = T.let(T.unsafe(nil), String)
|
||||||
|
@rname = T.let(T.unsafe(nil), String)
|
||||||
|
@serial = T.let(T.unsafe(nil), Integer)
|
||||||
|
@refresh = T.let(T.unsafe(nil), Integer)
|
||||||
|
@retry = T.let(T.unsafe(nil), Integer)
|
||||||
|
@expire = T.let(T.unsafe(nil), Integer)
|
||||||
|
@minimum = T.let(T.unsafe(nil), Integer)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :mname
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :rname
|
||||||
|
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :serial
|
||||||
|
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :refresh
|
||||||
|
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :retry
|
||||||
|
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :expire
|
||||||
|
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :minimum
|
||||||
|
end
|
||||||
|
|
||||||
|
class PTR < DomainName; end
|
||||||
|
|
||||||
|
class HINFO < Resource
|
||||||
|
sig { params(cpu: String, os: String).void }
|
||||||
|
def initialize(cpu, os)
|
||||||
|
@cpu = T.let(T.unsafe(nil), String)
|
||||||
|
@os = T.let(T.unsafe(nil), String)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :cpu
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :os
|
||||||
|
end
|
||||||
|
|
||||||
|
class MINFO < Resource
|
||||||
|
sig { params(rmailbx: String, emailbx: String).void }
|
||||||
|
def initialize(rmailbx, emailbx)
|
||||||
|
@rmailbx = T.let(T.unsafe(nil), String)
|
||||||
|
@emailbx = T.let(T.unsafe(nil), String)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :rmailbx
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :emailbx
|
||||||
|
end
|
||||||
|
|
||||||
|
class MX < Resource
|
||||||
|
sig { params(preference: Integer, exchange: String).void }
|
||||||
|
def initialize(preference, exchange)
|
||||||
|
@preference = T.let(T.unsafe(nil), Integer)
|
||||||
|
@exchange = T.let(T.unsafe(nil), String)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :preference
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :exchange
|
||||||
|
end
|
||||||
|
|
||||||
|
class TXT < Resource
|
||||||
|
sig { params(first_string: String, rest_strings: String).void }
|
||||||
|
def initialize(first_string, *rest_strings)
|
||||||
|
@strings = T.let(T.unsafe(nil), T::Array[String])
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(T::Array[String]) }
|
||||||
|
attr_reader :strings
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
def data; end
|
||||||
|
end
|
||||||
|
|
||||||
|
class LOC < Resource
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
version: String,
|
||||||
|
ssize: T.any(String, Resolv::LOC::Size),
|
||||||
|
hprecision: T.any(String, Resolv::LOC::Size),
|
||||||
|
vprecision: T.any(String, Resolv::LOC::Size),
|
||||||
|
latitude: T.any(String, Resolv::LOC::Coord),
|
||||||
|
longitude: T.any(String, Resolv::LOC::Coord),
|
||||||
|
altitude: T.any(String, Resolv::LOC::Alt)
|
||||||
|
).void
|
||||||
|
end
|
||||||
|
def initialize(version, ssize, hprecision, vprecision, latitude, longitude, altitude)
|
||||||
|
@version = T.let(T.unsafe(nil), String)
|
||||||
|
@ssize = T.let(T.unsafe(nil), Resolv::LOC::Size)
|
||||||
|
@hprecision = T.let(T.unsafe(nil), Resolv::LOC::Size)
|
||||||
|
@vprecision = T.let(T.unsafe(nil), Resolv::LOC::Size)
|
||||||
|
@latitude = T.let(T.unsafe(nil), Resolv::LOC::Coord)
|
||||||
|
@longitude = T.let(T.unsafe(nil), Resolv::LOC::Coord)
|
||||||
|
@altitude = T.let(T.unsafe(nil), Resolv::LOC::Alt)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :version
|
||||||
|
|
||||||
|
sig { returns(Resolv::LOC::Size) }
|
||||||
|
attr_reader :ssize
|
||||||
|
|
||||||
|
sig { returns(Resolv::LOC::Size) }
|
||||||
|
attr_reader :hprecision
|
||||||
|
|
||||||
|
sig { returns(Resolv::LOC::Size) }
|
||||||
|
attr_reader :vprecision
|
||||||
|
|
||||||
|
sig { returns(Resolv::LOC::Coord) }
|
||||||
|
attr_reader :latitude
|
||||||
|
|
||||||
|
sig { returns(Resolv::LOC::Coord) }
|
||||||
|
attr_reader :longitude
|
||||||
|
|
||||||
|
sig { returns(Resolv::LOC::Alt) }
|
||||||
|
attr_reader :altitude
|
||||||
|
end
|
||||||
|
|
||||||
|
class ANY < Query; end
|
||||||
|
|
||||||
|
module IN
|
||||||
|
class A < Resource
|
||||||
|
sig { params(address: String).void }
|
||||||
|
def initialize(address)
|
||||||
|
@address = T.let(T.unsafe(nil), Resolv::IPv4)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(Resolv::IPv4) }
|
||||||
|
attr_reader :address
|
||||||
|
end
|
||||||
|
|
||||||
|
class WKS < Resource
|
||||||
|
sig { params(address: String, protocol: Integer, bitmap: String).void }
|
||||||
|
def initialize(address, protocol, bitmap)
|
||||||
|
@address = T.let(T.unsafe(nil), Resolv::IPv4)
|
||||||
|
@protocol = T.let(T.unsafe(nil), Integer)
|
||||||
|
@bitmap = T.let(T.unsafe(nil), String)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(Resolv::IPv4) }
|
||||||
|
attr_reader :address
|
||||||
|
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :protocol
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :bitmap
|
||||||
|
end
|
||||||
|
|
||||||
|
class AAAA < Resource
|
||||||
|
sig { params(address: String).void }
|
||||||
|
def initialize(address)
|
||||||
|
@address = T.let(T.unsafe(nil), Resolv::IPv6)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(Resolv::IPv6) }
|
||||||
|
attr_reader :address
|
||||||
|
end
|
||||||
|
|
||||||
|
class SRV < Resource
|
||||||
|
# Create a SRV resource record.
|
||||||
|
#
|
||||||
|
# See the documentation for #priority, #weight, #port and #target
|
||||||
|
# for +priority+, +weight+, +port and +target+ respectively.
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
priority: T.any(Integer, String),
|
||||||
|
weight: T.any(Integer, String),
|
||||||
|
port: T.any(Integer, String),
|
||||||
|
target: T.any(String, Resolv::DNS::Name)
|
||||||
|
).void
|
||||||
|
end
|
||||||
|
def initialize(priority, weight, port, target)
|
||||||
|
@priority = T.let(T.unsafe(nil), Integer)
|
||||||
|
@weight = T.let(T.unsafe(nil), Integer)
|
||||||
|
@port = T.let(T.unsafe(nil), Integer)
|
||||||
|
@target = T.let(T.unsafe(nil), Resolv::DNS::Name)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :priority
|
||||||
|
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :weight
|
||||||
|
|
||||||
|
sig { returns(Integer) }
|
||||||
|
attr_reader :port
|
||||||
|
|
||||||
|
sig { returns(Resolv::DNS::Name) }
|
||||||
|
attr_reader :target
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
class IPv4
|
||||||
|
Regex256 = T.let(T.unsafe(nil), Regexp)
|
||||||
|
Regex = T.let(T.unsafe(nil), Regexp)
|
||||||
|
|
||||||
|
sig { params(arg: T.any(String, Resolv::IPv4)).returns(Resolv::IPv4) }
|
||||||
|
def self.create(arg); end
|
||||||
|
|
||||||
|
sig { params(address: String).void }
|
||||||
|
def initialize(address)
|
||||||
|
@address = T.let(T.unsafe(nil), String)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :address
|
||||||
|
|
||||||
|
sig { returns(DNS::Name) }
|
||||||
|
def to_name; end
|
||||||
|
end
|
||||||
|
|
||||||
|
class IPv6
|
||||||
|
Regex_8Hex = T.let(T.unsafe(nil), Regexp)
|
||||||
|
Regex_CompressedHex = T.let(T.unsafe(nil), Regexp)
|
||||||
|
Regex_6Hex4Dec = T.let(T.unsafe(nil), Regexp)
|
||||||
|
Regex_CompressedHex4Dec = T.let(T.unsafe(nil), Regexp)
|
||||||
|
Regex = T.let(T.unsafe(nil), Regexp)
|
||||||
|
|
||||||
|
sig { params(arg: T.any(String, Resolv::IPv6)).returns(Resolv::IPv6) }
|
||||||
|
def self.create(arg); end
|
||||||
|
|
||||||
|
sig { params(address: String).void }
|
||||||
|
def initialize(address)
|
||||||
|
@address = T.let(T.unsafe(nil), String)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :address
|
||||||
|
|
||||||
|
sig { returns(DNS::Name) }
|
||||||
|
def to_name; end
|
||||||
|
end
|
||||||
|
|
||||||
|
class MDNS < DNS
|
||||||
|
Port = T.let(T.unsafe(nil), Integer)
|
||||||
|
AddressV4 = T.let(T.unsafe(nil), String)
|
||||||
|
AddressV6 = T.let(T.unsafe(nil), String)
|
||||||
|
Addresses = T.let(T.unsafe(nil), [[String, Integer], [String, Integer]])
|
||||||
|
|
||||||
|
sig do
|
||||||
|
params(
|
||||||
|
config_info: T.any(
|
||||||
|
NilClass,
|
||||||
|
{ nameserver: T.any(String, T::Array[String]), search: T::Array[String], ndots: Integer },
|
||||||
|
{ nameserver_port: T::Array[[String, Integer]], search: T::Array[String], ndots: Integer }
|
||||||
|
)
|
||||||
|
).void
|
||||||
|
end
|
||||||
|
def initialize(config_info = nil); end
|
||||||
|
end
|
||||||
|
|
||||||
|
module LOC
|
||||||
|
class Size
|
||||||
|
Regex = T.let(T.unsafe(nil), Regexp)
|
||||||
|
|
||||||
|
sig { params(arg: T.any(String, Resolv::LOC::Size)).returns(Resolv::LOC::Size) }
|
||||||
|
def self.create(arg); end
|
||||||
|
|
||||||
|
sig { params(scalar: String).void }
|
||||||
|
def initialize(scalar)
|
||||||
|
@scalar = T.let(T.unsafe(nil), String)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :scalar
|
||||||
|
end
|
||||||
|
|
||||||
|
class Coord
|
||||||
|
Regex = T.let(T.unsafe(nil), Regexp)
|
||||||
|
|
||||||
|
sig { params(arg: T.any(String, Resolv::LOC::Coord)).returns(Resolv::LOC::Coord) }
|
||||||
|
def self.create(arg); end
|
||||||
|
|
||||||
|
sig { params(coordinates: String, orientation: T.enum(%w[lat lon])).void }
|
||||||
|
def initialize(coordinates, orientation)
|
||||||
|
@coordinates = T.let(T.unsafe(nil), String)
|
||||||
|
@orientation = T.let(T.unsafe(nil), T.enum(%w[lat lon]))
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :coordinates
|
||||||
|
|
||||||
|
sig { returns(T.enum(%w[lat lon])) }
|
||||||
|
attr_reader :orientation
|
||||||
|
end
|
||||||
|
|
||||||
|
class Alt
|
||||||
|
Regex = T.let(T.unsafe(nil), Regexp)
|
||||||
|
|
||||||
|
sig { params(arg: T.any(String, Resolv::LOC::Alt)).returns(Resolv::LOC::Alt) }
|
||||||
|
def self.create(arg); end
|
||||||
|
|
||||||
|
sig { params(altitude: String).void }
|
||||||
|
def initialize(altitude)
|
||||||
|
@altitude = T.let(T.unsafe(nil), String)
|
||||||
|
end
|
||||||
|
|
||||||
|
sig { returns(String) }
|
||||||
|
attr_reader :altitude
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
DefaultResolver = T.let(T.unsafe(nil), Resolv)
|
||||||
|
AddressRegex = T.let(T.unsafe(nil), Regexp)
|
||||||
|
end
|
@@ -1,12 +1,11 @@
|
|||||||
# frozen_string_literal: true
|
# typed: false
|
||||||
|
require 'spec_helper'
|
||||||
require_relative 'spec_helper'
|
|
||||||
|
|
||||||
describe Dyndnsd::Daemon do
|
describe Dyndnsd::Daemon do
|
||||||
include Rack::Test::Methods
|
include Rack::Test::Methods
|
||||||
|
|
||||||
def app
|
def app
|
||||||
Dyndnsd.logger = Logger.new($stdout)
|
Dyndnsd.logger = Logger.new(STDOUT)
|
||||||
Dyndnsd.logger.level = Logger::UNKNOWN
|
Dyndnsd.logger.level = Logger::UNKNOWN
|
||||||
|
|
||||||
config = {
|
config = {
|
||||||
|
@@ -1,10 +1,9 @@
|
|||||||
# frozen_string_literal: true
|
# typed: strong
|
||||||
|
|
||||||
require 'rubygems'
|
require 'rubygems'
|
||||||
require 'bundler/setup'
|
require 'bundler/setup'
|
||||||
require 'rack/test'
|
require 'rack/test'
|
||||||
|
|
||||||
require 'dyndnsd'
|
require 'dyndnsd'
|
||||||
|
require 'support/dummy_database'
|
||||||
require_relative 'support/dummy_database'
|
require 'support/dummy_updater'
|
||||||
require_relative 'support/dummy_updater'
|
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
# frozen_string_literal: true
|
# typed: true
|
||||||
|
|
||||||
require 'forwardable'
|
require 'forwardable'
|
||||||
|
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
# frozen_string_literal: true
|
# typed: true
|
||||||
|
|
||||||
module Dyndnsd
|
module Dyndnsd
|
||||||
module Updater
|
module Updater
|
||||||
|
Reference in New Issue
Block a user