| 566 | return nil |
| 567 | } |
| 568 | func (nvq *NodeVersionQuery) loadComfyNodes(ctx context.Context, query *ComfyNodeQuery, nodes []*NodeVersion, init func(*NodeVersion), assign func(*NodeVersion, *ComfyNode)) error { |
| 569 | fks := make([]driver.Value, 0, len(nodes)) |
| 570 | nodeids := make(map[uuid.UUID]*NodeVersion) |
| 571 | for i := range nodes { |
| 572 | fks = append(fks, nodes[i].ID) |
| 573 | nodeids[nodes[i].ID] = nodes[i] |
| 574 | if init != nil { |
| 575 | init(nodes[i]) |
| 576 | } |
| 577 | } |
| 578 | if len(query.ctx.Fields) > 0 { |
| 579 | query.ctx.AppendFieldOnce(comfynode.FieldNodeVersionID) |
| 580 | } |
| 581 | query.Where(predicate.ComfyNode(func(s *sql.Selector) { |
| 582 | s.Where(sql.InValues(s.C(nodeversion.ComfyNodesColumn), fks...)) |
| 583 | })) |
| 584 | neighbors, err := query.All(ctx) |
| 585 | if err != nil { |
| 586 | return err |
| 587 | } |
| 588 | for _, n := range neighbors { |
| 589 | fk := n.NodeVersionID |
| 590 | node, ok := nodeids[fk] |
| 591 | if !ok { |
| 592 | return fmt.Errorf(`unexpected referenced foreign-key "node_version_id" returned %v for node %v`, fk, n.ID) |
| 593 | } |
| 594 | assign(node, n) |
| 595 | } |
| 596 | return nil |
| 597 | } |
| 598 | |
| 599 | func (nvq *NodeVersionQuery) sqlCount(ctx context.Context) (int, error) { |
| 600 | _spec := nvq.querySpec() |