mau Comments - Answer Overflow

app.get(
  'connect',
  upgradeWebSocket((c) => {
    return {
      onMessage(event, ws) {
        // console.log(`Message from client: ${event.data}`);
        // let data = { ...event.data, event: 'send' };
        console.log(event);
        ws.send(event.data);
      },
      onClose: () => {
        console.log('Connection closed');
      },
      onOpen: (e) => {
        console.log('open', e);
      },
    };
  })
);

app.get(
  'connect',
  upgradeWebSocket((c) => {
    return {
      onMessage(event, ws) {
        // console.log(`Message from client: ${event.data}`);
        // let data = { ...event.data, event: 'send' };
        console.log(event);
        ws.send(event.data);
      },
      onClose: () => {
        console.log('Connection closed');
      },
      onOpen: (e) => {
        console.log('open', e);
      },
    };
  })
);

5 replies

HHono

•Created by Blankeos on 6/22/2024 in #help

Have you guys ever gotten websockets to work on Hono + `@hono/vite-dev-server` plugin?

i was able to get it to work but the issue was facing was with headers.

5 replies

HHono

•Created by Paul on 6/26/2024 in #help

Can the queue only be defined in the root?

Yes, i also did with root and i wasn't able to think of any other way myself.

import { Hono } from 'hono';

type Environment = {
  readonly ERROR_QUEUE: Queue<any>;
};

const queue = new Hono<{
  Bindings: Environment;
}>();

queue.get('/', async (c) => {
  await c.env.ERROR_QUEUE.send({ progressId: 1 });
  return c.json({ success: true });
});

export default queue;

export default {
  fetch: app.fetch,
  async queue(batch: MessageBatch<any>, env: any) {
    for (const message of batch.messages) {
      queueProcessor(message);
    }
  },
};

function queueProcessor(message: any) {
  const { body, attempts } = message;
  if (Math.random() < 0.5) {
    switch (body?.event) {
      case 'start-quiz':
        console.log('data', body, 'attempts', attempts);
        break;
      default:
        console.log('data', body, 'attempts', attempts);
        break;
    }
  } else {
    throw new Error('Failed!');
  }
}

import { Hono } from 'hono';

type Environment = {
  readonly ERROR_QUEUE: Queue<any>;
};

const queue = new Hono<{
  Bindings: Environment;
}>();

queue.get('/', async (c) => {
  await c.env.ERROR_QUEUE.send({ progressId: 1 });
  return c.json({ success: true });
});

export default queue;

export default {
  fetch: app.fetch,
  async queue(batch: MessageBatch<any>, env: any) {
    for (const message of batch.messages) {
      queueProcessor(message);
    }
  },
};

function queueProcessor(message: any) {
  const { body, attempts } = message;
  if (Math.random() < 0.5) {
    switch (body?.event) {
      case 'start-quiz':
        console.log('data', body, 'attempts', attempts);
        break;
      default:
        console.log('data', body, 'attempts', attempts);
        break;
    }
  } else {
    throw new Error('Failed!');
  }
}

2 replies

Gaming

Programming