@@ -48,7 +48,6 @@ pub struct Config {
48
48
pub history_url : Url ,
49
49
pub relayer_urls : Vec < Url > ,
50
50
pub publisher_id : u32 ,
51
- pub authorization_token : String ,
52
51
pub publish_keypair_path : PathBuf ,
53
52
#[ serde( with = "humantime_serde" , default = "default_publish_interval" ) ]
54
53
pub publish_interval_duration : Duration ,
@@ -87,19 +86,13 @@ impl RelayerSender {
87
86
88
87
async fn connect_to_relayer (
89
88
mut url : Url ,
90
- token : & str ,
91
89
) -> Result < (
92
90
SplitSink < WebSocketStream < MaybeTlsStream < TcpStream > > , TungsteniteMessage > ,
93
91
SplitStream < WebSocketStream < MaybeTlsStream < TcpStream > > > ,
94
92
) > {
95
93
tracing:: info!( "connecting to the relayer at {}" , url) ;
96
94
url. set_path ( "/v1/transaction" ) ;
97
95
let mut req = url. clone ( ) . into_client_request ( ) ?;
98
- let headers = req. headers_mut ( ) ;
99
- headers. insert (
100
- "Authorization" ,
101
- HeaderValue :: from_str ( & format ! ( "Bearer {}" , token) ) ?,
102
- ) ;
103
96
let ( ws_stream, _) = connect_async_with_config ( req, None , true ) . await ?;
104
97
Ok ( ws_stream. split ( ) )
105
98
}
@@ -113,8 +106,7 @@ async fn connect_to_relayers(
113
106
let mut relayer_senders = Vec :: new ( ) ;
114
107
let mut relayer_receivers = Vec :: new ( ) ;
115
108
for url in config. relayer_urls . clone ( ) {
116
- let ( relayer_sender, relayer_receiver) =
117
- connect_to_relayer ( url, & config. authorization_token ) . await ?;
109
+ let ( relayer_sender, relayer_receiver) = connect_to_relayer ( url) . await ?;
118
110
relayer_senders. push ( relayer_sender) ;
119
111
relayer_receivers. push ( relayer_receiver) ;
120
112
}
0 commit comments