Socket
Socket
Sign inDemoInstall

@adonisjs/transmit

Package Overview
Dependencies
Maintainers
3
Versions
32
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@adonisjs/transmit - npm Package Compare versions

Comparing version 0.5.1 to 0.5.2

build/test_helpers/index.d.ts

12

build/providers/transmit_provider.js

@@ -29,6 +29,7 @@ /*

const transmit = await this.app.container.make('transmit');
router.get('__transmit/events', (ctx) => {
const config = this.app.config.get('transmit', {});
const registerRoute = router.get('__transmit/events', (ctx) => {
transmit.$createStream(ctx);
});
router.post('__transmit/subscribe', async (ctx) => {
const subscribeRoute = router.post('__transmit/subscribe', async (ctx) => {
const uid = ctx.request.input('uid');

@@ -42,3 +43,3 @@ const channel = ctx.request.input('channel');

});
router.post('__transmit/unsubscribe', (ctx) => {
const unsubscribeRoute = router.post('__transmit/unsubscribe', (ctx) => {
const uid = ctx.request.input('uid');

@@ -52,2 +53,7 @@ const channel = ctx.request.input('channel');

});
if (config.routeHandlerDomain) {
registerRoute.domain(config.routeHandlerDomain);
subscribeRoute.domain(config.routeHandlerDomain);
unsubscribeRoute.domain(config.routeHandlerDomain);
}
}

@@ -54,0 +60,0 @@ async shutdown() {

@@ -22,2 +22,3 @@ import type { TransportFactory } from '@rlanz/bus/types/main';

};
routeHandlerDomain?: string;
}
{
"name": "@adonisjs/transmit",
"description": "A Server-Sent-Event module bringing real-time capabilities to AdonisJS.",
"version": "0.5.1",
"version": "0.5.2",
"engines": {

@@ -36,3 +36,3 @@ "node": ">=20.11.1"

"quick:test": "node --enable-source-maps --loader=ts-node/esm bin/test.ts",
"release": "np",
"release": "npx release-it",
"test": "c8 npm run quick:test",

@@ -63,4 +63,4 @@ "typecheck": "tsc --noEmit",

"eslint": "^8.57.0",
"np": "^10.0.2",
"prettier": "^3.2.5",
"release-it": "^17.1.1",
"ts-node": "^10.9.2",

@@ -97,7 +97,13 @@ "typescript": "^5.4.3"

},
"np": {
"message": "chore(release): %s",
"tag": "latest",
"branch": "main",
"anyBranch": false
"release-it": {
"git": {
"commitMessage": "chore(release): ${version}",
"tagAnnotation": "v${version}",
"tagName": "v${version}"
},
"github": {
"release": true,
"releaseName": "v${version}",
"web": true
}
},

@@ -104,0 +110,0 @@ "c8": {

@@ -36,8 +36,9 @@ /*

const transmit = await this.app.container.make('transmit')
const config = this.app.config.get<TransmitConfig>('transmit', {})
router.get('__transmit/events', (ctx) => {
const registerRoute = router.get('__transmit/events', (ctx) => {
transmit.$createStream(ctx)
})
router.post('__transmit/subscribe', async (ctx) => {
const subscribeRoute = router.post('__transmit/subscribe', async (ctx) => {
const uid = ctx.request.input('uid')

@@ -55,3 +56,3 @@ const channel = ctx.request.input('channel')

router.post('__transmit/unsubscribe', (ctx) => {
const unsubscribeRoute = router.post('__transmit/unsubscribe', (ctx) => {
const uid = ctx.request.input('uid')

@@ -68,2 +69,8 @@ const channel = ctx.request.input('channel')

})
if (config.routeHandlerDomain) {
registerRoute.domain(config.routeHandlerDomain)
subscribeRoute.domain(config.routeHandlerDomain)
unsubscribeRoute.domain(config.routeHandlerDomain)
}
}

@@ -70,0 +77,0 @@

@@ -29,2 +29,3 @@ /*

transport: null | { driver: TransportFactory; channel?: string }
routeHandlerDomain?: string
}
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc