Skip to content

Serverless#3884

Draft
j0sh wants to merge 15 commits intomasterfrom
ja/serverless
Draft

Serverless#3884
j0sh wants to merge 15 commits intomasterfrom
ja/serverless

Conversation

@j0sh
Copy link
Copy Markdown
Collaborator

@j0sh j0sh commented Mar 19, 2026

What does this pull request do? Explain your changes. (required)

Specific updates (required)

How did you test each of these updates (required)

Does this pull request close any open issues?

Checklist:

mjh1 and others added 5 commits March 3, 2026 16:34
* Don't create pub / sub trickle channels up front since those are
  now created on demand

* Listen to the events channel for payments instead of pub channel
@github-actions github-actions bot added go Pull requests that update Go code AI Issues and PR related to the AI-video branch. labels Mar 19, 2026
@codecov
Copy link
Copy Markdown

codecov bot commented Mar 19, 2026

Codecov Report

❌ Patch coverage is 3.54331% with 490 lines in your changes missing coverage. Please review.
✅ Project coverage is 32.54002%. Comparing base (48c5d86) to head (5e64de2).
⚠️ Report is 5 commits behind head on master.

Files with missing lines Patch % Lines
ai/worker/serverless_worker.go 0.00000% 433 Missing ⚠️
cmd/livepeer/starter/starter.go 7.69231% 24 Missing ⚠️
server/ai_http.go 0.00000% 15 Missing ⚠️
trickle/trickle_server.go 44.00000% 14 Missing ⚠️
server/ai_live_video.go 0.00000% 2 Missing ⚠️
cmd/livepeer/starter/flags.go 0.00000% 1 Missing ⚠️
server/ai_session.go 0.00000% 1 Missing ⚠️
Additional details and impacted files

Impacted file tree graph

@@                 Coverage Diff                 @@
##              master       #3884         +/-   ##
===================================================
- Coverage   32.79594%   32.54002%   -0.25592%     
===================================================
  Files            171         172          +1     
  Lines          41993       42480        +487     
===================================================
+ Hits           13772       13823         +51     
- Misses         27189       27621        +432     
- Partials        1032        1036          +4     
Files with missing lines Coverage Δ
trickle/local_publisher.go 78.57143% <100.00000%> (+56.94981%) ⬆️
cmd/livepeer/starter/flags.go 0.00000% <0.00000%> (ø)
server/ai_session.go 7.43243% <0.00000%> (ø)
server/ai_live_video.go 0.00000% <0.00000%> (ø)
trickle/trickle_server.go 72.01018% <44.00000%> (-0.15198%) ⬇️
server/ai_http.go 9.74729% <0.00000%> (-0.14282%) ⬇️
cmd/livepeer/starter/starter.go 21.68112% <7.69231%> (-0.11375%) ⬇️
ai/worker/serverless_worker.go 0.00000% <0.00000%> (ø)

... and 2 files with indirect coverage changes


Continue to review full report in Codecov by Sentry.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 48c5d86...5e64de2. Read the comment docs.

Files with missing lines Coverage Δ
trickle/local_publisher.go 78.57143% <100.00000%> (+56.94981%) ⬆️
cmd/livepeer/starter/flags.go 0.00000% <0.00000%> (ø)
server/ai_session.go 7.43243% <0.00000%> (ø)
server/ai_live_video.go 0.00000% <0.00000%> (ø)
trickle/trickle_server.go 72.01018% <44.00000%> (-0.15198%) ⬇️
server/ai_http.go 9.74729% <0.00000%> (-0.14282%) ⬇️
cmd/livepeer/starter/starter.go 21.68112% <7.69231%> (-0.11375%) ⬇️
ai/worker/serverless_worker.go 0.00000% <0.00000%> (ø)

... and 2 files with indirect coverage changes

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

}

// Dial before starting goroutines so errors can be returned to caller
websocketConn, _, err := websocket.DefaultDialer.Dial(wsURL, headers)

Check failure

Code scanning / CodeQL

Uncontrolled data used in network request Critical

The
WebSocket URL
of this request depends on a
user-provided value
.
Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is protected by an env var prefix: 5296840

j0sh added 7 commits March 20, 2026 15:14
If a client needs to start publishing again and doesn't know where
it left off, then it can add a Lp-Trickle-Reset header along with
the -1 seq ("write next empty segment") which is already supported.

This will unblock any subscribers that may be waiting for hanging
writes from the previous publisher.

Also add a Lp-Trickle-Seq header so publishers can correctly position
their next segment in the stream.

Fix a bookkeeping bug in the LocalPublisher, and add tests.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

AI Issues and PR related to the AI-video branch. go Pull requests that update Go code

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants