package ws
|
|
|
|
import (
|
|
"LAPP_ACURA_MOM_BACKEND/global"
|
|
"LAPP_ACURA_MOM_BACKEND/messaging"
|
|
baseModel "LAPP_ACURA_MOM_BACKEND/models/base"
|
|
"errors"
|
|
"github.com/kataras/neffos"
|
|
)
|
|
|
|
func init() {
|
|
global.WebsocketContext = messaging.Register(baseModel.NAMESPACE_EODS, neffos.Events{})
|
|
global.WebsocketContext.SetAuthenticator(func(headers map[string]string) (string, error) {
|
|
stn, ok := headers["STN"]
|
|
if !ok || stn == "" {
|
|
return "", errors.New("未获取到工位信息")
|
|
}
|
|
return stn, nil
|
|
})
|
|
}
|