Получать сообщения с сервера в реальном времени - авторизация

    using System;
    using System.Collections.Generic;
    using System.Threading;
    using System.Threading.Tasks;
    using Microsoft.AspNetCore.Mvc;
    using Microsoft.AspNetCore.Authorization;
    using Microsoft.AspNetCore.Http;
    
    using Services;
    using Models;
    
    [Route("api/[controller]")]
    [ApiController]
    public class FeedbackController : ControllerBase
    {
        public FeedbackController(FeedbackService feedbackService)
        {
            this.FeedbackService = feedbackService;
        }
        
        private FeedbackService FeedbackService { get; set; }
        
        // ...
        
        [Route("[action]")]
        [Authorize]
        [HttpGet]
        public async Task Push(CancellationToken cancellationToken)
        {
            Response.StatusCode = 200;
            Response.Headers.Add("Content-Type", "text/event-stream");

            EventHandler<FeedbackEventArgs> onFeedbackReceived = async (sender, eventArgs) =>
            {
                try
                {
                    var newMessageCount = eventArgs.NewMessageCount;
                    await Response.WriteAsync($"data:{newMessageCount}\n\n");
                    await Response.Body.FlushAsync();
                }
                catch (Exception ex)
                {
                    // Log the exception
                    Program.Logger.Error(ex, ex.Message);
                }
            };

            this.FeedbackService.Subscribe(onFeedbackReceived);

            while (!cancellationToken.IsCancellationRequested)
            {
                await Task.Delay(1000);
            }

            this.FeedbackService.Unsubscribe();
        }
    }

        // ...
        private NotificationService NotificationService;
        
        // ...
        
        public void Subscribe(EventHandler<FeedbackEventArgs> onFeedbackReceived)
        {
            this.NotificationService.Subscribe(this.CurrentLogin, onFeedbackReceived);
        }
        
        public void Unsubscribe()
        {
            this.NotificationService.Unsubscribe(this.CurrentLogin);
        }

        public void TriggerNewMessageNotification(string receiverLogin, int newMessageCount)
        {
            FeedbackEventArgs args = new FeedbackEventArgs { NewMessageCount = newMessageCount };
            this.NotificationService.Notify(receiverLogin, args);
        }
        // ...

    using System;
    
    public class FeedbackEventArgs : EventArgs
    {
        public int NewMessageCount { get; set; }
    }

class Notifier {
    
    constructor() {
        store.subscribe(this.onAppStateChange.bind(this))
    }
    
    _callbacks = []
    _timerId = null
    _stage = ''
    _evtSource = null
    _sound = null
    
    // ...

    connect() {
        try {
            this._evtSource = new EventSource('/api/Feedback/Push');
            this._evtSource.addEventListener("arrived", this.onMessageArrived.bind(this));
        }
        catch (err) {
            console.log('Браузер пользователя не поддерживает Server sent events.')
        }
        // Backup method if PUSH doesn't work, we'll check for notifications at least every half hour
        this._timerId = setInterval(this.checkForNotifications.bind(this), notifierCheckingDelay)
    }

    
    disconnect() {
        clearInterval(this._timerId)
        try {
            this._evtSource.close()
        }
        catch (err) {
            console.log(
                'Браузер пользователя не поддерживает Server sent events.'
            )
        }
    }
    
    // ...
    
}

HTTP/1.1 401 Unauthorized
X-Powered-By: Express
connection: close
date: Tue, 05 Mar 2024 13:28:07 GMT
server: Kestrel
content-length: 0
www-authenticate: Bearer

npm i eventsource

import EventSource from 'eventsource';
// ...
    connect() {
        try {
            let token = api.getAUTHToken();
            this._evtSource = new EventSource('/api/Feedback/Push', {
                headers: {
                    Authorization: `Bearer ${token.text}`
                }
            });
            this._evtSource.addEventListener("arrived", this.onMessageArrived.bind(this));
        }
        catch (err) {
            console.log('Браузер пользователя не поддерживает Server sent events.')
        }
        // Backup method if PUSH doesn't work, we'll check for notifications at least every half hour
        this._timerId = setInterval(this.checkForNotifications.bind(this), notifierCheckingDelay)
    }

        [Route("[action]")]
        [Authorize]
        [HttpGet]
        public async Task Push(CancellationToken cancellationToken)
        {
            Response.StatusCode = 200;
            Response.Headers.Add("Content-Type", "text/event-stream");
            Response.Headers.Add("Cache-Control", "no-transform");

            EventHandler<FeedbackEventArgs> onFeedbackReceived = async (sender, eventArgs) =>
            {
                try
                {
                    var newMessageCount = eventArgs.NewMessageCount;
                    await Response.WriteAsync($"data:{newMessageCount}\n\n");
                    await Response.Body.FlushAsync();
                }
                catch (Exception ex)
                {
                    // Log the exception
                    Program.Logger.Error(ex, ex.Message);
                }
            };

            this.FeedbackService.Subscribe(onFeedbackReceived);

            while (!cancellationToken.IsCancellationRequested)
            {
                await Task.Delay(1000);
            }

            this.FeedbackService.Unsubscribe();
        }