/*
NNCP -- Node to Node copy, utilities for store-and-forward data exchange
-Copyright (C) 2016-2022 Sergey Matveev <stargrave@stargrave.org>
+Copyright (C) 2016-2023 Sergey Matveev <stargrave@stargrave.org>
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
package nncp
import (
+ "errors"
"fmt"
- "io/ioutil"
+ "io/fs"
"os"
"path/filepath"
"sort"
if strings.HasSuffix(dst[len(dst)-1], "prv") {
mode = os.FileMode(0600)
}
- return ioutil.WriteFile(filepath.Join(dst...), []byte(r+"\n"), mode)
+ return os.WriteFile(filepath.Join(dst...), []byte(r+"\n"), mode)
}
func cfgDirTouch(dst ...string) error {
}
}
+ if n.ACK != nil {
+ if err = cfgDirMkdir(dst, "neigh", name, "ack"); err != nil {
+ return
+ }
+ if err = cfgDirSave(
+ n.ACK.MinSize,
+ dst, "neigh", name, "ack", "minsize",
+ ); err != nil {
+ return
+ }
+ if err = cfgDirSave(
+ n.ACK.Nice,
+ dst, "neigh", name, "ack", "nice",
+ ); err != nil {
+ return
+ }
+ }
+
if len(n.Via) > 0 {
if err = cfgDirSave(
strings.Join(n.Via, "\n"),
return
}
}
+ if call.AutoTossNoACK {
+ if err = cfgDirTouch(dst, "neigh", name, "calls", is, "autotoss-noack"); err != nil {
+ return
+ }
+ }
+ if call.AutoTossGenACK {
+ if err = cfgDirTouch(dst, "neigh", name, "calls", is, "autotoss-gen-ack"); err != nil {
+ return
+ }
+ }
}
}
}
func cfgDirLoad(src ...string) (v string, exists bool, err error) {
- b, err := ioutil.ReadFile(filepath.Join(src...))
+ b, err := os.ReadFile(filepath.Join(src...))
if err != nil {
- if os.IsNotExist(err) {
+ if errors.Is(err, fs.ErrNotExist) {
return "", false, nil
}
return "", false, err
cfg.MCDRxIfis = strings.Split(*sp, "\n")
}
- fis, err := ioutil.ReadDir(filepath.Join(src, "mcd-send"))
- if err != nil && !os.IsNotExist(err) {
+ fis, err := os.ReadDir(filepath.Join(src, "mcd-send"))
+ if err != nil && !errors.Is(err, fs.ErrNotExist) {
return nil, err
}
if len(fis) > 0 {
if n[0] == '.' {
continue
}
- b, err := ioutil.ReadFile(filepath.Join(src, "mcd-send", fi.Name()))
+ b, err := os.ReadFile(filepath.Join(src, "mcd-send", fi.Name()))
if err != nil {
return nil, err
}
return nil, err
}
}
- fis, err = ioutil.ReadDir(filepath.Join(src, "notify", "exec"))
- if err != nil && !os.IsNotExist(err) {
+ fis, err = os.ReadDir(filepath.Join(src, "notify", "exec"))
+ if err != nil && !errors.Is(err, fs.ErrNotExist) {
return nil, err
}
for _, fi := range fis {
cfg.Notify = ¬ify
}
- if _, err = ioutil.ReadDir(filepath.Join(src, "self")); err == nil {
+ if _, err = os.ReadDir(filepath.Join(src, "self")); err == nil {
self := NodeOurJSON{}
if self.Id, err = cfgDirLoadMust(src, "self", "id"); err != nil {
return nil, err
return nil, err
}
cfg.Self = &self
- } else if !os.IsNotExist(err) {
+ } else if !errors.Is(err, fs.ErrNotExist) {
return nil, err
}
cfg.Neigh = make(map[string]NodeJSON)
- fis, err = ioutil.ReadDir(filepath.Join(src, "neigh"))
- if err != nil && !os.IsNotExist(err) {
+ fis, err = os.ReadDir(filepath.Join(src, "neigh"))
+ if err != nil && !errors.Is(err, fs.ErrNotExist) {
return nil, err
}
for _, fi := range fis {
}
node.Exec = make(map[string][]string)
- fis2, err := ioutil.ReadDir(filepath.Join(src, "neigh", n, "exec"))
- if err != nil && !os.IsNotExist(err) {
+ fis2, err := os.ReadDir(filepath.Join(src, "neigh", n, "exec"))
+ if err != nil && !errors.Is(err, fs.ErrNotExist) {
return nil, err
}
for _, fi2 := range fis2 {
}
}
+ if cfgDirExists(src, "neigh", n, "ack") {
+ node.ACK = &NodeACKJSON{}
+ i64, err := cfgDirLoadIntOpt(src, "neigh", n, "ack", "minsize")
+ if err != nil {
+ return nil, err
+ }
+ if i64 != nil {
+ i := uint64(*i64)
+ node.ACK.MinSize = &i
+ }
+ if node.ACK.Nice, err = cfgDirLoadOpt(
+ src, "neigh", n, "ack", "nice",
+ ); err != nil {
+ return nil, err
+ }
+ }
+
via, err := cfgDirLoadOpt(src, "neigh", n, "via")
if err != nil {
return nil, err
}
node.Addrs = make(map[string]string)
- fis2, err = ioutil.ReadDir(filepath.Join(src, "neigh", n, "addrs"))
- if err != nil && !os.IsNotExist(err) {
+ fis2, err = os.ReadDir(filepath.Join(src, "neigh", n, "addrs"))
+ if err != nil && !errors.Is(err, fs.ErrNotExist) {
return nil, err
}
for _, fi2 := range fis2 {
node.MaxOnlineTime = &i
}
- fis2, err = ioutil.ReadDir(filepath.Join(src, "neigh", n, "calls"))
- if err != nil && !os.IsNotExist(err) {
+ fis2, err = os.ReadDir(filepath.Join(src, "neigh", n, "calls"))
+ if err != nil && !errors.Is(err, fs.ErrNotExist) {
return nil, err
}
callsIdx := make([]int, 0, len(fis2))
if cfgDirExists(src, "neigh", n, "calls", is, "autotoss-noarea") {
call.AutoTossNoArea = true
}
+ if cfgDirExists(src, "neigh", n, "calls", is, "autotoss-noack") {
+ call.AutoTossNoACK = true
+ }
+ if cfgDirExists(src, "neigh", n, "calls", is, "autotoss-gen-ack") {
+ call.AutoTossGenACK = true
+ }
node.Calls = append(node.Calls, call)
}
cfg.Neigh[n] = node
}
cfg.Areas = make(map[string]AreaJSON)
- fis, err = ioutil.ReadDir(filepath.Join(src, "areas"))
- if err != nil && !os.IsNotExist(err) {
+ fis, err = os.ReadDir(filepath.Join(src, "areas"))
+ if err != nil && !errors.Is(err, fs.ErrNotExist) {
return nil, err
}
for _, fi := range fis {
}
area.Exec = make(map[string][]string)
- fis2, err := ioutil.ReadDir(filepath.Join(src, "areas", n, "exec"))
- if err != nil && !os.IsNotExist(err) {
+ fis2, err := os.ReadDir(filepath.Join(src, "areas", n, "exec"))
+ if err != nil && !errors.Is(err, fs.ErrNotExist) {
return nil, err
}
for _, fi2 := range fis2 {
cfg.Areas[n] = area
}
- fis, err = ioutil.ReadDir(filepath.Join(src, "yggdrasil-aliases"))
- if err != nil && !os.IsNotExist(err) {
+ fis, err = os.ReadDir(filepath.Join(src, "yggdrasil-aliases"))
+ if err != nil && !errors.Is(err, fs.ErrNotExist) {
return nil, err
}
if len(fis) > 0 {
if n[0] == '.' {
continue
}
- b, err := ioutil.ReadFile(filepath.Join(src, "yggdrasil-aliases", fi.Name()))
+ b, err := os.ReadFile(filepath.Join(src, "yggdrasil-aliases", fi.Name()))
if err != nil {
return nil, err
}