- sds["node"] = nncp.ToBase32(pktEnc.Recipient[:])
- sds["pkt"] = pktName
- sds["fullsize"] = entry.Size
- selfPath = filepath.Join(ctx.Spool, ctx.SelfId.String(), string(nncp.TRx))
- dstPath = filepath.Join(selfPath, pktName)
+ sender := nncp.Base32Codec.EncodeToString(pktEnc.Sender[:])
+ les = nncp.LEs{
+ {K: "XX", V: string(nncp.TRx)},
+ {K: "Node", V: sender},
+ {K: "Pkt", V: pktName},
+ {K: "FullSize", V: entry.Size},
+ }
+ logMsg = func(les nncp.LEs) string {
+ return fmt.Sprintf("Bundle transfer %s/rx/%s", sender, pktName)
+ }
+ dstDirPath := filepath.Join(ctx.Spool, sender, string(nncp.TRx))
+ dstPath := filepath.Join(dstDirPath, pktName)