1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
/*
This file is part of keks-meet (https://codeberg.org/metamuffin/keks-meet)
which is licensed under the GNU Affero General Public License (version 3); see /COPYING.
Copyright (C) 2022 metamuffin <metamuffin@disroot.org>
*/
/// <reference lib="dom" />
import { display_filesize, ebutton, ediv, espan, sleep } from "../helper.ts";
import { log } from "../logger.ts";
import { StreamDownload } from "../sw/download_stream.ts";
import { LocalResource, ResourceHandlerDecl } from "./mod.ts";
const MAX_CHUNK_SIZE = 1 << 15;
export const resource_file: ResourceHandlerDecl = {
kind: "file",
new_remote(info, user, enable) {
const download_button = ebutton("Download", {
onclick: self => {
enable()
self.textContent = "Downloading…"
self.disabled = true
}
})
return {
info,
el: ediv({},
espan(`File: ${JSON.stringify(info.label)} (${display_filesize(info.size!)})`),
download_button,
),
on_statechange(_s) { },
on_enable(channel, disable) {
if (!(channel instanceof RTCDataChannel)) throw new Error("not a data channel");
const download = StreamDownload(
info.size!, info.label ?? "file",
position => {
display.status = `${display_filesize(position)} / ${display_filesize(info.size!)}`
}
);
const display = transfer_status_el()
this.el.appendChild(display.el)
channel.onopen = _ev => {
log("dc", `${user.display_name}: channel open`);
}
channel.onerror = _ev => {
log("dc", `${user.display_name}: channel error`);
}
channel.onclose = _ev => {
log("dc", `${user.display_name}: channel closed`);
this.el.removeChild(display.el)
download.close()
download_button.disabled = false
download_button.textContent = "Download"
disable()
}
channel.onmessage = ev => {
// console.log(ev.data);
download.write(ev.data)
}
}
}
}
}
export function create_file_res(): Promise<LocalResource> {
const picker = document.createElement("input")
picker.type = "file"
picker.click()
return new Promise((resolve, reject) => {
picker.addEventListener("change", () => {
if (!picker.files) return reject()
const f = picker.files.item(0)
if (!f) return reject()
resolve(file_res_inner(f))
})
})
}
function file_res_inner(file: File): LocalResource {
const transfers_el = ediv({})
return {
info: { kind: "file", id: Math.random().toString(), label: file.name, size: file.size },
destroy() { },
el: ediv({ class: "file" },
espan(`Sharing file: ${JSON.stringify(file.name)}`),
transfers_el
),
on_request(user, create_channel) {
const channel = create_channel()
channel.bufferedAmountLowThreshold = 1 << 16 // this appears to be the buffer size in firefox for reading files
const reader = file.stream().getReader()
console.log(`${user.display_name} started transfer`);
const display = transfer_status_el()
transfers_el.appendChild(display.el)
display.status = "Waiting for data channel to open…"
let position = 0
const finish = async () => {
while (channel.bufferedAmount) {
display.status = `Draining buffers… (buffer: ${channel.bufferedAmount})`
await sleep(10)
}
display.status = "Waiting for the channel to close…"
return channel.close()
}
const feed = async () => {
const { value: chunk, done }: { value?: Uint8Array, done: boolean } = await reader.read()
if (done) return await finish()
if (!chunk) return console.warn("no chunk");
position += chunk.length
for (let i = 0; i < chunk.length; i += MAX_CHUNK_SIZE) {
channel.send(chunk.slice(i, Math.min(i + MAX_CHUNK_SIZE, chunk.length)))
}
display.status = `${display_filesize(position)} / ${display_filesize(file.size!)}; (buffer=${display_filesize(channel.bufferedAmount)})`
}
const feed_until_full = async () => {
// this has to do with a bad browser implementation
// https://github.com/w3c/webrtc-pc/issues/1979
while (channel.bufferedAmount < channel.bufferedAmountLowThreshold * 2 && channel.readyState == "open") {
await feed()
}
}
channel.onbufferedamountlow = () => feed_until_full()
channel.onopen = _ev => {
display.status = "Buffering…"
log("dc", `${user.display_name}: channel open`);
feed_until_full()
}
channel.onerror = _ev => {
log("dc", `${user.display_name}: channel error`);
}
channel.onclosing = _ev => {
display.status = "Channel closing…"
}
channel.onclose = _ev => {
log("dc", `${user.display_name}: channel closed`);
transfers_el.removeChild(display.el)
}
return channel
}
}
}
function transfer_status_el() {
const status = espan("…")
return {
el: ediv({ class: "progress" }, status),
set status(s: string) {
status.textContent = s
}
}
}
|
