Stream real-time notifications via SSE

curl --request GET \
  --url https://core.cyberun.cloud/api/v1/notifications/stream \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://core.cyberun.cloud/api/v1/notifications/stream"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://core.cyberun.cloud/api/v1/notifications/stream', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://core.cyberun.cloud/api/v1/notifications/stream",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

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

func main() {

	url := "https://core.cyberun.cloud/api/v1/notifications/stream"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://core.cyberun.cloud/api/v1/notifications/stream")
  .header("Authorization", "Bearer <token>")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://core.cyberun.cloud/api/v1/notifications/stream")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

"<string>"

{
  "error_message": "resource not found"
}

Notifications

Stream real-time notifications via SSE

Server-Sent Events (SSE) endpoint for real-time notification delivery. Connect with EventSource to receive push notifications instantly.

Event types:

connected — Sent once on connection with { "unread_count": N }
notification — Full notification object pushed in real-time
: heartbeat — SSE comment sent every 30s to keep the connection alive

Example (JavaScript):

const es = new EventSource('/api/v1/notifications/stream', {
  headers: { 'Authorization': 'Bearer <jwt>' }
});
es.addEventListener('connected', (e) => {
  const { unread_count } = JSON.parse(e.data);
});
es.addEventListener('notification', (e) => {
  const notification = JSON.parse(e.data);
  // Show toast, update badge, etc.
});

Architecture: Uses the cache Pub/Sub for instant delivery with automatic fallback to DB polling (5s interval) if the cache is unavailable.

GET

notifications

stream

Stream real-time notifications via SSE

curl --request GET \
  --url https://core.cyberun.cloud/api/v1/notifications/stream \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://core.cyberun.cloud/api/v1/notifications/stream"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://core.cyberun.cloud/api/v1/notifications/stream', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://core.cyberun.cloud/api/v1/notifications/stream",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

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

func main() {

	url := "https://core.cyberun.cloud/api/v1/notifications/stream"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://core.cyberun.cloud/api/v1/notifications/stream")
  .header("Authorization", "Bearer <token>")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://core.cyberun.cloud/api/v1/notifications/stream")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

"<string>"

{
  "error_message": "resource not found"
}

Authorizations

Authorization

string

header

required

User session JWT (Bearer ). Must be paired with the X-Team-ID request header on team-scoped endpoints so the server knows which team's resources to operate on.

Response

SSE stream established

The response is of type string.

Mark all notifications as read List teams the current user belongs to

Overview

Guides

Endpoints

Stream real-time notifications via SSE

Authorizations

Response