leyoda/rqbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge pull request #218 from ikatson/mediaserver-response-proper-st

Browse source 
Mediaserver response proper st
This commit is contained in:
Igor Katson 2024-08-27 12:05:12 +01:00 • committed by GitHub
commit 78ee947d44
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 14 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

3
Makefile
View file

@ -111,6 +111,9 @@ create-target-docker:
cp -lf target/armv7-unknown-linux-musleabihf/release-github/rqbit target/docker/linux/arm/v7/rqbit && \
cp docker/Dockerfile target/Docker
@PHONE: docker-build-prereqs
docker-build-prereqs: release-linux-aarch64 release-linux-x86_64 release-linux-armv7
@PHONY: docker-build
docker-build: create-target-docker
docker build \

22
crates/upnp-serve/src/ssdp.rs
View file

@ -113,7 +113,6 @@ impl SsdpRunner {
#[cfg(not(target_os = "windows"))]
sock.set_reuse_port(true)
.context("error setting SO_REUSEPORT")?;
#[cfg(target_os = "windows")]
sock.set_reuse_address(true)
.context("error setting SO_REUSEADDR")?;
@ -153,10 +152,9 @@ USN: {usn}::{kind}\r
)
}
fn generate_ssdp_discover_response(&self) -> String {
fn generate_ssdp_discover_response(&self, st: &str) -> String {
let location = &self.opts.description_http_location;
let usn = &self.opts.usn;
let media_server = UPNP_KIND_MEDIASERVER;
let server = &self.opts.server_string;
format!(
"HTTP/1.1 200 OK\r
@ -164,8 +162,8 @@ Cache-Control: max-age=75\r
Ext: \r
Location: {location}\r
Server: {server}\r
St: {media_server}\r
Usn: {usn}::{media_server}\r
St: {st}\r
Usn: {usn}::{st}\r
Content-Length: 0\r\n\r\n"
)
}
@ -214,12 +212,14 @@ Content-Length: 0\r\n\r\n"
return Ok(());
}
let response = self.generate_ssdp_discover_response();
trace!(content = response, ?addr, "sending SSDP discover response");
self.socket
.send_to(response.as_bytes(), addr)
.await
.context("error sending")?;
if let Ok(st) = std::str::from_utf8(msg.st) {
let response = self.generate_ssdp_discover_response(st);
trace!(content = response, ?addr, "sending SSDP discover response");
self.socket
.send_to(response.as_bytes(), addr)
.await
.context("error sending")?;
}
Ok(())
}