From f01df6252d1791e5217e55c60147038baa3d71f4 Mon Sep 17 00:00:00 2001
From: YouROK <8YouROK8@mail.ru>
Date: Fri, 3 Feb 2023 12:44:55 +0300
Subject: [PATCH] add test

---
 server/rutor/mem_test.go | 76 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 76 insertions(+)
 create mode 100644 server/rutor/mem_test.go

diff --git a/server/rutor/mem_test.go b/server/rutor/mem_test.go
new file mode 100644
index 0000000..273314f
--- /dev/null
+++ b/server/rutor/mem_test.go
@@ -0,0 +1,76 @@
+package rutor
+
+import (
+	"compress/flate"
+	"encoding/json"
+	"fmt"
+	"os"
+	"path/filepath"
+	"server/rutor/models"
+	"testing"
+)
+
+func TestParseChannel(t *testing.T) {
+	var channel = make(chan *models.TorrentDetails, 0)
+	var ftors []*models.TorrentDetails
+	go func() {
+		for torr := range channel {
+			ftors = append(ftors, torr)
+		}
+	}()
+
+	path, _ := os.Getwd()
+	ff, err := os.Open(filepath.Join(path, "rutor.ls"))
+	if err == nil {
+		defer ff.Close()
+		r := flate.NewReader(ff)
+		defer r.Close()
+		dec := json.NewDecoder(r)
+
+		_, err := dec.Token()
+		if err != nil {
+			t.Error(err)
+		}
+
+		for dec.More() {
+			var torr *models.TorrentDetails
+			err = dec.Decode(&torr)
+			if err != nil {
+				t.Error(err)
+			}
+			channel <- torr
+		}
+		close(channel)
+	} else {
+		t.Error(err)
+	}
+}
+
+func TestParseArr(t *testing.T) {
+	var ftors []*models.TorrentDetails
+	path, _ := os.Getwd()
+	ff, err := os.Open(filepath.Join(path, "rutor.ls"))
+	if err == nil {
+		defer ff.Close()
+		r := flate.NewReader(ff)
+		defer r.Close()
+		dec := json.NewDecoder(r)
+
+		_, err := dec.Token()
+		if err != nil {
+			t.Error(err)
+		}
+
+		for dec.More() {
+			var torr *models.TorrentDetails
+			err = dec.Decode(&torr)
+			if err != nil {
+				t.Error(err)
+			}
+			ftors = append(ftors, torr)
+			fmt.Println(len(ftors))
+		}
+	} else {
+		t.Error(err)
+	}
+}