expose stubs for testing

Author: hmoragrega

aws/sqs_publisher_scheduler_test.go

@@ -10,8 +10,8 @@ import (
 	"time"
 
 	"github.com/hmoragrega/pubsub"
-	"github.com/hmoragrega/pubsub/internal/stubs"
 	"github.com/hmoragrega/pubsub/marshaller"
+	"github.com/hmoragrega/pubsub/pubsubtest/stubs"
 )
 
 const maxDelay = 15 * time.Minute

aws/subscriber_test.go

@@ -23,9 +23,10 @@ import (
 	"github.com/aws/aws-sdk-go-v2/service/sqs"
 	"github.com/aws/aws-sdk-go-v2/service/sqs/types"
 	"github.com/aws/smithy-go/logging"
+
 	"github.com/hmoragrega/pubsub"
-	"github.com/hmoragrega/pubsub/internal/stubs"
 	"github.com/hmoragrega/pubsub/marshaller"
+	"github.com/hmoragrega/pubsub/pubsubtest/stubs"
 )
 
 var (

letterbox/letterbox_test.go

@@ -8,8 +8,8 @@ import (
 	"time"
 
 	"github.com/hmoragrega/pubsub"
-	"github.com/hmoragrega/pubsub/internal/channels"
 	"github.com/hmoragrega/pubsub/marshaller"
+	"github.com/hmoragrega/pubsub/pubsubtest/channels"
 )
 
 type sumRequest struct {

marshaller/marshaller_byte_test.go

@@ -7,7 +7,7 @@ import (
 	"testing"
 
 	"github.com/hmoragrega/pubsub"
-	"github.com/hmoragrega/pubsub/internal/stubs"
+	"github.com/hmoragrega/pubsub/pubsubtest/stubs"
 )
 
 func TestByteMarshaller_Marshal(t *testing.T) {

marshaller/marshaller_json_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 
 	"github.com/hmoragrega/pubsub"
-	"github.com/hmoragrega/pubsub/internal/stubs"
+	"github.com/hmoragrega/pubsub/pubsubtest/stubs"
 )
 
 type testJSONStruct struct {

marshaller/unmarshaller_chain_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 
 	"github.com/hmoragrega/pubsub"
-	"github.com/hmoragrega/pubsub/internal/stubs"
+	"github.com/hmoragrega/pubsub/pubsubtest/stubs"
 )
 
 func TestChainUnmarshaller_Success(t *testing.T) {

marshaller_test.go

@@ -5,7 +5,7 @@ import (
 	"testing"
 
 	"github.com/hmoragrega/pubsub"
-	"github.com/hmoragrega/pubsub/internal/stubs"
+	"github.com/hmoragrega/pubsub/pubsubtest/stubs"
 )
 
 func TestNoOpUnmarshaller(t *testing.T) {

message_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 
 	"github.com/hmoragrega/pubsub"
-	"github.com/hmoragrega/pubsub/internal/stubs"
+	"github.com/hmoragrega/pubsub/pubsubtest/stubs"
 )
 
 func TestMessage_Ack(t *testing.T) {

publisher_test.go

@@ -7,8 +7,8 @@ import (
 	"testing"
 
 	"github.com/hmoragrega/pubsub"
-	"github.com/hmoragrega/pubsub/internal/stubs"
 	"github.com/hmoragrega/pubsub/marshaller"
+	"github.com/hmoragrega/pubsub/pubsubtest/stubs"
 )
 
 func TestPublisher_PublishMarshallFailure(t *testing.T) {

internal/channels/publisher.go renamed to pubsubtest/channels/publisher.go

@@ -5,7 +5,7 @@ import (
 	"sync"
 
 	"github.com/hmoragrega/pubsub"
-	"github.com/hmoragrega/pubsub/internal/stubs"
+	"github.com/hmoragrega/pubsub/pubsubtest/stubs"
 )
 
 const queueBuffer = 100
@@ -21,24 +21,25 @@ func (p *Publisher) Publish(ctx context.Context, topic string, envelopes ...*pub
 
 	for _, s := range p.subscribers[topic] {
 		for _, envelope := range envelopes {
+			e := envelope
 			rm := stubs.NewNoOpReceivedMessage()
 			rm.IDFunc = func() string {
-				return envelope.ID
+				return e.ID
 			}
 			rm.NameFunc = func() string {
-				return envelope.Name
+				return e.Name
 			}
 			rm.KeyFunc = func() string {
-				return envelope.Key
+				return e.Key
 			}
 			rm.BodyFunc = func() []byte {
-				return envelope.Body
+				return e.Body
 			}
 			rm.VersionFunc = func() string {
-				return envelope.Version
+				return e.Version
 			}
 			rm.AttributesFunc = func() pubsub.Attributes {
-				return envelope.Attributes
+				return e.Attributes
 			}
 			select {
 			case <-ctx.Done():