160 lines
7.9 KiB
Plaintext
160 lines
7.9 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_hostname = environment.get(default="icedream-bitwave", "METADATA_API_HOSTNAME")
|
|
|
|
def http_export_meta(%argsof(json.stringify), 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 = drop_metadata(s) # stream metadata wipes out own data
|
|
s = insert_metadata(s)
|
|
|
|
# Handler for fetching metadata
|
|
def on_http_get_metadata(request) =
|
|
http_version = request.http_version
|
|
headers = request.headers
|
|
|
|
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)
|
|
m = if has_cover and not has_cover_url then
|
|
list.add(
|
|
("cover_url", "http://#{metadata_api_hostname}:#{metadata_api_port}/#{url.encode(id)}/cover"),
|
|
m
|
|
)
|
|
else
|
|
m
|
|
end
|
|
|
|
# data = metadata.json.stringify(compact=true, m)
|
|
m = metadata.cover.remove(m)
|
|
data = http_export_meta(compact=true, m)
|
|
|
|
http.response(http_version=http_version, status_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"),
|
|
("expires", "0"),
|
|
("cache-control", "no-store"),
|
|
], data=data)
|
|
end
|
|
|
|
# Handler for fetching current cover art
|
|
def on_http_get_cover(request) =
|
|
http_version = request.http_version
|
|
headers = request.headers
|
|
|
|
m = s.last_metadata() ?? []
|
|
cover = metadata.cover(m) ?? "".{mime="text/plain"}
|
|
if string.length(cover) > 0 then
|
|
http.response(http_version=http_version, status_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"),
|
|
("cache-control", "no-store"),
|
|
("expires", "0"),
|
|
("content-type", cover.mime),
|
|
], data=string_of(cover))
|
|
else
|
|
http.response(http_version=http_version, status_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"),
|
|
("expires", "0"),
|
|
("cache-control", "no-store"),
|
|
], data="")
|
|
end
|
|
end
|
|
|
|
# Handler for receiving metadata
|
|
def on_http_metadata(request) =
|
|
http_version = request.http_version
|
|
data = request.data()
|
|
headers = request.headers
|
|
|
|
let json.parse (data : {
|
|
data: [(string * string)] as json.object
|
|
}) = data
|
|
|
|
m = 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", m))) 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(http_version=http_version, status_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(request) =
|
|
http_version = request.http_version
|
|
headers = request.headers
|
|
|
|
http.response(http_version=http_version, status_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.simple(port=metadata_api_port, method="GET", "/#{id}/meta", on_http_get_metadata)
|
|
harbor.http.register.simple(port=metadata_api_port, method="OPTIONS", "/#{id}/meta", on_http_metadata_cors)
|
|
|
|
harbor.http.register.simple(port=metadata_api_port, method="GET", "/#{id}/cover", on_http_get_cover)
|
|
harbor.http.register.simple(port=metadata_api_port, method="OPTIONS", "/#{id}/cover", on_http_metadata_cors)
|
|
|
|
harbor.http.register.simple(port=metadata_api_port, method="POST", "/#{id}", on_http_metadata)
|
|
harbor.http.register.simple(port=metadata_api_port, method="OPTIONS", "/#{id}", on_http_metadata_cors)
|
|
|
|
harbor.http.register.simple(port=metadata_api_port, method="POST", "/", on_http_metadata)
|
|
harbor.http.register.simple(port=metadata_api_port, method="OPTIONS", "/", on_http_metadata_cors)
|
|
|
|
s
|
|
end
|