diff options
Diffstat (limited to 'src/gateway')
| -rw-r--r-- | src/gateway/prep.rs | 6 | ||||
| -rw-r--r-- | src/gateway/shard.rs | 4 |
2 files changed, 5 insertions, 5 deletions
diff --git a/src/gateway/prep.rs b/src/gateway/prep.rs index 6a415f8..8e04df4 100644 --- a/src/gateway/prep.rs +++ b/src/gateway/prep.rs @@ -1,3 +1,4 @@ +use chrono::{Duration, UTC}; use serde_json::Value; use std::sync::mpsc::{ Receiver as MpscReceiver, @@ -8,7 +9,6 @@ use std::sync::{Arc, Mutex}; use std::time::{Duration as StdDuration, Instant}; use std::{env, thread}; use super::{GatewayError, GatewayStatus}; -use time::{self, Duration}; use websocket::client::request::Url as RequestUrl; use websocket::client::{Receiver, Sender}; use websocket::result::WebSocketError as WsError; @@ -81,7 +81,7 @@ pub fn keepalive(interval: u64, mut sender: Sender<WebSocketStream>, channel: &MpscReceiver<GatewayStatus>) { let mut base_interval = Duration::milliseconds(interval as i64); - let mut next_tick = time::get_time() + base_interval; + let mut next_tick = UTC::now() + base_interval; let mut last_sequence = 0; let mut last_successful = false; @@ -110,7 +110,7 @@ pub fn keepalive(interval: u64, } } - if time::get_time() >= next_tick { + if UTC::now() >= next_tick { // If the last heartbeat didn't receive an acknowledgement, then // shutdown and auto-reconnect. if !*last_ack.lock().unwrap() { diff --git a/src/gateway/shard.rs b/src/gateway/shard.rs index 7790cc6..343aa06 100644 --- a/src/gateway/shard.rs +++ b/src/gateway/shard.rs @@ -1,3 +1,4 @@ +use chrono::UTC; use std::io::Write; use std::net::Shutdown; use std::sync::mpsc::{self, Sender as MpscSender}; @@ -6,7 +7,6 @@ use std::thread::{self, Builder as ThreadBuilder}; use std::time::{Duration as StdDuration, Instant}; use std::mem; use super::{GatewayError, GatewayStatus, prep}; -use time; use websocket::client::{Client as WsClient, Sender, Receiver}; use websocket::message::Message as WsMessage; use websocket::result::WebSocketError; @@ -788,7 +788,7 @@ impl Shard { fn update_presence(&self) { let (ref game, status, afk) = self.current_presence; - let now = time::get_time().sec as u64; + let now = UTC::now().timestamp() as u64; let msg = json!({ "op": OpCode::StatusUpdate.num(), |