summary refs log tree commit diff
path: root/syweb/webclient/test/unit/event-stream-service.spec.js
diff options
context:
space:
mode:
Diffstat (limited to 'syweb/webclient/test/unit/event-stream-service.spec.js')
-rw-r--r--syweb/webclient/test/unit/event-stream-service.spec.js80
1 files changed, 0 insertions, 80 deletions
diff --git a/syweb/webclient/test/unit/event-stream-service.spec.js b/syweb/webclient/test/unit/event-stream-service.spec.js
deleted file mode 100644
index 6fd7693a70..0000000000
--- a/syweb/webclient/test/unit/event-stream-service.spec.js
+++ /dev/null
@@ -1,80 +0,0 @@
-describe('EventStreamService', function() {
-    var q, scope;
-
-    var testInitialSync, testEventStream;
-
-    var matrixService = {
-        initialSync: function(limit, feedback) {
-            var defer = q.defer();
-            defer.resolve(testInitialSync);
-            return defer.promise;
-        },
-        getEventStream: function(from, svrTimeout, cliTimeout) {
-            var defer = q.defer();
-            defer.resolve(testEventStream);
-            return defer.promise;
-        }
-    };
-    
-    var eventHandlerService = {
-        handleInitialSyncDone: function(response) {
-        
-        },
-        
-        handleEvents: function(chunk, isLive) {
-        
-        }
-    };
-
-    // setup the dependencies
-    beforeEach(function() {
-    
-        // reset test data
-        testInitialSync = {
-            data: {
-                end: "foo",
-                presence: [],
-                rooms: []
-            }
-        };
-        testEventStream = {
-            data: {
-                start: "foostart",
-                end: "fooend",
-                chunk: []
-            }
-        };
-    
-        // dependencies
-        module(function ($provide) {
-          $provide.value('matrixService', matrixService);
-          $provide.value('eventHandlerService', eventHandlerService);
-        });
-        
-        // tested service
-        module('eventStreamService');
-    });
-    
-    beforeEach(inject(function($q, $rootScope) {
-        q = $q;
-        scope = $rootScope;
-    }));
-
-    it('should start with /initialSync then go onto /events', inject(
-    function(eventStreamService) {
-        spyOn(eventHandlerService, "handleInitialSyncDone");
-        spyOn(eventHandlerService, "handleEvents");
-        eventStreamService.resume();
-        scope.$apply(); // initialSync request
-        expect(eventHandlerService.handleInitialSyncDone).toHaveBeenCalledWith(testInitialSync);
-        expect(eventHandlerService.handleEvents).toHaveBeenCalledWith(testEventStream.data.chunk, true);
-    }));
-    
-    it('should use the end token in /initialSync for the next /events request', inject(
-    function(eventStreamService) {
-        spyOn(matrixService, "getEventStream").and.callThrough();
-        eventStreamService.resume();
-        scope.$apply(); // initialSync request
-        expect(matrixService.getEventStream).toHaveBeenCalledWith("foo", eventStreamService.SERVER_TIMEOUT, eventStreamService.CLIENT_TIMEOUT);
-    }));
-});