All files / kernel-browser-runtime/src/vat iframe.ts

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
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
import type { JsonRpcMessage } from '@metamask/kernel-utils';
import { isJsonRpcMessage } from '@metamask/kernel-utils';
import { Logger } from '@metamask/logger';
import { VatSupervisor } from '@metamask/ocap-kernel';
import {
  MessagePortDuplexStream,
  receiveMessagePort,
} from '@metamask/streams/browser';
import { makePlatform } from '@ocap/kernel-platforms/browser';
 
import { setupConsoleForwarding } from '../utils/console-forwarding.ts';
 
const logger = new Logger('vat-iframe');
 
main().catch(logger.error);
 
/**
 * The main function for the iframe.
 */
async function main(): Promise<void> {
  const kernelStream = await receiveMessagePort(
    (listener) => addEventListener('message', listener),
    (listener) => removeEventListener('message', listener),
  ).then(async (port) =>
    MessagePortDuplexStream.make<JsonRpcMessage, JsonRpcMessage>(
      port,
      isJsonRpcMessage,
    ),
  );
 
  const urlParams = new URLSearchParams(window.location.search);
  const vatId = urlParams.get('vatId') ?? 'unknown';
 
  setupConsoleForwarding({
    source: `vat-${vatId}`,
    onMessage: (message) => {
      window.parent.postMessage(message, '*');
    },
  });
 
  // eslint-disable-next-line no-new
  new VatSupervisor({
    id: vatId,
    kernelStream,
    logger: logger.subLogger(vatId),
    makePlatform,
  });
 
  logger.info('VatSupervisor initialized with vatId:', vatId);
}