MCPcopy
hub / github.com/tinode/chat / pbCliDeserialize

Function pbCliDeserialize

server/pbconverter.go:391–503  ·  view source on GitHub ↗

Convert pbx.ClientMsg to ClientComMessage

(pkt *pbx.ClientMsg)

Source from the content-addressed store, hash-verified

389
390// Convert pbx.ClientMsg to ClientComMessage
391func pbCliDeserialize(pkt *pbx.ClientMsg) *ClientComMessage {
392 var msg ClientComMessage
393 if hi := pkt.GetHi(); hi != nil {
394 msg.Hi = &MsgClientHi{
395 Id: hi.GetId(),
396 UserAgent: hi.GetUserAgent(),
397 Version: hi.GetVer(),
398 DeviceID: hi.GetDeviceId(),
399 Platform: hi.GetPlatform(),
400 Lang: hi.GetLang(),
401 Background: hi.GetBackground(),
402 }
403 } else if acc := pkt.GetAcc(); acc != nil {
404 msg.Acc = &MsgClientAcc{
405 Id: acc.GetId(),
406 User: acc.GetUserId(),
407 State: acc.GetState(),
408 TmpScheme: acc.GetTmpScheme(),
409 TmpSecret: acc.GetTmpSecret(),
410 AuthLevel: acc.GetAuthLevel().String(),
411 Scheme: acc.GetScheme(),
412 Secret: acc.GetSecret(),
413 Login: acc.GetLogin(),
414 Tags: acc.GetTags(),
415 Desc: pbSetDescDeserialize(acc.GetDesc()),
416 Cred: pbClientCredsDeserialize(acc.GetCred()),
417 }
418 } else if login := pkt.GetLogin(); login != nil {
419 msg.Login = &MsgClientLogin{
420 Id: login.GetId(),
421 Scheme: login.GetScheme(),
422 Secret: login.GetSecret(),
423 Cred: pbClientCredsDeserialize(login.GetCred()),
424 }
425 } else if sub := pkt.GetSub(); sub != nil {
426 msg.Sub = &MsgClientSub{
427 Id: sub.GetId(),
428 Topic: sub.GetTopic(),
429 Get: pbGetQueryDeserialize(sub.GetGetQuery()),
430 Set: pbSetQueryDeserialize(sub.GetSetQuery()),
431 }
432 } else if leave := pkt.GetLeave(); leave != nil {
433 msg.Leave = &MsgClientLeave{
434 Id: leave.GetId(),
435 Topic: leave.GetTopic(),
436 Unsub: leave.GetUnsub(),
437 }
438 } else if pub := pkt.GetPub(); pub != nil {
439 msg.Pub = &MsgClientPub{
440 Id: pub.GetId(),
441 Topic: pub.GetTopic(),
442 NoEcho: pub.GetNoEcho(),
443 Head: byteMapToInterfaceMap(pub.GetHead()),
444 Content: bytesToInterface(pub.GetContent()),
445 }
446 } else if get := pkt.GetGet(); get != nil {
447 msg.Get = &MsgClientGet{
448 Id: get.GetId(),

Callers 2

MessageLoopMethod · 0.85
pluginFireHoseFunction · 0.85

Calls 15

pbSetDescDeserializeFunction · 0.85
pbClientCredsDeserializeFunction · 0.85
pbGetQueryDeserializeFunction · 0.85
pbSetQueryDeserializeFunction · 0.85
byteMapToInterfaceMapFunction · 0.85
bytesToInterfaceFunction · 0.85
pbDelQueryDeserializeFunction · 0.85
pbClientCredDeserializeFunction · 0.85
pbCallEventDeserializeFunction · 0.85
GetVerMethod · 0.80
GetPlatformMethod · 0.80

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…