Function TestMemoryStorage_OpenWriter

internal/caches/storage_memory_test.go:18–99

(t *testing.T)

)

func TestMemoryStorage_OpenWriter(t *testing.T) {
	var storage = NewMemoryStorage(&serverconfigs.HTTPCachePolicy{}, nil)

	writer, err := storage.OpenWriter("abc", time.Now().Unix()+60, 200, -1, -1, -1, false)
	if err != nil {
		t.Fatal(err)
	}
	if err != nil {
		t.Fatal(err)
	}
	_, _ = writer.WriteHeader([]byte("Header"))
	_, _ = writer.Write([]byte("Hello"))
	_, _ = writer.Write([]byte(", World"))
	err = writer.Close()
	if err != nil {
		t.Fatal(err)
	}
	t.Log(storage.valuesMap)

	{
		reader, err := storage.OpenReader("abc", false, false)
		if err != nil {
			if err == ErrNotFound {
				t.Log("not found: abc")
				return
			} else {
				t.Fatal(err)
			}
		}
		buf := make([]byte, 1024)
		t.Log("status:", reader.Status())
		err = reader.ReadHeader(buf, func(n int) (goNext bool, err error) {
			t.Log("header:", string(buf[:n]))
			return true, nil
		})
		if err != nil {
			t.Fatal(err)
		}
		err = reader.ReadBody(buf, func(n int) (goNext bool, err error) {
			t.Log("body:", string(buf[:n]))
			return true, nil
		})
		if err != nil {
			t.Fatal(err)
		}
	}

	{
		_, err := storage.OpenReader("abc 2", false, false)
		if err != nil {
			if err == ErrNotFound {
				t.Log("not found: abc2")
			} else {
				t.Fatal(err)
			}
		}
	}