Function createMockConnectorApp

cli/src/mock-app.ts:45–422

(stateManager: MockConnectorStateManager)

}

function createMockConnectorApp(stateManager: MockConnectorStateManager) {
  const app = new H3()

  app.use((event: H3Event) => {
    const corsResult = handleCors(event, corsOptions)
    if (corsResult !== false) {
      return corsResult
    }
  })

  function requireAuth(event: H3Event): void {
    const authHeader = event.req.headers.get('authorization')
    if (!authHeader || !authHeader.startsWith('Bearer ')) {
      throw new HTTPError({ statusCode: 401, message: 'Authorization required' })
    }
    const token = authHeader.slice(7)
    if (token !== stateManager.token) {
      throw new HTTPError({ statusCode: 401, message: 'Invalid token' })
    }
    if (!stateManager.isConnected()) {
      throw new HTTPError({ statusCode: 401, message: 'Not connected' })
    }
  }

  // POST /connect
  app.post('/connect', async (event: H3Event) => {
    const body = (await event.req.json()) as { token?: string }
    const token = body?.token

    if (!token || token !== stateManager.token) {
      throw new HTTPError({ statusCode: 401, message: 'Invalid token' })
    }

    stateManager.connect(token)

    return {
      success: true,
      data: {
        npmUser: stateManager.config.npmUser,
        avatar: stateManager.config.avatar ?? null,
        connectedAt: stateManager.state.connectedAt ?? Date.now(),
      },
    } satisfies ApiResponse<ConnectorEndpoints['POST /connect']['data']>
  })

  // GET /state
  app.get('/state', (event: H3Event) => {
    requireAuth(event)

    return {
      success: true,
      data: {
        npmUser: stateManager.config.npmUser,
        avatar: stateManager.config.avatar ?? null,
        operations: stateManager.getOperations(),
      },
    } satisfies ApiResponse<ConnectorEndpoints['GET /state']['data']>
  })