From b6334162446d017b2f25cd883645c697e7b1497c Mon Sep 17 00:00:00 2001 From: postmannen Date: Fri, 21 Jan 2022 06:49:32 +0100 Subject: [PATCH] removed done todo's --- requests.go | 6 +----- stew/messageSlide.go | 1 - 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/requests.go b/requests.go index 3aab673..434a568 100644 --- a/requests.go +++ b/requests.go @@ -460,7 +460,6 @@ func (m methodREQOpProcessStart) handler(proc process, message Message, node str er := fmt.Errorf(txt) proc.processes.errorKernel.errSend(proc, message, er) - // TODO: What should this look like ? out = []byte(txt + "\n") newReplyMessage(proc, message, out) }() @@ -768,9 +767,6 @@ func (m methodREQCopyFileFrom) handler(proc process, message Message, node strin proc.toRingbufferCh <- []subjectAndMessage{sam} - // TODO: Should we also send a reply message with the result back - // to where the message originated ? - replyData := fmt.Sprintf("info: succesfully read the file %v, and sent the content to %v\n", SrcFilePath, DstNode) newReplyMessage(proc, message, []byte(replyData)) @@ -1659,7 +1655,7 @@ func (m methodREQToSocket) handler(proc process, message Message, node string) ( for _, d := range message.Data { // TODO: Write the data to the socket here. - fmt.Printf("Info: Data to write to socket: %v\n", d) + fmt.Printf("Info: REQToSocket is not yet implemented. Data to write to socket: %v\n", d) } ackMsg := []byte("confirmed from: " + node + ": " + fmt.Sprint(message.ID)) diff --git a/stew/messageSlide.go b/stew/messageSlide.go index 8439138..2560826 100644 --- a/stew/messageSlide.go +++ b/stew/messageSlide.go @@ -97,7 +97,6 @@ func messageSlide(app *tview.Application) tview.Primitive { // Get nodes from file. values, err = getNodeNames("nodeslist.cfg") if err != nil { - // TODO: Handle error here, exit ? return nil }