| 92 | } |
| 93 | |
| 94 | func (t *TreeHandler) CreateNodeStream(s tree.NodeReceiverStream_CreateNodeStreamServer) error { |
| 95 | router := t.getRouter() |
| 96 | var err error |
| 97 | for { |
| 98 | r, e := s.Recv() |
| 99 | if e != nil { |
| 100 | if e != io.EOF { |
| 101 | s.SendMsg(e) |
| 102 | err = e |
| 103 | } |
| 104 | break |
| 105 | } |
| 106 | t.fixMode(r.Node) |
| 107 | resp, er := router.CreateNode(s.Context(), r) |
| 108 | if er != nil { |
| 109 | s.SendMsg(er) |
| 110 | err = er |
| 111 | break |
| 112 | } |
| 113 | if err = s.Send(resp); err != nil { |
| 114 | break |
| 115 | } |
| 116 | } |
| 117 | return err //errors.BadRequest("not.implemented", "CreateNodeStream not implemented yet") |
| 118 | } |
| 119 | |
| 120 | func (t *TreeHandler) UpdateNodeStream(tree.NodeReceiverStream_UpdateNodeStreamServer) error { |
| 121 | return errors.WithMessage(errors.StatusNotImplemented, "UpdateNodeStream not implemented yet") |