| 18218 | } |
| 18219 | }; |
| 18220 | function upgrade(opts, callback) { |
| 18221 | if (callback === void 0) { |
| 18222 | return new Promise((resolve, reject) => { |
| 18223 | upgrade.call(this, opts, (err, data) => { |
| 18224 | return err ? reject(err) : resolve(data); |
| 18225 | }); |
| 18226 | }); |
| 18227 | } |
| 18228 | try { |
| 18229 | const upgradeHandler = new UpgradeHandler(opts, callback); |
| 18230 | const upgradeOpts = { |
| 18231 | ...opts, |
| 18232 | method: opts.method || "GET", |
| 18233 | upgrade: opts.protocol || "Websocket" |
| 18234 | }; |
| 18235 | this.dispatch(upgradeOpts, upgradeHandler); |
| 18236 | } catch (err) { |
| 18237 | if (typeof callback !== "function") { |
| 18238 | throw err; |
| 18239 | } |
| 18240 | const opaque = opts?.opaque; |
| 18241 | queueMicrotask(() => callback(err, { opaque })); |
| 18242 | } |
| 18243 | } |
| 18244 | __name(upgrade, "upgrade"); |
| 18245 | module2.exports = upgrade; |
| 18246 | } |