diamondburned/arikawa
1
0
Fork 0
mirror of https://github.com/diamondburned/arikawa.git synced 2024-11-01 04:24:19 +00:00
Code Issues Releases Activity

gateway: Expose GatewayOpts getter

Browse source
This commit is contained in:
diamondburned 2022-11-18 02:01:18 -08:00
parent 78ad477b83
commit 5a156cc699
No known key found for this signature in database
GPG key ID: D78C4471CE776659
2 changed files with 12 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
gateway/gateway.go
View file

@ -171,13 +171,17 @@ func NewFromState(gatewayURL string, state State, opts *ws.GatewayOpts) *Gateway
} }
gw := ws.NewGateway(ws.NewWebsocket(ws.NewCodec(OpUnmarshalers), gatewayURL), opts) gw := ws.NewGateway(ws.NewWebsocket(ws.NewCodec(OpUnmarshalers), gatewayURL), opts)
return &Gateway{ return &Gateway{
gateway: gw, gateway: gw,
state: state, state: state,
} }
} }
// Opts returns a copy of the gateway options that are being used.
func (g *Gateway) Opts() *ws.GatewayOpts {
return g.gateway.Opts()
}
// State returns a copy of the gateway's internal state. It panics if the // State returns a copy of the gateway's internal state. It panics if the
// gateway is currently running. // gateway is currently running.
func (g *Gateway) State() State { func (g *Gateway) State() State {

7
utils/ws/gateway.go
View file

@ -159,6 +159,13 @@ func NewGateway(ws *Websocket, opts *GatewayOpts) *Gateway {
} }
} }
// Opts returns a copy of the gateway options. The options can only be changed
// during construction, so a copy is a must.
func (g *Gateway) Opts() *GatewayOpts {
cpy := g.opts
return &cpy
}
// Send is a function to send an Op payload to the Gateway. // Send is a function to send an Op payload to the Gateway.
func (g *Gateway) Send(ctx context.Context, data Event) error { func (g *Gateway) Send(ctx context.Context, data Event) error {
op := Op{ op := Op{