Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Azure webpubsub integration #1

Merged
merged 17 commits into from
Nov 16, 2023
Merged

Azure webpubsub integration #1

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
17 commits
Select commit Hold shift + click to select a range
45bf721
Fix webrtc glare
dextertanyj Oct 27, 2022
946f612
Support for obtaining the current online client
fEyebrow Mar 21, 2023
9d399e3
rename message.number to message.clients
fEyebrow Mar 21, 2023
ac29b5d
Merge pull request #44 from fEyebrow/initial-content
dmonad Mar 21, 2023
7529899
fix typo in package.json
asmodehn May 22, 2023
7f81858
fix(package): missing "type" property in export
AkaraChen May 25, 2023
42967de
Fix type in documentation
Flamenco Jun 14, 2023
ec65bac
Merge pull request #51 from Flamenco/patch-typo
dmonad Jun 16, 2023
661a9e2
Merge pull request #50 from AkaraChen/master
dmonad Jun 16, 2023
240e793
Merge pull request #48 from asmodehn/patch-1
dmonad Jun 16, 2023
0cb5412
Merge pull request #39 from dextertanyj/fix/webrtc-glare
dmonad Jun 16, 2023
48a1435
bump ws to 8.13.0
clemos Jun 23, 2023
0011323
Upgrade yjs, ws and y-protocols packages
stephane-klein Nov 14, 2023
135dffa
Merge pull request #58 from stephane-klein/upgrade-yjs-ws-y-protocols…
dmonad Nov 16, 2023
c29267b
recreate package-lock
dmonad Nov 16, 2023
c7489c9
10.2.6
dmonad Nov 16, 2023
ca12e7d
Merge tag 'v10.2.6' into azure-webpubsub-integration
byrond Nov 16, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions bin/server.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
#!/usr/bin/env node

import ws from 'ws'
import { WebSocketServer } from 'ws'
import http from 'http'
import * as map from 'lib0/map'

Expand All @@ -12,8 +12,7 @@ const wsReadyStateClosed = 3 // eslint-disable-line
const pingTimeout = 30000

const port = process.env.PORT || 4444
// @ts-ignore
const wss = new ws.Server({ noServer: true })
const wss = new WebSocketServer({ noServer: true })

const server = http.createServer((request, response) => {
response.writeHead(200, { 'Content-Type': 'text/plain' })
Expand Down Expand Up @@ -81,7 +80,7 @@ const onconnection = conn => {
closed = true
})
conn.on('message', /** @param {object} message */ message => {
if (typeof message === 'string') {
if (typeof message === 'string' || message instanceof Buffer) {
message = JSON.parse(message)
}
if (message && message.type && !closed) {
Expand Down Expand Up @@ -109,6 +108,7 @@ const onconnection = conn => {
if (message.topic) {
const receivers = topics.get(message.topic)
if (receivers) {
message.clients = receivers.size
receivers.forEach(receiver =>
send(receiver, message)
)
Expand Down
Loading