Skip to content

Commit 9fdfe9d

Browse files
authored
re-enable zmq auth by adding missing line (#170)
1 parent c3933dd commit 9fdfe9d

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

application/lib/config.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,10 @@ type Config struct {
2020
// variable.
2121
func ParseConfig() (*Config, error) {
2222
var c Config
23-
_, err := toml.DecodeFile(os.Getenv("CJ_STATION_CONFIG"), &c)
23+
var envPath = os.Getenv("CJ_STATION_CONFIG")
24+
_, err := toml.DecodeFile(envPath, &c)
2425
if err != nil {
25-
return nil, fmt.Errorf("failed to load config: %v", err)
26+
return nil, fmt.Errorf("failed to load config(%s): %v", envPath, err)
2627
}
2728

2829
c.ParseBlocklists()

pkg/regprocessor/regprocessor.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,11 @@ func NewRegProcessor(zmqBindAddr string, zmqPort uint16, privkey string, authVer
6363
zmq.AuthSetVerbose(authVerbose)
6464
zmq.AuthAllow("*")
6565
zmq.AuthCurveAdd("*", stationPublicKeys...)
66+
err = zmq.AuthStart()
67+
if err != nil {
68+
return nil, ErrZmqAuthFail
69+
}
70+
6671
err = sock.ServerAuthCurve("*", privkey)
6772
if err != nil {
6873
return nil, ErrZmqAuthFail

0 commit comments

Comments
 (0)