@cerebral/firebase
Advanced tools
Comparing version
@@ -16,4 +16,6 @@ 'use strict'; | ||
function createTask(options, executionId, functionIndex) { | ||
function createTask(options) { | ||
return function (name) { | ||
var _this = this; | ||
var payload = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {}; | ||
@@ -28,8 +30,9 @@ | ||
_state: options.specPrefix ? options.specPrefix + '_' + name : name, | ||
_token: _token, | ||
_token: _token | ||
}, options.sendTaskExecutionDetails ? { | ||
_execution: { | ||
id: executionId, | ||
functionIndex: functionIndex | ||
id: _this.context.execution.id, | ||
functionIndex: _this.functionDetails.functionIndex | ||
} | ||
}, payload)); | ||
} : {}, payload)); | ||
@@ -36,0 +39,0 @@ var taskRef = _firebase2.default.database().ref(tasksPath + '/' + taskKey.key); |
102
lib/index.js
@@ -24,2 +24,4 @@ 'use strict'; | ||
var _cerebral = require('cerebral'); | ||
var _firebase = require('firebase'); | ||
@@ -39,17 +41,17 @@ | ||
var _createOnChildAdded = require('./createOnChildAdded'); | ||
var _onChildAdded = require('./onChildAdded'); | ||
var _createOnChildAdded2 = _interopRequireDefault(_createOnChildAdded); | ||
var _onChildAdded2 = _interopRequireDefault(_onChildAdded); | ||
var _createOnChildRemoved = require('./createOnChildRemoved'); | ||
var _onChildRemoved = require('./onChildRemoved'); | ||
var _createOnChildRemoved2 = _interopRequireDefault(_createOnChildRemoved); | ||
var _onChildRemoved2 = _interopRequireDefault(_onChildRemoved); | ||
var _createOnChildChanged = require('./createOnChildChanged'); | ||
var _onChildChanged = require('./onChildChanged'); | ||
var _createOnChildChanged2 = _interopRequireDefault(_createOnChildChanged); | ||
var _onChildChanged2 = _interopRequireDefault(_onChildChanged); | ||
var _createOnValue = require('./createOnValue'); | ||
var _onValue = require('./onValue'); | ||
var _createOnValue2 = _interopRequireDefault(_createOnValue); | ||
var _onValue2 = _interopRequireDefault(_onValue); | ||
@@ -149,52 +151,38 @@ var _createTask = require('./createTask'); | ||
var cachedProvider = null; | ||
function FirebaseProvider(context, functionDetails) { | ||
if (cachedProvider) { | ||
context.firebase = cachedProvider; | ||
} else { | ||
context.firebase = cachedProvider = { | ||
cancelOnDisconnect: _onDisconnect.cancelOnDisconnect, | ||
createUserWithEmailAndPassword: _createUserWithEmailAndPassword2.default, | ||
delete: _delete2.default, | ||
deleteFile: _delete2.default, | ||
deleteUser: _deleteUser2.default, | ||
getUser: _getUser2.default, | ||
linkWithFacebook: _linkWithFacebook2.default, | ||
linkWithGithub: _linkWithGithub2.default, | ||
linkWithGoogle: _linkWithGoogle2.default, | ||
off: _helpers.stopListening, | ||
onChildAdded: (0, _createOnChildAdded2.default)(context.controller), | ||
onChildChanged: (0, _createOnChildChanged2.default)(context.controller), | ||
onChildRemoved: (0, _createOnChildRemoved2.default)(context.controller), | ||
onValue: (0, _createOnValue2.default)(context.controller), | ||
push: _push2.default, | ||
put: _put2.default, | ||
remove: _remove2.default, | ||
sendPasswordResetEmail: _sendPasswordResetEmail2.default, | ||
set: _set2.default, | ||
setOnDisconnect: _onDisconnect.setOnDisconnect, | ||
signInAnonymously: _signInAnonymously2.default, | ||
signInWithCustomToken: _signInWithCustomToken2.default, | ||
signInWithEmailAndPassword: _signInWithEmailAndPassword2.default, | ||
signInWithFacebook: _signInWithFacebook2.default, | ||
signInWithGithub: _signInWithGithub2.default, | ||
signInWithGoogle: _signInWithGoogle2.default, | ||
signOut: _signOut2.default, | ||
transaction: _transaction2.default, | ||
update: _update2.default, | ||
value: _value2.default | ||
}; | ||
} | ||
context.firebase.task = (0, _createTask2.default)(options, context.execution.id, functionDetails.functionIndex); | ||
if (context.debugger) { | ||
context.debugger.wrapProvider('firebase'); | ||
} | ||
return context; | ||
} | ||
return FirebaseProvider; | ||
return (0, _cerebral.Provider)({ | ||
cancelOnDisconnect: _onDisconnect.cancelOnDisconnect, | ||
createUserWithEmailAndPassword: _createUserWithEmailAndPassword2.default, | ||
delete: _delete2.default, | ||
deleteFile: _delete2.default, | ||
deleteUser: _deleteUser2.default, | ||
getUser: _getUser2.default, | ||
linkWithFacebook: _linkWithFacebook2.default, | ||
linkWithGithub: _linkWithGithub2.default, | ||
linkWithGoogle: _linkWithGoogle2.default, | ||
off: _helpers.stopListening, | ||
onChildAdded: _onChildAdded2.default, | ||
onChildChanged: _onChildChanged2.default, | ||
onChildRemoved: _onChildRemoved2.default, | ||
onValue: _onValue2.default, | ||
push: _push2.default, | ||
put: _put2.default, | ||
remove: _remove2.default, | ||
sendPasswordResetEmail: _sendPasswordResetEmail2.default, | ||
set: _set2.default, | ||
setOnDisconnect: _onDisconnect.setOnDisconnect, | ||
signInAnonymously: _signInAnonymously2.default, | ||
signInWithCustomToken: _signInWithCustomToken2.default, | ||
signInWithEmailAndPassword: _signInWithEmailAndPassword2.default, | ||
signInWithFacebook: _signInWithFacebook2.default, | ||
signInWithGithub: _signInWithGithub2.default, | ||
signInWithGoogle: _signInWithGoogle2.default, | ||
signOut: _signOut2.default, | ||
task: (0, _createTask2.default)(options), | ||
transaction: _transaction2.default, | ||
update: _update2.default, | ||
value: _value2.default | ||
}, { | ||
cache: !options.sendTaskExecutionDetails | ||
}); | ||
} | ||
//# sourceMappingURL=index.js.map |
{ | ||
"name": "@cerebral/firebase", | ||
"version": "3.6.0-1510070698645", | ||
"version": "4.0.0-1511080103283", | ||
"description": "Firebase provider for Cerebral", | ||
@@ -29,7 +29,7 @@ "main": "lib/index.js", | ||
"peerDependencies": { | ||
"cerebral": "^3.6.0-1510070698645" | ||
"cerebral": "^4.0.0-1511080103284" | ||
}, | ||
"devDependencies": { | ||
"cerebral": "^3.6.0-1510070698645" | ||
"cerebral": "^4.0.0-1511080103284" | ||
} | ||
} |
@@ -33,3 +33,6 @@ # @cerebral/firebase | ||
// Use a different queue path. | ||
queuePath: 'myqueue' // default = 'queue' | ||
queuePath: 'myqueue' // default = 'queue', | ||
// Set to true if you are using debugger cross client | ||
// and server | ||
sendTaskExecutionDetails: false | ||
}) | ||
@@ -36,0 +39,0 @@ ] |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
1229
0.24%182009
-0.96%1844
-0.59%