ChromaGaming/DiscordPlayerStatCollector
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Saving all messages of a channel

Browse source 
Also fixed dep
This commit is contained in:
Norbi Peti 2019-03-19 23:28:35 +01:00
parent 16508000a7
commit ecff849ace
No known key found for this signature in database
GPG key ID: DBA4C4549A927E56
2 changed files with 53 additions and 2 deletions
pom.xml
src/main/java
MainDl.java

4
pom.xml
View file

@ -29,9 +29,9 @@
<dependencies>
<dependency>
<groupId>com.github.austinv11</groupId>
<groupId>com.discord4j</groupId>
<artifactId>Discord4j</artifactId>
<version>master-SNAPSHOT</version>
<version>2.10.1</version>
</dependency>
</dependencies>

51
src/main/java/MainDl.java Normal file
View file

@ -0,0 +1,51 @@
import sx.blah.discord.api.ClientBuilder;
import sx.blah.discord.api.IDiscordClient;
import sx.blah.discord.api.events.IListener;
import sx.blah.discord.handle.impl.events.ReadyEvent;
import sx.blah.discord.handle.obj.IChannel;
import sx.blah.discord.util.MessageHistory;
import sx.blah.discord.util.RequestBuffer;
import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.StandardOpenOption;
import java.time.Instant;
import java.util.function.BiConsumer;
import java.util.regex.Pattern;
public class MainDl {
public static void main(String... args) throws IOException {
IDiscordClient idc = new ClientBuilder().withToken(Files.readAllLines(new File("Token.txt").toPath()).get(0))
.registerListener((IListener<ReadyEvent>) event -> {
IChannel chan = event.getClient().getChannelByID(209720707188260864L);
Pattern patplayer = Pattern.compile("(\\S+).*");
File f = new File("dataDl.csv");
f.delete();
long mc = 0;
BiConsumer<MessageHistory, Boolean> cmh = (mh, skip) -> {
RequestBuffer.request(() -> { //? eh
try {
Files.write(f.toPath(),
(Iterable<String>) mh.stream().skip(skip ? 1 : 0) //Skip 'from' message to avoid double processing
.filter(msg -> !msg.getAuthor().isBot() || (!msg.getContent().toLowerCase().contains("music")
&& !msg.getContent().toLowerCase().contains("song")))
.map(msg -> msg.getCreationDate().toString() + "\t" + msg.getAuthor().getStringID() + "\t" + msg.getAuthor().getName() + "\t" + msg.getFormattedContent().replace("\r", "").replace("\n", "\\n").replace("\t", "\\t"))::iterator, StandardOpenOption.CREATE, StandardOpenOption.APPEND);
} catch (IOException e) {
e.printStackTrace();
}
}).get(); //Wait for completion
};
MessageHistory mh = chan.getMessageHistoryFrom(Instant.now(), 100);
cmh.accept(mh, false);
System.out.println("Processed " + (mc += mh.size()) + " messages.");
while (mh.size() > 1) {
cmh.accept(mh, true);
mh = chan.getMessageHistoryFrom(mh.get(mh.size() - 1).getLongID(), 100);
System.out.println("Processed " + (mc += mh.size()) + " messages.");
}
System.out.println("DONE!");
System.exit(0);
}).login();
}
}