Сервер отправил события с Kitura

Question

Я пытаюсь создать клиент-серверное приложение на стороне клиента на веб-сайте Angular2/typescript, а на стороне сервера - на сервере Kitura в Swift на Mac OSX. На стороне клиента код машинописного текста создает объект EventSource:

    this.eventSource = new EventSource(this.webSocketServerUrl);
    this.eventSource.onopen = (event: Event): any => {
        console.log("ServerNotificationsService.onopen - " + JSON.stringify(event) + " " + this.eventSource.readyState);
        event.stopPropagation();
        return null;
    }
    this.eventSource.onerror = (event: sse.IOnMessageEvent) => {
        console.log("ServerNotificationsService.onerror - " + JSON.stringify(event) + " " + this.eventSource.readyState);
    }
    this.eventSource.onmessage = (event: Event): any => {
        console.log("ServerNotificationsService.onmessage - " + JSON.stringify(event) + " " + this.eventSource.readyState);
        event.stopPropagation();
        return null;
    }
    console.log("ServerNotificationsService.constructor - " + this.eventSource.readyState);

На стороне сервера мой код для обработки запроса GET выглядит следующим образом:

router.get("/notifications") { request, response, next in 
response.headers.append("Access-Control-Allow-Origin", value: "*")

if((request.accepts(header: "Accept", type: "text/event-stream")) != nil)
{
  response.headers.append("content-type", value: "text/event-stream; charset=utf-8")
  response.headers.append("cache-control", value: "no-cache")
  response.headers.append("connection", value: "keep-alive")
  try response.end()
  Logger.sharedInstance.verbose(msg: "Request GET /notifications OK")
}
else
{
  try response.status(.internalServerError).end()
  Logger.sharedInstance.verbose(msg: "Request GET /notifications internalServerError")
}

next()
}

и обработать почтовый запрос:

router.post("/notifications") { request, response, next in
Logger.sharedInstance.verbose(msg: "Request POST /notifications ...")
response.headers.append("Access-Control-Allow-Origin", value: "*")
response.headers.append("content-type", value: "text/event-stream; charset=utf-8")
response.headers.append("cache-control", value: "no-cache")
response.headers.append("connection", value: "keep-alive")

while (true)
{
  // wait here 5s. for the <nextMessage>
  response.send(<nextMessage>)
  try response.end()
  Logger.sharedInstance.verbose(msg: "Request POST /notifications OK")
  next()
}
}

Проблема заключается в том, что на стороне клиента я получаю уведомление onopen, источник события readyState переходит в "Open" (1), но я получаю сразу же после уведомления об ошибке, и readyState передает "Connecting" (0). И так далее: подключение, закрытие, подключение, закрытие... И, как следствие, почтовый запрос никогда не выполняется.

Я буду признателен за помощь, чтобы иметь код, который поддерживает открытую связь.

Спасибо,

Notux

Answer 1

Kitura в настоящее время не поддерживает постоянные открытые HTTP-соединения. Тем не менее, вы можете реплицировать функциональность, используя WebSocket вместо отправляемых сервером событий по HTTP (вам нужно переписать код внешнего интерфейса, чтобы использовать WebSockets вместо EventSource): https://github.com/IBM-Swift/Kitura-WebSocket

И пример приложения Kitura-WebSocket можно найти здесь: https://github.com/IBM-Swift/Kitura-Chat-Server