@adonisjs/transmit
Advanced tools
Comparing version 0.5.1 to 0.5.2
@@ -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 | ||
} |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
77275
61
1881