mirror of
https://github.com/Control-D-Inc/ctrld.git
synced 2026-09-29 13:51:51 +02:00
internal/router: disable native dot on merlin
While at it, also ensure custom config is ignored when running on router, because we need to point to 127.0.0.1:53 (dnsmasq listener).
This commit is contained in:
1 parent
be497a68de
commit
5b6a3a4c6f
4 files changed
+107
-57
No files matched your search
@@ -743,6 +743,13 @@ func processCDFlags() {
|
|||||||
listener.Port = 53
|
listener.Port = 53
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
// On router, we want to keep the listener address point to dnsmasq listener, aka 127.0.0.1:53.
|
||||||
|
if router.Name() != "" {
|
||||||
|
if lc := cfg.Listener["0"]; lc != nil {
|
||||||
|
lc.IP = "127.0.0.1"
|
||||||
|
lc.Port = 53
|
||||||
|
}
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
cfg = ctrld.Config{}
|
cfg = ctrld.Config{}
|
||||||
cfg.Network = make(map[string]*ctrld.NetworkConfig)
|
cfg.Network = make(map[string]*ctrld.NetworkConfig)
|
||||||
|
|||||||
@@ -1,11 +1,9 @@
|
|||||||
package router
|
package router
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"os/exec"
|
"os/exec"
|
||||||
"strings"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
@@ -19,12 +17,6 @@ var ddwrtJffs2NotEnabledErr = errors.New(`could not install service without jffs
|
|||||||
https://wiki.dd-wrt.com/wiki/index.php/Journalling_Flash_File_System
|
https://wiki.dd-wrt.com/wiki/index.php/Journalling_Flash_File_System
|
||||||
`)
|
`)
|
||||||
|
|
||||||
var nvramKeys = map[string]string{
|
|
||||||
"dns_dnsmasq": "1", // Make dnsmasq running but disable DNS ability, ctrld will replace it.
|
|
||||||
"dnsmasq_options": "", // Configuration of dnsmasq set by ctrld, filled by setupDDWrt.
|
|
||||||
"dns_crypt": "0", // Disable DNSCrypt.
|
|
||||||
}
|
|
||||||
|
|
||||||
func setupDDWrt() error {
|
func setupDDWrt() error {
|
||||||
// Already setup.
|
// Already setup.
|
||||||
if val, _ := nvram("get", nvramCtrldSetupKey); val == "1" {
|
if val, _ := nvram("get", nvramCtrldSetupKey); val == "1" {
|
||||||
@@ -35,28 +27,13 @@ func setupDDWrt() error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
nvramKeys["dnsmasq_options"] = data
|
|
||||||
// Backup current value, store ctrld's configs.
|
nvramKvMap := nvramKV()
|
||||||
for key, value := range nvramKeys {
|
nvramKvMap["dnsmasq_options"] = data
|
||||||
old, err := nvram("get", key)
|
if err := nvramSetup(nvramKvMap); err != nil {
|
||||||
if err != nil {
|
return err
|
||||||
return fmt.Errorf("%s: %w", old, err)
|
|
||||||
}
|
|
||||||
if out, err := nvram("set", nvramCtrldKeyPrefix+key+"="+old); err != nil {
|
|
||||||
return fmt.Errorf("%s: %w", out, err)
|
|
||||||
}
|
|
||||||
if out, err := nvram("set", key+"="+value); err != nil {
|
|
||||||
return fmt.Errorf("%s: %w", out, err)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if out, err := nvram("set", nvramCtrldSetupKey+"=1"); err != nil {
|
|
||||||
return fmt.Errorf("%s: %w", out, err)
|
|
||||||
}
|
|
||||||
// Commit.
|
|
||||||
if out, err := nvram("commit"); err != nil {
|
|
||||||
return fmt.Errorf("%s: %w", out, err)
|
|
||||||
}
|
|
||||||
// Restart dnsmasq service.
|
// Restart dnsmasq service.
|
||||||
if err := ddwrtRestartDNSMasq(); err != nil {
|
if err := ddwrtRestartDNSMasq(); err != nil {
|
||||||
return err
|
return err
|
||||||
@@ -66,24 +43,8 @@ func setupDDWrt() error {
|
|||||||
|
|
||||||
func cleanupDDWrt() error {
|
func cleanupDDWrt() error {
|
||||||
// Restore old configs.
|
// Restore old configs.
|
||||||
for key := range nvramKeys {
|
if err := nvramRestore(nvramKV()); err != nil {
|
||||||
ctrldKey := nvramCtrldKeyPrefix + key
|
return err
|
||||||
old, err := nvram("get", ctrldKey)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("%s: %w", old, err)
|
|
||||||
}
|
|
||||||
_, _ = nvram("unset", ctrldKey)
|
|
||||||
if out, err := nvram("set", key+"="+old); err != nil {
|
|
||||||
return fmt.Errorf("%s: %w", out, err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if out, err := nvram("unset", "ctrld_setup"); err != nil {
|
|
||||||
return fmt.Errorf("%s: %w", out, err)
|
|
||||||
}
|
|
||||||
// Commit.
|
|
||||||
if out, err := nvram("commit"); err != nil {
|
|
||||||
return fmt.Errorf("%s: %w", out, err)
|
|
||||||
}
|
}
|
||||||
// Restart dnsmasq service.
|
// Restart dnsmasq service.
|
||||||
if err := ddwrtRestartDNSMasq(); err != nil {
|
if err := ddwrtRestartDNSMasq(); err != nil {
|
||||||
@@ -96,17 +57,6 @@ func postInstallDDWrt() error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func nvram(args ...string) (string, error) {
|
|
||||||
cmd := exec.Command("nvram", args...)
|
|
||||||
var stdout, stderr bytes.Buffer
|
|
||||||
cmd.Stdout = &stdout
|
|
||||||
cmd.Stderr = &stderr
|
|
||||||
if err := cmd.Run(); err != nil {
|
|
||||||
return "", fmt.Errorf("%s:%w", stderr.String(), err)
|
|
||||||
}
|
|
||||||
return strings.TrimSpace(stdout.String()), nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func ddwrtRestartDNSMasq() error {
|
func ddwrtRestartDNSMasq() error {
|
||||||
if out, err := exec.Command("restart_dns").CombinedOutput(); err != nil {
|
if out, err := exec.Command("restart_dns").CombinedOutput(); err != nil {
|
||||||
return fmt.Errorf("restart_dns: %s, %w", string(out), err)
|
return fmt.Errorf("restart_dns: %s, %w", string(out), err)
|
||||||
|
|||||||
@@ -38,10 +38,19 @@ func setupMerlin() error {
|
|||||||
if err := merlinRestartDNSMasq(); err != nil {
|
if err := merlinRestartDNSMasq(); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if err := nvramSetup(nvramKV()); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func cleanupMerlin() error {
|
func cleanupMerlin() error {
|
||||||
|
// Restore old configs.
|
||||||
|
if err := nvramRestore(nvramKV()); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
buf, err := os.ReadFile(merlinDNSMasqPostConfPath)
|
buf, err := os.ReadFile(merlinDNSMasqPostConfPath)
|
||||||
if err != nil && !os.IsNotExist(err) {
|
if err != nil && !os.IsNotExist(err) {
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -0,0 +1,84 @@
|
|||||||
|
package router
|
||||||
|
|
||||||
|
import (
|
||||||
|
"bytes"
|
||||||
|
"fmt"
|
||||||
|
"os/exec"
|
||||||
|
"strings"
|
||||||
|
)
|
||||||
|
|
||||||
|
func nvram(args ...string) (string, error) {
|
||||||
|
cmd := exec.Command("nvram", args...)
|
||||||
|
var stdout, stderr bytes.Buffer
|
||||||
|
cmd.Stdout = &stdout
|
||||||
|
cmd.Stderr = &stderr
|
||||||
|
if err := cmd.Run(); err != nil {
|
||||||
|
return "", fmt.Errorf("%s:%w", stderr.String(), err)
|
||||||
|
}
|
||||||
|
return strings.TrimSpace(stdout.String()), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func nvramKV() map[string]string {
|
||||||
|
switch Name() {
|
||||||
|
case DDWrt:
|
||||||
|
return map[string]string{
|
||||||
|
"dns_dnsmasq": "1", // Make dnsmasq running but disable DNS ability, ctrld will replace it.
|
||||||
|
"dnsmasq_options": "", // Configuration of dnsmasq set by ctrld, filled by setupDDWrt.
|
||||||
|
"dns_crypt": "0", // Disable DNSCrypt.
|
||||||
|
}
|
||||||
|
case Merlin:
|
||||||
|
return map[string]string{
|
||||||
|
"dnspriv_enable": "0", // Ensure Merlin native DoT disabled.
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func nvramSetup(m map[string]string) error {
|
||||||
|
// Backup current value, store ctrld's configs.
|
||||||
|
for key, value := range m {
|
||||||
|
old, err := nvram("get", key)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("%s: %w", old, err)
|
||||||
|
}
|
||||||
|
if out, err := nvram("set", nvramCtrldKeyPrefix+key+"="+old); err != nil {
|
||||||
|
return fmt.Errorf("%s: %w", out, err)
|
||||||
|
}
|
||||||
|
if out, err := nvram("set", key+"="+value); err != nil {
|
||||||
|
return fmt.Errorf("%s: %w", out, err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if out, err := nvram("set", nvramCtrldSetupKey+"=1"); err != nil {
|
||||||
|
return fmt.Errorf("%s: %w", out, err)
|
||||||
|
}
|
||||||
|
// Commit.
|
||||||
|
if out, err := nvram("commit"); err != nil {
|
||||||
|
return fmt.Errorf("%s: %w", out, err)
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func nvramRestore(m map[string]string) error {
|
||||||
|
// Restore old configs.
|
||||||
|
for key := range m {
|
||||||
|
ctrldKey := nvramCtrldKeyPrefix + key
|
||||||
|
old, err := nvram("get", ctrldKey)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("%s: %w", old, err)
|
||||||
|
}
|
||||||
|
_, _ = nvram("unset", ctrldKey)
|
||||||
|
if out, err := nvram("set", key+"="+old); err != nil {
|
||||||
|
return fmt.Errorf("%s: %w", out, err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if out, err := nvram("unset", "ctrld_setup"); err != nil {
|
||||||
|
return fmt.Errorf("%s: %w", out, err)
|
||||||
|
}
|
||||||
|
// Commit.
|
||||||
|
if out, err := nvram("commit"); err != nil {
|
||||||
|
return fmt.Errorf("%s: %w", out, err)
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
Reference in new issue
Block a user