// Copyright 2011 The Go Authors.  All rights reserved.

// Use of this source code is governed by a BSD-style

// license that can be found in the LICENSE file.

// This file contains the three layers of processing for the

// communication with the server: transport (where TLS happens), XML

// (where strings are converted to go structures), and Stream (where

// we respond to XMPP events on behalf of the library client), or send

// those events to the client.

package xmpp

import (

	"big"

	"crypto/md5"

	"crypto/rand"

	"crypto/tls"

	"encoding/base64"

	"fmt"

	"io"

	"log"

	"net"

	"os"

	"regexp"

	"strings"

	"time"

	"xml"

)

// Callback to handle a stanza with a particular id.

type stanzaHandler struct {

	id string

	// Return true means pass this to the application

	f func(Stanza) bool

}

// BUG(cjyar) Review all these *Client receiver methods. They should

// probably either all be receivers, or none.

func (cl *Client) readTransport(w io.Writer) {

	defer tryClose(cl.socket, w)

	cl.socket.SetReadTimeout(1e8)

	p := make([]byte, 1024)

	for {

		if cl.socket == nil {

			cl.waitForSocket()

		}

		nr, err := cl.socket.Read(p)

		if nr == 0 {

			if errno, ok := err.(*net.OpError) ; ok {

				if errno.Timeout() {

					continue

				}

			}

			log.Printf("read: %s", err.String())

			break

		}

		nw, err := w.Write(p[:nr])

		if nw < nr {

			log.Println("read: %s", err.String())

			break

		}

	}

}

func (cl *Client) writeTransport(r io.Reader) {

	defer tryClose(r, cl.socket)

	p := make([]byte, 1024)

	for {

		nr, err := r.Read(p)

		if nr == 0 {

			log.Printf("write: %s", err.String())

			break

		}

		nw, err := cl.socket.Write(p[:nr])

		if nw < nr {

			log.Println("write: %s", err.String())

			break

		}

	}

}

func readXml(r io.Reader, ch chan<- interface{}) {

	if debug {

		pr, pw := io.Pipe()

		go tee(r, pw, "S: ")

		r = pr

	}

	defer tryClose(r, ch)

	p := xml.NewParser(r)

	for {

		// Sniff the next token on the stream.

		t, err := p.Token()

		if t == nil {

			if err != os.EOF {

				log.Printf("read: %v", err)

			}

			break

		}

		var se xml.StartElement

		var ok bool

		if se, ok = t.(xml.StartElement) ; !ok {

			continue

		}

		// Allocate the appropriate structure for this token.

		var obj interface{}

		switch se.Name.Space + " " + se.Name.Local {

		case nsStream + " stream":

			st, err := parseStream(se)

			if err != nil {

				log.Printf("unmarshal stream: %v",

					err)

				break

			}

			ch <- st

			continue

		case "stream error", nsStream + " error":

			obj = &StreamError{}

		case nsStream + " features":

			obj = &Features{}

		case nsTLS + " proceed", nsTLS + " failure":

			obj = &starttls{}

		case nsSASL + " challenge", nsSASL + " failure",

			nsSASL + " success":

			obj = &auth{}

		case "jabber:client iq":

			obj = &Iq{}

		case "jabber:client message":

			obj = &Message{}

		case "jabber:client presence":

			obj = &Presence{}

		default:

			obj = &Generic{}

			log.Printf("Ignoring unrecognized: %s %s\n",

				se.Name.Space, se.Name.Local)

		}

		// Read the complete XML stanza.

		err = p.Unmarshal(obj, &se)

		if err != nil {

			log.Printf("unmarshal: %v", err)

			break

		}

		// BUG(cjyar) If it's a Stanza, use reflection to

		// search for any Generic elements and fill in

		// their attributes.

		// Put it on the channel.

		ch <- obj

	}

}

func writeXml(w io.Writer, ch <-chan interface{}) {

	if debug {

		pr, pw := io.Pipe()

		go tee(pr, w, "C: ")

		w = pw

	}

	defer tryClose(w, ch)

	for obj := range ch {

		err := xml.Marshal(w, obj)

		if err != nil {

			log.Printf("write: %v", err)

			break

		}

	}

}

// BUG(cjyar) This should go away. We shouldn't allow writing of

// unstructured data.

func writeText(w io.Writer, ch <-chan *string) {

	if debug {

		pr, pw := io.Pipe()

		go tee(pr, w, "C: ")

		w = pw

	}

	defer tryClose(w, ch)

	for str := range ch {

		_, err := w.Write([]byte(*str))

		if err != nil {

			log.Printf("writeStr: %v", err)

			break

		}

	}

}

