kavin/Piped-Backend
1
0
Fork 0
mirror of https://github.com/TeamPiped/Piped-Backend.git synced 2024-12-14 22:30:29 +05:30
Code Issues Projects Releases Wiki Activity

Merge pull request #505 from TeamPiped/drop-ipfs

Browse Source 
Drop IPFS publish code.
This commit is contained in:
Kavin 2023-01-14 14:43:51 +00:00 committed by GitHub
commit 939b0bbaa8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 0 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
build.gradle
View File

@ -23,7 +23,6 @@ dependencies {
implementation 'com.fasterxml.jackson.core:jackson-annotations:2.14.1' implementation 'com.fasterxml.jackson.core:jackson-annotations:2.14.1'
implementation 'com.fasterxml.jackson.core:jackson-databind:2.14.1' implementation 'com.fasterxml.jackson.core:jackson-databind:2.14.1'
implementation 'com.rometools:rome:1.18.0' implementation 'com.rometools:rome:1.18.0'
implementation 'com.github.ipfs:java-ipfs-http-client:v1.3.3'
implementation 'org.jsoup:jsoup:1.15.3' implementation 'org.jsoup:jsoup:1.15.3'
implementation 'io.activej:activej-common:5.4.3' implementation 'io.activej:activej-common:5.4.3'
implementation 'io.activej:activej-http:5.4.3' implementation 'io.activej:activej-http:5.4.3'

20
src/main/java/me/kavin/piped/ipfs/IPFS.java
View File

@ -1,20 +0,0 @@
package me.kavin.piped.ipfs;
import me.kavin.piped.utils.Multithreading;
import me.kavin.piped.utils.obj.Channel;
public class IPFS {
// private static final io.ipfs.api.IPFS ipfs = new io.ipfs.api.IPFS(new MultiAddress("/ip4/127.0.0.1/tcp/5001"));
public static void publishData(final Channel channel) {
Multithreading.runAsync(() -> {
try {
// ipfs.pubsub.pub(URLUtils.silentEncode(channel.id),
// URLUtils.silentEncode(Constants.mapper.writeValueAsString(channel)));
} catch (Exception e) {
e.printStackTrace();
}
});
}
}

3
src/main/java/me/kavin/piped/server/handlers/ChannelHandlers.java
View File

@ -3,7 +3,6 @@ package me.kavin.piped.server.handlers;
import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.core.JsonProcessingException;
import io.sentry.Sentry; import io.sentry.Sentry;
import me.kavin.piped.consts.Constants; import me.kavin.piped.consts.Constants;
import me.kavin.piped.ipfs.IPFS;
import me.kavin.piped.utils.*; import me.kavin.piped.utils.*;
import me.kavin.piped.utils.obj.*; import me.kavin.piped.utils.obj.*;
import me.kavin.piped.utils.obj.db.Video; import me.kavin.piped.utils.obj.db.Video;
@ -138,8 +137,6 @@ public class ChannelHandlers {
rewriteURL(info.getBannerUrl()), info.getDescription(), info.getSubscriberCount(), info.isVerified(), rewriteURL(info.getBannerUrl()), info.getDescription(), info.getSubscriberCount(), info.isVerified(),
nextpage, relatedStreams, tabs); nextpage, relatedStreams, tabs);
IPFS.publishData(channel);
return mapper.writeValueAsBytes(channel); return mapper.writeValueAsBytes(channel);
} }