// Durable Object
export default class WebSocketHibernationServer extends DurableObject {
  async fetch(request: Request): Promise<Response> {
    const upgradeHeader = request.headers.get('Upgrade');
    if (!upgradeHeader || upgradeHeader !== 'websocket') {
      return new Response('Expected Upgrade: websocket', { status: 426 });
    }

    // Extract userId from the protocol
    const wsProtocol = request.headers.get('Sec-WebSocket-Protocol');
    const [protocol] = wsProtocol?.split(', ') || [];

    console.log('server', { protocol });

    const webSocketPair = new WebSocketPair();
    const [client, server] = Object.values(webSocketPair);

    this.ctx.acceptWebSocket(server);

    return new Response(null, {
      status: 101,
      headers: {
        Upgrade: 'websocket',
        Connection: 'Upgrade',
        'Sec-WebSocket-Protocol': protocol || '',
      },
      webSocket: client,
    });
  }

  async webSocketMessage(ws: WebSocket, message: ArrayBuffer | string) {
    // TODO: How do we get the user ID from the websocket?

    const websockets = this.ctx.getWebSockets();
    for (const ws of websockets) {
      ws.send(message);
    }
  }

  async webSocketClose(ws: WebSocket, code: number, reason: string, _wasClean: boolean) {
    ws.close(code, reason);
  }
}

// Durable Object
export default class WebSocketHibernationServer extends DurableObject {
  async fetch(request: Request): Promise<Response> {
    const upgradeHeader = request.headers.get('Upgrade');
    if (!upgradeHeader || upgradeHeader !== 'websocket') {
      return new Response('Expected Upgrade: websocket', { status: 426 });
    }

    // Extract userId from the protocol
    const wsProtocol = request.headers.get('Sec-WebSocket-Protocol');
    const [protocol] = wsProtocol?.split(', ') || [];

    console.log('server', { protocol });

    const webSocketPair = new WebSocketPair();
    const [client, server] = Object.values(webSocketPair);

    this.ctx.acceptWebSocket(server);

    return new Response(null, {
      status: 101,
      headers: {
        Upgrade: 'websocket',
        Connection: 'Upgrade',
        'Sec-WebSocket-Protocol': protocol || '',
      },
      webSocket: client,
    });
  }

  async webSocketMessage(ws: WebSocket, message: ArrayBuffer | string) {
    // TODO: How do we get the user ID from the websocket?

    const websockets = this.ctx.getWebSockets();
    for (const ws of websockets) {
      ws.send(message);
    }
  }

  async webSocketClose(ws: WebSocket, code: number, reason: string, _wasClean: boolean) {
    ws.close(code, reason);
  }
}

// This gets called in my fetch handler
/*
if (request.url.includes('/websocket')) {
        return handleWebsocketRequest(request, env, appUrl, user);
      }
*/
export const handleWebsocketRequest = async (
  request: Request,
  env: Env,
  appUrl: string,
  user: User | null,
): Promise<Response> => {
  if (request.url.includes('/websocket') && user) {
    let id = env.WEBSOCKET_HIBERNATION_SERVER.idFromName(`user-${user?.id}`);
    let stub = env.WEBSOCKET_HIBERNATION_SERVER.get(id);
    // Let the Durable Object handle the WebSocket creation and upgrade
    const response = await stub.fetch(request.url, {
      method: request.method,
      headers: request.headers,
      body: request.body,
    });

    return response as Response;
  }

  return new Response(
    JSON.stringify({
      error: {
        code: 'Unauthorized',
        message: 'You must be logged in to use this endpoint',
      },
    }),
    {
      status: 401,
      headers: {
        'content-type': 'application/json',
        'Access-Control-Allow-Origin': appUrl,
        'Access-Control-Allow-Credentials': 'true',
      },
    },
  );
};

// This gets called in my fetch handler
/*
if (request.url.includes('/websocket')) {
        return handleWebsocketRequest(request, env, appUrl, user);
      }
*/
export const handleWebsocketRequest = async (
  request: Request,
  env: Env,
  appUrl: string,
  user: User | null,
): Promise<Response> => {
  if (request.url.includes('/websocket') && user) {
    let id = env.WEBSOCKET_HIBERNATION_SERVER.idFromName(`user-${user?.id}`);
    let stub = env.WEBSOCKET_HIBERNATION_SERVER.get(id);
    // Let the Durable Object handle the WebSocket creation and upgrade
    const response = await stub.fetch(request.url, {
      method: request.method,
      headers: request.headers,
      body: request.body,
    });

    return response as Response;
  }

  return new Response(
    JSON.stringify({
      error: {
        code: 'Unauthorized',
        message: 'You must be logged in to use this endpoint',
      },
    }),
    {
      status: 401,
      headers: {
        'content-type': 'application/json',
        'Access-Control-Allow-Origin': appUrl,
        'Access-Control-Allow-Credentials': 'true',
      },
    },
  );
};