aboutsummaryrefslogtreecommitdiff
path: root/src/gnunet/service/gns/service.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/gnunet/service/gns/service.go')
-rw-r--r--src/gnunet/service/gns/service.go20
1 files changed, 10 insertions, 10 deletions
diff --git a/src/gnunet/service/gns/service.go b/src/gnunet/service/gns/service.go
index 45eb700..fb6aea0 100644
--- a/src/gnunet/service/gns/service.go
+++ b/src/gnunet/service/gns/service.go
@@ -96,7 +96,7 @@ func (s *Service) ServeClient(ctx context.Context, id int, mc *service.Connectio
96 logger.Printf(logger.INFO, "[gns:%d:%d] Received request: %v\n", id, reqID, msg) 96 logger.Printf(logger.INFO, "[gns:%d:%d] Received request: %v\n", id, reqID, msg)
97 97
98 // handle message 98 // handle message
99 valueCtx := context.WithValue(ctx, service.CtxKey("label"), fmt.Sprintf(":%d:%d", id, reqID)) 99 valueCtx := context.WithValue(ctx, core.CtxKey("label"), fmt.Sprintf(":%d:%d", id, reqID))
100 s.HandleMessage(valueCtx, nil, msg, mc) 100 s.HandleMessage(valueCtx, nil, msg, mc)
101 } 101 }
102 // close client connection 102 // close client connection
@@ -136,7 +136,7 @@ func (s *Service) HandleMessage(ctx context.Context, sender *util.PeerID, msg me
136 logger.Printf(logger.DBG, "[gns%s] Lookup request finished.\n", label) 136 logger.Printf(logger.DBG, "[gns%s] Lookup request finished.\n", label)
137 }() 137 }()
138 138
139 kind := NewRRTypeList(enums.GNSType(m.Type)) 139 kind := NewRRTypeList(enums.GNSType(m.RType))
140 recset, err := s.Resolve(ctx, label, m.Zone, kind, int(m.Options), 0) 140 recset, err := s.Resolve(ctx, label, m.Zone, kind, int(m.Options), 0)
141 if err != nil { 141 if err != nil {
142 logger.Printf(logger.ERROR, "[gns%s] Failed to lookup block: %s\n", label, err.Error()) 142 logger.Printf(logger.ERROR, "[gns%s] Failed to lookup block: %s\n", label, err.Error())
@@ -159,7 +159,7 @@ func (s *Service) HandleMessage(ctx context.Context, sender *util.PeerID, msg me
159 logger.Printf(logger.DBG, "[gns%s] Record #%d: %v\n", label, i, rec) 159 logger.Printf(logger.DBG, "[gns%s] Record #%d: %v\n", label, i, rec)
160 160
161 // is this the record type we are looking for? 161 // is this the record type we are looking for?
162 if rec.Type == m.Type || enums.GNSType(m.Type) == enums.GNS_TYPE_ANY { 162 if rec.RType == m.RType || enums.GNSType(m.RType) == enums.GNS_TYPE_ANY {
163 // add it to the response message 163 // add it to the response message
164 if err := resp.AddRecord(rec); err != nil { 164 if err := resp.AddRecord(rec); err != nil {
165 logger.Printf(logger.ERROR, "[gns%s] failed: %sv", label, err.Error()) 165 logger.Printf(logger.ERROR, "[gns%s] failed: %sv", label, err.Error())
@@ -173,7 +173,7 @@ func (s *Service) HandleMessage(ctx context.Context, sender *util.PeerID, msg me
173 //---------------------------------------------------------- 173 //----------------------------------------------------------
174 // UNKNOWN message type received 174 // UNKNOWN message type received
175 //---------------------------------------------------------- 175 //----------------------------------------------------------
176 logger.Printf(logger.ERROR, "[gns%s] Unhandled message of type (%d)\n", label, msg.Header().MsgType) 176 logger.Printf(logger.ERROR, "[gns%s] Unhandled message of type (%s)\n", label, msg.Type())
177 return false 177 return false
178 } 178 }
179 return true 179 return true
@@ -238,7 +238,7 @@ func (s *Service) RevokeKey(ctx context.Context, rd *revocation.RevData) (succes
238 238
239// LookupNamecache returns a cached lookup (if available) 239// LookupNamecache returns a cached lookup (if available)
240func (s *Service) LookupNamecache(ctx context.Context, query *blocks.GNSQuery) (block *blocks.GNSBlock, err error) { 240func (s *Service) LookupNamecache(ctx context.Context, query *blocks.GNSQuery) (block *blocks.GNSBlock, err error) {
241 logger.Printf(logger.DBG, "[gns] LookupNamecache(%s)...\n", hex.EncodeToString(query.Key().Bits)) 241 logger.Printf(logger.DBG, "[gns] LookupNamecache(%s)...\n", hex.EncodeToString(query.Key().Data))
242 242
243 // assemble Namecache request 243 // assemble Namecache request
244 req := message.NewNamecacheLookupMsg(query.Key()) 244 req := message.NewNamecacheLookupMsg(query.Key())
@@ -292,7 +292,7 @@ func (s *Service) LookupNamecache(ctx context.Context, query *blocks.GNSQuery) (
292 break 292 break
293 } 293 }
294 default: 294 default:
295 logger.Printf(logger.ERROR, "[gns] Got invalid response type (%d)\n", m.Header().MsgType) 295 logger.Printf(logger.ERROR, "[gns] Got invalid response type (%s)\n", m.Type())
296 err = ErrInvalidResponseType 296 err = ErrInvalidResponseType
297 } 297 }
298 return 298 return
@@ -328,7 +328,7 @@ func (s *Service) StoreNamecache(ctx context.Context, query *blocks.GNSQuery, bl
328 } 328 }
329 return fmt.Errorf("failed with rc=%d", m.Result) 329 return fmt.Errorf("failed with rc=%d", m.Result)
330 default: 330 default:
331 logger.Printf(logger.ERROR, "[gns] Got invalid response type (%d)\n", m.Header().MsgType) 331 logger.Printf(logger.ERROR, "[gns] Got invalid response type (%s)\n", m.Type())
332 err = ErrInvalidResponseType 332 err = ErrInvalidResponseType
333 } 333 }
334 return 334 return
@@ -340,7 +340,7 @@ func (s *Service) StoreNamecache(ctx context.Context, query *blocks.GNSQuery, bl
340 340
341// LookupDHT gets a GNS block from the DHT for the given query key. 341// LookupDHT gets a GNS block from the DHT for the given query key.
342func (s *Service) LookupDHT(ctx context.Context, query blocks.Query) (block blocks.Block, err error) { 342func (s *Service) LookupDHT(ctx context.Context, query blocks.Query) (block blocks.Block, err error) {
343 logger.Printf(logger.DBG, "[gns] LookupDHT(%s)...\n", hex.EncodeToString(query.Key().Bits)) 343 logger.Printf(logger.DBG, "[gns] LookupDHT(%s)...\n", hex.EncodeToString(query.Key().Data))
344 block = nil 344 block = nil
345 345
346 // client-connect to the DHT service 346 // client-connect to the DHT service
@@ -375,7 +375,7 @@ func (s *Service) LookupDHT(ctx context.Context, query blocks.Query) (block bloc
375 reqGet := message.NewDHTClientGetMsg(query.Key()) 375 reqGet := message.NewDHTClientGetMsg(query.Key())
376 reqGet.ID = uint64(util.NextID()) 376 reqGet.ID = uint64(util.NextID())
377 reqGet.ReplLevel = uint32(enums.GNS_REPLICATION_LEVEL) 377 reqGet.ReplLevel = uint32(enums.GNS_REPLICATION_LEVEL)
378 reqGet.Type = uint32(enums.BLOCK_TYPE_GNS_NAMERECORD) 378 reqGet.BType = enums.BLOCK_TYPE_GNS_NAMERECORD
379 reqGet.Options = uint32(enums.DHT_RO_DEMULTIPLEX_EVERYWHERE) 379 reqGet.Options = uint32(enums.DHT_RO_DEMULTIPLEX_EVERYWHERE)
380 380
381 if err = interact(reqGet, true); err != nil { 381 if err = interact(reqGet, true); err != nil {
@@ -413,7 +413,7 @@ func (s *Service) LookupDHT(ctx context.Context, query blocks.Query) (block bloc
413 break 413 break
414 } 414 }
415 // check if result is of requested type 415 // check if result is of requested type
416 if enums.BlockType(m.Type) != enums.BLOCK_TYPE_GNS_NAMERECORD { 416 if enums.BlockType(m.BType) != enums.BLOCK_TYPE_GNS_NAMERECORD {
417 logger.Println(logger.ERROR, "[gns] DHT response has wrong type") 417 logger.Println(logger.ERROR, "[gns] DHT response has wrong type")
418 break 418 break
419 } 419 }