[BEAM-13241] [Playground] Frontend Routing

playground/frontend/build.gradle

@@ -22,6 +22,10 @@ apply plugin: 'base'
 applyDockerNature()
 
 def playgroundBackendUrl = project.playgroundBackendUrl
+def playgroundBackendJavaRouteUrl = project.playgroundBackendJavaRouteUrl
+def playgroundBackendGoRouteUrl = project.playgroundBackendGoRouteUrl
+def playgroundBackendPythonRouteUrl = project.playgroundBackendPythonRouteUrl
+def playgroundBackendScioRouteUrl = project.playgroundBackendScioRouteUrl
 
 def playgroundJobServerProject = "${project.path.replace('-container', '')}"
 
@@ -159,6 +163,14 @@ task("createConfig") {
 
 const String kApiClientURL =
     '${playgroundBackendUrl}';
+const String kApiJavaClientURL =
+    '${playgroundBackendJavaRouteUrl}';
+const String kApiGoClientURL =
+    '${playgroundBackendGoRouteUrl}';
+const String kApiPythonClientURL =
+    '${playgroundBackendPythonRouteUrl}';
+const String kApiScioClientURL =
+    '${playgroundBackendScioRouteUrl}';
 """)
   }
 }

playground/frontend/gradle.properties

@@ -15,4 +15,8 @@
 #  See the License for the specific language governing permissions and
 # limitations under the License.
 ################################################################################
-playgroundBackendUrl=https://backend-dot-datatokenization.uc.r.appspot.com
+playgroundBackendUrl=https://backend-dot-datatokenization.uc.r.appspot.com
+playgroundBackendJavaRouteUrl=https://backend-dot-datatokenization.uc.r.appspot.com/java/
+playgroundBackendGoRouteUrl=https://backend-dot-datatokenization.uc.r.appspot.com/go/
+playgroundBackendPythonRouteUrl=https://backend-dot-datatokenization.uc.r.appspot.com/python/
+playgroundBackendScioRouteUrl=https://backend-dot-datatokenization.uc.r.appspot.com/scio/

playground/frontend/lib/api/iis_workaround_channel.dart

@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import 'package:grpc/grpc_connection_interface.dart';
+// ignore: implementation_imports
+import 'package:grpc/src/client/transport/xhr_transport.dart';
+
+class IisWorkaroundChannel extends ClientChannelBase {
+  final Uri uri;
+
+  IisWorkaroundChannel.xhr(this.uri) : super();
+
+  @override
+  ClientConnection createConnection() {
+    return IisClientConnection(uri);
+  }
+}
+
+class IisClientConnection extends XhrClientConnection {
+  IisClientConnection(Uri uri) : super(uri);
+
+  @override
+  GrpcTransportStream makeRequest(String path, Duration? timeout,
+      Map<String, String> metadata, ErrorHandler onError,
+      {CallOptions? callOptions}) {
+    print(path);
+    var pathWithoutFirstSlash = path.substring(1);
+    print(pathWithoutFirstSlash);
+    return super.makeRequest(pathWithoutFirstSlash, timeout, metadata, onError,
+        callOptions: callOptions);
+  }
+}

playground/frontend/lib/config.g.dart

@@ -18,3 +18,11 @@
 
 const String kApiClientURL =
     'https://backend-dot-datatokenization.uc.r.appspot.com';
+const String kApiJavaClientURL =
+    'https://backend-dot-datatokenization.uc.r.appspot.com/java/';
+const String kApiGoClientURL =
+    'https://backend-dot-datatokenization.uc.r.appspot.com/go/';
+const String kApiPythonClientURL =
+    'https://backend-dot-datatokenization.uc.r.appspot.com/python/';
+const String kApiScioClientURL =
+    'https://backend-dot-datatokenization.uc.r.appspot.com/scio/';

playground/frontend/lib/modules/editor/repository/code_repository/code_client/code_client.dart

@@ -24,11 +24,23 @@ import 'package:playground/modules/editor/repository/code_repository/run_code_re
 abstract class CodeClient {
   Future<RunCodeResponse> runCode(RunCodeRequestWrapper request);
 
-  Future<CheckStatusResponse> checkStatus(String pipelineUuid);
+  Future<CheckStatusResponse> checkStatus(
+    String pipelineUuid,
+    RunCodeRequestWrapper request,
+  );
 
-  Future<OutputResponse> getCompileOutput(String pipelineUuid);
+  Future<OutputResponse> getCompileOutput(
+    String pipelineUuid,
+    RunCodeRequestWrapper request,
+  );
 
-  Future<OutputResponse> getRunOutput(String pipelineUuid);
+  Future<OutputResponse> getRunOutput(
+    String pipelineUuid,
+    RunCodeRequestWrapper request,
+  );
 
-  Future<OutputResponse> getRunErrorOutput(String pipelineUuid);
+  Future<OutputResponse> getRunErrorOutput(
+    String pipelineUuid,
+    RunCodeRequestWrapper request,
+  );
 }

playground/frontend/lib/modules/editor/repository/code_repository/code_client/grpc_code_client.dart

@@ -17,6 +17,7 @@
  */
 
 import 'package:grpc/grpc_web.dart';
+import 'package:playground/api/iis_workaround_channel.dart';
 import 'package:playground/api/v1/api.pbgrpc.dart' as grpc;
 import 'package:playground/config.g.dart';
 import 'package:playground/modules/editor/repository/code_repository/code_client/check_status_response.dart';
@@ -31,51 +32,64 @@ import 'package:playground/modules/sdk/models/sdk.dart';
 const kGeneralError = 'Failed to execute code';
 
 class GrpcCodeClient implements CodeClient {
-  late final GrpcWebClientChannel _channel;
-  late final grpc.PlaygroundServiceClient _client;
-
-  GrpcCodeClient() {
-    _channel = GrpcWebClientChannel.xhr(
-      Uri.parse(kApiClientURL),
+  grpc.PlaygroundServiceClient createClient(SDK? sdk) {
+    String apiClientURL = kApiClientURL;
+    if (sdk != null) {
+      apiClientURL = sdk.getRoute;
+    }
+    IisWorkaroundChannel channel = IisWorkaroundChannel.xhr(
+      Uri.parse(apiClientURL),
     );
-    _client = grpc.PlaygroundServiceClient(_channel);
+    return grpc.PlaygroundServiceClient(channel);
   }
 
   @override
   Future<RunCodeResponse> runCode(RunCodeRequestWrapper request) {
-    return _runSafely(() => _client
+    return _runSafely(() => createClient(request.sdk)
         .runCode(_toGrpcRequest(request))
         .then((response) => RunCodeResponse(response.pipelineUuid)));
   }
 
   @override
-  Future<CheckStatusResponse> checkStatus(String pipelineUuid) {
-    return _runSafely(() => _client
+  Future<CheckStatusResponse> checkStatus(
+    String pipelineUuid,
+    RunCodeRequestWrapper request,
+  ) {
+    return _runSafely(() => createClient(request.sdk)
         .checkStatus(grpc.CheckStatusRequest(pipelineUuid: pipelineUuid))
         .then(
           (response) => CheckStatusResponse(_toClientStatus(response.status)),
         ));
   }
 
   @override
-  Future<OutputResponse> getCompileOutput(String pipelineUuid) {
-    return _runSafely(() => _client
+  Future<OutputResponse> getCompileOutput(
+    String pipelineUuid,
+    RunCodeRequestWrapper request,
+  ) {
+    return _runSafely(() => createClient(request.sdk)
         .getCompileOutput(
           grpc.GetCompileOutputRequest(pipelineUuid: pipelineUuid),
         )
         .then((response) => OutputResponse(response.output)));
   }
 
   @override
-  Future<OutputResponse> getRunOutput(String pipelineUuid) {
-    return _runSafely(() => _client
+  Future<OutputResponse> getRunOutput(
+    String pipelineUuid,
+    RunCodeRequestWrapper request,
+  ) {
+    return _runSafely(() => createClient(request.sdk)
         .getRunOutput(grpc.GetRunOutputRequest(pipelineUuid: pipelineUuid))
         .then((response) => OutputResponse(response.output)));
   }
 
   @override
-  Future<OutputResponse> getRunErrorOutput(String pipelineUuid) {
-    return _runSafely(() => _client
+  Future<OutputResponse> getRunErrorOutput(
+    String pipelineUuid,
+    RunCodeRequestWrapper request,
+  ) {
+    return _runSafely(() => createClient(request.sdk)
         .getRunError(grpc.GetRunErrorRequest(pipelineUuid: pipelineUuid))
         .then((response) => OutputResponse(response.output)));
   }

playground/frontend/lib/modules/editor/repository/code_repository/code_repository.dart

@@ -38,7 +38,7 @@ class CodeRepository {
       yield RunCodeResult(status: RunCodeStatus.preparation);
       var runCodeResponse = await _client.runCode(request);
       final pipelineUuid = runCodeResponse.pipelineUuid;
-      yield* _checkPipelineExecution(pipelineUuid);
+      yield* _checkPipelineExecution(pipelineUuid, request);
     } on RunCodeError catch (error) {
       yield RunCodeResult(
         status: RunCodeStatus.unknownError,
@@ -48,47 +48,53 @@ class CodeRepository {
   }
 
   Stream<RunCodeResult> _checkPipelineExecution(
-    String pipelineUuid, {
+    String pipelineUuid,
+    RunCodeRequestWrapper request, {
     RunCodeResult? prevResult,
   }) async* {
-    final statusResponse = await _client.checkStatus(pipelineUuid);
+    final statusResponse = await _client.checkStatus(pipelineUuid, request);
     final result = await _getPipelineResult(
       pipelineUuid,
       statusResponse.status,
       prevResult,
+      request,
     );
     yield result;
     if (!result.isFinished) {
       await Future.delayed(kPipelineCheckDelay);
-      yield* _checkPipelineExecution(pipelineUuid, prevResult: result);
+      yield* _checkPipelineExecution(pipelineUuid, request, prevResult: result);
     }
   }
 
   Future<RunCodeResult> _getPipelineResult(
     String pipelineUuid,
     RunCodeStatus status,
     RunCodeResult? prevResult,
+    RunCodeRequestWrapper request,
   ) async {
     final prevOutput = prevResult?.output ?? '';
     switch (status) {
       case RunCodeStatus.compileError:
-        final compileOutput = await _client.getCompileOutput(pipelineUuid);
+        final compileOutput = await _client.getCompileOutput(
+          pipelineUuid,
+          request,
+        );
         return RunCodeResult(status: status, output: compileOutput.output);
       case RunCodeStatus.timeout:
         return RunCodeResult(status: status, errorMessage: kTimeoutErrorText);
       case RunCodeStatus.runError:
-        final output = await _client.getRunErrorOutput(pipelineUuid);
+        final output = await _client.getRunErrorOutput(pipelineUuid, request);
         return RunCodeResult(status: status, output: output.output);
       case RunCodeStatus.unknownError:
         return RunCodeResult(status: status, errorMessage: kUnknownErrorText);
       case RunCodeStatus.executing:
-        final output = await _client.getRunOutput(pipelineUuid);
+        final output = await _client.getRunOutput(pipelineUuid, request);
         return RunCodeResult(
           status: status,
           output: prevOutput + output.output,
         );
       case RunCodeStatus.finished:
-        final output = await _client.getRunOutput(pipelineUuid);
+        final output = await _client.getRunOutput(pipelineUuid, request);
         return RunCodeResult(
             status: status, output: prevOutput + output.output);
       default:

playground/frontend/lib/modules/examples/components/example_list/expansion_panel_item.dart

@@ -36,8 +36,10 @@ class ExpansionPanelItem extends StatelessWidget {
         child: GestureDetector(
           onTap: () async {
             if (playgroundState.selectedExample != example) {
-              final exampleWithInfo =
-                  await exampleState.loadExampleInfo(example);
+              final exampleWithInfo = await exampleState.loadExampleInfo(
+                example,
+                playgroundState.sdk,
+              );
               playgroundState.setExample(exampleWithInfo);
             }
           },

playground/frontend/lib/modules/examples/repositories/example_client/grpc_example_client.dart

@@ -17,8 +17,8 @@
  */
 
 import 'package:grpc/grpc_web.dart';
+import 'package:playground/api/iis_workaround_channel.dart';
 import 'package:playground/api/v1/api.pbgrpc.dart' as grpc;
-import 'package:playground/config.g.dart';
 import 'package:playground/modules/editor/repository/code_repository/code_client/output_response.dart';
 import 'package:playground/modules/examples/models/category_model.dart';
 import 'package:playground/modules/examples/models/example_model.dart';
@@ -30,22 +30,23 @@ import 'package:playground/modules/examples/repositories/models/get_list_of_exam
 import 'package:playground/modules/sdk/models/sdk.dart';
 
 class GrpcExampleClient implements ExampleClient {
-  late final GrpcWebClientChannel _channel;
-  late final grpc.PlaygroundServiceClient _client;
-
-  GrpcExampleClient() {
-    _channel = GrpcWebClientChannel.xhr(
-      Uri.parse(kApiClientURL),
+  grpc.PlaygroundServiceClient createClient(SDK? sdk) {
+    String apiClientURL = SDK.java.getRoute;
+    // if (sdk != null) {
+    //   apiClientURL = sdk.getRoute;
+    // }
+    IisWorkaroundChannel channel = IisWorkaroundChannel.xhr(
+      Uri.parse(apiClientURL),
     );
-    _client = grpc.PlaygroundServiceClient(_channel);
+    return grpc.PlaygroundServiceClient(channel);
   }
 
   @override
   Future<GetListOfExampleResponse> getListOfExamples(
     GetListOfExamplesRequestWrapper request,
   ) {
     return _runSafely(
-      () => _client
+      () => createClient(request.sdk)
           .getPrecompiledObjects(
               _getListOfExamplesRequestToGrpcRequest(request))
           .then((response) => GetListOfExampleResponse(
@@ -56,7 +57,7 @@ class GrpcExampleClient implements ExampleClient {
   @override
   Future<GetExampleResponse> getExample(GetExampleRequestWrapper request) {
     return _runSafely(
-      () => _client
+      () => createClient(request.sdk)
           .getPrecompiledObjectCode(_getExampleRequestToGrpcRequest(request))
           .then((response) => GetExampleResponse(response.code)),
     );
@@ -65,7 +66,7 @@ class GrpcExampleClient implements ExampleClient {
   @override
   Future<OutputResponse> getExampleOutput(GetExampleRequestWrapper request) {
     return _runSafely(
-      () => _client
+      () => createClient(request.sdk)
           .getPrecompiledObjectOutput(_getExampleRequestToGrpcRequest(request))
           .then((response) => OutputResponse(response.output)),
     );

playground/frontend/lib/modules/examples/repositories/models/get_example_request.dart

@@ -16,8 +16,11 @@
  * limitations under the License.
  */
 
+import 'package:playground/modules/sdk/models/sdk.dart';
+
 class GetExampleRequestWrapper {
   final String path;
+  final SDK sdk;
 
-  GetExampleRequestWrapper(this.path);
+  GetExampleRequestWrapper(this.path, this.sdk);
 }

playground/frontend/lib/modules/sdk/models/sdk.dart

@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+import 'package:playground/config.g.dart';
+
 enum SDK {
   java,
   go,
@@ -37,3 +39,20 @@ extension SDKToString on SDK {
     }
   }
 }
+
+extension SdkToRoute on SDK {
+  String get getRoute {
+    switch (this) {
+      case SDK.java:
+        return kApiJavaClientURL;
+      case SDK.go:
+        return kApiGoClientURL;
+      case SDK.python:
+        return kApiPythonClientURL;
+      case SDK.scio:
+        return kApiScioClientURL;
+      default:
+        return '';
+    }
+  }
+}