mirror/DisCal-Discord-Bot
1
0
Fork 0
mirror of https://github.com/DreamExposure/DisCal-Discord-Bot.git synced 2026-04-30 06:09:52 -05:00
Code Issues Packages Projects Releases Wiki Activity

Okay, for now this is how we will start the announcement thread

Browse Source 
Now to actually debug and validate that the system is processing
announcements correctly.
This commit is contained in:
NovaFox161
2020-05-15 01:05:57 -05:00
parent 13fee5ea02
commit 4f89b898a0
1 changed files with 10 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/dreamexposure/discal/client/DisCalClient.java
+10 -17
View File
@@ -127,6 +127,14 @@ public class DisCalClient {
.flatMap(ReadyEventListener::handle)
.then();
Mono<Void> startAnnouncement = client.on(ReadyEvent.class)
.doOnNext(ignore -> LogFeed.log(LogObject.forDebug("Ready event hit in announcement start")))
.next()
.flatMapMany(ignore -> Flux.interval(Duration.ofMinutes(5)))
.onBackpressureBuffer()
.flatMap(i -> new AnnouncementThread(client).run())
.then();
Mono<Void> onTextChannelDelete = client.on(TextChannelDeleteEvent.class)
.flatMap(ChannelDeleteListener::handle)
.then();
@@ -139,23 +147,8 @@ public class DisCalClient {
.flatMap(MessageCreateListener::handle)
.then();
Mono<Void> startAnnouncement = Flux.interval(Duration.ZERO)
.onBackpressureBuffer()
.doOnNext(ignore -> LogFeed.log(LogObject.forDebug("Tick")))
.flatMap(ignore -> new AnnouncementThread(client).run())
.then();
/*
client.on(ReadyEvent.class)
.doOnNext(ignore -> LogFeed.log(LogObject.forDebug("Ready event hit in announcement start")))
.next()
.flatMapMany(ignore -> Flux.interval(Duration.ZERO))
.onBackpressureBuffer()
.flatMap(i -> new AnnouncementThread(client).run())
.then();
*/
return Mono.when(onReady, onTextChannelDelete, onRoleDelete, onCommand, startAnnouncement);
//TODO: Wait for Quantic to figure this one out. Its weird race condition non-sense
return Mono.when(onReady, startAnnouncement, onTextChannelDelete, onRoleDelete, onCommand);
}).block();
}