func (cl *Client) readStream(srvIn <-chan interface{}, cliOut chan<- interface{}) {

	defer tryClose(srvIn, cliOut)

	handlers := make(map[string] func(Stanza) bool)

	// BUG(cjyar) This for loop will never terminate, even when

	// the channels are closed.

	for {

		select {

		case h := <- cl.handlers:

			handlers[h.id] = h.f

		case x := <- srvIn:

			send := false

			switch obj := x.(type) {

				handleStream(obj)

			case *Features:

				cl.handleFeatures(obj)

			case *starttls:

				cl.handleTls(obj)

			case *auth:

				cl.handleSasl(obj)

			default:

				send = true

			}

			if st, ok := x.(Stanza) ; ok &&

				handlers[st.XId()] != nil {

				f := handlers[st.XId()]

				handlers[st.XId()] = nil

				send = f(st)

			}

			if send {

				cliOut <- x

			}

		}

	}

}

// BUG(cjyar) Disable this loop until resource binding is

// complete. Otherwise the app might inject something weird into our

// negotiation stream.

func writeStream(srvOut chan<- interface{}, cliIn <-chan interface{}) {

	defer tryClose(srvOut, cliIn)

	for x := range cliIn {

		srvOut <- x

	}

}

}

func (cl *Client) handleFeatures(fe *Features) {

	if fe.Starttls != nil {

		start := &starttls{XMLName: xml.Name{Space: nsTLS,

			Local: "starttls"}}

		cl.xmlOut <- start

		return

	}

	if len(fe.Mechanisms.Mechanism) > 0 {

		cl.chooseSasl(fe)

		return

	}

	if fe.Bind != nil {

		cl.bind(fe.Bind)

		return

	}

}

// readTransport() is running concurrently. We need to stop it,

// negotiate TLS, then start it again. It calls waitForSocket() in

// its inner loop; see below.

func (cl *Client) handleTls(t *starttls) {

	tcp := cl.socket

	// Set the socket to nil, and wait for the reader routine to

	// signal that it's paused.

	cl.socket = nil

	cl.socketSync.Add(1)

	cl.socketSync.Wait()

	// Negotiate TLS with the server.

	tls := tls.Client(tcp, nil)

	// Make the TLS connection available to the reader, and wait

	// for it to signal that it's working again.

	cl.socketSync.Add(1)

	cl.socket = tls

	cl.socketSync.Wait()

	// Reset the read timeout on the (underlying) socket so the

	// reader doesn't get woken up unnecessarily.

	tcp.SetReadTimeout(0)

	log.Println("TLS negotiation succeeded.")

	// Now re-send the initial handshake message to start the new

	// session.

	cl.xmlOut <- hsOut

}

// Synchronize with handleTls(). Called from readTransport() when

// cl.socket is nil.

func (cl *Client) waitForSocket() {

	// Signal that we've stopped reading from the socket.

	cl.socketSync.Done()

	// Wait until the socket is available again.

	for cl.socket == nil {

		time.Sleep(1e8)

	}

	// Signal that we're going back to the read loop.

	cl.socketSync.Done()

}

// BUG(cjyar) Doesn't implement TLS/SASL EXTERNAL.

func (cl *Client) chooseSasl(fe *Features) {

	var digestMd5 bool

	for _, m := range(fe.Mechanisms.Mechanism) {

		switch strings.ToLower(m) {

		case "digest-md5":

			digestMd5 = true

		}

	}

	if digestMd5 {

		auth := &auth{XMLName: xml.Name{Space: nsSASL, Local:

				"auth"}, Mechanism: "DIGEST-MD5"}

		cl.xmlOut <- auth

	}

}

func (cl *Client) handleSasl(srv *auth) {

	switch strings.ToLower(srv.XMLName.Local) {

	case "challenge":

		b64 := base64.StdEncoding

		str, err := b64.DecodeString(srv.Chardata)

		if err != nil {

			log.Printf("SASL challenge decode: %s",

				err.String())

			return;

		}

		srvMap := parseSasl(string(str))

		if cl.saslExpected == "" {

			cl.saslDigest1(srvMap)

		} else {

			cl.saslDigest2(srvMap)

		}

	case "failure":

		log.Println("SASL authentication failed")

	case "success":

		log.Println("SASL authentication succeeded")

		cl.xmlOut <- ss

	}

}

func (cl *Client) saslDigest1(srvMap map[string] string) {

	// Make sure it supports qop=auth

	var hasAuth bool

	for _, qop := range(strings.Fields(srvMap["qop"])) {

		if qop == "auth" {

			hasAuth = true

		}

	}

	if !hasAuth {

		log.Println("Server doesn't support SASL auth")

		return;

	}

	// Pick a realm.

	var realm string