README.md

Discord4J Gateway

The gateway module provides a low-level WebSocket client for interacting with the Discord Gateway.

Installation

Just replace @VERSION@ with the latest given by

Gradle

repositories {
  mavenCentral()
}

dependencies {
  implementation 'com.discord4j:discord4j-gateway:@VERSION@'
}

Maven

<dependencies>
  <dependency>
    <groupId>com.discord4j</groupId>
    <artifactId>discord4j-gateway</artifactId>
    <version>@VERSION@</version>
  </dependency>
</dependencies>

SBT

libraryDependencies ++= Seq(
  "com.discord4j" % "discord4j-gateway" % "@VERSION@"
)

Development builds

Please follow our instructions at Using Jitpack

Example Usage

String token = "...";
ObjectMapper mapper = getMapper();
PayloadReader reader = new JacksonPayloadReader(mapper);
PayloadWriter writer = new JacksonPayloadWriter(mapper);
RetryOptions retryOptions = new RetryOptions(Duration.ofSeconds(5), Duration.ofSeconds(120),
        Integer.MAX_VALUE, Schedulers.elastic());
GatewayClient gatewayClient = new DefaultGatewayClient(HttpClient.create(),
        reader, writer, retryOptions, token,
        new IdentifyOptions(0, 1, null), null,
        new RateLimiterTransformer(new SimpleBucket(1, Duration.ofSeconds(6))));

gatewayClient.dispatch().subscribe(dispatch -> {
    if (dispatch instanceof Ready) {
        System.out.println("Test received READY!");
    }
});

gatewayClient.receiver(byteBuf -> Mono.fromRunnable(() -> {
    try {
        String json = mapper.writeValueAsString(mapper.readTree(byteBuf.array()));
        System.out.println(json);
    } catch (IOException e) {
        e.printStackTrace();
    }
})).subscribe();

gatewayClient.dispatch().ofType(MessageCreate.class)
        .subscribe(message -> {
            String content = message.getContent();
            System.out.println(content);
            if ("!close".equals(content)) {
                gatewayClient.close(false).block();
            } else if ("!retry".equals(content)) {
                gatewayClient.close(true).block();
            }
        });

gatewayClient.execute(gatewayUrl).block();