feat: implement benchmark app

example/index.js

@@ -2,6 +2,6 @@ import '@bacons/text-decoder/install'
 
 import { AppRegistry } from 'react-native'
 
-import { App } from './App'
+import { BenchmarkUI } from './tests/benchmark'
 
-AppRegistry.registerComponent('NitroPlayground', () => App)
+AppRegistry.registerComponent('NitroPlayground', () => BenchmarkUI)

example/package.json

@@ -5,7 +5,7 @@
     "android": "react-native run-android",
     "ios": "react-native run-ios",
     "start": "react-native start",
-    "server": "bun server.ts"
+    "server": "bun server/index.ts"
   },
   "dependencies": {
     "@bacons/text-decoder": "^0.0.0",

example/server/createServer.ts

@@ -0,0 +1,39 @@
+/// <reference types="bun-types" />
+
+/**
+ * Creates a WebSocket server that sends configurable responses
+ */
+export function createServer(payload: string | Bun.BufferSource, port: number) {
+  const server = Bun.serve({
+    fetch(req, server) {
+      if (server.upgrade(req)) {
+        return
+      }
+      return new Response('Upgrade failed', { status: 500 })
+    },
+    websocket: {
+      message(ws, message: string) {
+        if (typeof message !== 'string') {
+          return
+        }
+        const count = parseInt(message)
+        if (isNaN(count)) {
+          return
+        }
+        try {
+          for (let i = 0; i < count; i++) {
+            ws.send(payload)
+          }
+        } catch (error) {
+          console.error('Failed to parse message:', error)
+        }
+      },
+    },
+    port,
+  })
+
+  console.log(`WebSocket server listening on ws://localhost:${port}`)
+
+  // Return cleanup function
+  return () => server.stop()
+}

example/server/index.ts

@@ -0,0 +1,41 @@
+import { createServer } from './createServer'
+import {
+  CHAT_PAYLOAD,
+  CHAT_PAYLOAD_BINARY,
+  CHAT_SERVER_BINARY_PORT,
+  CHAT_SERVER_PORT,
+  COORDINATE_PAYLOAD,
+  COORDINATE_PAYLOAD_BINARY,
+  COORDINATE_SERVER_BINARY_PORT,
+  COORDINATE_SERVER_PORT,
+  IMAGE_SERVER_PORT,
+} from './payloads'
+
+async function run() {
+  const stopChatServer = createServer(CHAT_PAYLOAD, CHAT_SERVER_PORT)
+  const stopChatBinaryServer = createServer(CHAT_PAYLOAD_BINARY, CHAT_SERVER_BINARY_PORT)
+  const stopCoordinateServer = createServer(COORDINATE_PAYLOAD, COORDINATE_SERVER_PORT)
+  const stopCoordinateBinaryServer = createServer(
+    COORDINATE_PAYLOAD_BINARY,
+    COORDINATE_SERVER_BINARY_PORT
+  )
+  const stopImageServer = createServer(
+    await Bun.file(__dirname + '/img.jpg').arrayBuffer(),
+    IMAGE_SERVER_PORT
+  )
+
+  const stopAllServers = () => {
+    stopChatServer()
+    stopChatBinaryServer()
+    stopCoordinateServer()
+    stopCoordinateBinaryServer()
+    stopImageServer()
+  }
+
+  process.on('SIGINT', () => {
+    stopAllServers()
+    process.exit(0)
+  })
+}
+
+run()

example/server/payloads.ts

@@ -0,0 +1,37 @@
+/**
+ * This file contains the payloads that are used in the test.
+ */
+
+const encoder = new TextEncoder()
+
+export const CHAT_PAYLOAD = JSON.stringify({
+  id: '123e4567-e89b-12d3-a456-426614174000',
+  type: 'message',
+  content: {
+    text: 'Hello! How are you doing today? 👋',
+    mentions: ['@mike'],
+    attachments: [],
+  },
+  room: {
+    id: 'room_456',
+    type: 'direct',
+  },
+  metadata: {
+    client: 'react-native-fast-ws/1.0.0',
+  },
+})
+
+export const CHAT_PAYLOAD_BINARY = encoder.encode(JSON.stringify(CHAT_PAYLOAD))
+
+export const COORDINATE_PAYLOAD = JSON.stringify({
+  coords: [456, 750],
+})
+export const COORDINATE_PAYLOAD_BINARY = encoder.encode(JSON.stringify(COORDINATE_PAYLOAD))
+
+export const CHAT_SERVER_PORT = 3000
+export const CHAT_SERVER_BINARY_PORT = 3001
+
+export const COORDINATE_SERVER_PORT = 3002
+export const COORDINATE_SERVER_BINARY_PORT = 3003
+
+export const IMAGE_SERVER_PORT = 3004