/*
NNCP -- Node to Node copy, utilities for store-and-forward data exchange
-Copyright (C) 2016-2019 Sergey Matveev <stargrave@stargrave.org>
+Copyright (C) 2016-2021 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
[]string{"arg0", "arg1"},
strings.NewReader("BODY\n"),
1<<15,
+ false,
+ false,
); err != nil {
t.Error(err)
return false
incomingPath := filepath.Join(spool, "incoming")
for _, fileData := range files {
checksum := blake2b.Sum256(fileData)
- fileName := ToBase32(checksum[:])
+ fileName := Base32Codec.EncodeToString(checksum[:])
src := filepath.Join(spool, fileName)
if err := ioutil.WriteFile(src, fileData, os.FileMode(0600)); err != nil {
panic(err)
}
for _, fileData := range files {
checksum := blake2b.Sum256(fileData)
- fileName := ToBase32(checksum[:])
+ fileName := Base32Codec.EncodeToString(checksum[:])
data, err := ioutil.ReadFile(filepath.Join(incomingPath, fileName))
if err != nil {
panic(err)
}
for job := range ctx.Jobs(ctx.Self.Id, TTx) {
var buf bytes.Buffer
- _, _, err := PktEncRead(ctx.Self, ctx.Neigh, job.Fd, &buf)
+ fd, err := os.Open(job.Path)
+ if err != nil {
+ t.Error(err)
+ return false
+ }
+ _, _, err = PktEncRead(ctx.Self, ctx.Neigh, fd, &buf)
if err != nil {
t.Error(err)
return false
Magic: MagicNNCPPv3,
Type: PktTypeTrns,
PathLen: blake2b.Size256,
- Path: new([MaxPathSize]byte),
}
copy(pktTrans.Path[:], nodeOur.Id[:])
var dst bytes.Buffer
- if err := PktEncWrite(
+ if _, err := PktEncWrite(
ctx.Self,
ctx.Neigh[*nodeOur.Id],
&pktTrans,
}
checksum := blake2b.Sum256(dst.Bytes())
if err := ioutil.WriteFile(
- filepath.Join(rxPath, ToBase32(checksum[:])),
+ filepath.Join(rxPath, Base32Codec.EncodeToString(checksum[:])),
dst.Bytes(),
os.FileMode(0600),
); err != nil {