Skip to content

Commit 9742119

Browse files
committed
remove token for symbols endpoint
1 parent cdd2caf commit 9742119

File tree

1 file changed

+4
-9
lines changed

1 file changed

+4
-9
lines changed

src/agent/services/lazer_exporter.rs

Lines changed: 4 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -105,20 +105,13 @@ struct SymbolResponse {
105105
pub hermes_id: Option<String>,
106106
}
107107

108-
async fn fetch_symbols(
109-
history_url: &Url,
110-
token: &str,
111-
) -> Result<Vec<SymbolResponse>> {
108+
async fn fetch_symbols(history_url: &Url) -> Result<Vec<SymbolResponse>> {
112109
let mut url = history_url.clone();
113110
url.set_scheme("http").unwrap();
114111
url.set_path("/history/v1/symbols");
115112
let client = Client::new();
116113
let response = client
117114
.get(url)
118-
.header(
119-
"Authorization",
120-
HeaderValue::from_str(&format!("Bearer {}", token))?,
121-
)
122115
.send()
123116
.await?
124117
.text()
@@ -129,6 +122,7 @@ async fn fetch_symbols(
129122
#[instrument(skip(config, state))]
130123
pub fn lazer_exporter(config: Config, state: Arc<state::State>) -> Vec<JoinHandle<()>>
131124
{
125+
// TODO: add loop to handle relayer failure/retry
132126
let mut handles = Vec::new();
133127
handles.push(tokio::spawn(lazer_exporter::lazer_exporter(config.clone(), state)));
134128
handles
@@ -151,7 +145,7 @@ mod lazer_exporter {
151145
S: Send + Sync + 'static,
152146
{
153147
// TODO: Re-fetch on an interval?
154-
let lazer_symbols: HashMap<String, SymbolResponse> = match fetch_symbols(&config.history_url, &config.authorization_token).await {
148+
let lazer_symbols: HashMap<String, SymbolResponse> = match fetch_symbols(&config.history_url).await {
155149
Ok(symbols) => symbols.into_iter().filter_map(|symbol| {
156150
symbol.hermes_id.clone().map(|id| (id, symbol))
157151
}).collect(),
@@ -201,6 +195,7 @@ mod lazer_exporter {
201195
tracing::error!("Error receiving message from at relayer {relayer_url}: {e:?}");
202196
}
203197
None => {
198+
// TODO: Probably still appropriate to return here, but retry in caller.
204199
tracing::error!("relayer connection closed");
205200
return;
206201
}

0 commit comments

Comments
 (0)