Skip to content

Commit 1707937

Browse files
committed
fix some tests
1 parent 7121652 commit 1707937

File tree

4 files changed

+306
-381
lines changed

4 files changed

+306
-381
lines changed

examples/server/memory/kb.go

Lines changed: 24 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -434,7 +434,7 @@ func (k knowledgeBase) openNodes(names []string) (KnowledgeGraph, error) {
434434
func (k knowledgeBase) CreateEntities(ctx context.Context, req *mcp.ServerRequest[*mcp.CallToolParams], args CreateEntitiesArgs) (*mcp.CallToolResult, CreateEntitiesResult, error) {
435435
var res mcp.CallToolResult
436436

437-
entities, err := k.createEntities(req.Params.Arguments.Entities)
437+
entities, err := k.createEntities(args.Entities)
438438
if err != nil {
439439
return nil, CreateEntitiesResult{}, err
440440
}
@@ -447,90 +447,84 @@ func (k knowledgeBase) CreateEntities(ctx context.Context, req *mcp.ServerReques
447447
Entities: entities,
448448
}
449449

450-
return &res, entities, nil
450+
return &res, CreateEntitiesResult{Entities: entities}, nil
451451
}
452452

453453
func (k knowledgeBase) CreateRelations(ctx context.Context, req *mcp.ServerRequest[*mcp.CallToolParams], args CreateRelationsArgs) (*mcp.CallToolResult, CreateRelationsResult, error) {
454454
var res mcp.CallToolResult
455455

456-
relations, err := k.createRelations(req.Params.Arguments.Relations)
456+
relations, err := k.createRelations(args.Relations)
457457
if err != nil {
458-
return nil, err
458+
return nil, CreateRelationsResult{}, err
459459
}
460460

461461
res.Content = []mcp.Content{
462462
&mcp.TextContent{Text: "Relations created successfully"},
463463
}
464464

465-
res.StructuredContent = CreateRelationsResult{
466-
Relations: relations,
467-
}
468-
469-
return &res, nil
465+
return &res, CreateRelationsResult{Relations: relations}, nil
470466
}
471467

472468
func (k knowledgeBase) AddObservations(ctx context.Context, req *mcp.ServerRequest[*mcp.CallToolParams], args AddObservationsArgs) (*mcp.CallToolResult, AddObservationsResult, error) {
473469
var res mcp.CallToolResult
474470

475-
observations, err := k.addObservations(req.Params.Arguments.Observations)
471+
observations, err := k.addObservations(args.Observations)
476472
if err != nil {
477-
return nil, err
473+
return nil, AddObservationsResult{}, err
478474
}
479475

480476
res.Content = []mcp.Content{
481477
&mcp.TextContent{Text: "Observations added successfully"},
482478
}
483479

484-
res.StructuredContent = AddObservationsResult{
480+
return &res, AddObservationsResult{
485481
Observations: observations,
486-
}
487-
488-
return &res, nil
482+
}, nil
489483
}
490484

491485
func (k knowledgeBase) DeleteEntities(ctx context.Context, req *mcp.ServerRequest[*mcp.CallToolParams], args DeleteEntitiesArgs) (*mcp.CallToolResult, struct{}, error) {
492486
var res mcp.CallToolResult
493487

494-
err := k.deleteEntities(req.Params.Arguments.EntityNames)
488+
err := k.deleteEntities(args.EntityNames)
495489
if err != nil {
496-
return nil, err
490+
return nil, struct{}{}, err
497491
}
498492

499493
res.Content = []mcp.Content{
500494
&mcp.TextContent{Text: "Entities deleted successfully"},
501495
}
502496

503-
return &res, nil
497+
return &res, struct{}{}, nil
504498
}
505499

506500
func (k knowledgeBase) DeleteObservations(ctx context.Context, req *mcp.ServerRequest[*mcp.CallToolParams], args DeleteObservationsArgs) (*mcp.CallToolResult, struct{}, error) {
507501
var res mcp.CallToolResult
508502

509-
err := k.deleteObservations(req.Params.Arguments.Deletions)
503+
err := k.deleteObservations(args.Deletions)
510504
if err != nil {
511-
return nil, err
505+
return nil, struct{}{}, err
512506
}
513507

514508
res.Content = []mcp.Content{
515509
&mcp.TextContent{Text: "Observations deleted successfully"},
516510
}
517511

518-
return &res, nil
512+
return &res, struct{}{}, nil
519513
}
520514

521515
func (k knowledgeBase) DeleteRelations(ctx context.Context, req *mcp.ServerRequest[*mcp.CallToolParams], args DeleteRelationsArgs) (*mcp.CallToolResult, struct{}, error) {
522516
var res mcp.CallToolResult
523517

524-
err := k.deleteRelations(req.Params.Arguments.Relations)
518+
err := k.deleteRelations(args.Relations)
525519
if err != nil {
526-
return nil, err
520+
return nil, struct{}{}, err
527521
}
528522

529523
res.Content = []mcp.Content{
530524
&mcp.TextContent{Text: "Relations deleted successfully"},
531525
}
532526

533-
return &res, nil
527+
return &res, struct{}{}, nil
534528
}
535529

536530
func (k knowledgeBase) ReadGraph(ctx context.Context, req *mcp.ServerRequest[*mcp.CallToolParams], args any) (*mcp.CallToolResult, KnowledgeGraph, error) {
@@ -551,31 +545,29 @@ func (k knowledgeBase) ReadGraph(ctx context.Context, req *mcp.ServerRequest[*mc
551545
func (k knowledgeBase) SearchNodes(ctx context.Context, req *mcp.ServerRequest[*mcp.CallToolParams], args SearchNodesArgs) (*mcp.CallToolResult, KnowledgeGraph, error) {
552546
var res mcp.CallToolResult
553547

554-
graph, err := k.searchNodes(req.Params.Arguments.Query)
548+
graph, err := k.searchNodes(args.Query)
555549
if err != nil {
556-
return nil, err
550+
return nil, KnowledgeGraph{}, err
557551
}
558552

559553
res.Content = []mcp.Content{
560554
&mcp.TextContent{Text: "Nodes searched successfully"},
561555
}
562556

563557
res.StructuredContent = graph
564-
return &res, nil
558+
return &res, KnowledgeGraph{}, nil
565559
}
566560

567561
func (k knowledgeBase) OpenNodes(ctx context.Context, req *mcp.ServerRequest[*mcp.CallToolParams], args OpenNodesArgs) (*mcp.CallToolResult, KnowledgeGraph, error) {
568562
var res mcp.CallToolResult
569563

570-
graph, err := k.openNodes(req.Params.Arguments.Names)
564+
graph, err := k.openNodes(args.Names)
571565
if err != nil {
572-
return nil, err
566+
return nil, KnowledgeGraph{}, err
573567
}
574568

575569
res.Content = []mcp.Content{
576570
&mcp.TextContent{Text: "Nodes opened successfully"},
577571
}
578-
579-
res.StructuredContent = graph
580-
return &res, nil
572+
return &res, graph, nil
581573
}

0 commit comments

Comments
 (0)