From c8a5510d522002a770214b2204c0f330bece43b3 Mon Sep 17 00:00:00 2001
From: Jono Wenger <jono@elixxir.io>
Date: Wed, 30 Mar 2022 14:43:16 -0700
Subject: [PATCH] fix parse
---
e2e/parse/partition_test.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/e2e/parse/partition_test.go b/e2e/parse/partition_test.go
index 3412924f7..98970c881 100644
--- a/e2e/parse/partition_test.go
+++ b/e2e/parse/partition_test.go
@@ -24,7 +24,7 @@ var ipsumTestStr = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cra
// Test that NewPartitioner outputs a correctly made Partitioner
func TestNewPartitioner(t *testing.T) {
- p := NewPartitioner(4096, versioned.NewKV(make(ekv.Memstore)))
+ p := NewPartitioner(versioned.NewKV(make(ekv.Memstore)), 4096)
if p.baseMessageSize != 4096 {
t.Errorf("baseMessageSize content mismatch."+
@@ -57,7 +57,7 @@ func TestNewPartitioner(t *testing.T) {
// Test that no error is returned running Partitioner.Partition.
func TestPartitioner_Partition(t *testing.T) {
- p := NewPartitioner(len(ipsumTestStr), versioned.NewKV(make(ekv.Memstore)))
+ p := NewPartitioner(versioned.NewKV(make(ekv.Memstore)), len(ipsumTestStr))
_, _, err := p.Partition(
&id.DummyUser, catalog.XxMessage, netTime.Now(), []byte(ipsumTestStr))
@@ -68,7 +68,7 @@ func TestPartitioner_Partition(t *testing.T) {
// Test that Partitioner.HandlePartition can handle a message part.
func TestPartitioner_HandlePartition(t *testing.T) {
- p := NewPartitioner(len(ipsumTestStr), versioned.NewKV(make(ekv.Memstore)))
+ p := NewPartitioner(versioned.NewKV(make(ekv.Memstore)), len(ipsumTestStr))
m := newMessagePart(1107, 1, []byte(ipsumTestStr))
_, _ = p.HandlePartition(
@@ -80,7 +80,7 @@ func TestPartitioner_HandlePartition(t *testing.T) {
// Test that HandlePartition can handle a first message part
func TestPartitioner_HandleFirstPartition(t *testing.T) {
- p := NewPartitioner(len(ipsumTestStr), versioned.NewKV(make(ekv.Memstore)))
+ p := NewPartitioner(versioned.NewKV(make(ekv.Memstore)), len(ipsumTestStr))
m := newFirstMessagePart(
catalog.XxMessage, 1107, 1, netTime.Now(), []byte(ipsumTestStr))
--
GitLab