[TT-14429]: added fail test for bloblang

[kofoworola]

User description

TT-14429

Summary	add test cases for bloblang
Type	Sub-task
Status	In Code Review
Points	N/A
Labels	-

---

Description

TT-14429

Related Issue

Motivation and Context

How This Has Been Tested

Screenshots (if appropriate)

Types of changes

• Bug fix (non-breaking change which fixes an issue)
• New feature (non-breaking change which adds functionality)
• Breaking change (fix or feature that would cause existing functionality to change)
• Refactoring or add test (improvements in base code or adds test coverage to functionality)

Checklist

• I ensured that the documentation is up to date
• I explained why this PR updates go.mod in detail with reasoning why it's required
• I would like a code coverage CI quality gate exception and have explained why

---

PR Type

Tests

---

Description

• Add test for invalid Bloblang expression in streaming pipeline

• Introduce invalid Bloblang config template for NATS input

• Ensure WebSocket connection fails with invalid Bloblang

• Maintain test isolation with container cleanup

---

Changes walkthrough 📝

Relevant files

Tests

mw_streaming_test.go Add test for invalid Bloblang in streaming pipeline            gateway/mw_streaming_test.go Added bentoNatsTemplateInvalidBloblang with an invalid Bloblang expression Introduced TestStreamingInvalidBloblang to verify error handling on invalid Bloblang Ensured test cleans up NATS container and test server resources Confirmed WebSocket connection fails as expected with invalid config +71/-0

---

Need help?

Type /help how to ... in the comments thread for any questions about PR-Agent usage.

Check out the documentation for more information.

[buger]

I'm a bot and I 👍 this PR title. 🤖

[github-actions]

PR Reviewer Guide 🔍

Here are some key observations to aid the review process:

⏱️ Estimated effort to review: 2 🔵🔵⚪⚪⚪

🧪 PR contains tests

🔒 No security concerns identified

⚡ Recommended focus areas for review Test Coverage The new test TestStreamingInvalidBloblang is designed to verify behavior when an invalid Bloblang expression is used. Ensure that this test reliably fails for the correct reason and that error assertions are specific enough to catch only the intended failure mode. func TestStreamingInvalidBloblang(t *testing.T) { ctx := context.Background() natsContainer, err := natscon.Run( ctx, "nats:2.9", testcontainers.WithWaitStrategy(wait.ForAll( wait.ForLog("Server is ready"), wait.ForListeningPort("4222/tcp"), ).WithDeadline(30*time.Second))) require.NoError(t, err) t.Cleanup(func() { natsContainer.Terminate(ctx) }) //skip if is dynamic, does not work configSubject := "test" connectionStr, err := natsContainer.ConnectionString(ctx) assert.NoError(t, err) streamConfig := fmt.Sprintf(bentoNatsTemplateInvalidBloblang, configSubject, connectionStr) ts := StartTest(func(globalConf *config.Config) { globalConf.Streaming.Enabled = true }) t.Cleanup(func() { ts.Close() }) //t.Cleanup(func() { ts.Close() }) apiName := "test-api" if err = setUpStreamAPI(ts, apiName, streamConfig); err != nil { t.Fatal(err) } const totalMessages = 3 dialer := websocket.Dialer{ HandshakeTimeout: 1 * time.Second, TLSClientConfig: &tls.Config{InsecureSkipVerify: true}, } wsURL := strings.Replace(ts.URL, "http", "ws", 1) + fmt.Sprintf("/%s/get/ws", apiName) _, _, err = dialer.Dial(wsURL, nil) assert.Error(t, err) }

[github-actions]

PR Code Suggestions ✨

No code suggestions found for the PR.

[github-actions]

API Changes

no api changes detected

[sonarqubecloud]

Quality Gate passed

Issues
0 New issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud