From ada1317ec840e5a2c9e0a3f9060c14c56c9cd198 Mon Sep 17 00:00:00 2001
From: Aaron Lindsay <aaron@aclindsay.com>
Date: Mon, 1 Apr 2013 23:59:40 -0400
Subject: [PATCH] Add downloading of remotely-updated files

---
 client/asink.go | 34 ++++++++++++++++++++++++++++++++--
 1 file changed, 32 insertions(+), 2 deletions(-)

diff --git a/client/asink.go b/client/asink.go
index c024e82..74fa351 100644
--- a/client/asink.go
+++ b/client/asink.go
@@ -6,6 +6,7 @@ import (
 	"code.google.com/p/goconf/conf"
 	"flag"
 	"fmt"
+	"io/ioutil"
 	"os"
 	"os/user"
 	"path"
@@ -162,9 +163,38 @@ func ProcessLocalEvent(globals AsinkGlobals, event *asink.Event) {
 	}
 }
 
+func ProcessRemoteEvent(globals AsinkGlobals, event *asink.Event) {
+	//Download event
+	if event.IsUpdate() {
+		outfile, err := ioutil.TempFile(globals.tmpDir, "asink")
+		if err != nil {
+			panic(err) //TODO handle sensibly
+		}
+		tmpfilename := outfile.Name()
+		outfile.Close()
+		err = globals.storage.Get(tmpfilename, event.Hash)
+		if err != nil {
+			panic(err) //TODO handle sensibly
+		}
+
+		//rename to local hashed filename
+		err = os.Rename(tmpfilename, path.Join(globals.cacheDir, event.Hash))
+		if err != nil {
+			err := os.Remove(tmpfilename)
+			if err != nil {
+				panic(err)
+			}
+			panic(err)
+		}
+	}
+
+	fmt.Println(event)
+	//TODO make sure file being overwritten is either unchanged or already copied off and hashed
+	//TODO add event to the local database, and populate the local directory
+}
+
 func ProcessRemoteEvents(globals AsinkGlobals, eventChan chan *asink.Event) {
 	for event := range eventChan {
-		fmt.Println(event)
-		//TODO actually download event, add it to the local database, and populate the local directory
+		ProcessRemoteEvent(globals, event)
 	}
 }