Implemented XMPP federation.

Author: ortuman

Gopkg.lock

@@ -100,6 +100,7 @@ $ docker run --name jackal -p 5222:5222 ortuman/jackal
 - [XEP-0160: Best Practices for Handling Offline Messages](https://xmpp.org/extensions/xep-0160.html)
 - [XEP-0191: Blocking Command](https://xmpp.org/extensions/xep-0191.html)
 - [XEP-0199: XMPP Ping](https://xmpp.org/extensions/xep-0199.html)
+- [XEP-0220: Server Dialback](https://xmpp.org/extensions/xep-0220.html)
 - [XEP-0237: Roster Versioning](https://xmpp.org/extensions/xep-0237.html)
 
 ## Join and Contribute

README.md

@@ -8,10 +8,10 @@ package auth
 import (
 	"testing"
 
+	"github.com/ortuman/jackal/model"
 	"github.com/ortuman/jackal/storage"
-	"github.com/ortuman/jackal/storage/model"
 	"github.com/ortuman/jackal/stream"
-	"github.com/ortuman/jackal/xml"
+	"github.com/ortuman/jackal/xml/jid"
 	"github.com/pborman/uuid"
 	"github.com/stretchr/testify/require"
 )
@@ -21,14 +21,14 @@ func authTestSetup(user *model.User) *stream.MockC2S {
 
 	storage.Instance().InsertOrUpdateUser(user)
 
-	jid, _ := xml.NewJID("mariana", "localhost", "res", true)
+	j, _ := jid.New("mariana", "localhost", "res", true)
 
-	testStrm := stream.NewMockC2S(uuid.New(), jid)
+	testStrm := stream.NewMockC2S(uuid.New(), j)
 	testStrm.SetUsername("mariana")
 	testStrm.SetDomain("localhost")
 	testStrm.SetResource("res")
 
-	testStrm.SetJID(jid)
+	testStrm.SetJID(j)
 	return testStrm
 }
 

auth/auth_test.go

@@ -13,8 +13,8 @@ import (
 	"fmt"
 	"strings"
 
+	"github.com/ortuman/jackal/model"
 	"github.com/ortuman/jackal/storage"
-	"github.com/ortuman/jackal/storage/model"
 	"github.com/ortuman/jackal/stream"
 	"github.com/ortuman/jackal/util"
 	"github.com/ortuman/jackal/xml"

auth/digest_md5.go

@@ -11,9 +11,9 @@ import (
 	"fmt"
 	"testing"
 
+	"github.com/ortuman/jackal/model"
 	"github.com/ortuman/jackal/storage"
 	"github.com/ortuman/jackal/storage/memstorage"
-	"github.com/ortuman/jackal/storage/model"
 	"github.com/ortuman/jackal/stream"
 	"github.com/ortuman/jackal/util"
 	"github.com/ortuman/jackal/xml"

auth/digest_md5_test.go

@@ -10,9 +10,9 @@ import (
 	"encoding/base64"
 	"testing"
 
+	"github.com/ortuman/jackal/model"
 	"github.com/ortuman/jackal/storage"
 	"github.com/ortuman/jackal/storage/memstorage"
-	"github.com/ortuman/jackal/storage/model"
 	"github.com/ortuman/jackal/xml"
 	"github.com/stretchr/testify/require"
 )

auth/plain_test.go

@@ -15,8 +15,8 @@ import (
 	"hash"
 	"strings"
 
+	"github.com/ortuman/jackal/model"
 	"github.com/ortuman/jackal/storage"
-	"github.com/ortuman/jackal/storage/model"
 	"github.com/ortuman/jackal/stream"
 	"github.com/ortuman/jackal/transport"
 	"github.com/ortuman/jackal/util"

auth/scram.go

@@ -11,14 +11,15 @@ import (
 	"crypto/sha1"
 	"crypto/sha256"
 	"crypto/tls"
+	"crypto/x509"
 	"encoding/base64"
 	"fmt"
 	"hash"
 	"strconv"
 	"strings"
 	"testing"
 
-	"github.com/ortuman/jackal/storage/model"
+	"github.com/ortuman/jackal/model"
 	"github.com/ortuman/jackal/transport"
 	"github.com/ortuman/jackal/transport/compress"
 	"github.com/ortuman/jackal/util"
@@ -41,6 +42,7 @@ func (ft *fakeTransport) EnableCompression(compress.Level)        { return }
 func (ft *fakeTransport) ChannelBindingBytes(transport.ChannelBindingMechanism) []byte {
 	return ft.cbBytes
 }
+func (ft *fakeTransport) PeerCertificates() []*x509.Certificate { return nil }
 
 type scramAuthTestCase struct {
 	id          int