io.eof ready

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

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)
+	}
+}