mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-15 18:58:14 +00:00
Code Activity

removed done todo's

Browse source
This commit is contained in:
postmannen 2022-01-21 06:49:32 +01:00
parent 48500aa1fb
commit b633416244
2 changed files with 1 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
requests.go
View file

@ -460,7 +460,6 @@ func (m methodREQOpProcessStart) handler(proc process, message Message, node str
er := fmt.Errorf(txt) er := fmt.Errorf(txt)
proc.processes.errorKernel.errSend(proc, message, er) proc.processes.errorKernel.errSend(proc, message, er)
// TODO: What should this look like ?
out = []byte(txt + "\n") out = []byte(txt + "\n")
newReplyMessage(proc, message, out) newReplyMessage(proc, message, out)
}() }()
@ -768,9 +767,6 @@ func (m methodREQCopyFileFrom) handler(proc process, message Message, node strin
proc.toRingbufferCh <- []subjectAndMessage{sam} 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) replyData := fmt.Sprintf("info: succesfully read the file %v, and sent the content to %v\n", SrcFilePath, DstNode)
newReplyMessage(proc, message, []byte(replyData)) newReplyMessage(proc, message, []byte(replyData))
@ -1659,7 +1655,7 @@ func (m methodREQToSocket) handler(proc process, message Message, node string) (
for _, d := range message.Data { for _, d := range message.Data {
// TODO: Write the data to the socket here. // 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)) ackMsg := []byte("confirmed from: " + node + ": " + fmt.Sprint(message.ID))

1
stew/messageSlide.go
View file

@ -97,7 +97,6 @@ func messageSlide(app *tview.Application) tview.Primitive {
// Get nodes from file. // Get nodes from file.
values, err = getNodeNames("nodeslist.cfg") values, err = getNodeNames("nodeslist.cfg")
if err != nil { if err != nil {
// TODO: Handle error here, exit ?
return nil return nil
} }