Extend swift storage with link and file exists methods

swift/public.go

@@ -265,26 +265,39 @@ func (storage *PublishedStorage) RenameFile(oldName, newName string) error {
 	return nil
 }
 
-// SymLink creates a symbolic link, which can be read with ReadLink
+// SymLink creates a copy of src file and adds link information as meta data
 func (storage *PublishedStorage) SymLink(src string, dst string) error {
-	// TODO: create a file containing dst
+	srcObjectName := filepath.Join(storage.prefix, src)
-	return fmt.Errorf("SWIFT: symlinks not implemented")
+	dstObjectName := filepath.Join(storage.prefix, dst)
+
+	headers := map[string]string{
+		"SymLink": srcObjectName,
+	}
+	_, err := storage.conn.ObjectCopy(storage.container, srcObjectName, storage.container, dstObjectName, headers)
+	if err != nil {
+		return fmt.Errorf("error symlinking %s -> %s in %s: %s", srcObjectName, dstObjectName, storage, err)
+	}
+	return err
 }
 
-// HardLink creates a hardlink of a file
+// HardLink using symlink functionality as hard links do not exist
 func (storage *PublishedStorage) HardLink(src string, dst string) error {
-	// TODO: create a copy of the file
+	return storage.SymLink(src, dst)
-	return fmt.Errorf("SWIFT: hardlinks not implemented")
 }
 
 // FileExists returns true if path exists
 func (storage *PublishedStorage) FileExists(path string) bool {
-	// TODO: implement
+	_, _, err := storage.conn.Object(storage.container, filepath.Join(storage.prefix, path))
-	return false
+	return err == nil
 }
 
 // ReadLink returns the symbolic link pointed to by path
 func (storage *PublishedStorage) ReadLink(path string) (string, error) {
-	// TODO: read the path and return the content of the file
+	srcObjectName := filepath.Join(storage.prefix, path)
-	return "", fmt.Errorf("SWIFT: ReadLink not implemented")
+	_, headers, err := storage.conn.Object(storage.container, srcObjectName)
+	if err != nil {
+		return "", fmt.Errorf("error reading symlink %s in %s: %s", srcObjectName, storage, err)
+	}
+
+	return headers["SymLink"], nil
 }

swift/public_test.go

@@ -194,3 +194,37 @@ func (s *PublishedStorageSuite) TestLinkFromPool(c *C) {
 	c.Check(err, IsNil)
 	c.Check(data, DeepEquals, []byte("Spam"))
 }
+
+func (s *PublishedStorageSuite) TestSymLink(c *C) {
+	dir := c.MkDir()
+	err := ioutil.WriteFile(filepath.Join(dir, "a"), []byte("welcome to swift!"), 0644)
+	c.Assert(err, IsNil)
+
+	err = s.storage.PutFile("a/b.txt", filepath.Join(dir, "a"))
+	c.Check(err, IsNil)
+
+	err = s.storage.SymLink("a/b.txt", "a/b.txt.link")
+	c.Check(err, IsNil)
+
+	var link string
+	link, err = s.storage.ReadLink("a/b.txt.link")
+	c.Check(err, IsNil)
+	c.Check(link, Equals, "a/b")
+
+	c.Skip("copy not availbale in s3test")
+}
+
+func (s *PublishedStorageSuite) TestFileExists(c *C) {
+	dir := c.MkDir()
+	err := ioutil.WriteFile(filepath.Join(dir, "a"), []byte("welcome to swift!"), 0644)
+	c.Assert(err, IsNil)
+
+	err = s.storage.PutFile("a/b.txt", filepath.Join(dir, "a"))
+	c.Check(err, IsNil)
+
+	exists := s.storage.FileExists("a/b.txt")
+	c.Check(exists, Equals, true)
+
+	exists = s.storage.FileExists("a/b.invalid")
+	c.Check(exists, Equals, false)
+}