Move OC.EventSource to the server bundle

Signed-off-by: Christoph Wurst <christoph@winzerhof-wurst.at>

core/js/core.json

@@ -21,7 +21,6 @@
 		"sharedialogshareelistview.js",
 		"octemplate.js",
 		"contactsmenu_templates.js",
-		"eventsource.js",
 		"public/appconfig.js",
 		"public/comments.js",
 		"public/publicpage.js",

core/js/merged-template-prepend.json

@@ -4,7 +4,6 @@
   "js.js",
   "l10n.js",
   "octemplate.js",
-  "eventsource.js",
   "public/appconfig.js",
   "public/comments.js",
   "public/whatsnew.js",

core/src/OC/eventsource.js

@@ -30,70 +30,72 @@
 
 /* global EventSource */
 
+import $ from 'jquery'
+
 /**
  * Create a new event source
  * @param {string} src
  * @param {object} [data] to be send as GET
  *
- * @constructs OC.EventSource
+ * @constructs OCEventSource
  */
-OC.EventSource=function(src,data){
+const OCEventSource = function (src, data) {
-	var dataStr='';
+	var dataStr = '';
 	var name;
 	var joinChar;
-	this.typelessListeners=[];
+	this.typelessListeners = [];
 	this.closed = false;
-	this.listeners={};
+	this.listeners = {};
-	if(data){
+	if (data) {
-		for(name in data){
+		for (name in data) {
-			dataStr+=name+'='+encodeURIComponent(data[name])+'&';
+			dataStr += name + '=' + encodeURIComponent(data[name]) + '&';
 		}
 	}
-	dataStr+='requesttoken='+encodeURIComponent(oc_requesttoken);
+	dataStr += 'requesttoken=' + encodeURIComponent(oc_requesttoken);
-	if(!this.useFallBack && typeof EventSource !== 'undefined'){
+	if (!this.useFallBack && typeof EventSource !== 'undefined') {
 		joinChar = '&';
-		if(src.indexOf('?') === -1) {
+		if (src.indexOf('?') === -1) {
 			joinChar = '?';
 		}
-		this.source= new EventSource(src+joinChar+dataStr);
+		this.source = new EventSource(src + joinChar + dataStr);
-		this.source.onmessage=function(e){
+		this.source.onmessage = function (e) {
-			for(var i=0;i<this.typelessListeners.length;i++){
+			for (var i = 0; i < this.typelessListeners.length; i++) {
 				this.typelessListeners[i](JSON.parse(e.data));
 			}
 		}.bind(this);
-	}else{
+	} else {
-		var iframeId='oc_eventsource_iframe_'+OC.EventSource.iframeCount;
+		var iframeId = 'oc_eventsource_iframe_' + OCEventSource.iframeCount;
-		OC.EventSource.fallBackSources[OC.EventSource.iframeCount]=this;
+		OCEventSource.fallBackSources[OCEventSource.iframeCount] = this;
-		this.iframe=$('<iframe/>');
+		this.iframe = $('<iframe/>');
-		this.iframe.attr('id',iframeId);
+		this.iframe.attr('id', iframeId);
 		this.iframe.hide();
 
 		joinChar = '&';
-		if(src.indexOf('?') === -1) {
+		if (src.indexOf('?') === -1) {
 			joinChar = '?';
 		}
-		this.iframe.attr('src',src+joinChar+'fallback=true&fallback_id='+OC.EventSource.iframeCount+'&'+dataStr);
+		this.iframe.attr('src', src + joinChar + 'fallback=true&fallback_id=' + OCEventSource.iframeCount + '&' + dataStr);
 		$('body').append(this.iframe);
-		this.useFallBack=true;
+		this.useFallBack = true;
-		OC.EventSource.iframeCount++;
+		OCEventSource.iframeCount++;
 	}
 	//add close listener
-	this.listen('__internal__',function(data){
+	this.listen('__internal__', function (data) {
-		if(data === 'close'){
+		if (data === 'close') {
 			this.close();
 		}
 	}.bind(this));
 };
-OC.EventSource.fallBackSources=[];
+OCEventSource.fallBackSources = [];
-OC.EventSource.iframeCount=0;//number of fallback iframes
+OCEventSource.iframeCount = 0;//number of fallback iframes
-OC.EventSource.fallBackCallBack=function(id,type,data){
+OCEventSource.fallBackCallBack = function (id, type, data) {
-	OC.EventSource.fallBackSources[id].fallBackCallBack(type,data);
+	OCEventSource.fallBackSources[id].fallBackCallBack(type, data);
 };
-OC.EventSource.prototype={
+OCEventSource.prototype = {
-	typelessListeners:[],
+	typelessListeners: [],
-	iframe:null,
+	iframe: null,
-	listeners:{},//only for fallback
+	listeners: {},//only for fallback
-	useFallBack:false,
+	useFallBack: false,
 	/**
 	 * Fallback callback for browsers that don't have the
 	 * native EventSource object.
@@ -104,50 +106,50 @@ OC.EventSource.prototype={
 	 * @param {String} type event type
 	 * @param {Object} data received data
 	 */
-	fallBackCallBack:function(type,data){
+	fallBackCallBack: function (type, data) {
 		var i;
 		// ignore messages that might appear after closing
 		if (this.closed) {
 			return;
 		}
-		if(type){
+		if (type) {
 			if (typeof this.listeners.done !== 'undefined') {
-				for(i=0;i<this.listeners[type].length;i++){
+				for (i = 0; i < this.listeners[type].length; i++) {
 					this.listeners[type][i](data);
 				}
 			}
-		}else{
+		} else {
-			for(i=0;i<this.typelessListeners.length;i++){
+			for (i = 0; i < this.typelessListeners.length; i++) {
 				this.typelessListeners[i](data);
 			}
 		}
 	},
-	lastLength:0,//for fallback
+	lastLength: 0,//for fallback
 	/**
 	 * Listen to a given type of events.
 	 *
 	 * @param {String} type event type
 	 * @param {Function} callback event callback
 	 */
-	listen:function(type,callback){
+	listen: function (type, callback) {
-		if(callback && callback.call){
+		if (callback && callback.call) {
 
-			if(type){
+			if (type) {
-				if(this.useFallBack){
+				if (this.useFallBack) {
-					if(!this.listeners[type]){
+					if (!this.listeners[type]) {
-						this.listeners[type]=[];
+						this.listeners[type] = [];
 					}
 					this.listeners[type].push(callback);
-				}else{
+				} else {
-					this.source.addEventListener(type,function(e){
+					this.source.addEventListener(type, function (e) {
 						if (typeof e.data !== 'undefined') {
 							callback(JSON.parse(e.data));
 						} else {
 							callback('');
 						}
-					},false);
+					}, false);
 				}
-			}else{
+			} else {
 				this.typelessListeners.push(callback);
 			}
 		}
@@ -155,10 +157,12 @@ OC.EventSource.prototype={
 	/**
 	 * Closes this event source.
 	 */
-	close:function(){
+	close: function () {
 		this.closed = true;
 		if (typeof this.source !== 'undefined') {
 			this.source.close();
 		}
 	}
 };
+
+export default OCEventSource;

core/src/OC/index.js

@@ -24,6 +24,7 @@ import Backbone from 'backbone';
 import Apps from './apps'
 import AppConfig from './appconfig'
 import ContactsMenu from './contactsmenu';
+import EventSource from './eventsource'
 import {davCall, davSync} from './backbone-webdav';
 
 // Patch Backbone for DAV
@@ -37,5 +38,6 @@ export default {
 	Apps,
 	AppConfig,
 	Backbone,
+	EventSource,
 	ContactsMenu,
 };