@@ -29,6 +29,9 @@ import (
29
29
"github.com/TBD54566975/ftl/internal/rpc"
30
30
)
31
31
32
+ const TestPort = "9892"
33
+ const TestIngressPort = "9891"
34
+
32
35
func integrationTestTimeout () time.Duration {
33
36
timeout := optional .Zero (os .Getenv ("FTL_INTEGRATION_TEST_TIMEOUT" )).Default ("5s" )
34
37
d , err := time .ParseDuration (timeout )
@@ -174,16 +177,16 @@ func run(t *testing.T, actionsOrOptions ...ActionOrOption) {
174
177
t .Run (language , func (t * testing.T ) {
175
178
tmpDir := initWorkDir (t , cwd , opts )
176
179
177
- verbs := rpc .Dial (ftlv1connect .NewVerbServiceClient , "http://localhost:8892" , log .Debug )
180
+ verbs := rpc .Dial (ftlv1connect .NewVerbServiceClient , "http://localhost:" + TestPort , log .Debug )
178
181
179
182
var controller ftlv1connect.ControllerServiceClient
180
183
var console pbconsoleconnect.ConsoleServiceClient
181
184
if opts .startController {
182
- controller = rpc .Dial (ftlv1connect .NewControllerServiceClient , "http://localhost:8892" , log .Debug )
183
- console = rpc .Dial (pbconsoleconnect .NewConsoleServiceClient , "http://localhost:8892" , log .Debug )
185
+ controller = rpc .Dial (ftlv1connect .NewControllerServiceClient , "http://localhost:" + TestPort , log .Debug )
186
+ console = rpc .Dial (pbconsoleconnect .NewConsoleServiceClient , "http://localhost:" + TestPort , log .Debug )
184
187
185
188
Infof ("Starting ftl cluster" )
186
- ctx = startProcess (ctx , t , filepath .Join (binDir , "ftl" ), "serve" , "--recreate" )
189
+ ctx = startProcess (ctx , t , filepath .Join (binDir , "ftl" ), "serve" , "--recreate" , "--bind" , "http://127.0.0.1:" + TestIngressPort )
187
190
}
188
191
189
192
testData := filepath .Join (cwd , "testdata" , language )
0 commit comments