mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-31 01:24:31 +00:00
Code Activity

removed debug printing

Browse source
This commit is contained in:
postmannen 2022-02-11 09:04:14 +01:00
parent 1c17f82eef
commit def4bd8e58
5 changed files with 14 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
errorkernel.go
View file

@ -144,7 +144,7 @@ func (e *errorKernel) start(ringBufferBulkInCh chan<- []subjectAndMessage) error
}()
default:
fmt.Printf(" * case default\n")
// fmt.Printf(" * case default\n")
}
}
}

2
process.go
View file

@ -597,7 +597,7 @@ func (p process) publishMessages(natsConn *nats.Conn) {
case m := <-p.subject.messageCh:
// Sign the methodArgs, and add the signature to the message.
m.ArgSignature = p.addMethodArgSignature(m)
fmt.Printf(" * DEBUG: add signature, fromNode: %v, method: %v, len of signature: %v\n", m.FromNode, m.Method, len(m.ArgSignature))
// fmt.Printf(" * DEBUG: add signature, fromNode: %v, method: %v, len of signature: %v\n", m.FromNode, m.Method, len(m.ArgSignature))
p.publishAMessage(m, zEnc, once, natsConn)
case <-p.ctx.Done():

14
requests.go
View file

@ -1570,7 +1570,7 @@ func (m methodREQHttpGetScheduled) handler(proc process, message Message, node s
for {
select {
case <-ctxScheduler.Done():
fmt.Printf(" * DEBUG: <-ctxScheduler.Done()\n")
// fmt.Printf(" * DEBUG: <-ctxScheduler.Done()\n")
cancel()
er := fmt.Errorf("error: methodREQHttpGet: schedule context timed out: %v", message.MethodArgs)
proc.processes.errorKernel.errSend(proc, message, er)
@ -1707,7 +1707,7 @@ func (m methodREQCliCommandCont) handler(proc process, message Message, node str
defer proc.processes.wg.Done()
defer func() {
fmt.Printf(" * DONE *\n")
// fmt.Printf(" * DONE *\n")
}()
var a []string
@ -1802,7 +1802,7 @@ func (m methodREQCliCommandCont) handler(proc process, message Message, node str
proc.processes.errorKernel.infoSend(proc, message, er)
return
case out := <-outCh:
fmt.Printf(" * out: %v\n", string(out))
// fmt.Printf(" * out: %v\n", string(out))
newReplyMessage(proc, message, out)
case out := <-errCh:
newReplyMessage(proc, message, []byte(out))
@ -1828,10 +1828,10 @@ func (m methodREQToSocket) getKind() Event {
// Handler to write to unix socket file.
func (m methodREQToSocket) handler(proc process, message Message, node string) ([]byte, error) {
for _, d := range message.Data {
// TODO: Write the data to the socket here.
fmt.Printf("Info: REQToSocket is not yet implemented. Data to write to socket: %v\n", d)
}
// for _, d := range message.Data {
// // TODO: Write the data to the socket here.
// // 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))
return ackMsg, nil

2
server.go
View file

@ -141,7 +141,7 @@ func NewServer(configuration *Configuration, version string) (*server, error) {
}
signatures := newSignatures(configuration, errorKernel)
fmt.Printf(" * DEBUG: newServer: signatures contains: %+v\n", signatures)
// fmt.Printf(" * DEBUG: newServer: signatures contains: %+v\n", signatures)
s := &server{
ctx: ctx,

8
signatures.go
View file

@ -212,15 +212,15 @@ func (s *signatures) readKeyFile(keyFile string) (ed2519key []byte, b64Key []byt
// verifySignature
func (s *signatures) verifySignature(m Message) bool {
fmt.Printf(" * DEBUG: verifySignature, method: %v\n", m.Method)
// fmt.Printf(" * DEBUG: verifySignature, method: %v\n", m.Method)
if !s.configuration.EnableSignatureCheck {
fmt.Printf(" * DEBUG: verifySignature: AllowEmptySignature set to TRUE\n")
// fmt.Printf(" * DEBUG: verifySignature: AllowEmptySignature set to TRUE\n")
return true
}
// TODO: Only enable signature checking for REQCliCommand for now.
if m.Method != REQCliCommand {
fmt.Printf(" * DEBUG: verifySignature: WAS OTHER THAN CLI COMMAND\n")
// fmt.Printf(" * DEBUG: verifySignature: WAS OTHER THAN CLI COMMAND\n")
return true
}
@ -228,7 +228,7 @@ func (s *signatures) verifySignature(m Message) bool {
argsStringified := argsToString(m.MethodArgs)
ok := ed25519.Verify(s.SignPublicKey, []byte(argsStringified), m.ArgSignature)
fmt.Printf(" * DEBUG: verifySignature, result: %v, fromNode: %v, method: %v\n", ok, m.FromNode, m.Method)
// fmt.Printf(" * DEBUG: verifySignature, result: %v, fromNode: %v, method: %v\n", ok, m.FromNode, m.Method)
return ok
}