Have a QML Future object instead of JS dict

This commit is contained in:
miruka 2019-12-18 06:16:24 -04:00
parent d675b3a40b
commit 5d7d66f99b
3 changed files with 68 additions and 56 deletions

View File

@ -14,8 +14,8 @@ QtObject {
function onCoroutineDone(uuid, result, error, traceback) { function onCoroutineDone(uuid, result, error, traceback) {
let onSuccess = py.pendingCoroutines[uuid].onSuccess let onSuccess = py.privates.pendingCoroutines[uuid].onSuccess
let onError = py.pendingCoroutines[uuid].onError let onError = py.privates.pendingCoroutines[uuid].onError
if (error) { if (error) {
let type = py.getattr(py.getattr(error, "__class__"), "__name__") let type = py.getattr(py.getattr(error, "__class__"), "__name__")
@ -31,7 +31,7 @@ QtObject {
} else if (onSuccess) { onSuccess(result) } } else if (onSuccess) { onSuccess(result) }
delete pendingCoroutines[uuid] delete py.privates.pendingCoroutines[uuid]
} }

View File

@ -0,0 +1,25 @@
import QtQuick 2.12
QtObject {
id: future
property PythonBridge bridge
readonly property QtObject privates: QtObject {
onPythonFutureChanged: if (cancelPending) future.cancel()
property var pythonFuture: null
property bool cancelPending: false
}
function cancel() {
if (! privates.pythonFuture) {
privates.cancelPending = true
return
}
bridge.call(bridge.getattr(privates.pythonFuture, "cancel"))
}
}

View File

@ -3,86 +3,94 @@ import io.thp.pyotherside 1.5
Python { Python {
id: py id: py
Component.onCompleted: {
for (var func in privates.eventHandlers) {
if (! privates.eventHandlers.hasOwnProperty(func)) continue
setHandler(func.replace(/^on/, ""), privates.eventHandlers[func])
}
addImportPath("src")
addImportPath("qrc:/src")
importNames("backend", ["APP"], () => {
loadSettings(() => {
callCoro("saved_accounts.any_saved", [], any => {
if (any) { py.callCoro("load_saved_accounts", []) }
py.startupAnyAccountsSaved = any
py.ready = true
})
})
})
}
property bool ready: false property bool ready: false
property bool startupAnyAccountsSaved: false property bool startupAnyAccountsSaved: false
property var pendingCoroutines: ({})
property EventHandlers eventHandlers: EventHandlers {} readonly property QtObject privates: QtObject {
readonly property var pendingCoroutines: ({})
readonly property EventHandlers eventHandlers: EventHandlers {}
function makeFuture(callback) {
function newQmlFuture() { return Qt.createComponent("Future.qml")
return { .createObject(py, {bridge: py})
_pyFuture: null,
get pyFuture() { return this._pyFuture },
set pyFuture(value) {
this._pyFuture = value
if (this.cancelPending) this.cancel()
},
cancelPending: false,
cancel: function() {
if (! this.pyFuture) {
this.cancelPending = true
return
}
py.call(py.getattr(this.pyFuture, "cancel"))
},
} }
} }
function setattr(obj, attr, value, callback=null) { function setattr(obj, attr, value, callback=null) {
py.call(py.getattr(obj, "__setattr__"), [attr, value], callback) py.call(py.getattr(obj, "__setattr__"), [attr, value], callback)
} }
function callSync(name, args=[]) { function callSync(name, args=[]) {
return call_sync("APP.backend." + name, args) return call_sync("APP.backend." + name, args)
} }
function callCoro(name, args=[], onSuccess=null, onError=null) { function callCoro(name, args=[], onSuccess=null, onError=null) {
let uuid = name + "." + CppUtils.uuid() let uuid = name + "." + CppUtils.uuid()
pendingCoroutines[uuid] = {onSuccess, onError} privates.pendingCoroutines[uuid] = {onSuccess, onError}
let qmlFuture = py.newQmlFuture() let future = privates.makeFuture()
call("APP.call_backend_coro", [name, uuid, args], pyFuture => { call("APP.call_backend_coro", [name, uuid, args], pyFuture => {
qmlFuture.pyFuture = pyFuture future.privates.pythonFuture = pyFuture
}) })
return qmlFuture return future
} }
function callClientCoro( function callClientCoro(
accountId, name, args=[], onSuccess=null, onError=null accountId, name, args=[], onSuccess=null, onError=null
) { ) {
let qmlFuture = py.newQmlFuture() let future = privates.makeFuture()
callCoro("wait_until_client_exists", [accountId], () => { callCoro("wait_until_client_exists", [accountId], () => {
let uuid = accountId + "." + name + "." + CppUtils.uuid() let uuid = accountId + "." + name + "." + CppUtils.uuid()
pendingCoroutines[uuid] = {onSuccess, onError} privates.pendingCoroutines[uuid] = {onSuccess, onError}
let call_args = [accountId, name, uuid, args] let call_args = [accountId, name, uuid, args]
call("APP.call_client_coro", call_args, pyFuture => { call("APP.call_client_coro", call_args, pyFuture => {
qmlFuture.pyFuture = pyFuture future.privates.pythonFuture = pyFuture
}) })
}) })
return qmlFuture return future
} }
function saveConfig(backend_attribute, data, callback=null) { function saveConfig(backend_attribute, data, callback=null) {
if (! py.ready) { return } // config not loaded yet if (! py.ready) { return } // config not loaded yet
return callCoro(backend_attribute + ".write", [data], callback) return callCoro(backend_attribute + ".write", [data], callback)
} }
function loadSettings(callback=null) { function loadSettings(callback=null) {
let func = "load_settings" let func = "load_settings"
@ -95,25 +103,4 @@ Python {
if (callback) { callback(settings, uiState, theme) } if (callback) { callback(settings, uiState, theme) }
}) })
} }
Component.onCompleted: {
for (var func in eventHandlers) {
if (eventHandlers.hasOwnProperty(func)) {
setHandler(func.replace(/^on/, ""), eventHandlers[func])
}
}
addImportPath("src")
addImportPath("qrc:/src")
importNames("backend", ["APP"], () => {
loadSettings(() => {
callCoro("saved_accounts.any_saved", [], any => {
if (any) { py.callCoro("load_saved_accounts", []) }
py.startupAnyAccountsSaved = any
py.ready = true
})
})
})
}
} }