Network: move the protocol knowledge to the Remote

Having the knowledge in the Remote will allow us to use different
transports more effectively and abstract away the details of the
particular way of talking to the remote end.

References libgit2#210

Author: carlosmn

LibGit2Sharp/GitTransport.cs

@@ -1,4 +1,5 @@
 using System;
+using System.IO;
 using System.Net.Sockets;
 using System.Collections.Generic;
 using System.Text;
@@ -9,6 +10,9 @@ public class GitTransport : ITransport
     {
         Uri uri = null;
         List<PktRef> Refs;
+        bool connected;
+        Stream stream;
+
         public GitTransport(string url)
         {
             var uribld = new UriBuilder(url);
@@ -19,6 +23,7 @@ public GitTransport(string url)
                 uribld.Port = 9418;
 
             uri = uribld.Uri;
+            connected = false;
         }
 
         byte[] GenRequest(Uri uri)
@@ -31,30 +36,25 @@ public void Connect()
         {
             var req = GenRequest(uri);
             var tcp = new TcpClient(uri.Host, uri.Port);
-            var stream = tcp.GetStream();
+            stream = tcp.GetStream();
             stream.Write(req, 0, req.Length);
-            var parser = new PktParser(stream);
-            Refs = new List<PktRef>();
-            Pkt pkt;
-
-            /* Store the lines advertising references, stop at the flush */
-            while(true) {
-                pkt = parser.Next();
-                if (pkt is PktFlush)
-                    break;
-
-                if (pkt is PktRef)
-                    Refs.Add(pkt as PktRef);
-
-                if (pkt is PktError)
-                    throw new GitProtocolException((pkt as PktError).Error);
-            }
+            connected = true;
+        }
+
+        public Stream GetStream()
+        {
+            return stream;
         }
 
         public List<PktRef> ListRefs()
         {
             return Refs;
         }
+
+        public bool Connected()
+        {
+            return connected;
+        }
     }
 }
 

LibGit2Sharp/ITransport.cs

@@ -1,12 +1,14 @@
 using System;
+using System.IO;
 using System.Collections.Generic;
 
 namespace LibGit2Sharp
 {
     public interface ITransport
     {
         void Connect();
-        List<PktRef> ListRefs();
+        bool Connected();
+        Stream GetStream();
     }
 }
 

LibGit2Sharp/Remote.cs

@@ -1,5 +1,8 @@
 using System;
+using System.Linq;
+using System.Collections.Generic;
 using LibGit2Sharp.Core;
+using LibGit2Sharp.Core.Compat;
 using LibGit2Sharp.Core.Handles;
 
 namespace LibGit2Sharp
@@ -9,6 +12,51 @@ namespace LibGit2Sharp
     /// </summary>
     public class Remote : IEquatable<Remote>
     {
+        private readonly ITransport transport;
+        public List<PktRef> Refs { get; private set; }
+        private Lazy<IEnumerable<string>> refnames;
+
+        /* Mostly so that the already-existing code doesn't break */
+        public Remote()
+        {
+        }
+
+        public Remote(string url)
+        {
+            refnames = new Lazy<IEnumerable<string>>(() => Refs.Select(s => s.Name));
+            if (url.StartsWith("git://"))
+                transport = new GitTransport(url);
+            else
+                throw new NotImplementedException("This transport" + url + "isn't supported, sorry");
+        }
+
+        public IEnumerable<string> RefNames
+        {
+            get {
+                return refnames.Value;
+            }
+        }
+
+        public void Connect()
+        {
+            transport.Connect();
+            /* Store the lines advertising references, stop at the flush */
+            var parser = new PktParser(transport.GetStream());
+            Refs = new List<PktRef>();
+
+            while(true) {
+                var pkt = parser.Next();
+                if (pkt is PktFlush)
+                    break;
+
+                if (pkt is PktRef)
+                    Refs.Add(pkt as PktRef);
+
+                if (pkt is PktError)
+                    throw new GitProtocolException((pkt as PktError).Error);
+            }
+        }
+
         private static readonly LambdaEqualityHelper<Remote> equalityHelper =
             new LambdaEqualityHelper<Remote>(new Func<Remote, object>[] { x => x.Name, x => x.Url });