More test coverage

Author: simodima

consumer_test.go

@@ -33,6 +33,19 @@ func (suite *ConsumerTestSuite) TestNewConsumer() {
 	squeue.NewConsumer[*TestMessage](suite.driver, "test-queue")
 }
 
+func (suite *ConsumerTestSuite) TestPing() {
+	queue := "test-queue"
+	consumer := squeue.NewConsumer[*TestMessage](suite.driver, queue)
+
+	suite.driver.
+		EXPECT().
+		Ping().
+		Return(errors.New("consume error"))
+
+	err := consumer.Ping()
+	suite.Error(err)
+}
+
 func (suite *ConsumerTestSuite) TestConsumeMessages_DriverError() {
 	queue := "test-queue"
 	consumer := squeue.NewConsumer[*TestMessage](suite.driver, queue)

sqs/sqs_test.go

@@ -58,6 +58,16 @@ func (suite *SQSTestSuite) TestNewWithDefaultOptions() {
 	suite.Contains(err.Error(), "missing")
 }
 
+func (suite *SQSTestSuite) TestNew_InvalidQueueURL() {
+	os.Setenv("AWS_SHARED_CREDENTIALS_FILE", "/a/file")
+	_, err := sqs.New(
+		sqs.WithUrl("-"),
+	)
+
+	suite.Error(err)
+	suite.Contains(err.Error(), "invalid URI")
+}
+
 func (suite *SQSTestSuite) TestNewWithAClient() {
 	sqsDriver, err := sqs.New(sqs.WithClient(suite.sqsMock))