138 lines
7.3 KiB
Plaintext
138 lines
7.3 KiB
Plaintext
# This file listens on port 21338 for POST JSON data to apply new metadata to the stream live.
|
|
# Our Denon StagelinQ receiver will send the metadata to this interface.
|
|
# For fun, I tested this code with the port set to 1608 to emulate the OBS Tuna plugin's HTTP interface, and that works well!
|
|
|
|
#metadata_api_port = 1608 # Emulate Tuna API
|
|
|
|
def http_export_meta(~compact=false, ~json5=false, m) =
|
|
j = json()
|
|
list.iter((fun (v) -> j.add(fst(v), (snd(v):string))), m)
|
|
json.stringify(%argsof(json.stringify), j)
|
|
end
|
|
|
|
def setup_harbor_metadata_api(~metadata_api_port=21338, s) =
|
|
id = s.id()
|
|
s = insert_metadata(s)
|
|
|
|
# Handler for fetching metadata
|
|
def on_http_get_metadata(~protocol, ~data, ~headers, uri) =
|
|
m = s.last_metadata() ?? []
|
|
|
|
# remove cover info and link to it instead if existing
|
|
has_cover = list.assoc.mem("metadata_block_picture", m) or list.assoc.mem("coverart", m)
|
|
has_cover_url = list.assoc.mem("cover_url", m)
|
|
if has_cover and not has_cover_url then
|
|
m = list.append(m, [
|
|
("cover_url", "http://icedream-bitwave:#{metadata_api_port}/#{url.encode(id)}/cover")
|
|
])
|
|
end
|
|
|
|
# data = metadata.json.stringify(compact=true, m)
|
|
m = metadata.cover.remove(m)
|
|
data = http_export_meta(compact=true, m)
|
|
|
|
http.response(protocol=protocol, code=200, headers=[
|
|
("access-control-allow-origin","*"),
|
|
("access-control-allow-credentials","true"),
|
|
("access-control-allow-methods","GET,POST"),
|
|
("access-control-allow-headers","Origin,X-Requested-With,Content-Type,Accept,Authorization,access-control-allow-headers,access-control-allow-origin"),
|
|
("content-type","application/json"),
|
|
], data=data)
|
|
end
|
|
|
|
# Handler for fetching current cover art
|
|
def on_http_get_cover(~protocol, ~data, ~headers, uri) =
|
|
m = s.last_metadata() ?? []
|
|
cover = metadata.cover(m) ?? "".{mime="text/plain"}
|
|
if string.length(cover) > 0 then
|
|
http.response(protocol=protocol, code=200, headers=[
|
|
("access-control-allow-origin","*"),
|
|
("access-control-allow-credentials","true"),
|
|
("access-control-allow-methods","GET,POST"),
|
|
("access-control-allow-headers","Origin,X-Requested-With,Content-Type,Accept,Authorization,access-control-allow-headers,access-control-allow-origin"),
|
|
("content-type", cover.mime),
|
|
("content-length", string_of(string.length(cover))),
|
|
], data=string_of(cover))
|
|
else
|
|
http.response(protocol=protocol, code=404, headers=[
|
|
("access-control-allow-origin","*"),
|
|
("access-control-allow-credentials","true"),
|
|
("access-control-allow-methods","GET,POST"),
|
|
("access-control-allow-headers","Origin,X-Requested-With,Content-Type,Accept,Authorization,access-control-allow-headers,access-control-allow-origin"),
|
|
], data="")
|
|
end
|
|
end
|
|
|
|
# Handler for receiving metadata
|
|
def on_http_metadata(~protocol, ~data, ~headers, uri) =
|
|
data = json.parse(default=[
|
|
("data",[("key","value")])
|
|
], data)
|
|
|
|
m = list.assoc(default=[], "data", data)
|
|
|
|
# TODO - we remove cover art for now as it disturbs REKT, this needs fixing
|
|
# m = metadata.cover.remove(m)
|
|
|
|
new_track = if list.assoc.mem("new_track", m) then bool_of_string(string_of(list.assoc("new_track"))) else false end
|
|
|
|
# merge old metadata except for the ones we expect to change
|
|
oldm = s.last_metadata() ?? []
|
|
oldm = if list.assoc.mem("artist", oldm) then list.assoc.remove("artist", oldm) else oldm end
|
|
oldm = if list.assoc.mem("title", oldm) then list.assoc.remove("title", oldm) else oldm end
|
|
oldm = if list.assoc.mem("album", oldm) then list.assoc.remove("album", oldm) else oldm end
|
|
oldm = if list.assoc.mem("publisher", oldm) then list.assoc.remove("publisher", oldm) else oldm end
|
|
oldm = if list.assoc.mem("genre", oldm) then list.assoc.remove("genre", oldm) else oldm end
|
|
oldm = if list.assoc.mem("date", oldm) then list.assoc.remove("date", oldm) else oldm end
|
|
oldm = if list.assoc.mem("tracknumber", oldm) then list.assoc.remove("tracknumber", oldm) else oldm end
|
|
oldm = if list.assoc.mem("comment", oldm) then list.assoc.remove("comment", oldm) else oldm end
|
|
oldm = if list.assoc.mem("track", oldm) then list.assoc.remove("track", oldm) else oldm end
|
|
oldm = if list.assoc.mem("year", oldm) then list.assoc.remove("year", oldm) else oldm end
|
|
oldm = if list.assoc.mem("dj", oldm) then list.assoc.remove("dj", oldm) else oldm end
|
|
oldm = if list.assoc.mem("next", oldm) then list.assoc.remove("next", oldm) else oldm end
|
|
oldm = if list.assoc.mem("apic", oldm) then list.assoc.remove("apic", oldm) else oldm end
|
|
oldm = if list.assoc.mem("metadata_block_picture", oldm) then list.assoc.remove("metadata_block_picture", oldm) else oldm end
|
|
oldm = if list.assoc.mem("coverart", oldm) then list.assoc.remove("coverart", oldm) else oldm end
|
|
oldm = if list.assoc.mem("cover_url", oldm) then list.assoc.remove("cover_url", oldm) else oldm end
|
|
m = list.append(oldm ?? [], m)
|
|
|
|
# set metadata on stream
|
|
s.insert_metadata(new_track=new_track, m)
|
|
|
|
http.response(protocol=protocol, code=200, headers=[
|
|
("allow","POST"),
|
|
("access-control-allow-origin","*"),
|
|
("access-control-allow-credentials","true"),
|
|
("access-control-allow-methods","GET,POST"),
|
|
("access-control-allow-headers","Origin,X-Requested-With,Content-Type,Accept,Authorization,access-control-allow-headers,access-control-allow-origin"),
|
|
("content-type","application/json"),
|
|
], data=json.stringify(data))
|
|
end
|
|
|
|
# Just in case we use a browser to send data to this (for example while emulating Tuna)
|
|
def on_http_metadata_cors(~protocol, ~data, ~headers, uri) =
|
|
http.response(protocol=protocol, code=200, headers=[
|
|
("allow","POST"),
|
|
("access-control-allow-origin","*"),
|
|
("access-control-allow-credentials","true"),
|
|
("access-control-allow-methods","GET,POST"),
|
|
("access-control-allow-headers","Origin,X-Requested-With,Content-Type,Accept,Authorization,access-control-allow-headers,access-control-allow-origin"),
|
|
("content-type","text/html; charset=utf-8"),
|
|
], data="POST")
|
|
end
|
|
|
|
harbor.http.register(port=metadata_api_port, method="GET", "/#{id}/meta", on_http_get_metadata)
|
|
harbor.http.register(port=metadata_api_port, method="OPTIONS", "/#{id}/meta", on_http_metadata_cors)
|
|
|
|
harbor.http.register(port=metadata_api_port, method="GET", "/#{id}/cover", on_http_get_cover)
|
|
harbor.http.register(port=metadata_api_port, method="OPTIONS", "/#{id}/cover", on_http_metadata_cors)
|
|
|
|
harbor.http.register(port=metadata_api_port, method="POST", "/#{id}", on_http_metadata)
|
|
harbor.http.register(port=metadata_api_port, method="OPTIONS", "/#{id}", on_http_metadata_cors)
|
|
|
|
harbor.http.register(port=metadata_api_port, method="POST", "/", on_http_metadata)
|
|
harbor.http.register(port=metadata_api_port, method="OPTIONS", "/", on_http_metadata_cors)
|
|
|
|
s
|
|
end
|