import (
"bufio"
"bytes"
- "compress/zlib"
"fmt"
"io"
"io/ioutil"
"strconv"
"strings"
- "github.com/davecgh/go-xdr/xdr2"
+ xdr "github.com/davecgh/go-xdr/xdr2"
"github.com/dustin/go-humanize"
+ "github.com/klauspost/compress/zstd"
"golang.org/x/crypto/blake2b"
"golang.org/x/crypto/poly1305"
)
SeenSuffix = ".seen"
)
-func newNotification(fromTo *FromToYAML, subject string) io.Reader {
+func newNotification(fromTo *FromToJSON, subject string) io.Reader {
return strings.NewReader(fmt.Sprintf(
"From: %s\nTo: %s\nSubject: %s\n",
fromTo.From,
dryRun, doSeen, noFile, noFreq, noExec, noTrns bool,
) bool {
isBad := false
+ decompressor, err := zstd.NewReader(nil)
+ if err != nil {
+ panic(err)
+ }
+ defer decompressor.Close()
for job := range ctx.Jobs(nodeId, TRx) {
pktName := filepath.Base(job.Fd.Name())
sds := SDS{"node": job.PktEnc.Sender, "pkt": pktName}
"type": "exec",
"dst": strings.Join(append([]string{handle}, args...), " "),
})
- decompressor, err := zlib.NewReader(pipeR)
- if err != nil {
- log.Fatalln(err)
- }
sender := ctx.Neigh[*job.PktEnc.Sender]
cmdline, exists := sender.Exec[handle]
if !exists || len(cmdline) == 0 {
isBad = true
goto Closing
}
+ if err = decompressor.Reset(pipeR); err != nil {
+ log.Fatalln(err)
+ }
if !dryRun {
cmd := exec.Command(
cmdline[0],
isBad = true
goto Closing
}
- dstPath = dstPathOrig + strconv.Itoa(dstPathCtr)
+ dstPath = dstPathOrig + "." + strconv.Itoa(dstPathCtr)
dstPathCtr++
}
if err = os.Rename(tmp.Name(), dstPath); err != nil {
dst := string(dstRaw)
sds["dst"] = dst
sender := ctx.Neigh[*job.PktEnc.Sender]
- freq := sender.Freq
- if freq == nil {
+ freqPath := sender.FreqPath
+ if freqPath == nil {
ctx.LogE("rx", sds, "freqing is not allowed")
isBad = true
goto Closing
err = ctx.TxFile(
sender,
pkt.Nice,
- filepath.Join(*freq, src),
+ filepath.Join(*freqPath, src),
dst,
sender.FreqMinSize,
)
err = ctx.TxFileChunked(
sender,
pkt.Nice,
- filepath.Join(*freq, src),
+ filepath.Join(*freqPath, src),
dst,
sender.FreqMinSize,
sender.FreqChunked,