# 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 = getenv(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(~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) 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(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"), ("expires", "0"), ("cache-control", "no-store"), ], 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"), ("cache-control", "no-store"), ("expires", "0"), ("content-type", cover.mime), ], 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"), ("expires", "0"), ("cache-control", "no-store"), ], data="") end end # Handler for receiving metadata def on_http_metadata(~protocol, ~data, ~headers, uri) = 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(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