Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commita28cd4f

Browse files
authored
feat: replace empty hook funcs with server hooks (#201)
1 parentd519519 commita28cd4f

File tree

1 file changed

+85
-30
lines changed

1 file changed

+85
-30
lines changed

‎server/server.go‎

Lines changed: 85 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -1213,28 +1213,37 @@ func (srv *server) initPluginHooks() error {
12131213
}
12141214
}
12151215
ifonAcceptWrappers!=nil {
1216-
onAccept:=func(ctx context.Context,conn net.Conn)bool {
1217-
returntrue
1216+
onAccept:=srv.hooks.OnAccept
1217+
ifonAccept==nil {
1218+
onAccept=func(ctx context.Context,conn net.Conn)bool {
1219+
returntrue
1220+
}
12181221
}
12191222
fori:=len(onAcceptWrappers);i>0;i-- {
12201223
onAccept=onAcceptWrappers[i-1](onAccept)
12211224
}
12221225
srv.hooks.OnAccept=onAccept
12231226
}
12241227
ifonBasicAuthWrappers!=nil {
1225-
onBasicAuth:=func(ctx context.Context,clientClient,req*ConnectRequest)error {
1226-
returnnil
1228+
onBasicAuth:=srv.hooks.OnBasicAuth
1229+
ifonBasicAuth==nil {
1230+
onBasicAuth=func(ctx context.Context,clientClient,req*ConnectRequest)error {
1231+
returnnil
1232+
}
12271233
}
12281234
fori:=len(onBasicAuthWrappers);i>0;i-- {
12291235
onBasicAuth=onBasicAuthWrappers[i-1](onBasicAuth)
12301236
}
12311237
srv.hooks.OnBasicAuth=onBasicAuth
12321238
}
12331239
ifonEnhancedAuthWrappers!=nil {
1234-
onEnhancedAuth:=func(ctx context.Context,clientClient,req*ConnectRequest) (resp*EnhancedAuthResponse,errerror) {
1235-
return&EnhancedAuthResponse{
1236-
Continue:false,
1237-
},nil
1240+
onEnhancedAuth:=srv.hooks.OnEnhancedAuth
1241+
ifonEnhancedAuth==nil {
1242+
onEnhancedAuth=func(ctx context.Context,clientClient,req*ConnectRequest) (resp*EnhancedAuthResponse,errerror) {
1243+
return&EnhancedAuthResponse{
1244+
Continue:false,
1245+
},nil
1246+
}
12381247
}
12391248
fori:=len(onEnhancedAuthWrappers);i>0;i-- {
12401249
onEnhancedAuth=onEnhancedAuthWrappers[i-1](onEnhancedAuth)
@@ -1243,111 +1252,157 @@ func (srv *server) initPluginHooks() error {
12431252
}
12441253

12451254
ifonConnectedWrappers!=nil {
1246-
onConnected:=func(ctx context.Context,clientClient) {}
1255+
onConnected:=srv.hooks.OnConnected
1256+
ifonConnected==nil {
1257+
onConnected=func(ctx context.Context,clientClient) {}
1258+
}
12471259
fori:=len(onConnectedWrappers);i>0;i-- {
12481260
onConnected=onConnectedWrappers[i-1](onConnected)
12491261
}
12501262
srv.hooks.OnConnected=onConnected
12511263
}
12521264
ifonSessionCreatedWrapper!=nil {
1253-
onSessionCreated:=func(ctx context.Context,clientClient) {}
1265+
onSessionCreated:=srv.hooks.OnSessionCreated
1266+
ifonSessionCreated==nil {
1267+
onSessionCreated=func(ctx context.Context,clientClient) {}
1268+
}
12541269
fori:=len(onSessionCreatedWrapper);i>0;i-- {
12551270
onSessionCreated=onSessionCreatedWrapper[i-1](onSessionCreated)
12561271
}
12571272
srv.hooks.OnSessionCreated=onSessionCreated
12581273
}
12591274
ifonSessionResumedWrapper!=nil {
1260-
onSessionResumed:=func(ctx context.Context,clientClient) {}
1275+
onSessionResumed:=srv.hooks.OnSessionResumed
1276+
ifonSessionResumed==nil {
1277+
onSessionResumed=func(ctx context.Context,clientClient) {}
1278+
}
12611279
fori:=len(onSessionResumedWrapper);i>0;i-- {
12621280
onSessionResumed=onSessionResumedWrapper[i-1](onSessionResumed)
12631281
}
12641282
srv.hooks.OnSessionResumed=onSessionResumed
12651283
}
12661284
ifonSessionTerminatedWrapper!=nil {
1267-
onSessionTerminated:=func(ctx context.Context,clientIDstring,reasonSessionTerminatedReason) {}
1285+
onSessionTerminated:=srv.hooks.OnSessionTerminated
1286+
ifonSessionTerminated==nil {
1287+
onSessionTerminated=func(ctx context.Context,clientIDstring,reasonSessionTerminatedReason) {}
1288+
}
12681289
fori:=len(onSessionTerminatedWrapper);i>0;i-- {
12691290
onSessionTerminated=onSessionTerminatedWrapper[i-1](onSessionTerminated)
12701291
}
12711292
srv.hooks.OnSessionTerminated=onSessionTerminated
12721293
}
12731294
ifonSubscribeWrappers!=nil {
1274-
onSubscribe:=func(ctx context.Context,clientClient,req*SubscribeRequest)error {
1275-
returnnil
1295+
onSubscribe:=srv.hooks.OnSubscribe
1296+
ifonSubscribe==nil {
1297+
onSubscribe=func(ctx context.Context,clientClient,req*SubscribeRequest)error {
1298+
returnnil
1299+
}
12761300
}
12771301
fori:=len(onSubscribeWrappers);i>0;i-- {
12781302
onSubscribe=onSubscribeWrappers[i-1](onSubscribe)
12791303
}
12801304
srv.hooks.OnSubscribe=onSubscribe
12811305
}
12821306
ifonSubscribedWrappers!=nil {
1283-
onSubscribed:=func(ctx context.Context,clientClient,subscription*gmqtt.Subscription) {}
1307+
onSubscribed:=srv.hooks.OnSubscribed
1308+
ifonSubscribed==nil {
1309+
onSubscribed=func(ctx context.Context,clientClient,subscription*gmqtt.Subscription) {}
1310+
}
1311+
12841312
fori:=len(onSubscribedWrappers);i>0;i-- {
12851313
onSubscribed=onSubscribedWrappers[i-1](onSubscribed)
12861314
}
12871315
srv.hooks.OnSubscribed=onSubscribed
12881316
}
12891317
ifonUnsubscribeWrappers!=nil {
1290-
onUnsubscribe:=func(ctx context.Context,clientClient,req*UnsubscribeRequest)error {
1291-
returnnil
1318+
onUnsubscribe:=srv.hooks.OnUnsubscribe
1319+
ifonUnsubscribe==nil {
1320+
onUnsubscribe=func(ctx context.Context,clientClient,req*UnsubscribeRequest)error {
1321+
returnnil
1322+
}
12921323
}
12931324
fori:=len(onUnsubscribeWrappers);i>0;i-- {
12941325
onUnsubscribe=onUnsubscribeWrappers[i-1](onUnsubscribe)
12951326
}
12961327
srv.hooks.OnUnsubscribe=onUnsubscribe
12971328
}
12981329
ifonUnsubscribedWrappers!=nil {
1299-
onUnsubscribed:=func(ctx context.Context,clientClient,topicNamestring) {}
1330+
onUnsubscribed:=srv.hooks.OnUnsubscribed
1331+
ifonUnsubscribed==nil {
1332+
onUnsubscribed=func(ctx context.Context,clientClient,topicNamestring) {}
1333+
}
13001334
fori:=len(onUnsubscribedWrappers);i>0;i-- {
13011335
onUnsubscribed=onUnsubscribedWrappers[i-1](onUnsubscribed)
13021336
}
13031337
srv.hooks.OnUnsubscribed=onUnsubscribed
13041338
}
13051339
ifonMsgArrivedWrappers!=nil {
1306-
onMsgArrived:=func(ctx context.Context,clientClient,req*MsgArrivedRequest)error {
1307-
returnnil
1340+
onMsgArrived:=srv.hooks.OnMsgArrived
1341+
ifonMsgArrived==nil {
1342+
onMsgArrived=func(ctx context.Context,clientClient,req*MsgArrivedRequest)error {
1343+
returnnil
1344+
}
13081345
}
13091346
fori:=len(onMsgArrivedWrappers);i>0;i-- {
13101347
onMsgArrived=onMsgArrivedWrappers[i-1](onMsgArrived)
13111348
}
13121349
srv.hooks.OnMsgArrived=onMsgArrived
13131350
}
13141351
ifOnDeliveredWrappers!=nil {
1315-
OnDelivered:=func(ctx context.Context,clientClient,msg*gmqtt.Message) {}
1352+
onDelivered:=srv.hooks.OnDelivered
1353+
ifonDelivered==nil {
1354+
onDelivered=func(ctx context.Context,clientClient,msg*gmqtt.Message) {}
1355+
}
13161356
fori:=len(OnDeliveredWrappers);i>0;i-- {
1317-
OnDelivered=OnDeliveredWrappers[i-1](OnDelivered)
1357+
onDelivered=OnDeliveredWrappers[i-1](onDelivered)
13181358
}
1319-
srv.hooks.OnDelivered=OnDelivered
1359+
srv.hooks.OnDelivered=onDelivered
13201360
}
13211361
ifOnClosedWrappers!=nil {
1322-
OnClosed:=func(ctx context.Context,clientClient,errerror) {}
1362+
onClosed:=srv.hooks.OnClosed
1363+
ifonClosed==nil {
1364+
onClosed=func(ctx context.Context,clientClient,errerror) {}
1365+
}
13231366
fori:=len(OnClosedWrappers);i>0;i-- {
1324-
OnClosed=OnClosedWrappers[i-1](OnClosed)
1367+
onClosed=OnClosedWrappers[i-1](onClosed)
13251368
}
1326-
srv.hooks.OnClosed=OnClosed
1369+
srv.hooks.OnClosed=onClosed
13271370
}
13281371
ifonStopWrappers!=nil {
1329-
onStop:=func(ctx context.Context) {}
1372+
onStop:=srv.hooks.OnStop
1373+
ifonStop==nil {
1374+
onStop=func(ctx context.Context) {}
1375+
}
13301376
fori:=len(onStopWrappers);i>0;i-- {
13311377
onStop=onStopWrappers[i-1](onStop)
13321378
}
13331379
srv.hooks.OnStop=onStop
13341380
}
13351381
ifonMsgDroppedWrappers!=nil {
1336-
onMsgDropped:=func(ctx context.Context,clientIDstring,msg*gmqtt.Message,errerror) {}
1382+
onMsgDropped:=srv.hooks.OnMsgDropped
1383+
ifonMsgDropped==nil {
1384+
onMsgDropped=func(ctx context.Context,clientIDstring,msg*gmqtt.Message,errerror) {}
1385+
}
13371386
fori:=len(onMsgDroppedWrappers);i>0;i-- {
13381387
onMsgDropped=onMsgDroppedWrappers[i-1](onMsgDropped)
13391388
}
13401389
srv.hooks.OnMsgDropped=onMsgDropped
13411390
}
13421391
ifonWillPublishWrappers!=nil {
1343-
onWillPublish:=func(ctx context.Context,clientIDstring,req*WillMsgRequest) {}
1392+
onWillPublish:=srv.hooks.OnWillPublish
1393+
ifonWillPublish==nil {
1394+
onWillPublish=func(ctx context.Context,clientIDstring,req*WillMsgRequest) {}
1395+
}
13441396
fori:=len(onWillPublishWrappers);i>0;i-- {
13451397
onWillPublish=onWillPublishWrappers[i-1](onWillPublish)
13461398
}
13471399
srv.hooks.OnWillPublish=onWillPublish
13481400
}
13491401
ifonWillPublishedWrappers!=nil {
1350-
onWillPublished:=func(ctx context.Context,clientIDstring,msg*gmqtt.Message) {}
1402+
onWillPublished:=srv.hooks.OnWillPublished
1403+
ifonWillPublished==nil {
1404+
onWillPublished=func(ctx context.Context,clientIDstring,msg*gmqtt.Message) {}
1405+
}
13511406
fori:=len(onWillPublishedWrappers);i>0;i-- {
13521407
onWillPublished=onWillPublishedWrappers[i-1](onWillPublished)
13531408
}

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp