websocket.go

History

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

package relayer

import (

"sync"

"github.com/fasthttp/websocket"

"golang.org/x/time/rate"

)

type WebSocket struct {

conn *websocket.Conn

mutex sync.Mutex

// nip42

challenge string

authed string

limiter *rate.Limiter

}

func (ws *WebSocket) WriteJSON(any interface{}) error {

ws.mutex.Lock()

defer ws.mutex.Unlock()

return ws.conn.WriteJSON(any)

}

func (ws *WebSocket) WriteMessage(t int, b []byte) error {

ws.mutex.Lock()

defer ws.mutex.Unlock()

return ws.conn.WriteMessage(t, b)

}

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

websocket.go

websocket.go

Files

websocket.go

Latest commit

History

websocket.go

File metadata and controls