AngularJS и зависимость от коннекта к серверу

Question

[Stricker]

Приветствую, проблема такая, есть сервис для работы с WebSocket и почти все приложение завязано на нем. Как сделать так, чтобы приложение работало лишь тогда - когда подключение осуществлено? Т.е. при запуске приложение ждать коннекта, лишь потом взаимодействовать с приложением?

Просто напросто вот этот сервис - https://github.com/ZloyDyadka/websocket-angular/bl...

И когда к примеру в контроллере вызываю -

app.controller('headerCtrl', ['$scope', 'ws', '$q', function($scope, ws, $q) {
    ws.call({
        "method"    : "getCountMsg",
        "params"    : ""
    }).then(function(d){
            $scope.countMsg = d;
        })
}]);

Соединение устанавливается не мгновенно, а вот запрос к серверу отсылает сразу же - на что получает ошибку что коннекта нет.

Т.е. мне нужно как-бы сделать работу контроллеров в зависимости от того есть ли подключение

Answer 1

[maxaon]

Плохая библиотека, поищите что-то лучше.
Метод call должен всегда возвращать промис, а не только тогда, когда произошло подключение (ready===true).
К тому же, этот код захламляет глобальную область видимости переменной ready. Также используется console вместо сервиса $log.

Comments

[Stricker]

Искал, они все практически такого же формата, в них все на кэлбэках все, а не defer. А библиотеку эту я как бы сам писал. Так что вот и моей писанины всплывают камни. А если вдруг микро отсоединение? Не знал про $log, извиняюсь. А вот насчет ready мне как раз и надо что-то такое, чтобы отследить состояние и если подключено - выполнять, если нет - ждать

[maxaon]

Во-первых везде пишите 'use strict' это избавит вас от головной боли.
Во-вторых, самое простое решение, которое я вижу, если нет подключения - заносить в массив pending, в другом случае - выполнять запрос. При onconnect выполнять все функции из pending. Аналогично ng.$q .
В-третьих лучше вызывать $apply как функцию:

$rootScope.$apply(function(){
    callbacks[reply.id].cb.resolve(reply.result)
});

поскольку код оборачивается в try/catch

[maxaon]

Примерно так:

function ($q, $rootScope, $timeout, $log) {
    var pending = [];
    //...
    ws.onopen = function () {
        $log.debug("WS ready");
        service.ready = true;
        if (pending.lenght)
        {
            for (var i=0; i<pending.lenght;i++)
            {
                try{
                    pending[i]();
                } catch(e) {
                    $log.error(e);
                }
            }
        }            
    }
    //...
    var service = {
        /* Calling function on server */
        call: function (request) {
            $log.debug("Sending request", request, ready);
            send=function(){
                ws.send(JSON.stringify(request));
            }
            if (this.ready){
                send();
            }
            else{
                pending.push(send);
            }         
                

            return defer.promise;
        }
    };
}