summaryrefslogtreecommitdiff
path: root/cli/ops/tls.rs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/ops/tls.rs')
-rw-r--r--cli/ops/tls.rs32
1 files changed, 9 insertions, 23 deletions
diff --git a/cli/ops/tls.rs b/cli/ops/tls.rs
index 8c648faaf..af507ce6a 100644
--- a/cli/ops/tls.rs
+++ b/cli/ops/tls.rs
@@ -2,7 +2,6 @@
use super::dispatch_json::{Deserialize, JsonOp, Value};
use super::io::StreamResource;
use crate::op_error::OpError;
-use crate::ops::json_op;
use crate::resolve_addr::resolve_addr;
use crate::state::State;
use deno_core::*;
@@ -34,18 +33,9 @@ use webpki::DNSNameRef;
use webpki_roots;
pub fn init(i: &mut Isolate, s: &State) {
- i.register_op(
- "connect_tls",
- s.core_op(json_op(s.stateful_op(op_connect_tls))),
- );
- i.register_op(
- "listen_tls",
- s.core_op(json_op(s.stateful_op(op_listen_tls))),
- );
- i.register_op(
- "accept_tls",
- s.core_op(json_op(s.stateful_op(op_accept_tls))),
- );
+ i.register_op("op_connect_tls", s.stateful_json_op(op_connect_tls));
+ i.register_op("op_listen_tls", s.stateful_json_op(op_listen_tls));
+ i.register_op("op_accept_tls", s.stateful_json_op(op_accept_tls));
}
#[derive(Deserialize)]
@@ -281,15 +271,6 @@ enum AcceptTlsState {
Done,
}
-/// Simply accepts a TLS connection.
-pub fn accept_tls(state: &State, rid: ResourceId) -> AcceptTls {
- AcceptTls {
- accept_state: AcceptTlsState::Pending,
- rid,
- state: state.clone(),
- }
-}
-
/// A future representing state of accepting a TLS connection.
pub struct AcceptTls {
accept_state: AcceptTlsState,
@@ -347,7 +328,12 @@ fn op_accept_tls(
let rid = args.rid as u32;
let state = state.clone();
let op = async move {
- let (tcp_stream, _socket_addr) = accept_tls(&state.clone(), rid).await?;
+ let accept_fut = AcceptTls {
+ accept_state: AcceptTlsState::Pending,
+ rid,
+ state: state.clone(),
+ };
+ let (tcp_stream, _socket_addr) = accept_fut.await?;
let local_addr = tcp_stream.local_addr()?;
let remote_addr = tcp_stream.peer_addr()?;
let tls_acceptor = {