Updated github.com/klauspost/compress without snappy dependency

[nncp.git] / src / tx.go

diff --git a/src/tx.go b/src/tx.go
index 95801d50b542000759b1a6ee787a388fd3ddc575..e096ed65f873ddeb48f9ac635a01bbeea8849ba2 100644 (file)
--- a/src/tx.go
+++ b/src/tx.go
@@ -239,7 +239,7 @@ func (ctx *Ctx) Tx(
                seenDir := filepath.Join(
                        ctx.Spool, ctx.SelfId.String(), AreaDir, areaId.String(),
                )
-               seenPath := filepath.Join(seenDir, msgHash+SeenSuffix)
+               seenPath := filepath.Join(seenDir, msgHash)
                les := LEs{
                        {"Node", node.Id},
                        {"Nice", int(nice)},
@@ -257,15 +257,9 @@ func (ctx *Ctx) Tx(
                                msgHash,
                        )
                }
-               if _, err = os.Stat(seenDir); err != nil {
-                       if !os.IsNotExist(err) {
-                               ctx.LogE("tx-mkdir", les, err, logMsg)
-                               return lastNode, err
-                       }
-                       if err = os.MkdirAll(seenDir, os.FileMode(0777)); err != nil {
-                               ctx.LogE("tx-mkdir", les, err, logMsg)
-                               return lastNode, err
-                       }
+               if err = ensureDir(seenDir); err != nil {
+                       ctx.LogE("tx-mkdir", les, err, logMsg)
+                       return lastNode, err
                }
                if fd, err := os.Create(seenPath); err == nil {
                        fd.Close()