-
Notifications
You must be signed in to change notification settings - Fork 171
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix: consolidate timeSkew functions and link better into CoinJoinService
- Loading branch information
1 parent
d93d0aa
commit c904b14
Showing
5 changed files
with
88 additions
and
47 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,58 @@ | ||
| package de.schildbach.wallet.util | ||
|
|
||
| import org.dash.wallet.common.util.Constants | ||
| import org.dash.wallet.common.util.head | ||
| import java.net.DatagramPacket | ||
| import java.net.DatagramSocket | ||
| import java.net.InetAddress | ||
| import kotlin.math.abs | ||
|
|
||
| private fun queryNtpTime(server: String): Long? { | ||
| try { | ||
| val address = InetAddress.getByName(server) | ||
| val message = ByteArray(48) | ||
| message[0] = 0b00100011 // NTP mode client (3) and version (4) | ||
|
|
||
| val socket = DatagramSocket().apply { | ||
| soTimeout = 3000 // Set timeout to 3000ms | ||
| } | ||
|
|
||
| val request = DatagramPacket(message, message.size, address, 123) | ||
| socket.send(request) // Send request | ||
|
|
||
| // Receive response | ||
| val response = DatagramPacket(message, message.size) | ||
| socket.receive(response) | ||
|
|
||
| // Timestamp starts at byte 40 of the received packet and is four bytes, | ||
| // or two words, long. First byte is the high-order byte of the integer; | ||
| // the last byte is the low-order byte. The high word is the seconds field, | ||
| // and the low word is the fractional field. | ||
| val seconds = message[40].toLong() and 0xff shl 24 or | ||
| (message[41].toLong() and 0xff shl 16) or | ||
| (message[42].toLong() and 0xff shl 8) or | ||
| (message[43].toLong() and 0xff) | ||
|
|
||
| // Convert seconds to milliseconds and adjust from 1900 to epoch (1970) | ||
| return (seconds - 2208988800L) * 1000 | ||
| } catch (e: Exception) { | ||
| e.printStackTrace() | ||
| } | ||
| return null | ||
| } | ||
|
|
||
| suspend fun getTimeSkew(): Long { | ||
| var networkTime = queryNtpTime("pool.ntp.org") | ||
| if (networkTime == null) { | ||
| var result = Constants.HTTP_CLIENT.head("https://www.dash.org/") | ||
|
|
||
| networkTime = result.headers.getDate("date")?.time | ||
| if (networkTime == null) { | ||
| result = Constants.HTTP_CLIENT.head("https://insight.dash.org/insight") | ||
| networkTime = result.headers.getDate("date")?.time | ||
| } | ||
| requireNotNull(networkTime) | ||
| } | ||
| val systemTimeMillis = System.currentTimeMillis() | ||
| return abs(systemTimeMillis - networkTime) | ||
| } |