2021-11-01 17:15:23 +01:00
|
|
|
<script>
|
2024-04-24 18:47:18 +02:00
|
|
|
import { onMount } from "svelte";
|
2021-11-01 17:15:23 +01:00
|
|
|
import { formatDataVolume, formatThousands } from "../util/Formatting.svelte"
|
|
|
|
|
|
|
|
export let file = {
|
|
|
|
id: "",
|
|
|
|
views: 0,
|
|
|
|
size: 0,
|
|
|
|
downloads: 0,
|
|
|
|
bandwidth_used: 0,
|
2023-05-19 21:45:42 +02:00
|
|
|
bandwidth_used_paid: 0,
|
2021-11-01 17:15:23 +01:00
|
|
|
}
|
2024-04-24 18:47:18 +02:00
|
|
|
export let view_token = ""
|
2021-11-01 17:15:23 +01:00
|
|
|
|
|
|
|
let views = 0
|
|
|
|
let downloads = 0
|
|
|
|
let size = 0
|
|
|
|
let socket = null
|
|
|
|
let error_msg = ""
|
|
|
|
|
|
|
|
$: update_stats(file.id)
|
2021-12-13 16:33:23 +01:00
|
|
|
let update_stats = async id => {
|
2021-11-01 22:32:46 +01:00
|
|
|
if (id === "" || id == "demo") {
|
2021-11-01 17:15:23 +01:00
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
views = file.views
|
|
|
|
if (file.size === 0) {
|
|
|
|
downloads = file.downloads
|
|
|
|
} else {
|
2022-02-08 22:24:14 +01:00
|
|
|
downloads = Math.round((file.bandwidth_used + file.bandwidth_used_paid) / file.size)
|
2021-11-01 17:15:23 +01:00
|
|
|
}
|
|
|
|
size = file.size
|
|
|
|
|
2024-04-24 18:47:18 +02:00
|
|
|
send_watch_command()
|
|
|
|
}
|
|
|
|
|
|
|
|
const send_watch_command = () => {
|
2024-04-25 11:15:24 +02:00
|
|
|
if (socket !== null && socket.readyState === WebSocket.OPEN) {
|
2024-04-24 18:47:18 +02:00
|
|
|
socket.send(
|
|
|
|
JSON.stringify(
|
|
|
|
{cmd: "watch_file", a1: file.id, a2: view_token}
|
|
|
|
)
|
|
|
|
)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
const init_socket = () => {
|
2024-04-25 11:15:24 +02:00
|
|
|
if (socket !== null && socket.readyState !== WebSocket.CLOSED) {
|
2024-04-24 18:47:18 +02:00
|
|
|
return
|
2021-11-01 17:15:23 +01:00
|
|
|
}
|
|
|
|
|
2024-04-24 18:47:18 +02:00
|
|
|
console.log("initializing socket")
|
|
|
|
socket = new WebSocket(location.origin.replace(/^http/, 'ws') + "/api/file_stats")
|
|
|
|
|
|
|
|
socket.onopen = () => send_watch_command()
|
2021-11-01 17:15:23 +01:00
|
|
|
socket.onmessage = msg => {
|
|
|
|
let j = JSON.parse(msg.data)
|
|
|
|
console.debug("WS update", j)
|
|
|
|
|
|
|
|
error_msg = ""
|
|
|
|
views = j.views
|
|
|
|
if (file.size === 0) {
|
|
|
|
downloads = j.downloads
|
|
|
|
} else {
|
2021-11-22 21:34:14 +01:00
|
|
|
downloads = Math.round((j.bandwidth + j.bandwidth_paid) / file.size)
|
2021-11-01 17:15:23 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
socket.onerror = err => {
|
|
|
|
if (socket === null) {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
console.error("WS error", err)
|
|
|
|
socket.close()
|
|
|
|
socket = null
|
|
|
|
error_msg = "failed to get stats, retrying..."
|
|
|
|
|
2024-04-24 18:47:18 +02:00
|
|
|
window.setTimeout(init_socket, 2000)
|
2021-11-01 17:15:23 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2024-04-24 18:47:18 +02:00
|
|
|
onMount(() => {
|
|
|
|
init_socket()
|
|
|
|
|
|
|
|
return () => {
|
|
|
|
if (socket !== null) {
|
|
|
|
socket.close()
|
|
|
|
socket = null
|
|
|
|
}
|
|
|
|
}
|
|
|
|
})
|
2021-11-01 17:15:23 +01:00
|
|
|
</script>
|
|
|
|
|
|
|
|
<div>
|
|
|
|
{#if error_msg !== ""}
|
|
|
|
{error_msg}
|
|
|
|
{:else}
|
|
|
|
<div class="label">Views</div>
|
|
|
|
<div class="stat">{formatThousands(views)}</div>
|
|
|
|
<div class="label">Downloads</div>
|
|
|
|
<div class="stat">{formatThousands(downloads)}</div>
|
|
|
|
<div class="label">Size</div>
|
|
|
|
<div class="stat">{formatDataVolume(size, 3)}</div>
|
|
|
|
{/if}
|
|
|
|
</div>
|
|
|
|
|
|
|
|
<style>
|
|
|
|
.label {
|
|
|
|
text-align: left;
|
|
|
|
padding-left: 10px;
|
|
|
|
font-size: 0.8em;
|
|
|
|
line-height: 0.7em;
|
|
|
|
margin-top: 0.5em;
|
|
|
|
}
|
|
|
|
.stat {
|
|
|
|
text-align: center;
|
|
|
|
}
|
|
|
|
</style>
|