Parse topic access parameters
(acs *MsgDefaultAcsMode, defAuth, defAnon types.AccessMode)
| 613 | |
| 614 | // Parse topic access parameters |
| 615 | func parseTopicAccess(acs *MsgDefaultAcsMode, defAuth, defAnon types.AccessMode) (auth, anon types.AccessMode, err error) { |
| 616 | |
| 617 | auth, anon = defAuth, defAnon |
| 618 | |
| 619 | if acs.Auth != "" { |
| 620 | if err = auth.UnmarshalText([]byte(acs.Auth)); err != nil { |
| 621 | log.Println("hub: invalid default auth access mode '" + acs.Auth + "'") |
| 622 | } |
| 623 | } |
| 624 | |
| 625 | if acs.Anon != "" { |
| 626 | if err = anon.UnmarshalText([]byte(acs.Anon)); err != nil { |
| 627 | log.Println("hub: invalid default anon access mode '" + acs.Anon + "'") |
| 628 | } |
| 629 | } |
| 630 | |
| 631 | return |
| 632 | } |
| 633 | |
| 634 | // simpleSender attempts to send a message to a connection, time out is 1 second |
| 635 | func simpleSender(sendto chan<- *ServerComMessage, msg *ServerComMessage) { |
no test coverage detected