TeamPiped-mirror/Piped-Backend
1
0
Fork 0
mirror of https://github.com/TeamPiped/Piped-Backend.git synced 2024-08-14 23:51:41 +00:00
Code Issues Projects Releases Packages Wiki Activity

Fix incorrect field.

Browse source
This commit is contained in:
Kavin 2022-11-13 00:48:12 +00:00
parent cd6e63130b
commit 9d8117239f
No known key found for this signature in database
GPG key ID: 49451E4482CC5BCD
2 changed files with 13 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/main/java/me/kavin/piped/server/handlers/StreamHandlers.java
View file

@ -22,6 +22,7 @@ import org.schabi.newpipe.extractor.stream.StreamInfo;
import org.schabi.newpipe.extractor.stream.StreamType;
import org.schabi.newpipe.extractor.utils.JsonUtils;
import java.io.IOException;
import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
@ -150,11 +151,17 @@ public class StreamHandlers {
if (info.getUploadDate() != null && System.currentTimeMillis() - time < TimeUnit.DAYS.toMillis(Constants.FEED_RETENTION)) {
VideoHelpers.updateVideo(info.getId(), info, time);
MatrixHelper.sendEvent("video.piped.stream.info", new FederatedVideoInfo(
info.getId(), StringUtils.substring(info.getUploaderUrl(), -24),
info.getName(),
info.getDuration(), info.getViewCount())
);
Multithreading.runAsync(() -> {
try {
MatrixHelper.sendEvent("video.piped.stream.info", new FederatedVideoInfo(
info.getId(), StringUtils.substring(info.getUploaderUrl(), -24),
info.getName(),
info.getDuration(), info.getViewCount())
);
} catch (IOException e) {
throw new RuntimeException(e);
}
});
}
String lbryId;

2
src/main/java/me/kavin/piped/utils/obj/MatrixHelper.java
View file

@ -77,7 +77,7 @@ public class MatrixHelper {
.put(RequestBody.create(mapper.writeValueAsBytes(
mapper.createObjectNode()
.put("msgtype", type)
.set("body", mapper.valueToTree(content))
.set("content", mapper.valueToTree(content))
), MediaType.get("application/json")))
.build()
).get("event_id").asText();