@@ -6,6 +6,9 @@ import { Configuration } from "./config"
6
6
import { URL , URLSearchParams } from "url"
7
7
import { Client } from "./client"
8
8
9
+ import { context } from "@opentelemetry/api"
10
+ import { suppressTracing } from "@opentelemetry/core"
11
+
9
12
const REDIRECT_COUNT = Symbol ( "redirect-count" )
10
13
11
14
type TransmitterRequestOptions = {
@@ -101,32 +104,34 @@ export class Transmitter {
101
104
}
102
105
103
106
public request ( requestOptions : TransmitterRequestOptions ) {
104
- const { method, params = new URLSearchParams ( ) , onError } = requestOptions
107
+ context . with ( suppressTracing ( context . active ( ) ) , ( ) => {
108
+ const { method, params = new URLSearchParams ( ) , onError } = requestOptions
105
109
106
- const initialOptions = {
107
- method,
108
- ...this . urlRequestOptions ( )
109
- }
110
+ const initialOptions = {
111
+ method,
112
+ ...this . urlRequestOptions ( )
113
+ }
110
114
111
- const { protocol, path } = initialOptions
115
+ const { protocol, path } = initialOptions
112
116
113
- const options = {
114
- ...initialOptions ,
115
- ...this . paramsRequestOptions ( path ?? "" , params ) ,
116
- ...this . bodyRequestOptions ( method ) ,
117
- ...this . caRequestOptions ( protocol ?? "" )
118
- }
117
+ const options = {
118
+ ...initialOptions ,
119
+ ...this . paramsRequestOptions ( path ?? "" , params ) ,
120
+ ...this . bodyRequestOptions ( method ) ,
121
+ ...this . caRequestOptions ( protocol ?? "" )
122
+ }
119
123
120
- const module = this . requestModule ( protocol ?? "" )
124
+ const module = this . requestModule ( protocol ?? "" )
121
125
122
- const callback = this . handleRedirectsCallback ( requestOptions )
126
+ const callback = this . handleRedirectsCallback ( requestOptions )
123
127
124
- const request = module . request ( options , callback )
128
+ const request = module . request ( options , callback )
125
129
126
- request . on ( "error" , onError )
130
+ request . on ( "error" , onError )
127
131
128
- this . writeRequest ( method , request )
129
- request . end ( )
132
+ this . writeRequest ( method , request )
133
+ request . end ( )
134
+ } )
130
135
}
131
136
132
137
private handleRedirectsCallback ( {
0 commit comments