async plugins support about primus HOT 8 CLOSED

I think it's better to use a middleware if the validation should be done before the 'connection' event is emitted.

from primus.

I think it's better to use a middleware if the validation should be done before the 'connection' event is emitted.

Hi,

Yes, I looked at middleware and tried to implement that but I had some problems with that.

What I tried looked something like this:

  this.primus.use(() => {
      return async (req, res) => {
        if(await doStuff()) {
          req.socket.destroy();
          return;
        }
      }
    });

And it worked as I wanted to (connection was closed if wrong params were provided) but the client kept creating new connections and I couldn't find out why.

That's why I tried with plugin where I have access to spark and it worked in the way I described in the issue.

Is there a way I use middleware and tell the client to not open new connections?

from primus.

One issue I see in the above example is that Primus does not support middleware that return a promise. Asynchronous middleware take an additional next argument that should be called. You could do something like this

primus.use(() => {
  return async (req, res, next) => {
    let ret;

    try {
      ret = await doStuff();
    } catch(e) {
      res.destroy();
      return;
    }

    if (ret) {
      res.destroy();
      return;
    }

    next();
  }
});

from primus.

One issue I see in the above example is that Primus does not support middleware that return a promise. Asynchronous middleware take an additional next argument that should be called. You could do something like this

primus.use(() => {
  return async (req, res, next) => {
    let ret;

    try {
      ret = await doStuff();
    } catch(e) {
      res.destroy();
      return;
    }

    if (ret) {
      res.destroy();
      return;
    }

    next();
  }
});

I tried it but the issue is that I'm using TypeScript and definition in the declaration file does not allow addional next parameter as it looks this:

type Middleware = (req: http.IncomingMessage, res: http.ServerResponse) => void;

And use function looks like this:

use(fn: () => Middleware | Middleware, options?: object, level?: number): this;

Aynyway I overwrote it and I tried something like this:

    this.primus.use(() => {
      return async (req, res, next) => {

        try {
          if (!await doStuff()) {
            res.destroy();
            return;
          }
        } catch (error) {
          res.destroy();
          return;
        }

        next();
      }
    });

Unfortunately it still didn't work so most likely I'll have to stick to calling the plugin directly in the 'connection' handler. Unless there's another solution.

from primus.

What is the issue? The client keeps connecting when "validation" fails? If so it might be a reconnection issue. The client does not know if the disconnection was caused by a validation failure. In that case you might want to disable automatic reconnection.

from primus.

What is the issue? The client keeps connecting when "validation" fails? If so it might be a reconnection issue. The client does not know if the disconnection was caused by a validation failure. In that case you might want to disable automatic reconnection.

Yes, this is exactly the issue and I think that you're right about the reconnection. The issue is that I'm not sure if I can disable it but I would say that we can close this issue with that conclusion. Thank you very much for your help!

from primus.

You can try to remove the 'timeout' strategy and see it makes any difference. See https://github.com/primus/primus#strategy.

See also https://github.com/primus/mirage for an example of an "async" plugin but I don't think it makes much sense in your case.

from primus.

You can try to remove the 'timeout' strategy and see it makes any difference. See https://github.com/primus/primus#strategy.

See also https://github.com/primus/mirage for an example of an "async" plugin but I don't think it makes much sense in your case.

Yeah, I tried removing the strategy after I closed the issue and it worked like I wanted to but unfortunately we need some reconnection strategy in our app so this is not applicable in my case.

I'll have look at the async plugin example you referenced, thank you.

from primus.