summaryrefslogtreecommitdiff
path: root/gateway/src
diff options
context:
space:
mode:
Diffstat (limited to 'gateway/src')
-rw-r--r--gateway/src/connection/stream.rs2
-rw-r--r--gateway/src/connection/utils.rs2
-rw-r--r--gateway/src/management/mod.rs0
-rw-r--r--gateway/src/payloads/events/resume.rs0
-rw-r--r--gateway/src/shard/actions.rs2
-rw-r--r--gateway/src/shard/connection.rs6
6 files changed, 6 insertions, 6 deletions
diff --git a/gateway/src/connection/stream.rs b/gateway/src/connection/stream.rs
index 767feec..5a12daf 100644
--- a/gateway/src/connection/stream.rs
+++ b/gateway/src/connection/stream.rs
@@ -2,7 +2,7 @@ use crate::{error::GatewayError, payloads::gateway::BaseMessage};
use super::Connection;
use futures::{FutureExt, Sink, SinkExt, Stream, StreamExt};
-use log::info;
+use common::log::info;
use serde::Serialize;
use std::{
pin::Pin,
diff --git a/gateway/src/connection/utils.rs b/gateway/src/connection/utils.rs
index fb07229..bb425da 100644
--- a/gateway/src/connection/utils.rs
+++ b/gateway/src/connection/utils.rs
@@ -1,6 +1,6 @@
use std::str::from_utf8;
use tokio_tungstenite::tungstenite::Message;
-use log::info;
+use common::log::info;
use crate::error::GatewayError;
diff --git a/gateway/src/management/mod.rs b/gateway/src/management/mod.rs
deleted file mode 100644
index e69de29..0000000
--- a/gateway/src/management/mod.rs
+++ /dev/null
diff --git a/gateway/src/payloads/events/resume.rs b/gateway/src/payloads/events/resume.rs
deleted file mode 100644
index e69de29..0000000
--- a/gateway/src/payloads/events/resume.rs
+++ /dev/null
diff --git a/gateway/src/shard/actions.rs b/gateway/src/shard/actions.rs
index 86e5f98..b6ef038 100644
--- a/gateway/src/shard/actions.rs
+++ b/gateway/src/shard/actions.rs
@@ -1,7 +1,7 @@
use std::env;
use futures::SinkExt;
-use log::{debug, error, info};
+use common::log::{debug, error, info};
use serde::Serialize;
use serde_json::Value;
use std::fmt::Debug;
diff --git a/gateway/src/shard/connection.rs b/gateway/src/shard/connection.rs
index f31a89b..2f7f2d5 100644
--- a/gateway/src/shard/connection.rs
+++ b/gateway/src/shard/connection.rs
@@ -7,8 +7,8 @@ use crate::{connection::Connection, error::GatewayError, payloads::{
use super::{state::ConnectionState, ConnectionWithState, Shard};
use futures::StreamExt;
-use log::{error, info};
-use tokio::{select, time::{Instant, sleep}};
+use common::{log::{error, info}};
+use tokio::{select, time::{Instant, interval_at, sleep}};
impl Shard {
pub async fn start(self: &mut Self) {
@@ -159,7 +159,7 @@ impl Shard {
info!("Server hello received");
self._util_set_seq(msg.sequence);
if let Some(conn) = &mut self.connection {
- conn.state.interval = Some(tokio::time::interval_at(
+ conn.state.interval = Some(interval_at(
Instant::now() + Duration::from_millis(msg.data.heartbeat_interval),
Duration::from_millis(msg.data.heartbeat_interval),
));