summaryrefslogtreecommitdiff
path: root/xmpp/conn.go
diff options
context:
space:
mode:
authorxengineering <me@xengineering.eu>2023-06-26 18:37:16 +0200
committerxengineering <me@xengineering.eu>2023-06-27 15:04:33 +0200
commit8715603ce1a713d1c8841382bb965cb55948fedd (patch)
treec3af42979a443168d85dd194b063308417ad0f42 /xmpp/conn.go
parenta8a6c31d862ec1d491fc76ed21c46d7e0b35b7f2 (diff)
downloadlimox-8715603ce1a713d1c8841382bb965cb55948fedd.tar
limox-8715603ce1a713d1c8841382bb965cb55948fedd.tar.zst
limox-8715603ce1a713d1c8841382bb965cb55948fedd.zip
xmpp: Remove unused code
This is part of the refactoring. Details of the old implementation should be looked up by older commits.
Diffstat (limited to 'xmpp/conn.go')
-rw-r--r--xmpp/conn.go96
1 files changed, 0 insertions, 96 deletions
diff --git a/xmpp/conn.go b/xmpp/conn.go
deleted file mode 100644
index f017889..0000000
--- a/xmpp/conn.go
+++ /dev/null
@@ -1,96 +0,0 @@
-package xmpp
-
-import (
- "crypto/tls"
- "crypto/x509"
- "log"
-)
-
-type Event uint8
-
-const (
- DisconnectEvent Event = iota
- ConnectEvent
- ShouldDisconnectEvent
-)
-
-type Conn struct {
- ch chan Event
- jid, pwd string
- tcp *tls.Conn
- enc encoder
-}
-
-func NewConn(ch chan Event, jid string, pwd string) *Conn {
- c := Conn{
- ch: ch,
- jid: jid,
- pwd: pwd}
-
- return &c
-}
-
-func (c *Conn) Connect() error {
- var err error
-
- domain := domainpart(c.jid)
-
- roots, err := x509.SystemCertPool()
- if err != nil {
- log.Println(err)
- return err
- }
-
- c.tcp, err = tls.Dial("tcp", domain+":"+"5223", &tls.Config{RootCAs: roots})
- if err != nil {
- log.Println(err)
- return err
- }
-
- return nil
-}
-
-func (c *Conn) Disconnect() {
- c.tcp.Close()
-}
-
-func (c *Conn) Run() {
- err := c.Connect()
- if err != nil {
- return
- }
- defer c.Disconnect()
-
- decoder := newDecoder(c.tcp)
- go decoder.run()
- defer decoder.stop()
-
- c.enc = newEncoder(c.tcp)
- defer c.enc.Close()
-
- tr := newTokenRouter()
-
- end := sendStreamStart(&c.enc, c.jid)
- defer sendStreamEnd(&c.enc, end)
-
- c.ch <- ConnectEvent
- defer func() { c.ch <- DisconnectEvent }()
-
- for {
- select {
- case ev := <-c.ch:
- switch ev {
- case ShouldDisconnectEvent:
- return
- default:
- log.Printf("Unknown Event '%d'!\n", ev)
- }
- case token := <-decoder.data:
- err = tr.route(token, c)
- if err != nil {
- log.Println(err)
- return
- }
- }
- }
-}