From 5e6fd81921e8f3e5b42cb36a185e9cc4d5d12b1e Mon Sep 17 00:00:00 2001 From: Bel LaPointe <153096461+breel-render@users.noreply.github.com> Date: Thu, 8 May 2025 15:58:05 -0600 Subject: [PATCH] io.eof ready --- src/asses/one.go | 2 ++ src/asses/one_test.go | 25 +++++++++++++++++++++++++ 2 files changed, 27 insertions(+) create mode 100644 src/asses/one_test.go diff --git a/src/asses/one.go b/src/asses/one.go index 7ad908b..a91403d 100644 --- a/src/asses/one.go +++ b/src/asses/one.go @@ -5,6 +5,7 @@ import ( "crypto/md5" "encoding/base64" "io" + "log" "math/rand" "os" "time" @@ -23,6 +24,7 @@ func One(ctx context.Context, p string) error { return io.EOF + log.Printf("assing %s", p) cksum, err := cksum(ctx, p) if err != nil { return err diff --git a/src/asses/one_test.go b/src/asses/one_test.go new file mode 100644 index 0000000..a90dae5 --- /dev/null +++ b/src/asses/one_test.go @@ -0,0 +1,25 @@ +package asses_test + +import ( + "context" + "os" + "path" + "show-rss/src/asses" + "show-rss/src/db" + "testing" +) + +func TestOne(t *testing.T) { + ctx := db.Test(t, context.Background()) + + d := t.TempDir() + b, _ := os.ReadFile(path.Join("testdata", "survivor_au_S11E12.smoller.mkv")) + p := path.Join(d, "f.mkv") + os.WriteFile(p, b, os.ModePerm) + + if err := asses.One(ctx, p); err != nil { + t.Fatal(err) + } else if err := asses.One(ctx, p); err != nil { + t.Fatal(err) + } +}