API DOCS

Download Beispielcode

Dies ist ein schneller Beispielcode. Wir sind keine Java-Programmierer. Daher bitte entsprechend überprüfen und gerne Feedback geben.

    /*
     * This source file was generated by the Gradle 'init' task
     */
    package org.example;


    import com.pusher.client.Pusher;
    import com.pusher.client.channel.Channel;
    import com.pusher.client.channel.SubscriptionEventListener;
    import com.pusher.client.connection.ConnectionEventListener;
    import com.pusher.client.connection.ConnectionState;
    import com.pusher.client.PusherOptions;
    import com.pusher.client.channel.PusherEvent;
    import com.pusher.client.connection.ConnectionStateChange;


    public class App {
        public String getGreeting() {
            return "Hello World!";
        }

        public static void main(String[] args) {
            System.out.println(new App().getGreeting());
            String YOUR_APP_KEY="mqfzsnt3n1tetbgezmfb";
            String YOUR_APP_HOST="streamer.make-a-wish.at";

            // Create a new Pusher instance
            PusherOptions options = new PusherOptions();
            options.setHost(YOUR_APP_HOST);
            options.setActivityTimeout((long)10000L);


            Pusher pusher = new Pusher(YOUR_APP_KEY, options);

            pusher.connect(new ConnectionEventListener() {
                @Override
                public void onConnectionStateChange(ConnectionStateChange change) {
                    System.out.println("State changed to " + change.getCurrentState() +
                                       " from " + change.getPreviousState());
                }

                @Override
                public void onError(String message, String code, Exception e) {
                    System.out.println("There was a problem connecting!");
                    System.out.println(message);
                    System.out.println(code);
                    System.out.println(e);
                }
            }, ConnectionState.ALL);

            // Subscribe to a channel
            Channel channel = pusher.subscribe("donations");

            // Bind to listen for events called "my-event" sent to "my-channel"
            channel.bind("App\\Events\\DonationCompleted", new SubscriptionEventListener() {
                @Override
                public void onEvent(PusherEvent event) {
                    System.out.println("Received event with data: " + event.toString());
                    // TODO: Check if the streamer of the event is <streamer_slug>
                }
            });

            // Disconnect from the service
            pusher.disconnect();

            // Reconnect, with all channel subscriptions and event bindings automatically recreated
            pusher.connect();
            // The state change listener is notified when the connection has been re-established,
            // the subscription to "my-channel" and binding on "my-event" still exist.

            try
            {
                Thread.sleep(1000 * 60);
            }
            catch(InterruptedException e)
            {
                 // this part is executed when an exception (in this example InterruptedException) occurs
            }
            //delay(5000);

            System.out.println("The end");

        }
    }
                        

Schau die auch die Dokumentation für Laravel Echo / Broadcasting an.

npm install --save-dev laravel-echo pusher-js

    import Echo from 'laravel-echo';

    import Pusher from 'pusher-js';
    window.Pusher = Pusher;

    window.Echo = new Echo({
        broadcaster: 'reverb',
        key: 'mqfzsnt3n1tetbgezmfb',
        wsHost: 'streamer.make-a-wish.at',
        wsPort: 443,
        wssPort: 443,
        forceTLS: !0,
        enabledTransports: ['ws', 'wss'],
    });
                            

Die Daten im donation event sind die gleichen wie oben im POST-Request

    Echo.channel('donations')
        .listen('DonationCompleted', (donation) => {
        // This will be sent when a real donation is sent.
        // TODO: Check if the streamer of the event is <streamer_slug>
        console.log('Donation retrieved');
        console.log(donation);
    }).listen('DonationCompletedTest', (donation) => {
        // This will be sent when a test is triggered via the backend
        // TODO: Check if the streamer of the event is <streamer_slug>
        console.log('TestDonation retrieved');
        console.log(donation);
    });
                            

Danke an Cyber, der uns folgendes Codeschnipsel zur Verfügung gestellt hat:

import io.ktor.client.HttpClient
import io.ktor.client.engine.cio.CIO
import io.ktor.client.plugins.websocket.WebSockets
import io.ktor.client.plugins.websocket.webSocket
import io.ktor.http.HttpMethod
import io.ktor.http.URLProtocol
import io.ktor.websocket.Frame
import io.ktor.websocket.readText
import kotlinx.coroutines.delay
import kotlinx.serialization.Serializable
import kotlinx.serialization.json.Json
import kotlinx.serialization.json.JsonElement
import kotlinx.serialization.json.contentOrNull
import kotlinx.serialization.json.jsonPrimitive


//JSON Vorlagen
@Serializable
data class BaseEvent(
    val event: String,
    val data: JsonElement? = null
)

@Serializable
data class DonationCompleted(
    val username: String? = null,
    val amount: Int,
    val amount_net: Int,
    val streamer_slug: String,
    val message: String? = null,
    val metadata: JsonElement? = null
)

object Eventhandler {

    val json = Json { ignoreUnknownKeys = true }
    val client = HttpClient(CIO) { install(WebSockets) }

    suspend fun schedule() {
        while (true) {
            try {
                //Verbindung aufbauen
                client.webSocket(
                    method = HttpMethod.Get,
                    host = "streamer.make-a-wish.at",
                    path = "/app/mqfzsnt3n1tetbgezmfb?protocol=7&client=ktor&version=1.0",
                    request = { url.protocol = URLProtocol.WSS }
                ) {

                    //Websocket auslesen
                    for (frame in incoming) {

                        //JSON überprüfen
                        if (frame is Frame.Text) {


                            handle(frame.readText())

                            //Pusher Notification
                            if (frame.readText().contains("pusher:connection_established")) {

                                //Pusher Kanal abonnieren = nur gewisse Events abhören (z.B. 'donations')
                                val subscribe = """{"event":"pusher:subscribe","data":{"channel":"donations"}}"""
                                send(Frame.Text(subscribe))

                            }
                        }
                    }

                }

            } catch (e: Exception) {
                //Delay vor einem Reconnect
                delay(5000)
            }
        }
    }

    fun handle(text: String){

        //JSON String umwandeln
        val base = json.decodeFromString(text)

        //Keine Donation = Pusher notification etc.
        if (!base.event.contains("DonationCompleted")){
            return
        }

        //Informationen holen
        val inner = base.data?.jsonPrimitive?.contentOrNull ?: return
        val data = json.decodeFromString(inner)

        //hier z.B. data.streamer_slug überprüfen etc.
    }
}

kotlinx.coroutines.GlobalScope.launch {
    Eventhandler.schedule()
}