sdk/go/arvados/fs_project_test.go

   1 // Copyright (C) The Arvados Authors. All rights reserved.
   2 //
   3 // SPDX-License-Identifier: Apache-2.0
   4
   5 package arvados
   6
   7 import (
   8         "bytes"
   9         "encoding/json"
  10         "io"
  11         "os"
  12         "path/filepath"
  13
  14         "git.curoverse.com/arvados.git/sdk/go/arvadostest"
  15         check "gopkg.in/check.v1"
  16 )
  17
  18 type spiedRequest struct {
  19         method string
  20         path   string
  21         params map[string]interface{}
  22 }
  23
  24 type spyingClient struct {
  25         *Client
  26         calls []spiedRequest
  27 }
  28
  29 func (sc *spyingClient) RequestAndDecode(dst interface{}, method, path string, body io.Reader, params interface{}) error {
  30         var paramsCopy map[string]interface{}
  31         var buf bytes.Buffer
  32         json.NewEncoder(&buf).Encode(params)
  33         json.NewDecoder(&buf).Decode(&paramsCopy)
  34         sc.calls = append(sc.calls, spiedRequest{
  35                 method: method,
  36                 path:   path,
  37                 params: paramsCopy,
  38         })
  39         return sc.Client.RequestAndDecode(dst, method, path, body, params)
  40 }
  41
  42 func (s *SiteFSSuite) TestCurrentUserHome(c *check.C) {
  43         s.fs.MountProject("home", "")
  44         s.testHomeProject(c, "/home")
  45 }
  46
  47 func (s *SiteFSSuite) TestUsersDir(c *check.C) {
  48         s.testHomeProject(c, "/users/active")
  49 }
  50
  51 func (s *SiteFSSuite) testHomeProject(c *check.C, path string) {
  52         f, err := s.fs.Open(path)
  53         c.Assert(err, check.IsNil)
  54         fis, err := f.Readdir(-1)
  55         c.Check(len(fis), check.Not(check.Equals), 0)
  56
  57         ok := false
  58         for _, fi := range fis {
  59                 c.Check(fi.Name(), check.Not(check.Equals), "")
  60                 if fi.Name() == "A Project" {
  61                         ok = true
  62                 }
  63         }
  64         c.Check(ok, check.Equals, true)
  65
  66         f, err = s.fs.Open(path + "/A Project/..")
  67         c.Assert(err, check.IsNil)
  68         fi, err := f.Stat()
  69         c.Check(err, check.IsNil)
  70         c.Check(fi.IsDir(), check.Equals, true)
  71         _, basename := filepath.Split(path)
  72         c.Check(fi.Name(), check.Equals, basename)
  73
  74         f, err = s.fs.Open(path + "/A Project/A Subproject")
  75         c.Check(err, check.IsNil)
  76         fi, err = f.Stat()
  77         c.Check(err, check.IsNil)
  78         c.Check(fi.IsDir(), check.Equals, true)
  79
  80         for _, nx := range []string{
  81                 path + "/Unrestricted public data",
  82                 path + "/Unrestricted public data/does not exist",
  83                 path + "/A Project/does not exist",
  84         } {
  85                 c.Log(nx)
  86                 f, err = s.fs.Open(nx)
  87                 c.Check(err, check.NotNil)
  88                 c.Check(os.IsNotExist(err), check.Equals, true)
  89         }
  90 }
  91
  92 func (s *SiteFSSuite) TestProjectUpdatedByOther(c *check.C) {
  93         s.fs.MountProject("home", "")
  94
  95         project, err := s.fs.OpenFile("/home/A Project", 0, 0)
  96         c.Check(err, check.IsNil)
  97
  98         _, err = s.fs.Open("/home/A Project/oob")
  99         c.Check(err, check.NotNil)
 100
 101         oob := Collection{
 102                 Name:      "oob",
 103                 OwnerUUID: arvadostest.AProjectUUID,
 104         }
 105         err = s.client.RequestAndDecode(&oob, "POST", "arvados/v1/collections", s.client.UpdateBody(&oob), nil)
 106         c.Assert(err, check.IsNil)
 107         defer s.client.RequestAndDecode(nil, "DELETE", "arvados/v1/collections/"+oob.UUID, nil, nil)
 108
 109         err = project.Sync()
 110         c.Check(err, check.IsNil)
 111         f, err := s.fs.Open("/home/A Project/oob")
 112         c.Assert(err, check.IsNil)
 113         fi, err := f.Stat()
 114         c.Check(fi.IsDir(), check.Equals, true)
 115         f.Close()
 116
 117         wf, err := s.fs.OpenFile("/home/A Project/oob/test.txt", os.O_CREATE|os.O_RDWR, 0700)
 118         c.Assert(err, check.IsNil)
 119         _, err = wf.Write([]byte("hello oob\n"))
 120         c.Check(err, check.IsNil)
 121         err = wf.Close()
 122         c.Check(err, check.IsNil)
 123
 124         // Delete test.txt behind s.fs's back by updating the
 125         // collection record with the old (empty) ManifestText.
 126         err = s.client.RequestAndDecode(nil, "PATCH", "arvados/v1/collections/"+oob.UUID, s.client.UpdateBody(&oob), nil)
 127         c.Assert(err, check.IsNil)
 128
 129         err = project.Sync()
 130         c.Check(err, check.IsNil)
 131         _, err = s.fs.Open("/home/A Project/oob/test.txt")
 132         c.Check(err, check.NotNil)
 133         _, err = s.fs.Open("/home/A Project/oob")
 134         c.Check(err, check.IsNil)
 135
 136         err = s.client.RequestAndDecode(nil, "DELETE", "arvados/v1/collections/"+oob.UUID, nil, nil)
 137         c.Assert(err, check.IsNil)
 138
 139         err = project.Sync()
 140         c.Check(err, check.IsNil)
 141         _, err = s.fs.Open("/home/A Project/oob")
 142         c.Check(err, check.NotNil)
 143 }