Refactor code to reflect refactored sugoi code

canopus.go

@@ -212,4 +212,15 @@ type CoapServer interface {
 
 	IsDuplicateMessage(msg *Message) bool
 	UpdateMessageTS(msg *Message)
+}
+
+// A simple wrapper interface around a connection
+// This was primarily concieved so that mocks could be
+// created to unit test connection code
+type CanopusConnection interface {
+	GetConnection() net.Conn
+	Write(b []byte) (int, error)
+	SetReadDeadline(t time.Time) error
+	Read() (buf []byte, n int, err error)
+	WriteTo(b []byte, addr net.Addr) (int, error)
 }

conn.go

@@ -6,17 +6,6 @@ import (
 	"time"
 )
 
-// A simple wrapper interface around a connection
-// This was primarily concieved so that mocks could be
-// created to unit test connection code
-type CanopusConnection interface {
-	GetConnection() net.Conn
-	Write(b []byte) (int, error)
-	SetReadDeadline(t time.Time) error
-	Read() (buf []byte, n int, err error)
-	WriteTo(b []byte, addr net.Addr) (int, error)
-}
-
 // ----------------------------------------------------------------
 
 func NewCanopusUDPConnection(c *net.UDPConn) CanopusConnection {

examples/proxy-reverse/run-example.go

@@ -1,5 +1,4 @@
 package main
-import "github.com/zubairhamed/canopus"
 
 func main() {
 
@@ -8,12 +7,12 @@ func main() {
 		out string
 	}
 
-	var server *canopus.CoapServer
-	server.AddProxyPass(in, out)
-	server.RemoveProxyPass(in)
-
-	server.AddProxyPassReverse(in, out)
-	server.AddRemoveProxyPassReverse
+//	var server *canopus.CoapServer
+//	server.AddProxyPass(in, out)
+//	server.RemoveProxyPass(in)
+//
+//	server.AddProxyPassReverse(in, out)
+//	server.AddRemoveProxyPassReverse
 
 
 }

server.go

@@ -315,9 +315,7 @@ func (s *DefaultCoapServer) RemoveObservation(resource string, addr *net.UDPAddr
 }
 
 func (c *DefaultCoapServer) Dial(host string) {
-	remoteAddr, _ := net.ResolveUDPAddr("udp6", host)
-
-	c.remoteAddr = remoteAddr
+	c.Dial6(host)
 }
 
 func (c *DefaultCoapServer) Dial6(host string) {