feat(envoy-client): fully flesh out tunnel impl

.github/workflows/pkg-pr-new.yaml

@@ -24,4 +24,4 @@ jobs:
           find /tmp/inspector-repack -name '*.map' -delete
           tar czf inspector.tar.gz -C /tmp/inspector-repack .
           rm -rf /tmp/inspector-repack
-      - run: pnpm dlx pkg-pr-new publish 'shared/typescript/*' 'engine/sdks/typescript/runner/' 'engine/sdks/typescript/runner-protocol/' 'rivetkit-typescript/packages/*' --packageManager pnpm --template './examples/*'
+      - run: pnpm dlx pkg-pr-new publish 'shared/typescript/*' 'engine/sdks/typescript/runner/' 'engine/sdks/typescript/runner-protocol/' 'engine/sdks/typescript/envoy-client/' 'engine/sdks/typescript/envoy-protocol/' 'rivetkit-typescript/packages/*' --packageManager pnpm --template './examples/*'

engine/packages/api-peer/src/actors/create.rs

@@ -38,39 +38,3 @@ pub async fn create(
 
 	Ok(CreateResponse { actor: res.actor })
 }
-
-#[tracing::instrument(skip_all)]
-pub async fn create2(
-	ctx: ApiCtx,
-	_path: (),
-	query: CreateQuery,
-	body: CreateRequest,
-) -> Result<CreateResponse> {
-	let namespace = ctx
-		.op(namespace::ops::resolve_for_name_global::Input {
-			name: query.namespace.clone(),
-		})
-		.await?
-		.ok_or_else(|| namespace::errors::Namespace::NotFound.build())?;
-
-	let actor_id = Id::new_v1(ctx.config().dc_label());
-
-	let res = ctx
-		.op(pegboard::ops::actor::create::Input2 {
-			actor_id,
-			namespace_id: namespace.namespace_id,
-			name: body.name.clone(),
-			key: body.key,
-			pool_name: body.runner_name_selector,
-			input: body.input.clone(),
-			crash_policy: body.crash_policy,
-			// NOTE: This can forward if the user attempts to create an actor with a target dc and this dc
-			// ends up forwarding to another.
-			forward_request: true,
-			// api-peer is always creating in its own datacenter
-			datacenter_name: None,
-		})
-		.await?;
-
-	Ok(CreateResponse { actor: res.actor })
-}