crowser 0.4.1

Create "desktop apps" using user-installed browsers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

if (!window.__CROWSER) {
  window.__CROWSER = {}

  /**
   * IPC related functionality, such as events and sending messages
   */
  window.__CROWSER.ipc = {
    // List of messages to send
    // id, cmd, args
    outbound_invokes: [],

    // List of events to listen for
    // id, evt, callback
    inbound_events: {},

    // List of messages to consume
    // id, cmd, args
    inbound_invokes: {},

    // Master message queue to consume from
    // id, type, payload
    message_queue: [],

    invoke: (cmd, args = {}) => {
      if (cmd === "") {
        console.error("[Crowser IPC] Empty command")
        return
      }

      if (typeof args !== "object") {
        console.error("[Crowser IPC] Args must be an object")
        return
      }

      let uuid = generateUUID()
      window.__CROWSER.ipc.outbound_invokes.push({ uuid, cmd, args })

      // Wait for a response
      return new Promise(async (resolve, reject) => {
        while (window.__CROWSER.ipc.inbound_invokes[uuid] === undefined) {
          await wait(5)
        }

        resolve(window.__CROWSER.ipc.inbound_invokes[uuid])
      })
    },
    event: {
      listen: (evt, callback) => {
        if (!window.__CROWSER.ipc.inbound_events[evt]) {
          window.__CROWSER.ipc.inbound_events[evt] = []
        }

        window.__CROWSER.ipc.inbound_events[evt].push(callback)

        return () => {
          window.__CROWSER.ipc.inbound_events[evt] = window.__CROWSER.ipc.inbound_events[evt].filter(cb => cb !== callback)
        }
      },
      unlisten: (evt, callback) => {
        window.__CROWSER.ipc.inbound_events[evt] = window.__CROWSER.ipc.inbound_events[evt].filter(cb => cb !== callback)
      },
      emit: (evt, payload) => {
        window.__CROWSER.ipc.outbound_event.push({ evt, payload })
      },
    },

    _consume: async () => {
      while (true) {
        await wait(5)

        // Check if any items are in the queue
        if (window.__CROWSER.ipc.message_queue.length === 0) {
          break
        }

        const item = window.__CROWSER.ipc.message_queue.shift()

        if (item.type === 'invoke') {
          const callback = window.__CROWSER.ipc.inbound_invokes[item.id]

          if (callback) {
            callback(item.payload)
          }
        } else if (item.type === 'event') {
          const callbacks = window.__CROWSER.ipc.inbound_events[item.evt]

          if (callbacks) {
            callbacks.forEach(cb => cb(item.payload))
          }
        }
      }
    },

    _backend_consume: () => {
      return window.__CROWSER.ipc.outbound_invokes.shift()
    },

    _backend_respond: (uuid, result) => {
      window.__CROWSER.ipc.inbound_invokes[uuid] = result
    }
  }

  window.__CROWSER.ipc._consume()
}

function wait(ms) {
  return new Promise((r) => setTimeout(r, ms))
}

// https://stackoverflow.com/a/8809472/13438741
function generateUUID() {
  var d = new Date().getTime();//Timestamp
  var d2 = ((typeof performance !== 'undefined') && performance.now && (performance.now() * 1000)) || 0;
  return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) {
    var r = Math.random() * 16;
    if (d > 0) {
      r = (d + r) % 16 | 0;
      d = Math.floor(d / 16);
    } else {
      r = (d2 + r) % 16 | 0;
      d2 = Math.floor(d2 / 16);
    }
    return (c === 'x' ? r : (r & 0x3 | 0x8)).toString(16);
  });
}