diff options
Diffstat (limited to 'syweb/webclient/test/unit/event-stream-service.spec.js')
-rw-r--r-- | syweb/webclient/test/unit/event-stream-service.spec.js | 80 |
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); - })); -}); |