Disponibilité partage d'écran

// Importer le polyfill
const { EventSourcePolyfill } = require('event-source-polyfill');
// Ton Bearer Token
const token = 'votre token';

// Utiliser EventSourcePolyfill pour envoyer le token dans l'en-tête Authorization
const eventSource = new EventSourcePolyfill('https://mdm.pulse-xr.com/devices/:id/stream-status', {
  headers: {
    Authorization: `Bearer ${token}`,
  },
});

eventSource.onopen = function (data) {
  console.log('connection opened ');
};

eventSource.onmessage = function (event) {
  const updatedDevice = JSON.parse(event.data);
  console.log('Mise à jour du device:', updatedDevice);
  if (newMessage.streaming === true) {
    console.log('✅ Stream prêt');
    eventSource.close();
  }
};

eventSource.onerror = function (err) {
  console.error('Erreur dans la connexion SSE:' + err);
};

import requests
import sseclient

# URL du serveur SSE
url = "https://mdm.pulse-xr.com/devices/:id/updates"

# Bearer Token
headers = {
    "Authorization": "Bearer votre_token"
}

# Ouvrir la connexion SSE
response = requests.get(url, headers=headers, stream=True)
client = sseclient.SSEClient(response)

for event in client.events():
    print("Mise à jour du device:", event.data)

import okhttp3.*
import java.io.IOException

fun main() {
    val client = OkHttpClient()

    val request = Request.Builder()
        .url("https://mdm.pulse-xr.com/devices/:id/updates")
        .addHeader("Authorization", "Bearer votre_token")
        .build()

    client.newCall(request).enqueue(object : Callback {
        override fun onFailure(call: Call, e: IOException) {
            println("Erreur SSE: ${e.message}")
        }

        override fun onResponse(call: Call, response: Response) {
            response.body?.string()?.let {
                println("Mise à jour du device: $it")
            }
        }
    })
}

using System;
using System.IO;
using System.Net.Http;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        using (HttpClient client = new HttpClient())
        {
            client.DefaultRequestHeaders.Add("Authorization", "Bearer votre_token");
            var response = await client.GetStreamAsync("https://mdm.pulse-xr.com/devices/:id/updates");

            using (StreamReader reader = new StreamReader(response))
            {
                string line;
                while ((line = await reader.ReadLineAsync()) != null)
                {
                    Console.WriteLine($"Mise à jour du device: {line}");
                }
            }
        }
    }
}

package main

import (
	"bufio"
	"fmt"
	"net/http"
)

func main() {
	req, _ := http.NewRequest("GET", "https://mdm.pulse-xr.com/devices/:id/updates", nil)
	req.Header.Set("Authorization", "Bearer votre_token")

	client := &http.Client{}
	resp, err := client.Do(req)
	if err != nil {
		fmt.Println("Erreur SSE:", err)
		return
	}
	defer resp.Body.Close()

	scanner := bufio.NewScanner(resp.Body)
	for scanner.Scan() {
		fmt.Println("Mise à jour du device:", scanner.Text())
	}
}

{
	"streaming": boolean
}