Added the command controller

does complex things like saving w/o blocking the UI thread

Author: tkellogg

Jump.Location.Specs/CommandControllerSpec.cs

@@ -0,0 +1,31 @@
+using System.Threading;
+using Moq;
+using Xunit;
+
+namespace Jump.Location.Specs
+{
+    public class CommandControllerSpec
+    {
+        public class DescribeUpdateTimes
+        {
+            private readonly Mock<IDatabase> dbMock;
+            private readonly Mock<IFileStoreProvider> fsMock;
+            private readonly CommandController controller;
+
+            public DescribeUpdateTimes()
+            {
+                dbMock = new Mock<IDatabase>();
+                fsMock = new Mock<IFileStoreProvider>();
+                controller = new CommandController(dbMock.Object, fsMock.Object);
+            }
+
+            [Fact]
+            public void It_saves_eventually()
+            {
+                controller.UpdateLocation("foo");
+                Thread.Sleep(30);
+                fsMock.Verify(x => x.Save(dbMock.Object));
+            }
+        }
+    }
+}

Jump.Location.Specs/DatabaseSpec.cs

@@ -7,20 +7,59 @@ namespace Jump.Location.Specs
 {
     public class DatabaseSpec
     {
-        [Fact]
-        public void It_adds_a_new_record_by_path()
+        public class DescribeAdding
         {
-            var db = new Database();
-            db.Add("full::path");
-            db.Records.Count().ShouldEqual(1);
+            [Fact]
+            public void It_adds_a_new_record_by_path()
+            {
+                var db = new Database();
+                db.Add("full::path");
+                db.Records.Count().ShouldEqual(1);
+            }
+
+            [Fact]
+            public void It_adds_a_new_record_by_object()
+            {
+                var db = new Database();
+                db.Add(Mock.Of<IRecord>());
+                db.Records.Count().ShouldEqual(1);
+            }
         }
 
-        [Fact]
-        public void It_adds_a_new_record_by_object()
+        public class DescribeFindingByFullName
         {
-            var db = new Database();
-            db.Add(Mock.Of<IRecord>());
-            db.Records.Count().ShouldEqual(1);
+            [Fact]
+            public void It_returns_the_matching_record()
+            {
+                var db = new Database();
+                db.Add(Mock.Of<IRecord>(x => x.FullName == "foo"));
+                db.Add(Mock.Of<IRecord>(x => x.FullName == "bar"));
+
+                db.GetByFullName("bar").ShouldNotBeNull();
+            }
+
+            [Fact]
+            public void It_creates_a_record_when_missing()
+            {
+                var db = new Database();
+                db.Add(Mock.Of<IRecord>(x => x.FullName == "foo"));
+                db.Add(Mock.Of<IRecord>(x => x.FullName == "bar"));
+
+                var baz = db.GetByFullName("foo::bar");
+                baz.ShouldNotBeNull();
+                baz.ShouldBeType<Record>();
+            }
+
+            [Fact]
+            public void It_adds_the_missing_record_to_its_list()
+            {
+                var db = new Database();
+                db.Add(Mock.Of<IRecord>(x => x.FullName == "foo"));
+                db.Add(Mock.Of<IRecord>(x => x.FullName == "bar"));
+
+                db.GetByFullName("foo::bar");
+                db.Records.Count().ShouldEqual(3);
+            }
         }
     }
 }

Jump.Location.Specs/Jump.Location.Specs.csproj

@@ -54,6 +54,7 @@
     </Reference>
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="CommandControllerSpec.cs" />
     <Compile Include="DatabaseSpec.cs" />
     <Compile Include="DirectoryWaitPeriodSpec.cs" />
     <Compile Include="FileStoreProviderSpec.cs" />

Jump.Location/CommandController.cs

@@ -0,0 +1,51 @@
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Jump.Location
+{
+    class CommandController
+    {
+        private readonly IDatabase database;
+        private readonly IFileStoreProvider fileStore;
+        private bool needsToSave;
+
+        public CommandController(IDatabase database, IFileStoreProvider fileStore)
+        {
+            this.database = database;
+            this.fileStore = fileStore;
+            Task.Factory.StartNew(SaveLoop);
+        }
+
+        public CommandController(string path)
+            :this(new Database(), new FileStoreProvider(path))
+        {
+        }
+
+        public void UpdateLocation(string fullName)
+        {
+            var record = database.GetByFullName(fullName);
+            needsToSave = true;
+        }
+
+        private void SaveLoop()
+        {
+            while(true)
+            {
+                if (needsToSave)
+                {
+                    try
+                    {
+                        needsToSave = false;
+                        fileStore.Save(database);
+                    }
+                    catch(Exception e)
+                    {
+                        Console.Error.WriteLine("Jump-Location received {0}: {1}", e.GetType().Name, e.Message);
+                    }
+                }
+                else Thread.Sleep(0);
+            }
+        }
+    }
+}

Jump.Location/Database.cs

@@ -1,4 +1,5 @@
 using System.Collections.Generic;
+using System.Linq;
 
 namespace Jump.Location
 {
@@ -7,6 +8,7 @@ public interface IDatabase
         IEnumerable<IRecord> Records { get; }
         void Add(string fullPath);
         void Add(IRecord record);
+        IRecord GetByFullName(string fullName);
     }
 
     class Database : IDatabase
@@ -24,5 +26,18 @@ public void Add(IRecord record)
         {
             records.Add(record);
         }
+
+        public IRecord GetByFullName(string fullName)
+        {
+            var record = records.FirstOrDefault(x => x.FullName == fullName);
+
+            if (record == null)
+            {
+                record = new Record(fullName);
+                Add(record);
+            }
+
+            return record;
+        }
     }
 }

Jump.Location/Jump.Location.csproj

@@ -58,6 +58,7 @@
     <Reference Include="System.Xml" />
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="CommandController.cs" />
     <Compile Include="Database.cs" />
     <Compile Include="DirectoryWaitPeriod.cs" />
     <Compile Include="FileStoreProvider.cs" />

Jump.Location/JumpLocationCommand.cs

@@ -1,16 +1,14 @@
 using System;
 using System.Linq;
 using System.Management.Automation;
-using System.Management.Automation.Runspaces;
-using Microsoft.PowerShell.Commands;
 
 namespace Jump.Location
 {
     [Cmdlet("Jump", "Location")]
     public class JumpLocationCommand : PSCmdlet
     {
         private static bool _hasRegisteredDirectoryHook;
-        private Container container;
+        private static readonly CommandController Controller = new CommandController(@"C:\jump-location.db");
 
         /*
          * 1. Figure out how long they stay in the directory
@@ -22,21 +20,14 @@ public class JumpLocationCommand : PSCmdlet
         [Parameter(Position = 0)]
         public string Directory { get; set; }
 
-        class Container
-        {
-            public string Last { get; set; }
-        }
-
-        private static int counter = 0;
         public static void UpdateTime(string location)
         {
-            Console.WriteLine(location);
+            Controller.UpdateLocation(location);
         }
 
         protected override void BeginProcessing()
         {
             base.BeginProcessing();
-            container = container ?? new Container();
 
             if (_hasRegisteredDirectoryHook) return;