From f1050fd77f5811af4b2437a645ffe8b9b90d718f Mon Sep 17 00:00:00 2001 From: AnisB Date: Wed, 30 Sep 2020 16:33:23 +0100 Subject: [PATCH] update --- main.go | 37 ++++++++++++++++++------------------- 1 file changed, 18 insertions(+), 19 deletions(-) diff --git a/main.go b/main.go index 42f6631..39c45f2 100644 --- a/main.go +++ b/main.go @@ -105,9 +105,6 @@ func main() { defer f.Close() } - // ========================== - // Run TUI - //================================ startClient(c) } @@ -129,18 +126,6 @@ func startClient(config *config) { var client *xmpp.Client router := xmpp.NewRouter() - handleMessage := func(s xmpp.Sender, p stanza.Packet) { - msg, ok := p.(stanza.Message) - if !ok { - _, _ = fmt.Fprintf(os.Stdout, "Ignoring packet: %T\n", p) - return - } - - _, _ = fmt.Fprintf(os.Stdout, "Body = %s - from = %s\n", msg.Body, msg.From) - reply := stanza.Message{Attrs: stanza.Attrs{To: msg.From}, Body: msg.Body} - _ = s.Send(reply) - } - errorHandler:= func(err error) { fmt.Println(err.Error()) } @@ -176,10 +161,10 @@ func startClient(config *config) { // ==================== // Start working - currentContacts := strings.Split(config.Contacts, configContactSep)[0] - fmt.Println(infoFormat+"Now sending messages to "+currentContacts+" in a private conversation\n") - CorrespChan <- currentContacts - fmt.Println("currentContacts", currentContacts) + currentContact := strings.Split(config.Contacts, configContactSep)[0] + fmt.Println(infoFormat+"Now sending messages to "+currentContact+" in a private conversation\n") + CorrespChan <- currentContact + fmt.Println("currentContacts", currentContact) startMessaging(client, config) } @@ -187,6 +172,7 @@ func startClient(config *config) { func startMessaging(client xmpp.Sender, config *config) { + fmt.Println("START MESSAGING") var text string var correspondent string for { @@ -200,6 +186,7 @@ func startMessaging(client xmpp.Sender, config *config) { } return case text = <-textChan: + fmt.Println("TEST 1") reply := stanza.Message{Attrs: stanza.Attrs{To: correspondent, Type: stanza.MessageTypeChat}, Body: text} if logger != nil { raw, _ := xml.Marshal(reply) @@ -211,6 +198,7 @@ func startMessaging(client xmpp.Sender, config *config) { return } case text = <-rawTextChan: + fmt.Println("TEST 2") if logger != nil { logger.Println(text) } @@ -220,7 +208,18 @@ func startMessaging(client xmpp.Sender, config *config) { return } case crrsp := <-CorrespChan: + fmt.Println("TEST 3") correspondent = crrsp + reply := stanza.Message{Attrs: stanza.Attrs{To: correspondent, Type: stanza.MessageTypeChat}, Body: text} + if logger != nil { + raw, _ := xml.Marshal(reply) + logger.Println(string(raw)) + } + err := client.Send(reply) + if err != nil { + fmt.Printf("There was a problem sending the message : %v", reply) + return + } case <-rosterChan: fmt.Println("rosterchan") }