fix(vertex): honor custom base_url as gateway prefix - #4200
Merged
Calcium-Ion merged 1 commit intoApr 30, 2026
Conversation
Contributor
WalkthroughThis PR introduces a centralized URL builder system for Vertex endpoints in Changes
Estimated code review effort🎯 3 (Moderate) | ⏱️ ~20 minutes Possibly related PRs
Poem
🚥 Pre-merge checks | ✅ 4 | ❌ 1❌ Failed checks (1 warning)
✅ Passed checks (4 passed)
✏️ Tip: You can configure your own custom pre-merge checks in the settings. ✨ Finishing Touches🧪 Generate unit tests (beta)
Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out. Review rate limit: 7/8 reviews remaining, refill in 7 minutes and 30 seconds.Comment |
![coderabbitai[bot]](https://avatars.githubusercontent.com/in/347564?s=60&v=4){kind=small}
Contributor
There was a problem hiding this comment.
Actionable comments posted: 2
🤖 Prompt for all review comments with AI agents
Verify each finding against the current code and only fix it if needed.
Inline comments:
In `@relay/channel/task/vertex/adaptor.go`:
- Around line 233-241: The code currently allows a missing project when baseURL
is provided, causing malformed endpoints; update the logic in the adaptor where
extractProjectFromOperationName(upstreamName) is used to require a non-empty
project regardless of baseURL: validate project (from
extractProjectFromOperationName) with strings.TrimSpace and return an error like
"cannot extract project from operation name" if empty, before calling
vertexcore.BuildGoogleModelURL (which uses vertexcore.DefaultAPIVersion,
project, region, modelName, "fetchPredictOperation"); keep the existing
modelName check and ensure both modelName and project are validated and fail
fast rather than relying on BuildAPIBaseURL behavior.
In `@relay/channel/vertex/url_builder.go`:
- Around line 28-32: The code currently appends "/"+version to any normalized
base URL; change this in the normalizeVertexBaseURL usage so you only append
when the normalized base does not already include the version: trim spaces and
slashes from both normalized and version, normalize trailing slashes on
normalized, then check if normalized already has the version as the final path
segment (e.g., strings.HasSuffix(normalized, "/"+version) or normalized ==
version) and only do normalized = normalized + "/" + version when that check is
false; update the logic around normalizeVertexBaseURL, baseURL, and version to
perform these defensive checks.
🪄 Autofix (Beta)
Fix all unresolved CodeRabbit comments on this PR:
- Push a commit to this branch (recommended)
- Create a new PR with the fixes
ℹ️ Review info
⚙️ Run configuration
Configuration used: Organization UI
Review profile: CHILL
Plan: Pro
Run ID: 64bc7259-1c4b-4253-926b-6a759a848ff7
📒 Files selected for processing (5)
relay/channel/task/vertex/adaptor.gorelay/channel/task/vertex/adaptor_test.gorelay/channel/vertex/adaptor.gorelay/channel/vertex/url_builder.gorelay/channel/vertex/url_builder_test.go
Contributor
There was a problem hiding this comment.
Caution
Some comments are outside the diff and can’t be posted inline due to platform limitations.
⚠️ Outside diff range comments (1)
relay/channel/task/vertex/adaptor.go (1)
85-99:⚠️ Potential issue | 🟡 MinorFail fast when credentials are missing
project_idbefore building submit URL.At Line 98, URL construction proceeds even if
adc.ProjectIDis empty. With a custom gateway base URL, that can generate an invalid path and surface as a confusing upstream error instead of a clear local validation error.Suggested patch
func (a *TaskAdaptor) BuildRequestURL(info *relaycommon.RelayInfo) (string, error) { adc := &vertexcore.Credentials{} if err := common.Unmarshal([]byte(a.apiKey), adc); err != nil { return "", fmt.Errorf("failed to decode credentials: %w", err) } + if strings.TrimSpace(adc.ProjectID) == "" { + return "", fmt.Errorf("missing project_id in credentials") + } modelName := info.UpstreamModelName if modelName == "" { modelName = "veo-3.0-generate-001" }🤖 Prompt for AI Agents
Verify each finding against the current code and only fix it if needed. In `@relay/channel/task/vertex/adaptor.go` around lines 85 - 99, The code calls vertexcore.BuildGoogleModelURL using adc.ProjectID even when adc.ProjectID may be empty, which can produce invalid URLs; update the adaptor code (the block that decodes credentials into adc and then calls BuildGoogleModelURL) to validate adc.ProjectID after unmarshalling and return a clear error (e.g., "missing project_id in credentials") if it's empty before calling vertexcore.BuildGoogleModelURL or proceeding with URL construction, so callers get a fast, descriptive failure instead of an upstream error.
🧹 Nitpick comments (1)
relay/channel/vertex/url_builder_test.go (1)
83-194: Consider consolidating adaptor URL tests into a table-driven structure.The setup/assert pattern is repeated across multiple tests, which makes expansion noisier than needed.
♻️ Refactor sketch
+func assertRequestURL(t *testing.T, info *relaycommon.RelayInfo, want string) { + t.Helper() + adaptor := &Adaptor{} + adaptor.Init(info) + got, err := adaptor.GetRequestURL(info) + if err != nil { + t.Fatalf("GetRequestURL returned error: %v", err) + } + if got != want { + t.Fatalf("GetRequestURL() = %q, want %q", got, want) + } +} + -func TestAdaptorGetRequestURLUsesCustomBaseForGemini(t *testing.T) { - t.Parallel() - ... -} +func TestAdaptorGetRequestURLCases(t *testing.T) { + t.Parallel() + tests := []struct { + name string + info *relaycommon.RelayInfo + want string + }{ + // gemini/claude/open-source/api-key cases... + } + for _, tc := range tests { + tc := tc + t.Run(tc.name, func(t *testing.T) { + t.Parallel() + assertRequestURL(t, tc.info, tc.want) + }) + } +}🤖 Prompt for AI Agents
Verify each finding against the current code and only fix it if needed. In `@relay/channel/vertex/url_builder_test.go` around lines 83 - 194, Consolidate the four near-duplicate tests (TestAdaptorGetRequestURLUsesCustomBaseForGemini, TestAdaptorGetRequestURLUsesCustomBaseForClaude, TestAdaptorGetRequestURLUsesCustomBaseForOpenSource, TestAdaptorGetRequestURLPreservesAPIKeyQueryWithCustomBase) into a single table-driven test that iterates test cases describing RelayInfo/ChannelMeta inputs and expected URLs; for each case create an Adaptor, call adaptor.Init(info) and adaptor.GetRequestURL(info), assert error nil and compare got vs want. Reuse mustMarshalCredentials where needed and include fields IsStream, OriginModelName, ChannelMeta.ApiVersion, ChannelBaseUrl, ApiKey and ChannelOtherSettings.VertexKeyType in the table rows so each scenario (gemini streaming, claude, open-source, API-key query) is covered. Ensure each case t.Run with a descriptive name and keep t.Parallel() per subtest.
🤖 Prompt for all review comments with AI agents
Verify each finding against the current code and only fix it if needed.
Outside diff comments:
In `@relay/channel/task/vertex/adaptor.go`:
- Around line 85-99: The code calls vertexcore.BuildGoogleModelURL using
adc.ProjectID even when adc.ProjectID may be empty, which can produce invalid
URLs; update the adaptor code (the block that decodes credentials into adc and
then calls BuildGoogleModelURL) to validate adc.ProjectID after unmarshalling
and return a clear error (e.g., "missing project_id in credentials") if it's
empty before calling vertexcore.BuildGoogleModelURL or proceeding with URL
construction, so callers get a fast, descriptive failure instead of an upstream
error.
---
Nitpick comments:
In `@relay/channel/vertex/url_builder_test.go`:
- Around line 83-194: Consolidate the four near-duplicate tests
(TestAdaptorGetRequestURLUsesCustomBaseForGemini,
TestAdaptorGetRequestURLUsesCustomBaseForClaude,
TestAdaptorGetRequestURLUsesCustomBaseForOpenSource,
TestAdaptorGetRequestURLPreservesAPIKeyQueryWithCustomBase) into a single
table-driven test that iterates test cases describing RelayInfo/ChannelMeta
inputs and expected URLs; for each case create an Adaptor, call
adaptor.Init(info) and adaptor.GetRequestURL(info), assert error nil and compare
got vs want. Reuse mustMarshalCredentials where needed and include fields
IsStream, OriginModelName, ChannelMeta.ApiVersion, ChannelBaseUrl, ApiKey and
ChannelOtherSettings.VertexKeyType in the table rows so each scenario (gemini
streaming, claude, open-source, API-key query) is covered. Ensure each case
t.Run with a descriptive name and keep t.Parallel() per subtest.
ℹ️ Review info
⚙️ Run configuration
Configuration used: Organization UI
Review profile: CHILL
Plan: Pro
Run ID: 4df6d6d2-ea15-4cc6-8ed4-40b9fb47fbad
📒 Files selected for processing (4)
relay/channel/task/vertex/adaptor.gorelay/channel/task/vertex/adaptor_test.gorelay/channel/vertex/url_builder.gorelay/channel/vertex/url_builder_test.go
✅ Files skipped from review due to trivial changes (1)
- relay/channel/task/vertex/adaptor_test.go
🚧 Files skipped from review as they are similar to previous changes (1)
- relay/channel/vertex/url_builder.go
yyhhyyyyyy
force-pushed
the
fix/vertex-gateway-base-url
branch
from
April 30, 2026 07:09
ca44275 to
987b7ec
Compare
Contributor
There was a problem hiding this comment.
Caution
Some comments are outside the diff and can’t be posted inline due to platform limitations.
⚠️ Outside diff range comments (1)
relay/channel/task/vertex/adaptor.go (1)
84-99:⚠️ Potential issue | 🟠 Major | ⚡ Quick winValidate
adc.ProjectIDbefore buildingpredictLongRunningURL.If credentials are missing
project_id, this path can generate an invalid predict endpoint (especially with custombaseURL) and fail downstream with a less actionable error. Fail fast here.Suggested fix
func (a *TaskAdaptor) BuildRequestURL(info *relaycommon.RelayInfo) (string, error) { adc := &vertexcore.Credentials{} if err := common.Unmarshal([]byte(a.apiKey), adc); err != nil { return "", fmt.Errorf("failed to decode credentials: %w", err) } + if strings.TrimSpace(adc.ProjectID) == "" { + return "", fmt.Errorf("missing project_id in vertex credentials") + } modelName := info.UpstreamModelName if modelName == "" { modelName = "veo-3.0-generate-001" }🤖 Prompt for AI Agents
Verify each finding against the current code and only fix it if needed. In `@relay/channel/task/vertex/adaptor.go` around lines 84 - 99, TaskAdaptor.BuildRequestURL should validate adc.ProjectID after decoding credentials and before calling vertexcore.BuildGoogleModelURL: check that strings.TrimSpace(adc.ProjectID) is not empty and, if it is, return a descriptive error (e.g., "missing project_id in credentials") instead of constructing the URL; ensure this early return prevents calling vertexcore.BuildGoogleModelURL with an empty project ID and include reference to a.baseURL in the error context if helpful for debugging.
🤖 Prompt for all review comments with AI agents
Verify each finding against the current code and only fix it if needed.
Outside diff comments:
In `@relay/channel/task/vertex/adaptor.go`:
- Around line 84-99: TaskAdaptor.BuildRequestURL should validate adc.ProjectID
after decoding credentials and before calling vertexcore.BuildGoogleModelURL:
check that strings.TrimSpace(adc.ProjectID) is not empty and, if it is, return a
descriptive error (e.g., "missing project_id in credentials") instead of
constructing the URL; ensure this early return prevents calling
vertexcore.BuildGoogleModelURL with an empty project ID and include reference to
a.baseURL in the error context if helpful for debugging.
ℹ️ Review info
⚙️ Run configuration
Configuration used: Organization UI
Review profile: CHILL
Plan: Pro
Run ID: c0061f49-d7d8-4a01-9192-c08bfe66fb25
📒 Files selected for processing (3)
relay/channel/task/vertex/adaptor.gorelay/channel/vertex/adaptor.gorelay/channel/vertex/url_builder.go
Jinxuans
referenced
this pull request
in TokFlux-Org/TokFlux
May 9, 2026
fix(vertex): honor custom base_url as gateway prefix
11 tasks
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Important
📝 变更描述 / Description
当前 Vertex 渠道即使配置了自定义 base_url，请求仍会走硬编码的官方上游地址，导致如 Cloudflare AI Gateway 这类自定义网关无法生效。
🚀 变更类型 / Type of change
🔗 关联任务 / Related Issue
✅ 提交前检查项 / Checklist
Bug fix，我已提交或关联对应 Issue，且不会将设计取舍、预期不一致或理解偏差直接归类为 bug。📸 运行证明 / Proof of Work
(请在此粘贴截图、关键日志或测试报告，以证明变更生效)
2.修复后：已成功经过 Cloudflare AI Gateway
Summary by CodeRabbit