core.js 1.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. // Copyright 2019-2023 Tauri Programme within The Commons Conservancy
  2. // SPDX-License-Identifier: Apache-2.0
  3. // SPDX-License-Identifier: MIT
  4. ; (function () {
  5. function uid() {
  6. return window.crypto.getRandomValues(new Uint32Array(1))[0]
  7. }
  8. if (!window.__TAURI__) {
  9. Object.defineProperty(window, '__TAURI__', {
  10. value: {}
  11. })
  12. }
  13. window.__TAURI__.transformCallback = function transformCallback(
  14. callback,
  15. once
  16. ) {
  17. var identifier = uid()
  18. var prop = `_${identifier}`
  19. Object.defineProperty(window, prop, {
  20. value: (result) => {
  21. if (once) {
  22. Reflect.deleteProperty(window, prop)
  23. }
  24. return callback && callback(result)
  25. },
  26. writable: false,
  27. configurable: true
  28. })
  29. return identifier
  30. }
  31. const ipcQueue = []
  32. let isWaitingForIpc = false
  33. function waitForIpc() {
  34. if ('__TAURI_IPC__' in window) {
  35. for (const action of ipcQueue) {
  36. action()
  37. }
  38. } else {
  39. setTimeout(waitForIpc, 50)
  40. }
  41. }
  42. window.__TAURI_INVOKE__ = function invoke(cmd, args = {}) {
  43. return new Promise(function (resolve, reject) {
  44. var callback = window.__TAURI__.transformCallback(function (r) {
  45. resolve(r)
  46. delete window[`_${error}`]
  47. }, true)
  48. var error = window.__TAURI__.transformCallback(function (e) {
  49. reject(e)
  50. delete window[`_${callback}`]
  51. }, true)
  52. if (typeof cmd === 'string') {
  53. args.cmd = cmd
  54. } else if (typeof cmd === 'object') {
  55. args = cmd
  56. } else {
  57. return reject(new Error('Invalid argument type.'))
  58. }
  59. const action = () => {
  60. window.__TAURI_IPC__({
  61. ...args,
  62. callback,
  63. error: error
  64. })
  65. }
  66. if (window.__TAURI_IPC__) {
  67. action()
  68. } else {
  69. ipcQueue.push(action)
  70. if (!isWaitingForIpc) {
  71. waitForIpc()
  72. isWaitingForIpc = true
  73. }
  74. }
  75. })
  76. }
  77. })()