protocol_test.go 100 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788
  1. package common_test
  2. import (
  3. "bytes"
  4. "crypto/rand"
  5. "fmt"
  6. "io"
  7. "math"
  8. "net"
  9. "net/http"
  10. "os"
  11. "path"
  12. "path/filepath"
  13. "runtime"
  14. "strings"
  15. "testing"
  16. "time"
  17. _ "github.com/go-sql-driver/mysql"
  18. _ "github.com/lib/pq"
  19. _ "github.com/mattn/go-sqlite3"
  20. "github.com/pkg/sftp"
  21. "github.com/stretchr/testify/assert"
  22. "github.com/stretchr/testify/require"
  23. "golang.org/x/crypto/ssh"
  24. "github.com/rs/zerolog"
  25. "github.com/drakkan/sftpgo/v2/common"
  26. "github.com/drakkan/sftpgo/v2/config"
  27. "github.com/drakkan/sftpgo/v2/dataprovider"
  28. "github.com/drakkan/sftpgo/v2/httpclient"
  29. "github.com/drakkan/sftpgo/v2/httpdtest"
  30. "github.com/drakkan/sftpgo/v2/kms"
  31. "github.com/drakkan/sftpgo/v2/logger"
  32. "github.com/drakkan/sftpgo/v2/sdk"
  33. "github.com/drakkan/sftpgo/v2/vfs"
  34. )
  35. const (
  36. configDir = ".."
  37. httpAddr = "127.0.0.1:9999"
  38. httpProxyAddr = "127.0.0.1:7777"
  39. sftpServerAddr = "127.0.0.1:4022"
  40. defaultUsername = "test_common_sftp"
  41. defaultPassword = "test_password"
  42. defaultSFTPUsername = "test_common_sftpfs_user"
  43. osWindows = "windows"
  44. testFileName = "test_file_common_sftp.dat"
  45. testDir = "test_dir_common"
  46. )
  47. var (
  48. allPerms = []string{dataprovider.PermAny}
  49. homeBasePath string
  50. testFileContent = []byte("test data")
  51. )
  52. func TestMain(m *testing.M) {
  53. homeBasePath = os.TempDir()
  54. logFilePath := filepath.Join(configDir, "common_test.log")
  55. logger.InitLogger(logFilePath, 5, 1, 28, false, zerolog.DebugLevel)
  56. os.Setenv("SFTPGO_DATA_PROVIDER__CREATE_DEFAULT_ADMIN", "1")
  57. os.Setenv("SFTPGO_DEFAULT_ADMIN_USERNAME", "admin")
  58. os.Setenv("SFTPGO_DEFAULT_ADMIN_PASSWORD", "password")
  59. err := config.LoadConfig(configDir, "")
  60. if err != nil {
  61. logger.ErrorToConsole("error loading configuration: %v", err)
  62. os.Exit(1)
  63. }
  64. providerConf := config.GetProviderConf()
  65. logger.InfoToConsole("Starting COMMON tests, provider: %v", providerConf.Driver)
  66. err = common.Initialize(config.GetCommonConfig())
  67. if err != nil {
  68. logger.WarnToConsole("error initializing common: %v", err)
  69. os.Exit(1)
  70. }
  71. err = dataprovider.Initialize(providerConf, configDir, true)
  72. if err != nil {
  73. logger.ErrorToConsole("error initializing data provider: %v", err)
  74. os.Exit(1)
  75. }
  76. httpConfig := config.GetHTTPConfig()
  77. httpConfig.Timeout = 5
  78. httpConfig.RetryMax = 0
  79. httpConfig.Initialize(configDir) //nolint:errcheck
  80. kmsConfig := config.GetKMSConfig()
  81. err = kmsConfig.Initialize()
  82. if err != nil {
  83. logger.ErrorToConsole("error initializing kms: %v", err)
  84. os.Exit(1)
  85. }
  86. sftpdConf := config.GetSFTPDConfig()
  87. sftpdConf.Bindings[0].Port = 4022
  88. httpdConf := config.GetHTTPDConfig()
  89. httpdConf.Bindings[0].Port = 4080
  90. httpdtest.SetBaseURL("http://127.0.0.1:4080")
  91. go func() {
  92. if err := sftpdConf.Initialize(configDir); err != nil {
  93. logger.ErrorToConsole("could not start SFTP server: %v", err)
  94. os.Exit(1)
  95. }
  96. }()
  97. go func() {
  98. if err := httpdConf.Initialize(configDir); err != nil {
  99. logger.ErrorToConsole("could not start HTTP server: %v", err)
  100. os.Exit(1)
  101. }
  102. }()
  103. go func() {
  104. // start a test HTTP server to receive action notifications
  105. http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
  106. fmt.Fprintf(w, "OK\n")
  107. })
  108. http.HandleFunc("/404", func(w http.ResponseWriter, r *http.Request) {
  109. w.WriteHeader(http.StatusNotFound)
  110. fmt.Fprintf(w, "Not found\n")
  111. })
  112. if err := http.ListenAndServe(httpAddr, nil); err != nil {
  113. logger.ErrorToConsole("could not start HTTP notification server: %v", err)
  114. os.Exit(1)
  115. }
  116. }()
  117. go func() {
  118. common.Config.ProxyProtocol = 2
  119. listener, err := net.Listen("tcp", httpProxyAddr)
  120. if err != nil {
  121. logger.ErrorToConsole("error creating listener for proxy protocol server: %v", err)
  122. os.Exit(1)
  123. }
  124. proxyListener, err := common.Config.GetProxyListener(listener)
  125. if err != nil {
  126. logger.ErrorToConsole("error creating proxy protocol listener: %v", err)
  127. os.Exit(1)
  128. }
  129. common.Config.ProxyProtocol = 0
  130. s := &http.Server{}
  131. if err := s.Serve(proxyListener); err != nil {
  132. logger.ErrorToConsole("could not start HTTP proxy protocol server: %v", err)
  133. os.Exit(1)
  134. }
  135. }()
  136. waitTCPListening(httpAddr)
  137. waitTCPListening(httpProxyAddr)
  138. waitTCPListening(sftpdConf.Bindings[0].GetAddress())
  139. waitTCPListening(httpdConf.Bindings[0].GetAddress())
  140. exitCode := m.Run()
  141. os.Remove(logFilePath)
  142. os.Exit(exitCode)
  143. }
  144. func TestBaseConnection(t *testing.T) {
  145. u := getTestUser()
  146. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  147. assert.NoError(t, err)
  148. err = os.RemoveAll(user.GetHomeDir())
  149. assert.NoError(t, err)
  150. conn, client, err := getSftpClient(user)
  151. if assert.NoError(t, err) {
  152. defer conn.Close()
  153. defer client.Close()
  154. assert.NoError(t, checkBasicSFTP(client))
  155. _, err = client.ReadDir(testDir)
  156. assert.ErrorIs(t, err, os.ErrNotExist)
  157. err = client.RemoveDirectory(testDir)
  158. assert.ErrorIs(t, err, os.ErrNotExist)
  159. err = client.Mkdir(testDir)
  160. assert.NoError(t, err)
  161. err = client.Mkdir(testDir)
  162. assert.Error(t, err)
  163. info, err := client.Stat(testDir)
  164. if assert.NoError(t, err) {
  165. assert.True(t, info.IsDir())
  166. }
  167. err = client.RemoveDirectory(testDir)
  168. assert.NoError(t, err)
  169. err = client.Remove(testFileName)
  170. assert.ErrorIs(t, err, os.ErrNotExist)
  171. f, err := client.Create(testFileName)
  172. assert.NoError(t, err)
  173. _, err = f.Write(testFileContent)
  174. assert.NoError(t, err)
  175. err = f.Close()
  176. assert.NoError(t, err)
  177. linkName := testFileName + ".link"
  178. err = client.Symlink(testFileName, linkName)
  179. assert.NoError(t, err)
  180. err = client.Symlink(testFileName, testFileName)
  181. assert.Error(t, err)
  182. info, err = client.Stat(testFileName)
  183. if assert.NoError(t, err) {
  184. assert.Equal(t, int64(len(testFileContent)), info.Size())
  185. assert.False(t, info.IsDir())
  186. }
  187. info, err = client.Lstat(linkName)
  188. if assert.NoError(t, err) {
  189. assert.NotEqual(t, int64(7), info.Size())
  190. assert.True(t, info.Mode()&os.ModeSymlink != 0)
  191. assert.False(t, info.IsDir())
  192. }
  193. err = client.RemoveDirectory(linkName)
  194. if assert.Error(t, err) {
  195. assert.Contains(t, err.Error(), "SSH_FX_FAILURE")
  196. }
  197. err = client.Remove(testFileName)
  198. assert.NoError(t, err)
  199. err = client.Remove(linkName)
  200. assert.NoError(t, err)
  201. err = client.Rename(testFileName, "test")
  202. assert.ErrorIs(t, err, os.ErrNotExist)
  203. f, err = client.Create(testFileName)
  204. assert.NoError(t, err)
  205. err = f.Close()
  206. assert.NoError(t, err)
  207. err = client.Rename(testFileName, testFileName+"1")
  208. assert.NoError(t, err)
  209. err = client.Remove(testFileName + "1")
  210. assert.NoError(t, err)
  211. err = client.RemoveDirectory("missing")
  212. assert.Error(t, err)
  213. }
  214. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  215. assert.NoError(t, err)
  216. err = os.RemoveAll(user.GetHomeDir())
  217. assert.NoError(t, err)
  218. }
  219. func TestSetStat(t *testing.T) {
  220. u := getTestUser()
  221. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  222. assert.NoError(t, err)
  223. err = os.RemoveAll(user.GetHomeDir())
  224. assert.NoError(t, err)
  225. conn, client, err := getSftpClient(user)
  226. if assert.NoError(t, err) {
  227. defer conn.Close()
  228. defer client.Close()
  229. f, err := client.Create(testFileName)
  230. assert.NoError(t, err)
  231. _, err = f.Write(testFileContent)
  232. assert.NoError(t, err)
  233. err = f.Close()
  234. assert.NoError(t, err)
  235. acmodTime := time.Now().Add(36 * time.Hour)
  236. err = client.Chtimes(testFileName, acmodTime, acmodTime)
  237. assert.NoError(t, err)
  238. newFi, err := client.Lstat(testFileName)
  239. assert.NoError(t, err)
  240. diff := math.Abs(newFi.ModTime().Sub(acmodTime).Seconds())
  241. assert.LessOrEqual(t, diff, float64(1))
  242. if runtime.GOOS != osWindows {
  243. err = client.Chown(testFileName, os.Getuid(), os.Getgid())
  244. assert.NoError(t, err)
  245. }
  246. newPerm := os.FileMode(0666)
  247. err = client.Chmod(testFileName, newPerm)
  248. assert.NoError(t, err)
  249. newFi, err = client.Lstat(testFileName)
  250. if assert.NoError(t, err) {
  251. assert.Equal(t, newPerm, newFi.Mode().Perm())
  252. }
  253. err = client.Truncate(testFileName, 2)
  254. assert.NoError(t, err)
  255. info, err := client.Stat(testFileName)
  256. if assert.NoError(t, err) {
  257. assert.Equal(t, int64(2), info.Size())
  258. }
  259. err = client.Remove(testFileName)
  260. assert.NoError(t, err)
  261. err = client.Truncate(testFileName, 0)
  262. assert.ErrorIs(t, err, os.ErrNotExist)
  263. err = client.Chtimes(testFileName, acmodTime, acmodTime)
  264. assert.ErrorIs(t, err, os.ErrNotExist)
  265. if runtime.GOOS != osWindows {
  266. err = client.Chown(testFileName, os.Getuid(), os.Getgid())
  267. assert.ErrorIs(t, err, os.ErrNotExist)
  268. }
  269. err = client.Chmod(testFileName, newPerm)
  270. assert.ErrorIs(t, err, os.ErrNotExist)
  271. }
  272. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  273. assert.NoError(t, err)
  274. err = os.RemoveAll(user.GetHomeDir())
  275. assert.NoError(t, err)
  276. }
  277. func TestPermissionErrors(t *testing.T) {
  278. user, _, err := httpdtest.AddUser(getTestUser(), http.StatusCreated)
  279. assert.NoError(t, err)
  280. u := getTestSFTPUser()
  281. subDir := "/sub"
  282. u.Permissions[subDir] = nil
  283. sftpUser, _, err := httpdtest.AddUser(u, http.StatusCreated)
  284. assert.NoError(t, err)
  285. conn, client, err := getSftpClient(user)
  286. if assert.NoError(t, err) {
  287. defer conn.Close()
  288. defer client.Close()
  289. err = client.MkdirAll(path.Join(subDir, subDir))
  290. assert.NoError(t, err)
  291. f, err := client.Create(path.Join(subDir, subDir, testFileName))
  292. if assert.NoError(t, err) {
  293. _, err = f.Write(testFileContent)
  294. assert.NoError(t, err)
  295. err = f.Close()
  296. assert.NoError(t, err)
  297. }
  298. }
  299. conn, client, err = getSftpClient(sftpUser)
  300. if assert.NoError(t, err) {
  301. defer conn.Close()
  302. defer client.Close()
  303. assert.NoError(t, checkBasicSFTP(client))
  304. _, err = client.ReadDir(subDir)
  305. assert.ErrorIs(t, err, os.ErrPermission)
  306. err = client.Mkdir(path.Join(subDir, subDir))
  307. assert.ErrorIs(t, err, os.ErrPermission)
  308. err = client.RemoveDirectory(path.Join(subDir, subDir))
  309. assert.ErrorIs(t, err, os.ErrPermission)
  310. err = client.Symlink("test", path.Join(subDir, subDir))
  311. assert.ErrorIs(t, err, os.ErrPermission)
  312. err = client.Chmod(path.Join(subDir, subDir), os.ModePerm)
  313. assert.ErrorIs(t, err, os.ErrPermission)
  314. err = client.Chown(path.Join(subDir, subDir), os.Getuid(), os.Getgid())
  315. assert.ErrorIs(t, err, os.ErrPermission)
  316. err = client.Chtimes(path.Join(subDir, subDir), time.Now(), time.Now())
  317. assert.ErrorIs(t, err, os.ErrPermission)
  318. err = client.Truncate(path.Join(subDir, subDir), 0)
  319. assert.ErrorIs(t, err, os.ErrPermission)
  320. err = client.Remove(path.Join(subDir, subDir, testFileName))
  321. assert.ErrorIs(t, err, os.ErrPermission)
  322. }
  323. _, err = httpdtest.RemoveUser(sftpUser, http.StatusOK)
  324. assert.NoError(t, err)
  325. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  326. assert.NoError(t, err)
  327. err = os.RemoveAll(user.GetHomeDir())
  328. assert.NoError(t, err)
  329. }
  330. func TestFileNotAllowedErrors(t *testing.T) {
  331. deniedDir := "/denied"
  332. u := getTestUser()
  333. u.Filters.FilePatterns = []sdk.PatternsFilter{
  334. {
  335. Path: deniedDir,
  336. DeniedPatterns: []string{"*.txt"},
  337. },
  338. }
  339. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  340. assert.NoError(t, err)
  341. conn, client, err := getSftpClient(user)
  342. if assert.NoError(t, err) {
  343. defer conn.Close()
  344. defer client.Close()
  345. testFile := filepath.Join(u.GetHomeDir(), deniedDir, "file.txt")
  346. err = os.MkdirAll(filepath.Join(u.GetHomeDir(), deniedDir), os.ModePerm)
  347. assert.NoError(t, err)
  348. err = os.WriteFile(testFile, testFileContent, os.ModePerm)
  349. assert.NoError(t, err)
  350. err = client.Remove(path.Join(deniedDir, "file.txt"))
  351. // the sftp client will try to remove the path as directory after receiving
  352. // a permission denied error, so we get a generic failure here
  353. assert.Error(t, err)
  354. err = client.Rename(path.Join(deniedDir, "file.txt"), path.Join(deniedDir, "file1.txt"))
  355. assert.ErrorIs(t, err, os.ErrPermission)
  356. }
  357. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  358. assert.NoError(t, err)
  359. err = os.RemoveAll(user.GetHomeDir())
  360. assert.NoError(t, err)
  361. }
  362. func TestTruncateQuotaLimits(t *testing.T) {
  363. u := getTestUser()
  364. u.QuotaSize = 20
  365. mappedPath1 := filepath.Join(os.TempDir(), "mapped1")
  366. folderName1 := filepath.Base(mappedPath1)
  367. vdirPath1 := "/vmapped1"
  368. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  369. BaseVirtualFolder: vfs.BaseVirtualFolder{
  370. Name: folderName1,
  371. MappedPath: mappedPath1,
  372. },
  373. VirtualPath: vdirPath1,
  374. QuotaFiles: 10,
  375. })
  376. mappedPath2 := filepath.Join(os.TempDir(), "mapped2")
  377. folderName2 := filepath.Base(mappedPath2)
  378. vdirPath2 := "/vmapped2"
  379. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  380. BaseVirtualFolder: vfs.BaseVirtualFolder{
  381. Name: folderName2,
  382. MappedPath: mappedPath2,
  383. },
  384. VirtualPath: vdirPath2,
  385. QuotaFiles: -1,
  386. QuotaSize: -1,
  387. })
  388. localUser, _, err := httpdtest.AddUser(u, http.StatusCreated)
  389. assert.NoError(t, err)
  390. u = getTestSFTPUser()
  391. u.QuotaSize = 20
  392. sftpUser, _, err := httpdtest.AddUser(u, http.StatusCreated)
  393. assert.NoError(t, err)
  394. for _, user := range []dataprovider.User{localUser, sftpUser} {
  395. conn, client, err := getSftpClient(user)
  396. if assert.NoError(t, err) {
  397. defer conn.Close()
  398. defer client.Close()
  399. f, err := client.OpenFile(testFileName, os.O_WRONLY)
  400. if assert.NoError(t, err) {
  401. n, err := f.Write(testFileContent)
  402. assert.NoError(t, err)
  403. assert.Equal(t, len(testFileContent), n)
  404. err = f.Truncate(2)
  405. assert.NoError(t, err)
  406. expectedQuotaFiles := 0
  407. expectedQuotaSize := int64(2)
  408. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  409. assert.NoError(t, err)
  410. assert.Equal(t, expectedQuotaFiles, user.UsedQuotaFiles)
  411. assert.Equal(t, expectedQuotaSize, user.UsedQuotaSize)
  412. _, err = f.Seek(expectedQuotaSize, io.SeekStart)
  413. assert.NoError(t, err)
  414. n, err = f.Write(testFileContent)
  415. assert.NoError(t, err)
  416. assert.Equal(t, len(testFileContent), n)
  417. err = f.Truncate(5)
  418. assert.NoError(t, err)
  419. expectedQuotaSize = int64(5)
  420. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  421. assert.NoError(t, err)
  422. assert.Equal(t, expectedQuotaFiles, user.UsedQuotaFiles)
  423. assert.Equal(t, expectedQuotaSize, user.UsedQuotaSize)
  424. _, err = f.Seek(expectedQuotaSize, io.SeekStart)
  425. assert.NoError(t, err)
  426. n, err = f.Write(testFileContent)
  427. assert.NoError(t, err)
  428. assert.Equal(t, len(testFileContent), n)
  429. err = f.Close()
  430. assert.NoError(t, err)
  431. expectedQuotaFiles = 1
  432. expectedQuotaSize = int64(5) + int64(len(testFileContent))
  433. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  434. assert.NoError(t, err)
  435. assert.Equal(t, expectedQuotaFiles, user.UsedQuotaFiles)
  436. assert.Equal(t, expectedQuotaSize, user.UsedQuotaSize)
  437. }
  438. // now truncate by path
  439. err = client.Truncate(testFileName, 5)
  440. assert.NoError(t, err)
  441. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  442. assert.NoError(t, err)
  443. assert.Equal(t, 1, user.UsedQuotaFiles)
  444. assert.Equal(t, int64(5), user.UsedQuotaSize)
  445. // now open an existing file without truncate it, quota should not change
  446. f, err = client.OpenFile(testFileName, os.O_WRONLY)
  447. if assert.NoError(t, err) {
  448. err = f.Close()
  449. assert.NoError(t, err)
  450. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  451. assert.NoError(t, err)
  452. assert.Equal(t, 1, user.UsedQuotaFiles)
  453. assert.Equal(t, int64(5), user.UsedQuotaSize)
  454. }
  455. // open the file truncating it
  456. f, err = client.OpenFile(testFileName, os.O_WRONLY|os.O_TRUNC)
  457. if assert.NoError(t, err) {
  458. err = f.Close()
  459. assert.NoError(t, err)
  460. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  461. assert.NoError(t, err)
  462. assert.Equal(t, 1, user.UsedQuotaFiles)
  463. assert.Equal(t, int64(0), user.UsedQuotaSize)
  464. }
  465. // now test max write size
  466. f, err = client.OpenFile(testFileName, os.O_WRONLY)
  467. if assert.NoError(t, err) {
  468. n, err := f.Write(testFileContent)
  469. assert.NoError(t, err)
  470. assert.Equal(t, len(testFileContent), n)
  471. err = f.Truncate(11)
  472. assert.NoError(t, err)
  473. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  474. assert.NoError(t, err)
  475. assert.Equal(t, 1, user.UsedQuotaFiles)
  476. assert.Equal(t, int64(11), user.UsedQuotaSize)
  477. _, err = f.Seek(int64(11), io.SeekStart)
  478. assert.NoError(t, err)
  479. n, err = f.Write(testFileContent)
  480. assert.NoError(t, err)
  481. assert.Equal(t, len(testFileContent), n)
  482. err = f.Truncate(5)
  483. assert.NoError(t, err)
  484. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  485. assert.NoError(t, err)
  486. assert.Equal(t, 1, user.UsedQuotaFiles)
  487. assert.Equal(t, int64(5), user.UsedQuotaSize)
  488. _, err = f.Seek(int64(5), io.SeekStart)
  489. assert.NoError(t, err)
  490. n, err = f.Write(testFileContent)
  491. assert.NoError(t, err)
  492. assert.Equal(t, len(testFileContent), n)
  493. err = f.Truncate(12)
  494. assert.NoError(t, err)
  495. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  496. assert.NoError(t, err)
  497. assert.Equal(t, 1, user.UsedQuotaFiles)
  498. assert.Equal(t, int64(12), user.UsedQuotaSize)
  499. _, err = f.Seek(int64(12), io.SeekStart)
  500. assert.NoError(t, err)
  501. _, err = f.Write(testFileContent)
  502. if assert.Error(t, err) {
  503. assert.Contains(t, err.Error(), common.ErrQuotaExceeded.Error())
  504. }
  505. err = f.Close()
  506. assert.Error(t, err)
  507. // the file is deleted
  508. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  509. assert.NoError(t, err)
  510. assert.Equal(t, 0, user.UsedQuotaFiles)
  511. assert.Equal(t, int64(0), user.UsedQuotaSize)
  512. }
  513. if user.Username == defaultUsername {
  514. // basic test inside a virtual folder
  515. vfileName1 := path.Join(vdirPath1, testFileName)
  516. f, err = client.OpenFile(vfileName1, os.O_WRONLY)
  517. if assert.NoError(t, err) {
  518. n, err := f.Write(testFileContent)
  519. assert.NoError(t, err)
  520. assert.Equal(t, len(testFileContent), n)
  521. err = f.Truncate(2)
  522. assert.NoError(t, err)
  523. expectedQuotaFiles := 0
  524. expectedQuotaSize := int64(2)
  525. fold, _, err := httpdtest.GetFolderByName(folderName1, http.StatusOK)
  526. assert.NoError(t, err)
  527. assert.Equal(t, expectedQuotaSize, fold.UsedQuotaSize)
  528. assert.Equal(t, expectedQuotaFiles, fold.UsedQuotaFiles)
  529. err = f.Close()
  530. assert.NoError(t, err)
  531. expectedQuotaFiles = 1
  532. fold, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  533. assert.NoError(t, err)
  534. assert.Equal(t, expectedQuotaSize, fold.UsedQuotaSize)
  535. assert.Equal(t, expectedQuotaFiles, fold.UsedQuotaFiles)
  536. }
  537. err = client.Truncate(vfileName1, 1)
  538. assert.NoError(t, err)
  539. fold, _, err := httpdtest.GetFolderByName(folderName1, http.StatusOK)
  540. assert.NoError(t, err)
  541. assert.Equal(t, int64(1), fold.UsedQuotaSize)
  542. assert.Equal(t, 1, fold.UsedQuotaFiles)
  543. // now test on vdirPath2, the folder quota is included in the user's quota
  544. vfileName2 := path.Join(vdirPath2, testFileName)
  545. f, err = client.OpenFile(vfileName2, os.O_WRONLY)
  546. if assert.NoError(t, err) {
  547. n, err := f.Write(testFileContent)
  548. assert.NoError(t, err)
  549. assert.Equal(t, len(testFileContent), n)
  550. err = f.Truncate(3)
  551. assert.NoError(t, err)
  552. expectedQuotaFiles := 0
  553. expectedQuotaSize := int64(3)
  554. fold, _, err := httpdtest.GetFolderByName(folderName2, http.StatusOK)
  555. assert.NoError(t, err)
  556. assert.Equal(t, expectedQuotaSize, fold.UsedQuotaSize)
  557. assert.Equal(t, expectedQuotaFiles, fold.UsedQuotaFiles)
  558. err = f.Close()
  559. assert.NoError(t, err)
  560. expectedQuotaFiles = 1
  561. fold, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  562. assert.NoError(t, err)
  563. assert.Equal(t, expectedQuotaSize, fold.UsedQuotaSize)
  564. assert.Equal(t, expectedQuotaFiles, fold.UsedQuotaFiles)
  565. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  566. assert.NoError(t, err)
  567. assert.Equal(t, expectedQuotaFiles, user.UsedQuotaFiles)
  568. assert.Equal(t, expectedQuotaSize, user.UsedQuotaSize)
  569. }
  570. // cleanup
  571. err = os.RemoveAll(user.GetHomeDir())
  572. assert.NoError(t, err)
  573. user.UsedQuotaFiles = 0
  574. user.UsedQuotaSize = 0
  575. _, err = httpdtest.UpdateQuotaUsage(user, "reset", http.StatusOK)
  576. assert.NoError(t, err)
  577. user.QuotaSize = 0
  578. _, _, err = httpdtest.UpdateUser(user, http.StatusOK, "")
  579. assert.NoError(t, err)
  580. }
  581. }
  582. }
  583. _, err = httpdtest.RemoveUser(sftpUser, http.StatusOK)
  584. assert.NoError(t, err)
  585. _, err = httpdtest.RemoveUser(localUser, http.StatusOK)
  586. assert.NoError(t, err)
  587. err = os.RemoveAll(localUser.GetHomeDir())
  588. assert.NoError(t, err)
  589. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName1}, http.StatusOK)
  590. assert.NoError(t, err)
  591. err = os.RemoveAll(mappedPath1)
  592. assert.NoError(t, err)
  593. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName2}, http.StatusOK)
  594. assert.NoError(t, err)
  595. err = os.RemoveAll(mappedPath2)
  596. assert.NoError(t, err)
  597. }
  598. func TestVirtualFoldersQuotaRenameOverwrite(t *testing.T) {
  599. testFileSize := int64(131072)
  600. testFileSize1 := int64(65537)
  601. testFileName1 := "test_file1.dat" //nolint:goconst
  602. u := getTestUser()
  603. u.QuotaFiles = 0
  604. u.QuotaSize = 0
  605. mappedPath1 := filepath.Join(os.TempDir(), "vdir1")
  606. folderName1 := filepath.Base(mappedPath1)
  607. vdirPath1 := "/vdir1" //nolint:goconst
  608. mappedPath2 := filepath.Join(os.TempDir(), "vdir2")
  609. folderName2 := filepath.Base(mappedPath2)
  610. vdirPath2 := "/vdir2" //nolint:goconst
  611. mappedPath3 := filepath.Join(os.TempDir(), "vdir3")
  612. folderName3 := filepath.Base(mappedPath3)
  613. vdirPath3 := "/vdir3"
  614. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  615. BaseVirtualFolder: vfs.BaseVirtualFolder{
  616. Name: folderName1,
  617. MappedPath: mappedPath1,
  618. },
  619. VirtualPath: vdirPath1,
  620. QuotaFiles: 2,
  621. QuotaSize: 0,
  622. })
  623. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  624. BaseVirtualFolder: vfs.BaseVirtualFolder{
  625. MappedPath: mappedPath2,
  626. Name: folderName2,
  627. },
  628. VirtualPath: vdirPath2,
  629. QuotaFiles: 0,
  630. QuotaSize: testFileSize + testFileSize1 + 1,
  631. })
  632. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  633. BaseVirtualFolder: vfs.BaseVirtualFolder{
  634. Name: folderName3,
  635. MappedPath: mappedPath3,
  636. },
  637. VirtualPath: vdirPath3,
  638. QuotaFiles: 2,
  639. QuotaSize: testFileSize * 2,
  640. })
  641. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  642. assert.NoError(t, err)
  643. conn, client, err := getSftpClient(user)
  644. if assert.NoError(t, err) {
  645. defer conn.Close()
  646. defer client.Close()
  647. err = writeSFTPFile(path.Join(vdirPath1, testFileName), testFileSize, client)
  648. assert.NoError(t, err)
  649. err = writeSFTPFile(path.Join(vdirPath2, testFileName), testFileSize, client)
  650. assert.NoError(t, err)
  651. err = writeSFTPFile(path.Join(vdirPath1, testFileName1), testFileSize1, client)
  652. assert.NoError(t, err)
  653. err = writeSFTPFile(path.Join(vdirPath2, testFileName1), testFileSize1, client)
  654. assert.NoError(t, err)
  655. err = writeSFTPFile(testFileName, testFileSize, client)
  656. assert.NoError(t, err)
  657. err = writeSFTPFile(testFileName1, testFileSize1, client)
  658. assert.NoError(t, err)
  659. err = writeSFTPFile(path.Join(vdirPath3, testFileName), testFileSize, client)
  660. assert.NoError(t, err)
  661. err = writeSFTPFile(path.Join(vdirPath3, testFileName+"1"), testFileSize, client)
  662. assert.NoError(t, err)
  663. err = client.Rename(testFileName, path.Join(vdirPath1, testFileName+".rename"))
  664. assert.Error(t, err)
  665. // we overwrite an existing file and we have unlimited size
  666. err = client.Rename(testFileName, path.Join(vdirPath1, testFileName))
  667. assert.NoError(t, err)
  668. // we have no space and we try to overwrite a bigger file with a smaller one, this should succeed
  669. err = client.Rename(testFileName1, path.Join(vdirPath2, testFileName))
  670. assert.NoError(t, err)
  671. err = writeSFTPFile(path.Join(vdirPath2, testFileName), testFileSize, client)
  672. assert.NoError(t, err)
  673. err = writeSFTPFile(testFileName, testFileSize, client)
  674. assert.NoError(t, err)
  675. // we have no space and we try to overwrite a smaller file with a bigger one, this should fail
  676. err = client.Rename(testFileName, path.Join(vdirPath2, testFileName1))
  677. assert.Error(t, err)
  678. fi, err := client.Stat(path.Join(vdirPath1, testFileName1))
  679. if assert.NoError(t, err) {
  680. assert.Equal(t, testFileSize1, fi.Size())
  681. }
  682. // we are overquota inside vdir3 size 2/2 and size 262144/262144
  683. err = client.Rename(path.Join(vdirPath1, testFileName1), path.Join(vdirPath3, testFileName1+".rename"))
  684. assert.Error(t, err)
  685. // we overwrite an existing file and we have enough size
  686. err = client.Rename(path.Join(vdirPath1, testFileName1), path.Join(vdirPath3, testFileName))
  687. assert.NoError(t, err)
  688. testFileName2 := "test_file2.dat"
  689. err = writeSFTPFile(testFileName2, testFileSize+testFileSize1, client)
  690. assert.NoError(t, err)
  691. // we overwrite an existing file and we haven't enough size
  692. err = client.Rename(testFileName2, path.Join(vdirPath3, testFileName))
  693. assert.Error(t, err)
  694. // now remove a file from vdir3, create a dir with 2 files and try to rename it in vdir3
  695. // this will fail since the rename will result in 3 files inside vdir3 and quota limits only
  696. // allow 2 total files there
  697. err = client.Remove(path.Join(vdirPath3, testFileName+"1"))
  698. assert.NoError(t, err)
  699. aDir := "a dir"
  700. err = client.Mkdir(aDir)
  701. assert.NoError(t, err)
  702. err = writeSFTPFile(path.Join(aDir, testFileName1), testFileSize1, client)
  703. assert.NoError(t, err)
  704. err = writeSFTPFile(path.Join(aDir, testFileName1+"1"), testFileSize1, client)
  705. assert.NoError(t, err)
  706. err = client.Rename(aDir, path.Join(vdirPath3, aDir))
  707. assert.Error(t, err)
  708. }
  709. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  710. assert.NoError(t, err)
  711. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName1}, http.StatusOK)
  712. assert.NoError(t, err)
  713. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName2}, http.StatusOK)
  714. assert.NoError(t, err)
  715. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName3}, http.StatusOK)
  716. assert.NoError(t, err)
  717. err = os.RemoveAll(user.GetHomeDir())
  718. assert.NoError(t, err)
  719. err = os.RemoveAll(mappedPath1)
  720. assert.NoError(t, err)
  721. err = os.RemoveAll(mappedPath2)
  722. assert.NoError(t, err)
  723. err = os.RemoveAll(mappedPath3)
  724. assert.NoError(t, err)
  725. }
  726. func TestQuotaRenameOverwrite(t *testing.T) {
  727. u := getTestUser()
  728. u.QuotaFiles = 100
  729. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  730. assert.NoError(t, err)
  731. conn, client, err := getSftpClient(user)
  732. if assert.NoError(t, err) {
  733. defer conn.Close()
  734. defer client.Close()
  735. testFileSize := int64(131072)
  736. testFileSize1 := int64(65537)
  737. testFileName1 := "test_file1.dat"
  738. err = writeSFTPFile(testFileName, testFileSize, client)
  739. assert.NoError(t, err)
  740. err = writeSFTPFile(testFileName1, testFileSize1, client)
  741. assert.NoError(t, err)
  742. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  743. assert.NoError(t, err)
  744. assert.Equal(t, 2, user.UsedQuotaFiles)
  745. assert.Equal(t, testFileSize+testFileSize1, user.UsedQuotaSize)
  746. err = client.Rename(testFileName, testFileName1)
  747. assert.NoError(t, err)
  748. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  749. assert.NoError(t, err)
  750. assert.Equal(t, 1, user.UsedQuotaFiles)
  751. assert.Equal(t, testFileSize, user.UsedQuotaSize)
  752. err = client.Remove(testFileName1)
  753. assert.NoError(t, err)
  754. err = writeSFTPFile(testFileName, testFileSize, client)
  755. assert.NoError(t, err)
  756. err = writeSFTPFile(testFileName1, testFileSize1, client)
  757. assert.NoError(t, err)
  758. err = client.Rename(testFileName1, testFileName)
  759. assert.NoError(t, err)
  760. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  761. assert.NoError(t, err)
  762. assert.Equal(t, 1, user.UsedQuotaFiles)
  763. assert.Equal(t, testFileSize1, user.UsedQuotaSize)
  764. }
  765. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  766. assert.NoError(t, err)
  767. err = os.RemoveAll(user.GetHomeDir())
  768. assert.NoError(t, err)
  769. }
  770. func TestVirtualFoldersQuotaValues(t *testing.T) {
  771. u := getTestUser()
  772. u.QuotaFiles = 100
  773. mappedPath1 := filepath.Join(os.TempDir(), "vdir1")
  774. vdirPath1 := "/vdir1"
  775. folderName1 := filepath.Base(mappedPath1)
  776. mappedPath2 := filepath.Join(os.TempDir(), "vdir2")
  777. vdirPath2 := "/vdir2"
  778. folderName2 := filepath.Base(mappedPath2)
  779. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  780. BaseVirtualFolder: vfs.BaseVirtualFolder{
  781. Name: folderName1,
  782. MappedPath: mappedPath1,
  783. },
  784. VirtualPath: vdirPath1,
  785. // quota is included in the user's one
  786. QuotaFiles: -1,
  787. QuotaSize: -1,
  788. })
  789. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  790. BaseVirtualFolder: vfs.BaseVirtualFolder{
  791. Name: folderName2,
  792. MappedPath: mappedPath2,
  793. },
  794. VirtualPath: vdirPath2,
  795. // quota is unlimited and excluded from user's one
  796. QuotaFiles: 0,
  797. QuotaSize: 0,
  798. })
  799. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  800. assert.NoError(t, err)
  801. conn, client, err := getSftpClient(user)
  802. if assert.NoError(t, err) {
  803. defer conn.Close()
  804. defer client.Close()
  805. testFileSize := int64(131072)
  806. err = writeSFTPFile(testFileName, testFileSize, client)
  807. assert.NoError(t, err)
  808. // we copy the same file two times to test quota update on file overwrite
  809. err = writeSFTPFile(path.Join(vdirPath1, testFileName), testFileSize, client)
  810. assert.NoError(t, err)
  811. err = writeSFTPFile(path.Join(vdirPath1, testFileName), testFileSize, client)
  812. assert.NoError(t, err)
  813. err = writeSFTPFile(path.Join(vdirPath2, testFileName), testFileSize, client)
  814. assert.NoError(t, err)
  815. err = writeSFTPFile(path.Join(vdirPath2, testFileName), testFileSize, client)
  816. assert.NoError(t, err)
  817. expectedQuotaFiles := 2
  818. expectedQuotaSize := testFileSize * 2
  819. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  820. assert.NoError(t, err)
  821. assert.Equal(t, expectedQuotaFiles, user.UsedQuotaFiles)
  822. assert.Equal(t, expectedQuotaSize, user.UsedQuotaSize)
  823. f, _, err := httpdtest.GetFolderByName(folderName1, http.StatusOK)
  824. assert.NoError(t, err)
  825. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  826. assert.Equal(t, 1, f.UsedQuotaFiles)
  827. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  828. assert.NoError(t, err)
  829. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  830. assert.Equal(t, 1, f.UsedQuotaFiles)
  831. err = client.Remove(path.Join(vdirPath1, testFileName))
  832. assert.NoError(t, err)
  833. err = client.Remove(path.Join(vdirPath2, testFileName))
  834. assert.NoError(t, err)
  835. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  836. assert.NoError(t, err)
  837. assert.Equal(t, int64(0), f.UsedQuotaSize)
  838. assert.Equal(t, 0, f.UsedQuotaFiles)
  839. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  840. assert.NoError(t, err)
  841. assert.Equal(t, int64(0), f.UsedQuotaSize)
  842. assert.Equal(t, 0, f.UsedQuotaFiles)
  843. }
  844. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  845. assert.NoError(t, err)
  846. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName1}, http.StatusOK)
  847. assert.NoError(t, err)
  848. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName2}, http.StatusOK)
  849. assert.NoError(t, err)
  850. err = os.RemoveAll(user.GetHomeDir())
  851. assert.NoError(t, err)
  852. err = os.RemoveAll(mappedPath1)
  853. assert.NoError(t, err)
  854. err = os.RemoveAll(mappedPath2)
  855. assert.NoError(t, err)
  856. }
  857. func TestQuotaRenameInsideSameVirtualFolder(t *testing.T) {
  858. u := getTestUser()
  859. u.QuotaFiles = 100
  860. mappedPath1 := filepath.Join(os.TempDir(), "vdir1")
  861. vdirPath1 := "/vdir1"
  862. folderName1 := filepath.Base(mappedPath1)
  863. mappedPath2 := filepath.Join(os.TempDir(), "vdir2")
  864. vdirPath2 := "/vdir2"
  865. folderName2 := filepath.Base(mappedPath2)
  866. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  867. BaseVirtualFolder: vfs.BaseVirtualFolder{
  868. Name: folderName1,
  869. MappedPath: mappedPath1,
  870. },
  871. VirtualPath: vdirPath1,
  872. // quota is included in the user's one
  873. QuotaFiles: -1,
  874. QuotaSize: -1,
  875. })
  876. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  877. BaseVirtualFolder: vfs.BaseVirtualFolder{
  878. Name: folderName2,
  879. MappedPath: mappedPath2,
  880. },
  881. VirtualPath: vdirPath2,
  882. // quota is unlimited and excluded from user's one
  883. QuotaFiles: 0,
  884. QuotaSize: 0,
  885. })
  886. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  887. assert.NoError(t, err)
  888. conn, client, err := getSftpClient(user)
  889. if assert.NoError(t, err) {
  890. defer conn.Close()
  891. defer client.Close()
  892. testFileName1 := "test_file1.dat"
  893. testFileSize := int64(131072)
  894. testFileSize1 := int64(65535)
  895. dir1 := "dir1" //nolint:goconst
  896. dir2 := "dir2" //nolint:goconst
  897. assert.NoError(t, err)
  898. err = client.Mkdir(path.Join(vdirPath1, dir1))
  899. assert.NoError(t, err)
  900. err = client.Mkdir(path.Join(vdirPath1, dir2))
  901. assert.NoError(t, err)
  902. err = client.Mkdir(path.Join(vdirPath2, dir1))
  903. assert.NoError(t, err)
  904. err = client.Mkdir(path.Join(vdirPath2, dir2))
  905. assert.NoError(t, err)
  906. err = writeSFTPFile(path.Join(vdirPath1, dir1, testFileName), testFileSize, client)
  907. assert.NoError(t, err)
  908. err = writeSFTPFile(path.Join(vdirPath1, dir2, testFileName1), testFileSize1, client)
  909. assert.NoError(t, err)
  910. err = writeSFTPFile(path.Join(vdirPath2, dir1, testFileName), testFileSize, client)
  911. assert.NoError(t, err)
  912. err = writeSFTPFile(path.Join(vdirPath2, dir2, testFileName1), testFileSize1, client)
  913. assert.NoError(t, err)
  914. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  915. assert.NoError(t, err)
  916. assert.Equal(t, 2, user.UsedQuotaFiles)
  917. assert.Equal(t, testFileSize+testFileSize1, user.UsedQuotaSize)
  918. f, _, err := httpdtest.GetFolderByName(folderName1, http.StatusOK)
  919. assert.NoError(t, err)
  920. assert.Equal(t, testFileSize+testFileSize1, f.UsedQuotaSize)
  921. assert.Equal(t, 2, f.UsedQuotaFiles)
  922. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  923. assert.NoError(t, err)
  924. assert.Equal(t, testFileSize+testFileSize1, f.UsedQuotaSize)
  925. assert.Equal(t, 2, f.UsedQuotaFiles)
  926. // initial files:
  927. // - vdir1/dir1/testFileName
  928. // - vdir1/dir2/testFileName1
  929. // - vdir2/dir1/testFileName
  930. // - vdir2/dir2/testFileName1
  931. //
  932. // rename a file inside vdir1 it is included inside user quota, so we have:
  933. // - vdir1/dir1/testFileName.rename
  934. // - vdir1/dir2/testFileName1
  935. // - vdir2/dir1/testFileName
  936. // - vdir2/dir2/testFileName1
  937. err = client.Rename(path.Join(vdirPath1, dir1, testFileName), path.Join(vdirPath1, dir1, testFileName+".rename"))
  938. assert.NoError(t, err)
  939. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  940. assert.NoError(t, err)
  941. assert.Equal(t, 2, user.UsedQuotaFiles)
  942. assert.Equal(t, testFileSize+testFileSize1, user.UsedQuotaSize)
  943. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  944. assert.NoError(t, err)
  945. assert.Equal(t, testFileSize+testFileSize1, f.UsedQuotaSize)
  946. assert.Equal(t, 2, f.UsedQuotaFiles)
  947. // rename a file inside vdir2, it isn't included inside user quota, so we have:
  948. // - vdir1/dir1/testFileName.rename
  949. // - vdir1/dir2/testFileName1
  950. // - vdir2/dir1/testFileName.rename
  951. // - vdir2/dir2/testFileName1
  952. err = client.Rename(path.Join(vdirPath2, dir1, testFileName), path.Join(vdirPath2, dir1, testFileName+".rename"))
  953. assert.NoError(t, err)
  954. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  955. assert.NoError(t, err)
  956. assert.Equal(t, 2, user.UsedQuotaFiles)
  957. assert.Equal(t, testFileSize+testFileSize1, user.UsedQuotaSize)
  958. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  959. assert.NoError(t, err)
  960. assert.Equal(t, testFileSize+testFileSize1, f.UsedQuotaSize)
  961. assert.Equal(t, 2, f.UsedQuotaFiles)
  962. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  963. assert.NoError(t, err)
  964. assert.Equal(t, testFileSize+testFileSize1, f.UsedQuotaSize)
  965. assert.Equal(t, 2, f.UsedQuotaFiles)
  966. // rename a file inside vdir2 overwriting an existing, we now have:
  967. // - vdir1/dir1/testFileName.rename
  968. // - vdir1/dir2/testFileName1
  969. // - vdir2/dir1/testFileName.rename (initial testFileName1)
  970. err = client.Rename(path.Join(vdirPath2, dir2, testFileName1), path.Join(vdirPath2, dir1, testFileName+".rename"))
  971. assert.NoError(t, err)
  972. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  973. assert.NoError(t, err)
  974. assert.Equal(t, 2, user.UsedQuotaFiles)
  975. assert.Equal(t, testFileSize+testFileSize1, user.UsedQuotaSize)
  976. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  977. assert.NoError(t, err)
  978. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  979. assert.Equal(t, 1, f.UsedQuotaFiles)
  980. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  981. assert.NoError(t, err)
  982. assert.Equal(t, testFileSize+testFileSize1, f.UsedQuotaSize)
  983. assert.Equal(t, 2, f.UsedQuotaFiles)
  984. // rename a file inside vdir1 overwriting an existing, we now have:
  985. // - vdir1/dir1/testFileName.rename (initial testFileName1)
  986. // - vdir2/dir1/testFileName.rename (initial testFileName1)
  987. err = client.Rename(path.Join(vdirPath1, dir2, testFileName1), path.Join(vdirPath1, dir1, testFileName+".rename"))
  988. assert.NoError(t, err)
  989. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  990. assert.NoError(t, err)
  991. assert.Equal(t, 1, user.UsedQuotaFiles)
  992. assert.Equal(t, testFileSize1, user.UsedQuotaSize)
  993. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  994. assert.NoError(t, err)
  995. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  996. assert.Equal(t, 1, f.UsedQuotaFiles)
  997. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  998. assert.NoError(t, err)
  999. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  1000. assert.Equal(t, 1, f.UsedQuotaFiles)
  1001. // rename a directory inside the same virtual folder, quota should not change
  1002. err = client.RemoveDirectory(path.Join(vdirPath1, dir2))
  1003. assert.NoError(t, err)
  1004. err = client.RemoveDirectory(path.Join(vdirPath2, dir2))
  1005. assert.NoError(t, err)
  1006. err = client.Rename(path.Join(vdirPath1, dir1), path.Join(vdirPath1, dir2))
  1007. assert.NoError(t, err)
  1008. err = client.Rename(path.Join(vdirPath2, dir1), path.Join(vdirPath2, dir2))
  1009. assert.NoError(t, err)
  1010. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1011. assert.NoError(t, err)
  1012. assert.Equal(t, 1, user.UsedQuotaFiles)
  1013. assert.Equal(t, testFileSize1, user.UsedQuotaSize)
  1014. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1015. assert.NoError(t, err)
  1016. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  1017. assert.Equal(t, 1, f.UsedQuotaFiles)
  1018. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1019. assert.NoError(t, err)
  1020. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  1021. assert.Equal(t, 1, f.UsedQuotaFiles)
  1022. }
  1023. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  1024. assert.NoError(t, err)
  1025. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName1}, http.StatusOK)
  1026. assert.NoError(t, err)
  1027. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName2}, http.StatusOK)
  1028. assert.NoError(t, err)
  1029. err = os.RemoveAll(user.GetHomeDir())
  1030. assert.NoError(t, err)
  1031. err = os.RemoveAll(mappedPath1)
  1032. assert.NoError(t, err)
  1033. err = os.RemoveAll(mappedPath2)
  1034. assert.NoError(t, err)
  1035. }
  1036. func TestQuotaRenameBetweenVirtualFolder(t *testing.T) {
  1037. u := getTestUser()
  1038. u.QuotaFiles = 100
  1039. mappedPath1 := filepath.Join(os.TempDir(), "vdir1")
  1040. folderName1 := filepath.Base(mappedPath1)
  1041. vdirPath1 := "/vdir1"
  1042. mappedPath2 := filepath.Join(os.TempDir(), "vdir2")
  1043. folderName2 := filepath.Base(mappedPath2)
  1044. vdirPath2 := "/vdir2"
  1045. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  1046. BaseVirtualFolder: vfs.BaseVirtualFolder{
  1047. Name: folderName1,
  1048. MappedPath: mappedPath1,
  1049. },
  1050. VirtualPath: vdirPath1,
  1051. // quota is included in the user's one
  1052. QuotaFiles: -1,
  1053. QuotaSize: -1,
  1054. })
  1055. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  1056. BaseVirtualFolder: vfs.BaseVirtualFolder{
  1057. Name: folderName2,
  1058. MappedPath: mappedPath2,
  1059. },
  1060. VirtualPath: vdirPath2,
  1061. // quota is unlimited and excluded from user's one
  1062. QuotaFiles: 0,
  1063. QuotaSize: 0,
  1064. })
  1065. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  1066. assert.NoError(t, err)
  1067. conn, client, err := getSftpClient(user)
  1068. if assert.NoError(t, err) {
  1069. defer conn.Close()
  1070. defer client.Close()
  1071. testFileName1 := "test_file1.dat"
  1072. testFileSize := int64(131072)
  1073. testFileSize1 := int64(65535)
  1074. dir1 := "dir1"
  1075. dir2 := "dir2"
  1076. err = client.Mkdir(path.Join(vdirPath1, dir1))
  1077. assert.NoError(t, err)
  1078. err = client.Mkdir(path.Join(vdirPath1, dir2))
  1079. assert.NoError(t, err)
  1080. err = client.Mkdir(path.Join(vdirPath2, dir1))
  1081. assert.NoError(t, err)
  1082. err = client.Mkdir(path.Join(vdirPath2, dir2))
  1083. assert.NoError(t, err)
  1084. err = writeSFTPFile(path.Join(vdirPath1, dir1, testFileName), testFileSize, client)
  1085. assert.NoError(t, err)
  1086. err = writeSFTPFile(path.Join(vdirPath1, dir2, testFileName1), testFileSize1, client)
  1087. assert.NoError(t, err)
  1088. err = writeSFTPFile(path.Join(vdirPath2, dir1, testFileName), testFileSize, client)
  1089. assert.NoError(t, err)
  1090. err = writeSFTPFile(path.Join(vdirPath2, dir2, testFileName1), testFileSize1, client)
  1091. assert.NoError(t, err)
  1092. // initial files:
  1093. // - vdir1/dir1/testFileName
  1094. // - vdir1/dir2/testFileName1
  1095. // - vdir2/dir1/testFileName
  1096. // - vdir2/dir2/testFileName1
  1097. //
  1098. // rename a file from vdir1 to vdir2, vdir1 is included inside user quota, so we have:
  1099. // - vdir1/dir1/testFileName
  1100. // - vdir2/dir1/testFileName
  1101. // - vdir2/dir2/testFileName1
  1102. // - vdir2/dir1/testFileName1.rename
  1103. err = client.Rename(path.Join(vdirPath1, dir2, testFileName1), path.Join(vdirPath2, dir1, testFileName1+".rename"))
  1104. assert.NoError(t, err)
  1105. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1106. assert.NoError(t, err)
  1107. assert.Equal(t, 1, user.UsedQuotaFiles)
  1108. assert.Equal(t, testFileSize, user.UsedQuotaSize)
  1109. f, _, err := httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1110. assert.NoError(t, err)
  1111. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  1112. assert.Equal(t, 1, f.UsedQuotaFiles)
  1113. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1114. assert.NoError(t, err)
  1115. assert.Equal(t, testFileSize+testFileSize1+testFileSize1, f.UsedQuotaSize)
  1116. assert.Equal(t, 3, f.UsedQuotaFiles)
  1117. // rename a file from vdir2 to vdir1, vdir2 is not included inside user quota, so we have:
  1118. // - vdir1/dir1/testFileName
  1119. // - vdir1/dir2/testFileName.rename
  1120. // - vdir2/dir2/testFileName1
  1121. // - vdir2/dir1/testFileName1.rename
  1122. err = client.Rename(path.Join(vdirPath2, dir1, testFileName), path.Join(vdirPath1, dir2, testFileName+".rename"))
  1123. assert.NoError(t, err)
  1124. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1125. assert.NoError(t, err)
  1126. assert.Equal(t, 2, user.UsedQuotaFiles)
  1127. assert.Equal(t, testFileSize*2, user.UsedQuotaSize)
  1128. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1129. assert.NoError(t, err)
  1130. assert.Equal(t, testFileSize*2, f.UsedQuotaSize)
  1131. assert.Equal(t, 2, f.UsedQuotaFiles)
  1132. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1133. assert.NoError(t, err)
  1134. assert.Equal(t, testFileSize1*2, f.UsedQuotaSize)
  1135. assert.Equal(t, 2, f.UsedQuotaFiles)
  1136. // rename a file from vdir1 to vdir2 overwriting an existing file, vdir1 is included inside user quota, so we have:
  1137. // - vdir1/dir2/testFileName.rename
  1138. // - vdir2/dir2/testFileName1 (is the initial testFileName)
  1139. // - vdir2/dir1/testFileName1.rename
  1140. err = client.Rename(path.Join(vdirPath1, dir1, testFileName), path.Join(vdirPath2, dir2, testFileName1))
  1141. assert.NoError(t, err)
  1142. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1143. assert.NoError(t, err)
  1144. assert.Equal(t, 1, user.UsedQuotaFiles)
  1145. assert.Equal(t, testFileSize, user.UsedQuotaSize)
  1146. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1147. assert.NoError(t, err)
  1148. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  1149. assert.Equal(t, 1, f.UsedQuotaFiles)
  1150. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1151. assert.NoError(t, err)
  1152. assert.Equal(t, testFileSize1+testFileSize, f.UsedQuotaSize)
  1153. assert.Equal(t, 2, f.UsedQuotaFiles)
  1154. // rename a file from vdir2 to vdir1 overwriting an existing file, vdir2 is not included inside user quota, so we have:
  1155. // - vdir1/dir2/testFileName.rename (is the initial testFileName1)
  1156. // - vdir2/dir2/testFileName1 (is the initial testFileName)
  1157. err = client.Rename(path.Join(vdirPath2, dir1, testFileName1+".rename"), path.Join(vdirPath1, dir2, testFileName+".rename"))
  1158. assert.NoError(t, err)
  1159. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1160. assert.NoError(t, err)
  1161. assert.Equal(t, 1, user.UsedQuotaFiles)
  1162. assert.Equal(t, testFileSize1, user.UsedQuotaSize)
  1163. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1164. assert.NoError(t, err)
  1165. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  1166. assert.Equal(t, 1, f.UsedQuotaFiles)
  1167. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1168. assert.NoError(t, err)
  1169. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  1170. assert.Equal(t, 1, f.UsedQuotaFiles)
  1171. err = writeSFTPFile(path.Join(vdirPath1, dir2, testFileName), testFileSize, client)
  1172. assert.NoError(t, err)
  1173. err = writeSFTPFile(path.Join(vdirPath2, dir2, testFileName), testFileSize1, client)
  1174. assert.NoError(t, err)
  1175. err = writeSFTPFile(path.Join(vdirPath2, dir2, testFileName+"1.dupl"), testFileSize1, client)
  1176. assert.NoError(t, err)
  1177. err = client.RemoveDirectory(path.Join(vdirPath1, dir1))
  1178. assert.NoError(t, err)
  1179. err = client.RemoveDirectory(path.Join(vdirPath2, dir1))
  1180. assert.NoError(t, err)
  1181. // - vdir1/dir2/testFileName.rename (initial testFileName1)
  1182. // - vdir1/dir2/testFileName
  1183. // - vdir2/dir2/testFileName1 (initial testFileName)
  1184. // - vdir2/dir2/testFileName (initial testFileName1)
  1185. // - vdir2/dir2/testFileName1.dupl
  1186. // rename directories between the two virtual folders
  1187. err = client.Rename(path.Join(vdirPath2, dir2), path.Join(vdirPath1, dir1))
  1188. assert.NoError(t, err)
  1189. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1190. assert.NoError(t, err)
  1191. assert.Equal(t, 5, user.UsedQuotaFiles)
  1192. assert.Equal(t, testFileSize1*3+testFileSize*2, user.UsedQuotaSize)
  1193. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1194. assert.NoError(t, err)
  1195. assert.Equal(t, testFileSize1*3+testFileSize*2, f.UsedQuotaSize)
  1196. assert.Equal(t, 5, f.UsedQuotaFiles)
  1197. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1198. assert.NoError(t, err)
  1199. assert.Equal(t, int64(0), f.UsedQuotaSize)
  1200. assert.Equal(t, 0, f.UsedQuotaFiles)
  1201. // now move on vpath2
  1202. err = client.Rename(path.Join(vdirPath1, dir2), path.Join(vdirPath2, dir1))
  1203. assert.NoError(t, err)
  1204. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1205. assert.NoError(t, err)
  1206. assert.Equal(t, 3, user.UsedQuotaFiles)
  1207. assert.Equal(t, testFileSize1*2+testFileSize, user.UsedQuotaSize)
  1208. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1209. assert.NoError(t, err)
  1210. assert.Equal(t, testFileSize1*2+testFileSize, f.UsedQuotaSize)
  1211. assert.Equal(t, 3, f.UsedQuotaFiles)
  1212. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1213. assert.NoError(t, err)
  1214. assert.Equal(t, testFileSize+testFileSize1, f.UsedQuotaSize)
  1215. assert.Equal(t, 2, f.UsedQuotaFiles)
  1216. }
  1217. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  1218. assert.NoError(t, err)
  1219. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName1}, http.StatusOK)
  1220. assert.NoError(t, err)
  1221. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName2}, http.StatusOK)
  1222. assert.NoError(t, err)
  1223. err = os.RemoveAll(user.GetHomeDir())
  1224. assert.NoError(t, err)
  1225. err = os.RemoveAll(mappedPath1)
  1226. assert.NoError(t, err)
  1227. err = os.RemoveAll(mappedPath2)
  1228. assert.NoError(t, err)
  1229. }
  1230. func TestQuotaRenameFromVirtualFolder(t *testing.T) {
  1231. u := getTestUser()
  1232. u.QuotaFiles = 100
  1233. mappedPath1 := filepath.Join(os.TempDir(), "vdir1")
  1234. folderName1 := filepath.Base(mappedPath1)
  1235. vdirPath1 := "/vdir1"
  1236. mappedPath2 := filepath.Join(os.TempDir(), "vdir2")
  1237. folderName2 := filepath.Base(mappedPath2)
  1238. vdirPath2 := "/vdir2"
  1239. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  1240. BaseVirtualFolder: vfs.BaseVirtualFolder{
  1241. Name: folderName1,
  1242. MappedPath: mappedPath1,
  1243. },
  1244. VirtualPath: vdirPath1,
  1245. // quota is included in the user's one
  1246. QuotaFiles: -1,
  1247. QuotaSize: -1,
  1248. })
  1249. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  1250. BaseVirtualFolder: vfs.BaseVirtualFolder{
  1251. Name: folderName2,
  1252. MappedPath: mappedPath2,
  1253. },
  1254. VirtualPath: vdirPath2,
  1255. // quota is unlimited and excluded from user's one
  1256. QuotaFiles: 0,
  1257. QuotaSize: 0,
  1258. })
  1259. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  1260. assert.NoError(t, err)
  1261. conn, client, err := getSftpClient(user)
  1262. if assert.NoError(t, err) {
  1263. defer conn.Close()
  1264. defer client.Close()
  1265. testFileName1 := "test_file1.dat"
  1266. testFileSize := int64(131072)
  1267. testFileSize1 := int64(65535)
  1268. dir1 := "dir1"
  1269. dir2 := "dir2"
  1270. err = client.Mkdir(path.Join(vdirPath1, dir1))
  1271. assert.NoError(t, err)
  1272. err = client.Mkdir(path.Join(vdirPath1, dir2))
  1273. assert.NoError(t, err)
  1274. err = client.Mkdir(path.Join(vdirPath2, dir1))
  1275. assert.NoError(t, err)
  1276. err = client.Mkdir(path.Join(vdirPath2, dir2))
  1277. assert.NoError(t, err)
  1278. err = writeSFTPFile(path.Join(vdirPath1, dir1, testFileName), testFileSize, client)
  1279. assert.NoError(t, err)
  1280. err = writeSFTPFile(path.Join(vdirPath1, dir2, testFileName1), testFileSize1, client)
  1281. assert.NoError(t, err)
  1282. err = writeSFTPFile(path.Join(vdirPath2, dir1, testFileName), testFileSize, client)
  1283. assert.NoError(t, err)
  1284. err = writeSFTPFile(path.Join(vdirPath2, dir2, testFileName1), testFileSize1, client)
  1285. assert.NoError(t, err)
  1286. // initial files:
  1287. // - vdir1/dir1/testFileName
  1288. // - vdir1/dir2/testFileName1
  1289. // - vdir2/dir1/testFileName
  1290. // - vdir2/dir2/testFileName1
  1291. //
  1292. // rename a file from vdir1 to the user home dir, vdir1 is included in user quota so we have:
  1293. // - testFileName
  1294. // - vdir1/dir2/testFileName1
  1295. // - vdir2/dir1/testFileName
  1296. // - vdir2/dir2/testFileName1
  1297. err = client.Rename(path.Join(vdirPath1, dir1, testFileName), path.Join(testFileName))
  1298. assert.NoError(t, err)
  1299. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1300. assert.NoError(t, err)
  1301. assert.Equal(t, 2, user.UsedQuotaFiles)
  1302. assert.Equal(t, testFileSize+testFileSize1, user.UsedQuotaSize)
  1303. f, _, err := httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1304. assert.NoError(t, err)
  1305. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  1306. assert.Equal(t, 1, f.UsedQuotaFiles)
  1307. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1308. assert.NoError(t, err)
  1309. assert.Equal(t, testFileSize+testFileSize1, f.UsedQuotaSize)
  1310. assert.Equal(t, 2, f.UsedQuotaFiles)
  1311. // rename a file from vdir2 to the user home dir, vdir2 is not included in user quota so we have:
  1312. // - testFileName
  1313. // - testFileName1
  1314. // - vdir1/dir2/testFileName1
  1315. // - vdir2/dir1/testFileName
  1316. err = client.Rename(path.Join(vdirPath2, dir2, testFileName1), path.Join(testFileName1))
  1317. assert.NoError(t, err)
  1318. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1319. assert.NoError(t, err)
  1320. assert.Equal(t, 3, user.UsedQuotaFiles)
  1321. assert.Equal(t, testFileSize+testFileSize1+testFileSize1, user.UsedQuotaSize)
  1322. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1323. assert.NoError(t, err)
  1324. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  1325. assert.Equal(t, 1, f.UsedQuotaFiles)
  1326. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1327. assert.NoError(t, err)
  1328. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  1329. assert.Equal(t, 1, f.UsedQuotaFiles)
  1330. // rename a file from vdir1 to the user home dir overwriting an existing file, vdir1 is included in user quota so we have:
  1331. // - testFileName (initial testFileName1)
  1332. // - testFileName1
  1333. // - vdir2/dir1/testFileName
  1334. err = client.Rename(path.Join(vdirPath1, dir2, testFileName1), path.Join(testFileName))
  1335. assert.NoError(t, err)
  1336. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1337. assert.NoError(t, err)
  1338. assert.Equal(t, 2, user.UsedQuotaFiles)
  1339. assert.Equal(t, testFileSize1+testFileSize1, user.UsedQuotaSize)
  1340. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1341. assert.NoError(t, err)
  1342. assert.Equal(t, int64(0), f.UsedQuotaSize)
  1343. assert.Equal(t, 0, f.UsedQuotaFiles)
  1344. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1345. assert.NoError(t, err)
  1346. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  1347. assert.Equal(t, 1, f.UsedQuotaFiles)
  1348. // rename a file from vdir2 to the user home dir overwriting an existing file, vdir2 is not included in user quota so we have:
  1349. // - testFileName (initial testFileName1)
  1350. // - testFileName1 (initial testFileName)
  1351. err = client.Rename(path.Join(vdirPath2, dir1, testFileName), path.Join(testFileName1))
  1352. assert.NoError(t, err)
  1353. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1354. assert.NoError(t, err)
  1355. assert.Equal(t, 2, user.UsedQuotaFiles)
  1356. assert.Equal(t, testFileSize+testFileSize1, user.UsedQuotaSize)
  1357. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1358. assert.NoError(t, err)
  1359. assert.Equal(t, int64(0), f.UsedQuotaSize)
  1360. assert.Equal(t, 0, f.UsedQuotaFiles)
  1361. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1362. assert.NoError(t, err)
  1363. assert.Equal(t, int64(0), f.UsedQuotaSize)
  1364. assert.Equal(t, 0, f.UsedQuotaFiles)
  1365. // dir rename
  1366. err = writeSFTPFile(path.Join(vdirPath1, dir1, testFileName), testFileSize, client)
  1367. assert.NoError(t, err)
  1368. err = writeSFTPFile(path.Join(vdirPath1, dir1, testFileName1), testFileSize1, client)
  1369. assert.NoError(t, err)
  1370. err = writeSFTPFile(path.Join(vdirPath2, dir1, testFileName), testFileSize, client)
  1371. assert.NoError(t, err)
  1372. err = writeSFTPFile(path.Join(vdirPath2, dir1, testFileName1), testFileSize1, client)
  1373. assert.NoError(t, err)
  1374. // - testFileName (initial testFileName1)
  1375. // - testFileName1 (initial testFileName)
  1376. // - vdir1/dir1/testFileName
  1377. // - vdir1/dir1/testFileName1
  1378. // - dir1/testFileName
  1379. // - dir1/testFileName1
  1380. err = client.Rename(path.Join(vdirPath2, dir1), dir1)
  1381. assert.NoError(t, err)
  1382. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1383. assert.NoError(t, err)
  1384. assert.Equal(t, 6, user.UsedQuotaFiles)
  1385. assert.Equal(t, testFileSize*3+testFileSize1*3, user.UsedQuotaSize)
  1386. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1387. assert.NoError(t, err)
  1388. assert.Equal(t, testFileSize+testFileSize1, f.UsedQuotaSize)
  1389. assert.Equal(t, 2, f.UsedQuotaFiles)
  1390. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1391. assert.NoError(t, err)
  1392. assert.Equal(t, int64(0), f.UsedQuotaSize)
  1393. assert.Equal(t, 0, f.UsedQuotaFiles)
  1394. // - testFileName (initial testFileName1)
  1395. // - testFileName1 (initial testFileName)
  1396. // - dir2/testFileName
  1397. // - dir2/testFileName1
  1398. // - dir1/testFileName
  1399. // - dir1/testFileName1
  1400. err = client.Rename(path.Join(vdirPath1, dir1), dir2)
  1401. assert.NoError(t, err)
  1402. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1403. assert.NoError(t, err)
  1404. assert.Equal(t, 6, user.UsedQuotaFiles)
  1405. assert.Equal(t, testFileSize*3+testFileSize1*3, user.UsedQuotaSize)
  1406. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1407. assert.NoError(t, err)
  1408. assert.Equal(t, int64(0), f.UsedQuotaSize)
  1409. assert.Equal(t, 0, f.UsedQuotaFiles)
  1410. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1411. assert.NoError(t, err)
  1412. assert.Equal(t, int64(0), f.UsedQuotaSize)
  1413. assert.Equal(t, 0, f.UsedQuotaFiles)
  1414. }
  1415. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  1416. assert.NoError(t, err)
  1417. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName1}, http.StatusOK)
  1418. assert.NoError(t, err)
  1419. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName2}, http.StatusOK)
  1420. assert.NoError(t, err)
  1421. err = os.RemoveAll(user.GetHomeDir())
  1422. assert.NoError(t, err)
  1423. err = os.RemoveAll(mappedPath1)
  1424. assert.NoError(t, err)
  1425. err = os.RemoveAll(mappedPath2)
  1426. assert.NoError(t, err)
  1427. }
  1428. func TestQuotaRenameToVirtualFolder(t *testing.T) {
  1429. u := getTestUser()
  1430. u.QuotaFiles = 100
  1431. mappedPath1 := filepath.Join(os.TempDir(), "vdir1")
  1432. folderName1 := filepath.Base(mappedPath1)
  1433. vdirPath1 := "/vdir1"
  1434. mappedPath2 := filepath.Join(os.TempDir(), "vdir2")
  1435. folderName2 := filepath.Base(mappedPath2)
  1436. vdirPath2 := "/vdir2"
  1437. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  1438. BaseVirtualFolder: vfs.BaseVirtualFolder{
  1439. Name: folderName1,
  1440. MappedPath: mappedPath1,
  1441. },
  1442. VirtualPath: vdirPath1,
  1443. // quota is included in the user's one
  1444. QuotaFiles: -1,
  1445. QuotaSize: -1,
  1446. })
  1447. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  1448. BaseVirtualFolder: vfs.BaseVirtualFolder{
  1449. Name: folderName2,
  1450. MappedPath: mappedPath2,
  1451. },
  1452. VirtualPath: vdirPath2,
  1453. // quota is unlimited and excluded from user's one
  1454. QuotaFiles: 0,
  1455. QuotaSize: 0,
  1456. })
  1457. u.Permissions[vdirPath1] = []string{dataprovider.PermListItems, dataprovider.PermDownload, dataprovider.PermUpload,
  1458. dataprovider.PermOverwrite, dataprovider.PermDelete, dataprovider.PermCreateSymlinks, dataprovider.PermCreateDirs}
  1459. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  1460. assert.NoError(t, err)
  1461. conn, client, err := getSftpClient(user)
  1462. if assert.NoError(t, err) {
  1463. defer conn.Close()
  1464. defer client.Close()
  1465. testFileName1 := "test_file1.dat"
  1466. testFileSize := int64(131072)
  1467. testFileSize1 := int64(65535)
  1468. dir1 := "dir1"
  1469. dir2 := "dir2"
  1470. err = client.Mkdir(path.Join(vdirPath1, dir1))
  1471. assert.NoError(t, err)
  1472. err = client.Mkdir(path.Join(vdirPath1, dir2))
  1473. assert.NoError(t, err)
  1474. err = client.Mkdir(path.Join(vdirPath2, dir1))
  1475. assert.NoError(t, err)
  1476. err = client.Mkdir(path.Join(vdirPath2, dir2))
  1477. assert.NoError(t, err)
  1478. err = writeSFTPFile(testFileName, testFileSize, client)
  1479. assert.NoError(t, err)
  1480. err = writeSFTPFile(testFileName1, testFileSize1, client)
  1481. assert.NoError(t, err)
  1482. // initial files:
  1483. // - testFileName
  1484. // - testFileName1
  1485. //
  1486. // rename a file from user home dir to vdir1, vdir1 is included in user quota so we have:
  1487. // - testFileName
  1488. // - /vdir1/dir1/testFileName1
  1489. err = client.Rename(testFileName1, path.Join(vdirPath1, dir1, testFileName1))
  1490. assert.NoError(t, err)
  1491. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1492. assert.NoError(t, err)
  1493. assert.Equal(t, 2, user.UsedQuotaFiles)
  1494. assert.Equal(t, testFileSize+testFileSize1, user.UsedQuotaSize)
  1495. f, _, err := httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1496. assert.NoError(t, err)
  1497. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  1498. assert.Equal(t, 1, f.UsedQuotaFiles)
  1499. // rename a file from user home dir to vdir2, vdir2 is not included in user quota so we have:
  1500. // - /vdir2/dir1/testFileName
  1501. // - /vdir1/dir1/testFileName1
  1502. err = client.Rename(testFileName, path.Join(vdirPath2, dir1, testFileName))
  1503. assert.NoError(t, err)
  1504. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1505. assert.NoError(t, err)
  1506. assert.Equal(t, 1, user.UsedQuotaFiles)
  1507. assert.Equal(t, testFileSize1, user.UsedQuotaSize)
  1508. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1509. assert.NoError(t, err)
  1510. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  1511. assert.Equal(t, 1, f.UsedQuotaFiles)
  1512. // upload two new files to the user home dir so we have:
  1513. // - testFileName
  1514. // - testFileName1
  1515. // - /vdir1/dir1/testFileName1
  1516. // - /vdir2/dir1/testFileName
  1517. err = writeSFTPFile(testFileName, testFileSize, client)
  1518. assert.NoError(t, err)
  1519. err = writeSFTPFile(testFileName1, testFileSize1, client)
  1520. assert.NoError(t, err)
  1521. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1522. assert.NoError(t, err)
  1523. assert.Equal(t, 3, user.UsedQuotaFiles)
  1524. assert.Equal(t, testFileSize+testFileSize1+testFileSize1, user.UsedQuotaSize)
  1525. // rename a file from user home dir to vdir1 overwriting an existing file, vdir1 is included in user quota so we have:
  1526. // - testFileName1
  1527. // - /vdir1/dir1/testFileName1 (initial testFileName)
  1528. // - /vdir2/dir1/testFileName
  1529. err = client.Rename(testFileName, path.Join(vdirPath1, dir1, testFileName1))
  1530. assert.NoError(t, err)
  1531. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1532. assert.NoError(t, err)
  1533. assert.Equal(t, 2, user.UsedQuotaFiles)
  1534. assert.Equal(t, testFileSize+testFileSize1, user.UsedQuotaSize)
  1535. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1536. assert.NoError(t, err)
  1537. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  1538. assert.Equal(t, 1, f.UsedQuotaFiles)
  1539. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1540. assert.NoError(t, err)
  1541. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  1542. assert.Equal(t, 1, f.UsedQuotaFiles)
  1543. // rename a file from user home dir to vdir2 overwriting an existing file, vdir2 is not included in user quota so we have:
  1544. // - /vdir1/dir1/testFileName1 (initial testFileName)
  1545. // - /vdir2/dir1/testFileName (initial testFileName1)
  1546. err = client.Rename(testFileName1, path.Join(vdirPath2, dir1, testFileName))
  1547. assert.NoError(t, err)
  1548. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1549. assert.NoError(t, err)
  1550. assert.Equal(t, 1, user.UsedQuotaFiles)
  1551. assert.Equal(t, testFileSize, user.UsedQuotaSize)
  1552. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1553. assert.NoError(t, err)
  1554. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  1555. assert.Equal(t, 1, f.UsedQuotaFiles)
  1556. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1557. assert.NoError(t, err)
  1558. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  1559. assert.Equal(t, 1, f.UsedQuotaFiles)
  1560. err = client.Mkdir(dir1)
  1561. assert.NoError(t, err)
  1562. err = writeSFTPFile(path.Join(dir1, testFileName), testFileSize, client)
  1563. assert.NoError(t, err)
  1564. err = writeSFTPFile(path.Join(dir1, testFileName1), testFileSize1, client)
  1565. assert.NoError(t, err)
  1566. // - /dir1/testFileName
  1567. // - /dir1/testFileName1
  1568. // - /vdir1/dir1/testFileName1 (initial testFileName)
  1569. // - /vdir2/dir1/testFileName (initial testFileName1)
  1570. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1571. assert.NoError(t, err)
  1572. assert.Equal(t, 3, user.UsedQuotaFiles)
  1573. assert.Equal(t, testFileSize*2+testFileSize1, user.UsedQuotaSize)
  1574. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1575. assert.NoError(t, err)
  1576. assert.Equal(t, testFileSize, f.UsedQuotaSize)
  1577. assert.Equal(t, 1, f.UsedQuotaFiles)
  1578. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1579. assert.NoError(t, err)
  1580. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  1581. assert.Equal(t, 1, f.UsedQuotaFiles)
  1582. // - /vdir1/adir/testFileName
  1583. // - /vdir1/adir/testFileName1
  1584. // - /vdir1/dir1/testFileName1 (initial testFileName)
  1585. // - /vdir2/dir1/testFileName (initial testFileName1)
  1586. err = client.Rename(dir1, path.Join(vdirPath1, "adir"))
  1587. assert.NoError(t, err)
  1588. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1589. assert.NoError(t, err)
  1590. assert.Equal(t, 3, user.UsedQuotaFiles)
  1591. assert.Equal(t, testFileSize*2+testFileSize1, user.UsedQuotaSize)
  1592. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1593. assert.NoError(t, err)
  1594. assert.Equal(t, testFileSize*2+testFileSize1, f.UsedQuotaSize)
  1595. assert.Equal(t, 3, f.UsedQuotaFiles)
  1596. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1597. assert.NoError(t, err)
  1598. assert.Equal(t, testFileSize1, f.UsedQuotaSize)
  1599. assert.Equal(t, 1, f.UsedQuotaFiles)
  1600. err = client.Mkdir(dir1)
  1601. assert.NoError(t, err)
  1602. err = writeSFTPFile(path.Join(dir1, testFileName), testFileSize, client)
  1603. assert.NoError(t, err)
  1604. err = writeSFTPFile(path.Join(dir1, testFileName1), testFileSize1, client)
  1605. assert.NoError(t, err)
  1606. // - /vdir1/adir/testFileName
  1607. // - /vdir1/adir/testFileName1
  1608. // - /vdir1/dir1/testFileName1 (initial testFileName)
  1609. // - /vdir2/dir1/testFileName (initial testFileName1)
  1610. // - /vdir2/adir/testFileName
  1611. // - /vdir2/adir/testFileName1
  1612. err = client.Rename(dir1, path.Join(vdirPath2, "adir"))
  1613. assert.NoError(t, err)
  1614. user, _, err = httpdtest.GetUserByUsername(user.Username, http.StatusOK)
  1615. assert.NoError(t, err)
  1616. assert.Equal(t, 3, user.UsedQuotaFiles)
  1617. assert.Equal(t, testFileSize*2+testFileSize1, user.UsedQuotaSize)
  1618. f, _, err = httpdtest.GetFolderByName(folderName1, http.StatusOK)
  1619. assert.NoError(t, err)
  1620. assert.Equal(t, testFileSize*2+testFileSize1, f.UsedQuotaSize)
  1621. assert.Equal(t, 3, f.UsedQuotaFiles)
  1622. f, _, err = httpdtest.GetFolderByName(folderName2, http.StatusOK)
  1623. assert.NoError(t, err)
  1624. assert.Equal(t, testFileSize1*2+testFileSize, f.UsedQuotaSize)
  1625. assert.Equal(t, 3, f.UsedQuotaFiles)
  1626. }
  1627. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  1628. assert.NoError(t, err)
  1629. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName1}, http.StatusOK)
  1630. assert.NoError(t, err)
  1631. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName2}, http.StatusOK)
  1632. assert.NoError(t, err)
  1633. err = os.RemoveAll(user.GetHomeDir())
  1634. assert.NoError(t, err)
  1635. err = os.RemoveAll(mappedPath1)
  1636. assert.NoError(t, err)
  1637. err = os.RemoveAll(mappedPath2)
  1638. assert.NoError(t, err)
  1639. }
  1640. func TestVirtualFoldersLink(t *testing.T) {
  1641. u := getTestUser()
  1642. mappedPath1 := filepath.Join(os.TempDir(), "vdir1")
  1643. folderName1 := filepath.Base(mappedPath1)
  1644. vdirPath1 := "/vdir1"
  1645. mappedPath2 := filepath.Join(os.TempDir(), "vdir2")
  1646. folderName2 := filepath.Base(mappedPath2)
  1647. vdirPath2 := "/vdir2"
  1648. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  1649. BaseVirtualFolder: vfs.BaseVirtualFolder{
  1650. Name: folderName1,
  1651. MappedPath: mappedPath1,
  1652. },
  1653. VirtualPath: vdirPath1,
  1654. // quota is included in the user's one
  1655. QuotaFiles: -1,
  1656. QuotaSize: -1,
  1657. })
  1658. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  1659. BaseVirtualFolder: vfs.BaseVirtualFolder{
  1660. Name: folderName2,
  1661. MappedPath: mappedPath2,
  1662. },
  1663. VirtualPath: vdirPath2,
  1664. // quota is unlimited and excluded from user's one
  1665. QuotaFiles: 0,
  1666. QuotaSize: 0,
  1667. })
  1668. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  1669. assert.NoError(t, err)
  1670. conn, client, err := getSftpClient(user)
  1671. if assert.NoError(t, err) {
  1672. defer conn.Close()
  1673. defer client.Close()
  1674. testFileSize := int64(131072)
  1675. testDir := "adir"
  1676. err = writeSFTPFile(testFileName, testFileSize, client)
  1677. assert.NoError(t, err)
  1678. err = writeSFTPFile(path.Join(vdirPath1, testFileName), testFileSize, client)
  1679. assert.NoError(t, err)
  1680. err = writeSFTPFile(path.Join(vdirPath2, testFileName), testFileSize, client)
  1681. assert.NoError(t, err)
  1682. err = client.Mkdir(path.Join(vdirPath1, testDir))
  1683. assert.NoError(t, err)
  1684. err = client.Mkdir(path.Join(vdirPath2, testDir))
  1685. assert.NoError(t, err)
  1686. err = client.Symlink(testFileName, testFileName+".link")
  1687. assert.NoError(t, err)
  1688. err = client.Symlink(path.Join(vdirPath1, testFileName), path.Join(vdirPath1, testFileName+".link"))
  1689. assert.NoError(t, err)
  1690. err = client.Symlink(path.Join(vdirPath1, testFileName), path.Join(vdirPath1, testDir, testFileName+".link"))
  1691. assert.NoError(t, err)
  1692. err = client.Symlink(path.Join(vdirPath2, testFileName), path.Join(vdirPath2, testFileName+".link"))
  1693. assert.NoError(t, err)
  1694. err = client.Symlink(path.Join(vdirPath2, testFileName), path.Join(vdirPath2, testDir, testFileName+".link"))
  1695. assert.NoError(t, err)
  1696. err = client.Symlink(testFileName, path.Join(vdirPath1, testFileName+".link1"))
  1697. if assert.Error(t, err) {
  1698. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1699. }
  1700. err = client.Symlink(testFileName, path.Join(vdirPath1, testDir, testFileName+".link1"))
  1701. if assert.Error(t, err) {
  1702. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1703. }
  1704. err = client.Symlink(testFileName, path.Join(vdirPath2, testFileName+".link1"))
  1705. if assert.Error(t, err) {
  1706. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1707. }
  1708. err = client.Symlink(testFileName, path.Join(vdirPath2, testDir, testFileName+".link1"))
  1709. if assert.Error(t, err) {
  1710. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1711. }
  1712. err = client.Symlink(path.Join(vdirPath1, testFileName), testFileName+".link1")
  1713. if assert.Error(t, err) {
  1714. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1715. }
  1716. err = client.Symlink(path.Join(vdirPath2, testFileName), testFileName+".link1")
  1717. if assert.Error(t, err) {
  1718. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1719. }
  1720. err = client.Symlink(path.Join(vdirPath1, testFileName), path.Join(vdirPath2, testDir, testFileName+".link1"))
  1721. if assert.Error(t, err) {
  1722. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1723. }
  1724. err = client.Symlink(path.Join(vdirPath2, testFileName), path.Join(vdirPath1, testFileName+".link1"))
  1725. if assert.Error(t, err) {
  1726. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1727. }
  1728. err = client.Symlink("/", "/roolink")
  1729. assert.ErrorIs(t, err, os.ErrPermission)
  1730. err = client.Symlink(testFileName, "/")
  1731. assert.ErrorIs(t, err, os.ErrPermission)
  1732. err = client.Symlink(testFileName, vdirPath1)
  1733. if assert.Error(t, err) {
  1734. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1735. }
  1736. err = client.Symlink(vdirPath1, testFileName+".link2")
  1737. if assert.Error(t, err) {
  1738. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1739. }
  1740. }
  1741. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  1742. assert.NoError(t, err)
  1743. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName1}, http.StatusOK)
  1744. assert.NoError(t, err)
  1745. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName2}, http.StatusOK)
  1746. assert.NoError(t, err)
  1747. err = os.RemoveAll(user.GetHomeDir())
  1748. assert.NoError(t, err)
  1749. err = os.RemoveAll(mappedPath1)
  1750. assert.NoError(t, err)
  1751. err = os.RemoveAll(mappedPath2)
  1752. assert.NoError(t, err)
  1753. }
  1754. func TestDirs(t *testing.T) {
  1755. u := getTestUser()
  1756. mappedPath := filepath.Join(os.TempDir(), "vdir")
  1757. folderName := filepath.Base(mappedPath)
  1758. vdirPath := "/path/vdir"
  1759. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  1760. BaseVirtualFolder: vfs.BaseVirtualFolder{
  1761. Name: folderName,
  1762. MappedPath: mappedPath,
  1763. },
  1764. VirtualPath: vdirPath,
  1765. })
  1766. u.Permissions["/subdir"] = []string{dataprovider.PermDownload, dataprovider.PermUpload,
  1767. dataprovider.PermDelete, dataprovider.PermCreateDirs, dataprovider.PermRename, dataprovider.PermListItems}
  1768. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  1769. assert.NoError(t, err)
  1770. conn, client, err := getSftpClient(user)
  1771. if assert.NoError(t, err) {
  1772. defer conn.Close()
  1773. defer client.Close()
  1774. info, err := client.ReadDir("/")
  1775. if assert.NoError(t, err) {
  1776. assert.Len(t, info, 1)
  1777. assert.Equal(t, "path", info[0].Name())
  1778. }
  1779. fi, err := client.Stat(path.Dir(vdirPath))
  1780. if assert.NoError(t, err) {
  1781. assert.True(t, fi.IsDir())
  1782. }
  1783. err = client.RemoveDirectory("/")
  1784. assert.ErrorIs(t, err, os.ErrPermission)
  1785. err = client.RemoveDirectory(vdirPath)
  1786. assert.ErrorIs(t, err, os.ErrPermission)
  1787. err = client.RemoveDirectory(path.Dir(vdirPath))
  1788. if assert.Error(t, err) {
  1789. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1790. }
  1791. err = client.Mkdir(vdirPath)
  1792. assert.ErrorIs(t, err, os.ErrPermission)
  1793. err = client.Mkdir("adir")
  1794. assert.NoError(t, err)
  1795. err = client.Rename("/adir", path.Dir(vdirPath))
  1796. if assert.Error(t, err) {
  1797. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1798. }
  1799. err = client.MkdirAll("/subdir/adir")
  1800. assert.NoError(t, err)
  1801. err = client.Rename("adir", "subdir/adir")
  1802. if assert.Error(t, err) {
  1803. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1804. }
  1805. err = writeSFTPFile("/subdir/afile.bin", 64, client)
  1806. assert.NoError(t, err)
  1807. err = writeSFTPFile("/afile.bin", 32, client)
  1808. assert.NoError(t, err)
  1809. err = client.Rename("afile.bin", "subdir/afile.bin")
  1810. assert.ErrorIs(t, err, os.ErrPermission)
  1811. err = client.Rename("afile.bin", "subdir/afile1.bin")
  1812. assert.NoError(t, err)
  1813. err = client.Rename(path.Dir(vdirPath), "renamed_vdir")
  1814. if assert.Error(t, err) {
  1815. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  1816. }
  1817. }
  1818. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  1819. assert.NoError(t, err)
  1820. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName}, http.StatusOK)
  1821. assert.NoError(t, err)
  1822. err = os.RemoveAll(user.GetHomeDir())
  1823. assert.NoError(t, err)
  1824. err = os.RemoveAll(mappedPath)
  1825. assert.NoError(t, err)
  1826. }
  1827. func TestCryptFsStat(t *testing.T) {
  1828. user, _, err := httpdtest.AddUser(getCryptFsUser(), http.StatusCreated)
  1829. assert.NoError(t, err)
  1830. conn, client, err := getSftpClient(user)
  1831. if assert.NoError(t, err) {
  1832. defer conn.Close()
  1833. defer client.Close()
  1834. testFileSize := int64(4096)
  1835. err = writeSFTPFile(testFileName, testFileSize, client)
  1836. assert.NoError(t, err)
  1837. info, err := client.Stat(testFileName)
  1838. if assert.NoError(t, err) {
  1839. assert.Equal(t, testFileSize, info.Size())
  1840. }
  1841. info, err = os.Stat(filepath.Join(user.HomeDir, testFileName))
  1842. if assert.NoError(t, err) {
  1843. assert.Greater(t, info.Size(), testFileSize)
  1844. }
  1845. }
  1846. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  1847. assert.NoError(t, err)
  1848. err = os.RemoveAll(user.GetHomeDir())
  1849. assert.NoError(t, err)
  1850. }
  1851. func TestFsPermissionErrors(t *testing.T) {
  1852. if runtime.GOOS == osWindows {
  1853. t.Skip("this test is not available on Windows")
  1854. }
  1855. user, _, err := httpdtest.AddUser(getCryptFsUser(), http.StatusCreated)
  1856. assert.NoError(t, err)
  1857. conn, client, err := getSftpClient(user)
  1858. if assert.NoError(t, err) {
  1859. defer conn.Close()
  1860. defer client.Close()
  1861. testDir := "tDir"
  1862. err = client.Mkdir(testDir)
  1863. assert.NoError(t, err)
  1864. err = os.Chmod(user.GetHomeDir(), 0111)
  1865. assert.NoError(t, err)
  1866. err = client.RemoveDirectory(testDir)
  1867. assert.ErrorIs(t, err, os.ErrPermission)
  1868. err = client.Rename(testDir, testDir+"1")
  1869. assert.ErrorIs(t, err, os.ErrPermission)
  1870. err = os.Chmod(user.GetHomeDir(), os.ModePerm)
  1871. assert.NoError(t, err)
  1872. }
  1873. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  1874. assert.NoError(t, err)
  1875. err = os.RemoveAll(user.GetHomeDir())
  1876. assert.NoError(t, err)
  1877. }
  1878. func TestResolvePathError(t *testing.T) {
  1879. u := getTestUser()
  1880. u.HomeDir = "relative_path"
  1881. conn := common.NewBaseConnection("", common.ProtocolFTP, "", "", u)
  1882. testPath := "apath"
  1883. _, err := conn.ListDir(testPath)
  1884. assert.Error(t, err)
  1885. err = conn.CreateDir(testPath)
  1886. assert.Error(t, err)
  1887. err = conn.RemoveDir(testPath)
  1888. assert.Error(t, err)
  1889. err = conn.Rename(testPath, testPath+"1")
  1890. assert.Error(t, err)
  1891. err = conn.CreateSymlink(testPath, testPath+".sym")
  1892. assert.Error(t, err)
  1893. _, err = conn.DoStat(testPath, 0)
  1894. assert.Error(t, err)
  1895. err = conn.SetStat(testPath, &common.StatAttributes{
  1896. Atime: time.Now(),
  1897. Mtime: time.Now(),
  1898. })
  1899. assert.Error(t, err)
  1900. u = getTestUser()
  1901. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  1902. BaseVirtualFolder: vfs.BaseVirtualFolder{
  1903. MappedPath: "relative_mapped_path",
  1904. },
  1905. VirtualPath: "/vpath",
  1906. })
  1907. err = os.MkdirAll(u.HomeDir, os.ModePerm)
  1908. assert.NoError(t, err)
  1909. conn.User = u
  1910. err = conn.Rename(testPath, "/vpath/subpath")
  1911. assert.Error(t, err)
  1912. outHomePath := filepath.Join(os.TempDir(), testFileName)
  1913. err = os.WriteFile(outHomePath, testFileContent, os.ModePerm)
  1914. assert.NoError(t, err)
  1915. err = os.Symlink(outHomePath, filepath.Join(u.HomeDir, testFileName+".link"))
  1916. assert.NoError(t, err)
  1917. err = os.WriteFile(filepath.Join(u.HomeDir, testFileName), testFileContent, os.ModePerm)
  1918. assert.NoError(t, err)
  1919. err = conn.CreateSymlink(testFileName, testFileName+".link")
  1920. assert.Error(t, err)
  1921. err = os.RemoveAll(u.GetHomeDir())
  1922. assert.NoError(t, err)
  1923. err = os.Remove(outHomePath)
  1924. assert.NoError(t, err)
  1925. }
  1926. func TestUserPasswordHashing(t *testing.T) {
  1927. if config.GetProviderConf().Driver == dataprovider.MemoryDataProviderName {
  1928. t.Skip("this test is not supported with the memory provider")
  1929. }
  1930. u := getTestUser()
  1931. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  1932. assert.NoError(t, err)
  1933. err = dataprovider.Close()
  1934. assert.NoError(t, err)
  1935. err = config.LoadConfig(configDir, "")
  1936. assert.NoError(t, err)
  1937. providerConf := config.GetProviderConf()
  1938. providerConf.PasswordHashing.Algo = dataprovider.HashingAlgoArgon2ID
  1939. err = dataprovider.Initialize(providerConf, configDir, true)
  1940. assert.NoError(t, err)
  1941. currentUser, err := dataprovider.UserExists(user.Username)
  1942. assert.NoError(t, err)
  1943. assert.True(t, strings.HasPrefix(currentUser.Password, "$2a$"))
  1944. conn, client, err := getSftpClient(user)
  1945. if assert.NoError(t, err) {
  1946. defer conn.Close()
  1947. defer client.Close()
  1948. err = checkBasicSFTP(client)
  1949. assert.NoError(t, err)
  1950. }
  1951. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  1952. assert.NoError(t, err)
  1953. err = os.RemoveAll(user.GetHomeDir())
  1954. assert.NoError(t, err)
  1955. u = getTestUser()
  1956. user, _, err = httpdtest.AddUser(u, http.StatusCreated)
  1957. assert.NoError(t, err)
  1958. currentUser, err = dataprovider.UserExists(user.Username)
  1959. assert.NoError(t, err)
  1960. assert.True(t, strings.HasPrefix(currentUser.Password, "$argon2id$"))
  1961. conn, client, err = getSftpClient(user)
  1962. if assert.NoError(t, err) {
  1963. defer conn.Close()
  1964. defer client.Close()
  1965. err = checkBasicSFTP(client)
  1966. assert.NoError(t, err)
  1967. }
  1968. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  1969. assert.NoError(t, err)
  1970. err = os.RemoveAll(user.GetHomeDir())
  1971. assert.NoError(t, err)
  1972. err = dataprovider.Close()
  1973. assert.NoError(t, err)
  1974. err = config.LoadConfig(configDir, "")
  1975. assert.NoError(t, err)
  1976. providerConf = config.GetProviderConf()
  1977. err = dataprovider.Initialize(providerConf, configDir, true)
  1978. assert.NoError(t, err)
  1979. }
  1980. func TestDelayedQuotaUpdater(t *testing.T) {
  1981. err := dataprovider.Close()
  1982. assert.NoError(t, err)
  1983. err = config.LoadConfig(configDir, "")
  1984. assert.NoError(t, err)
  1985. providerConf := config.GetProviderConf()
  1986. providerConf.DelayedQuotaUpdate = 120
  1987. err = dataprovider.Initialize(providerConf, configDir, true)
  1988. assert.NoError(t, err)
  1989. u := getTestUser()
  1990. u.QuotaFiles = 100
  1991. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  1992. assert.NoError(t, err)
  1993. err = dataprovider.UpdateUserQuota(&user, 10, 6000, false)
  1994. assert.NoError(t, err)
  1995. files, size, err := dataprovider.GetUsedQuota(user.Username)
  1996. assert.NoError(t, err)
  1997. assert.Equal(t, 10, files)
  1998. assert.Equal(t, int64(6000), size)
  1999. userGet, err := dataprovider.UserExists(user.Username)
  2000. assert.NoError(t, err)
  2001. assert.Equal(t, 0, userGet.UsedQuotaFiles)
  2002. assert.Equal(t, int64(0), userGet.UsedQuotaSize)
  2003. err = dataprovider.UpdateUserQuota(&user, 10, 6000, true)
  2004. assert.NoError(t, err)
  2005. files, size, err = dataprovider.GetUsedQuota(user.Username)
  2006. assert.NoError(t, err)
  2007. assert.Equal(t, 10, files)
  2008. assert.Equal(t, int64(6000), size)
  2009. userGet, err = dataprovider.UserExists(user.Username)
  2010. assert.NoError(t, err)
  2011. assert.Equal(t, 10, userGet.UsedQuotaFiles)
  2012. assert.Equal(t, int64(6000), userGet.UsedQuotaSize)
  2013. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  2014. assert.NoError(t, err)
  2015. err = os.RemoveAll(user.GetHomeDir())
  2016. assert.NoError(t, err)
  2017. folder := vfs.BaseVirtualFolder{
  2018. Name: "folder",
  2019. MappedPath: filepath.Join(os.TempDir(), "p"),
  2020. }
  2021. err = dataprovider.AddFolder(&folder)
  2022. assert.NoError(t, err)
  2023. err = dataprovider.UpdateVirtualFolderQuota(&folder, 10, 6000, false)
  2024. assert.NoError(t, err)
  2025. files, size, err = dataprovider.GetUsedVirtualFolderQuota(folder.Name)
  2026. assert.NoError(t, err)
  2027. assert.Equal(t, 10, files)
  2028. assert.Equal(t, int64(6000), size)
  2029. folderGet, err := dataprovider.GetFolderByName(folder.Name)
  2030. assert.NoError(t, err)
  2031. assert.Equal(t, 0, folderGet.UsedQuotaFiles)
  2032. assert.Equal(t, int64(0), folderGet.UsedQuotaSize)
  2033. err = dataprovider.UpdateVirtualFolderQuota(&folder, 10, 6000, true)
  2034. assert.NoError(t, err)
  2035. files, size, err = dataprovider.GetUsedVirtualFolderQuota(folder.Name)
  2036. assert.NoError(t, err)
  2037. assert.Equal(t, 10, files)
  2038. assert.Equal(t, int64(6000), size)
  2039. folderGet, err = dataprovider.GetFolderByName(folder.Name)
  2040. assert.NoError(t, err)
  2041. assert.Equal(t, 10, folderGet.UsedQuotaFiles)
  2042. assert.Equal(t, int64(6000), folderGet.UsedQuotaSize)
  2043. err = dataprovider.DeleteFolder(folder.Name)
  2044. assert.NoError(t, err)
  2045. err = dataprovider.Close()
  2046. assert.NoError(t, err)
  2047. err = config.LoadConfig(configDir, "")
  2048. assert.NoError(t, err)
  2049. providerConf = config.GetProviderConf()
  2050. err = dataprovider.Initialize(providerConf, configDir, true)
  2051. assert.NoError(t, err)
  2052. }
  2053. func TestPasswordCaching(t *testing.T) {
  2054. user, _, err := httpdtest.AddUser(getTestUser(), http.StatusCreated)
  2055. assert.NoError(t, err)
  2056. found, match := dataprovider.CheckCachedPassword(user.Username, defaultPassword)
  2057. assert.False(t, found)
  2058. assert.False(t, match)
  2059. user.Password = "wrong"
  2060. _, _, err = getSftpClient(user)
  2061. assert.Error(t, err)
  2062. found, match = dataprovider.CheckCachedPassword(user.Username, defaultPassword)
  2063. assert.False(t, found)
  2064. assert.False(t, match)
  2065. user.Password = ""
  2066. conn, client, err := getSftpClient(user)
  2067. if assert.NoError(t, err) {
  2068. defer conn.Close()
  2069. defer client.Close()
  2070. err = checkBasicSFTP(client)
  2071. assert.NoError(t, err)
  2072. }
  2073. found, match = dataprovider.CheckCachedPassword(user.Username, defaultPassword)
  2074. assert.True(t, found)
  2075. assert.True(t, match)
  2076. found, match = dataprovider.CheckCachedPassword(user.Username, defaultPassword+"_")
  2077. assert.True(t, found)
  2078. assert.False(t, match)
  2079. found, match = dataprovider.CheckCachedPassword(user.Username+"_", defaultPassword)
  2080. assert.False(t, found)
  2081. assert.False(t, match)
  2082. user, _, err = httpdtest.UpdateUser(user, http.StatusOK, "")
  2083. assert.NoError(t, err)
  2084. found, match = dataprovider.CheckCachedPassword(user.Username, defaultPassword)
  2085. assert.False(t, found)
  2086. assert.False(t, match)
  2087. conn, client, err = getSftpClient(user)
  2088. if assert.NoError(t, err) {
  2089. defer conn.Close()
  2090. defer client.Close()
  2091. err = checkBasicSFTP(client)
  2092. assert.NoError(t, err)
  2093. }
  2094. found, match = dataprovider.CheckCachedPassword(user.Username, defaultPassword)
  2095. assert.True(t, found)
  2096. assert.True(t, match)
  2097. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  2098. assert.NoError(t, err)
  2099. err = os.RemoveAll(user.GetHomeDir())
  2100. assert.NoError(t, err)
  2101. found, match = dataprovider.CheckCachedPassword(user.Username, defaultPassword)
  2102. assert.False(t, found)
  2103. assert.False(t, match)
  2104. }
  2105. func TestSyncUploadAction(t *testing.T) {
  2106. if runtime.GOOS == osWindows {
  2107. t.Skip("this test is not available on Windows")
  2108. }
  2109. uploadScriptPath := filepath.Join(os.TempDir(), "upload.sh")
  2110. common.Config.Actions.ExecuteOn = []string{"upload"}
  2111. common.Config.Actions.ExecuteSync = []string{"upload"}
  2112. common.Config.Actions.Hook = uploadScriptPath
  2113. user, _, err := httpdtest.AddUser(getTestUser(), http.StatusCreated)
  2114. assert.NoError(t, err)
  2115. movedPath := filepath.Join(user.HomeDir, "moved.dat")
  2116. err = os.WriteFile(uploadScriptPath, getUploadScriptContent(movedPath), 0755)
  2117. assert.NoError(t, err)
  2118. conn, client, err := getSftpClient(user)
  2119. if assert.NoError(t, err) {
  2120. defer conn.Close()
  2121. defer client.Close()
  2122. size := int64(32768)
  2123. err = writeSFTPFileNoCheck(testFileName, size, client)
  2124. assert.NoError(t, err)
  2125. _, err = client.Stat(testFileName)
  2126. assert.Error(t, err)
  2127. info, err := client.Stat(filepath.Base(movedPath))
  2128. if assert.NoError(t, err) {
  2129. assert.Equal(t, size, info.Size())
  2130. }
  2131. }
  2132. err = os.Remove(uploadScriptPath)
  2133. assert.NoError(t, err)
  2134. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  2135. assert.NoError(t, err)
  2136. err = os.RemoveAll(user.GetHomeDir())
  2137. assert.NoError(t, err)
  2138. common.Config.Actions.ExecuteOn = nil
  2139. common.Config.Actions.ExecuteSync = nil
  2140. common.Config.Actions.Hook = uploadScriptPath
  2141. }
  2142. func TestQuotaTrackDisabled(t *testing.T) {
  2143. err := dataprovider.Close()
  2144. assert.NoError(t, err)
  2145. err = config.LoadConfig(configDir, "")
  2146. assert.NoError(t, err)
  2147. providerConf := config.GetProviderConf()
  2148. providerConf.TrackQuota = 0
  2149. err = dataprovider.Initialize(providerConf, configDir, true)
  2150. assert.NoError(t, err)
  2151. user, _, err := httpdtest.AddUser(getTestUser(), http.StatusCreated)
  2152. assert.NoError(t, err)
  2153. conn, client, err := getSftpClient(user)
  2154. if assert.NoError(t, err) {
  2155. defer conn.Close()
  2156. defer client.Close()
  2157. err = writeSFTPFile(testFileName, 32, client)
  2158. assert.NoError(t, err)
  2159. err = client.Rename(testFileName, testFileName+"1")
  2160. assert.NoError(t, err)
  2161. }
  2162. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  2163. assert.NoError(t, err)
  2164. err = os.RemoveAll(user.GetHomeDir())
  2165. assert.NoError(t, err)
  2166. err = dataprovider.Close()
  2167. assert.NoError(t, err)
  2168. err = config.LoadConfig(configDir, "")
  2169. assert.NoError(t, err)
  2170. providerConf = config.GetProviderConf()
  2171. err = dataprovider.Initialize(providerConf, configDir, true)
  2172. assert.NoError(t, err)
  2173. }
  2174. func TestGetQuotaError(t *testing.T) {
  2175. if dataprovider.GetProviderStatus().Driver == "memory" {
  2176. t.Skip("this test is not available with the memory provider")
  2177. }
  2178. u := getTestUser()
  2179. mappedPath := filepath.Join(os.TempDir(), "vdir")
  2180. folderName := filepath.Base(mappedPath)
  2181. vdirPath := "/vpath"
  2182. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  2183. BaseVirtualFolder: vfs.BaseVirtualFolder{
  2184. Name: folderName,
  2185. MappedPath: mappedPath,
  2186. },
  2187. VirtualPath: vdirPath,
  2188. QuotaSize: 0,
  2189. QuotaFiles: 10,
  2190. })
  2191. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  2192. assert.NoError(t, err)
  2193. conn, client, err := getSftpClient(user)
  2194. if assert.NoError(t, err) {
  2195. defer conn.Close()
  2196. defer client.Close()
  2197. err = writeSFTPFile(testFileName, 32, client)
  2198. assert.NoError(t, err)
  2199. err = dataprovider.Close()
  2200. assert.NoError(t, err)
  2201. err = client.Rename(testFileName, path.Join(vdirPath, testFileName))
  2202. assert.Error(t, err)
  2203. err = config.LoadConfig(configDir, "")
  2204. assert.NoError(t, err)
  2205. providerConf := config.GetProviderConf()
  2206. err = dataprovider.Initialize(providerConf, configDir, true)
  2207. assert.NoError(t, err)
  2208. }
  2209. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  2210. assert.NoError(t, err)
  2211. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderName}, http.StatusOK)
  2212. assert.NoError(t, err)
  2213. err = os.RemoveAll(user.GetHomeDir())
  2214. assert.NoError(t, err)
  2215. err = os.RemoveAll(mappedPath)
  2216. assert.NoError(t, err)
  2217. }
  2218. func TestRenameDir(t *testing.T) {
  2219. u := getTestUser()
  2220. testDir := "/dir-to-rename"
  2221. u.Permissions[testDir] = []string{dataprovider.PermListItems, dataprovider.PermUpload}
  2222. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  2223. assert.NoError(t, err)
  2224. conn, client, err := getSftpClient(user)
  2225. if assert.NoError(t, err) {
  2226. defer conn.Close()
  2227. defer client.Close()
  2228. err = client.Mkdir(testDir)
  2229. assert.NoError(t, err)
  2230. err = writeSFTPFile(path.Join(testDir, testFileName), 32, client)
  2231. assert.NoError(t, err)
  2232. err = client.Rename(testDir, testDir+"_rename")
  2233. assert.ErrorIs(t, err, os.ErrPermission)
  2234. }
  2235. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  2236. assert.NoError(t, err)
  2237. err = os.RemoveAll(user.GetHomeDir())
  2238. assert.NoError(t, err)
  2239. }
  2240. func TestRenameSymlink(t *testing.T) {
  2241. u := getTestUser()
  2242. testDir := "/dir-no-create-links"
  2243. otherDir := "otherdir"
  2244. u.Permissions[testDir] = []string{dataprovider.PermListItems, dataprovider.PermUpload, dataprovider.PermDelete,
  2245. dataprovider.PermCreateDirs}
  2246. user, _, err := httpdtest.AddUser(u, http.StatusCreated)
  2247. assert.NoError(t, err)
  2248. conn, client, err := getSftpClient(user)
  2249. if assert.NoError(t, err) {
  2250. defer conn.Close()
  2251. defer client.Close()
  2252. err = client.Mkdir(otherDir)
  2253. assert.NoError(t, err)
  2254. err = client.Symlink(otherDir, otherDir+".link")
  2255. assert.NoError(t, err)
  2256. err = client.Rename(otherDir+".link", path.Join(testDir, "symlink"))
  2257. assert.ErrorIs(t, err, os.ErrPermission)
  2258. err = client.Rename(otherDir+".link", "allowed_link")
  2259. assert.NoError(t, err)
  2260. }
  2261. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  2262. assert.NoError(t, err)
  2263. err = os.RemoveAll(user.GetHomeDir())
  2264. assert.NoError(t, err)
  2265. }
  2266. func TestSFTPLoopError(t *testing.T) {
  2267. user1 := getTestUser()
  2268. user2 := getTestUser()
  2269. user1.Username += "1"
  2270. user2.Username += "2"
  2271. // user1 is a local account with a virtual SFTP folder to user2
  2272. // user2 has user1 as SFTP fs
  2273. user1.VirtualFolders = append(user1.VirtualFolders, vfs.VirtualFolder{
  2274. BaseVirtualFolder: vfs.BaseVirtualFolder{
  2275. Name: "sftp",
  2276. FsConfig: vfs.Filesystem{
  2277. Provider: sdk.SFTPFilesystemProvider,
  2278. SFTPConfig: vfs.SFTPFsConfig{
  2279. SFTPFsConfig: sdk.SFTPFsConfig{
  2280. Endpoint: sftpServerAddr,
  2281. Username: user2.Username,
  2282. Password: kms.NewPlainSecret(defaultPassword),
  2283. },
  2284. },
  2285. },
  2286. },
  2287. VirtualPath: "/vdir",
  2288. })
  2289. user2.FsConfig.Provider = sdk.SFTPFilesystemProvider
  2290. user2.FsConfig.SFTPConfig = vfs.SFTPFsConfig{
  2291. SFTPFsConfig: sdk.SFTPFsConfig{
  2292. Endpoint: sftpServerAddr,
  2293. Username: user1.Username,
  2294. Password: kms.NewPlainSecret(defaultPassword),
  2295. },
  2296. }
  2297. user1, resp, err := httpdtest.AddUser(user1, http.StatusCreated)
  2298. assert.NoError(t, err, string(resp))
  2299. user2, resp, err = httpdtest.AddUser(user2, http.StatusCreated)
  2300. assert.NoError(t, err, string(resp))
  2301. user1.VirtualFolders[0].FsConfig.SFTPConfig.Password = kms.NewPlainSecret(defaultPassword)
  2302. user2.FsConfig.SFTPConfig.Password = kms.NewPlainSecret(defaultPassword)
  2303. conn := common.NewBaseConnection("", common.ProtocolWebDAV, "", "", user1)
  2304. _, _, err = conn.GetFsAndResolvedPath(user1.VirtualFolders[0].VirtualPath)
  2305. assert.ErrorIs(t, err, os.ErrPermission)
  2306. conn = common.NewBaseConnection("", common.ProtocolSFTP, "", "", user1)
  2307. _, _, err = conn.GetFsAndResolvedPath(user1.VirtualFolders[0].VirtualPath)
  2308. if assert.Error(t, err) {
  2309. assert.Contains(t, err.Error(), "SFTP loop")
  2310. }
  2311. conn = common.NewBaseConnection("", common.ProtocolFTP, "", "", user1)
  2312. _, _, err = conn.GetFsAndResolvedPath(user1.VirtualFolders[0].VirtualPath)
  2313. if assert.Error(t, err) {
  2314. assert.Contains(t, err.Error(), "SFTP loop")
  2315. }
  2316. _, err = httpdtest.RemoveUser(user1, http.StatusOK)
  2317. assert.NoError(t, err)
  2318. err = os.RemoveAll(user1.GetHomeDir())
  2319. assert.NoError(t, err)
  2320. _, err = httpdtest.RemoveUser(user2, http.StatusOK)
  2321. assert.NoError(t, err)
  2322. err = os.RemoveAll(user2.GetHomeDir())
  2323. assert.NoError(t, err)
  2324. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: "sftp"}, http.StatusOK)
  2325. assert.NoError(t, err)
  2326. }
  2327. func TestNonLocalCrossRename(t *testing.T) {
  2328. baseUser, resp, err := httpdtest.AddUser(getTestUser(), http.StatusCreated)
  2329. assert.NoError(t, err, string(resp))
  2330. u := getTestUser()
  2331. u.HomeDir += "_folders"
  2332. u.Username += "_folders"
  2333. mappedPathSFTP := filepath.Join(os.TempDir(), "sftp")
  2334. folderNameSFTP := filepath.Base(mappedPathSFTP)
  2335. vdirSFTPPath := "/vdir/sftp"
  2336. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  2337. BaseVirtualFolder: vfs.BaseVirtualFolder{
  2338. Name: folderNameSFTP,
  2339. FsConfig: vfs.Filesystem{
  2340. Provider: sdk.SFTPFilesystemProvider,
  2341. SFTPConfig: vfs.SFTPFsConfig{
  2342. SFTPFsConfig: sdk.SFTPFsConfig{
  2343. Endpoint: sftpServerAddr,
  2344. Username: baseUser.Username,
  2345. Password: kms.NewPlainSecret(defaultPassword),
  2346. },
  2347. },
  2348. },
  2349. },
  2350. VirtualPath: vdirSFTPPath,
  2351. })
  2352. mappedPathCrypt := filepath.Join(os.TempDir(), "crypt")
  2353. folderNameCrypt := filepath.Base(mappedPathCrypt)
  2354. vdirCryptPath := "/vdir/crypt"
  2355. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  2356. BaseVirtualFolder: vfs.BaseVirtualFolder{
  2357. Name: folderNameCrypt,
  2358. FsConfig: vfs.Filesystem{
  2359. Provider: sdk.CryptedFilesystemProvider,
  2360. CryptConfig: vfs.CryptFsConfig{
  2361. CryptFsConfig: sdk.CryptFsConfig{
  2362. Passphrase: kms.NewPlainSecret(defaultPassword),
  2363. },
  2364. },
  2365. },
  2366. MappedPath: mappedPathCrypt,
  2367. },
  2368. VirtualPath: vdirCryptPath,
  2369. })
  2370. user, resp, err := httpdtest.AddUser(u, http.StatusCreated)
  2371. assert.NoError(t, err, string(resp))
  2372. conn, client, err := getSftpClient(user)
  2373. if assert.NoError(t, err) {
  2374. defer conn.Close()
  2375. defer client.Close()
  2376. assert.NoError(t, checkBasicSFTP(client))
  2377. err = writeSFTPFile(testFileName, 4096, client)
  2378. assert.NoError(t, err)
  2379. err = writeSFTPFile(path.Join(vdirSFTPPath, testFileName), 8192, client)
  2380. assert.NoError(t, err)
  2381. err = writeSFTPFile(path.Join(vdirCryptPath, testFileName), 16384, client)
  2382. assert.NoError(t, err)
  2383. err = client.Rename(path.Join(vdirSFTPPath, testFileName), path.Join(vdirCryptPath, testFileName+".rename"))
  2384. assert.ErrorIs(t, err, os.ErrPermission)
  2385. err = client.Rename(path.Join(vdirCryptPath, testFileName), path.Join(vdirSFTPPath, testFileName+".rename"))
  2386. assert.ErrorIs(t, err, os.ErrPermission)
  2387. err = client.Rename(testFileName, path.Join(vdirCryptPath, testFileName+".rename"))
  2388. assert.ErrorIs(t, err, os.ErrPermission)
  2389. err = client.Rename(testFileName, path.Join(vdirSFTPPath, testFileName+".rename"))
  2390. assert.ErrorIs(t, err, os.ErrPermission)
  2391. err = client.Rename(path.Join(vdirSFTPPath, testFileName), testFileName+".rename")
  2392. assert.ErrorIs(t, err, os.ErrPermission)
  2393. err = client.Rename(path.Join(vdirCryptPath, testFileName), testFileName+".rename")
  2394. assert.ErrorIs(t, err, os.ErrPermission)
  2395. // rename on local fs or on the same folder must work
  2396. err = client.Rename(testFileName, testFileName+".rename")
  2397. assert.NoError(t, err)
  2398. err = client.Rename(path.Join(vdirSFTPPath, testFileName), path.Join(vdirSFTPPath, testFileName+"_rename"))
  2399. assert.NoError(t, err)
  2400. err = client.Rename(path.Join(vdirCryptPath, testFileName), path.Join(vdirCryptPath, testFileName+"_rename"))
  2401. assert.NoError(t, err)
  2402. // renaming a virtual folder is not allowed
  2403. err = client.Rename(vdirSFTPPath, vdirSFTPPath+"_rename")
  2404. assert.ErrorIs(t, err, os.ErrPermission)
  2405. err = client.Rename(vdirCryptPath, vdirCryptPath+"_rename")
  2406. assert.ErrorIs(t, err, os.ErrPermission)
  2407. err = client.Rename(vdirCryptPath, path.Join(vdirCryptPath, "rename"))
  2408. assert.ErrorIs(t, err, os.ErrPermission)
  2409. err = client.Mkdir(path.Join(vdirCryptPath, "subcryptdir"))
  2410. assert.NoError(t, err)
  2411. err = client.Rename(path.Join(vdirCryptPath, "subcryptdir"), vdirCryptPath)
  2412. assert.ErrorIs(t, err, os.ErrPermission)
  2413. // renaming root folder is not allowed
  2414. err = client.Rename("/", "new_name")
  2415. assert.ErrorIs(t, err, os.ErrPermission)
  2416. // renaming a path to a virtual folder is not allowed
  2417. err = client.Rename("/vdir", "new_vdir")
  2418. if assert.Error(t, err) {
  2419. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  2420. }
  2421. }
  2422. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  2423. assert.NoError(t, err)
  2424. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderNameCrypt}, http.StatusOK)
  2425. assert.NoError(t, err)
  2426. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderNameSFTP}, http.StatusOK)
  2427. assert.NoError(t, err)
  2428. _, err = httpdtest.RemoveUser(baseUser, http.StatusOK)
  2429. assert.NoError(t, err)
  2430. err = os.RemoveAll(user.GetHomeDir())
  2431. assert.NoError(t, err)
  2432. err = os.RemoveAll(baseUser.GetHomeDir())
  2433. assert.NoError(t, err)
  2434. err = os.RemoveAll(mappedPathCrypt)
  2435. assert.NoError(t, err)
  2436. err = os.RemoveAll(mappedPathSFTP)
  2437. assert.NoError(t, err)
  2438. }
  2439. func TestNonLocalCrossRenameNonLocalBaseUser(t *testing.T) {
  2440. baseUser, resp, err := httpdtest.AddUser(getTestUser(), http.StatusCreated)
  2441. assert.NoError(t, err, string(resp))
  2442. u := getTestSFTPUser()
  2443. mappedPathLocal := filepath.Join(os.TempDir(), "local")
  2444. folderNameLocal := filepath.Base(mappedPathLocal)
  2445. vdirLocalPath := "/vdir/local"
  2446. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  2447. BaseVirtualFolder: vfs.BaseVirtualFolder{
  2448. Name: folderNameLocal,
  2449. MappedPath: mappedPathLocal,
  2450. },
  2451. VirtualPath: vdirLocalPath,
  2452. })
  2453. mappedPathCrypt := filepath.Join(os.TempDir(), "crypt")
  2454. folderNameCrypt := filepath.Base(mappedPathCrypt)
  2455. vdirCryptPath := "/vdir/crypt"
  2456. u.VirtualFolders = append(u.VirtualFolders, vfs.VirtualFolder{
  2457. BaseVirtualFolder: vfs.BaseVirtualFolder{
  2458. Name: folderNameCrypt,
  2459. FsConfig: vfs.Filesystem{
  2460. Provider: sdk.CryptedFilesystemProvider,
  2461. CryptConfig: vfs.CryptFsConfig{
  2462. CryptFsConfig: sdk.CryptFsConfig{
  2463. Passphrase: kms.NewPlainSecret(defaultPassword),
  2464. },
  2465. },
  2466. },
  2467. MappedPath: mappedPathCrypt,
  2468. },
  2469. VirtualPath: vdirCryptPath,
  2470. })
  2471. user, resp, err := httpdtest.AddUser(u, http.StatusCreated)
  2472. assert.NoError(t, err, string(resp))
  2473. conn, client, err := getSftpClient(user)
  2474. if assert.NoError(t, err) {
  2475. defer conn.Close()
  2476. defer client.Close()
  2477. assert.NoError(t, checkBasicSFTP(client))
  2478. err = writeSFTPFile(testFileName, 4096, client)
  2479. assert.NoError(t, err)
  2480. err = writeSFTPFile(path.Join(vdirLocalPath, testFileName), 8192, client)
  2481. assert.NoError(t, err)
  2482. err = writeSFTPFile(path.Join(vdirCryptPath, testFileName), 16384, client)
  2483. assert.NoError(t, err)
  2484. err = client.Rename(path.Join(vdirLocalPath, testFileName), path.Join(vdirCryptPath, testFileName+".rename"))
  2485. assert.ErrorIs(t, err, os.ErrPermission)
  2486. err = client.Rename(path.Join(vdirCryptPath, testFileName), path.Join(vdirLocalPath, testFileName+".rename"))
  2487. assert.ErrorIs(t, err, os.ErrPermission)
  2488. err = client.Rename(testFileName, path.Join(vdirCryptPath, testFileName+".rename"))
  2489. assert.ErrorIs(t, err, os.ErrPermission)
  2490. err = client.Rename(testFileName, path.Join(vdirLocalPath, testFileName+".rename"))
  2491. assert.ErrorIs(t, err, os.ErrPermission)
  2492. err = client.Rename(path.Join(vdirLocalPath, testFileName), testFileName+".rename")
  2493. assert.ErrorIs(t, err, os.ErrPermission)
  2494. err = client.Rename(path.Join(vdirCryptPath, testFileName), testFileName+".rename")
  2495. assert.ErrorIs(t, err, os.ErrPermission)
  2496. // rename on local fs or on the same folder must work
  2497. err = client.Rename(testFileName, testFileName+".rename")
  2498. assert.NoError(t, err)
  2499. err = client.Rename(path.Join(vdirLocalPath, testFileName), path.Join(vdirLocalPath, testFileName+"_rename"))
  2500. assert.NoError(t, err)
  2501. err = client.Rename(path.Join(vdirCryptPath, testFileName), path.Join(vdirCryptPath, testFileName+"_rename"))
  2502. assert.NoError(t, err)
  2503. // renaming a virtual folder is not allowed
  2504. err = client.Rename(vdirLocalPath, vdirLocalPath+"_rename")
  2505. assert.ErrorIs(t, err, os.ErrPermission)
  2506. err = client.Rename(vdirCryptPath, vdirCryptPath+"_rename")
  2507. assert.ErrorIs(t, err, os.ErrPermission)
  2508. // renaming root folder is not allowed
  2509. err = client.Rename("/", "new_name")
  2510. assert.ErrorIs(t, err, os.ErrPermission)
  2511. // renaming a path to a virtual folder is not allowed
  2512. err = client.Rename("/vdir", "new_vdir")
  2513. if assert.Error(t, err) {
  2514. assert.Contains(t, err.Error(), "SSH_FX_OP_UNSUPPORTED")
  2515. }
  2516. }
  2517. _, err = httpdtest.RemoveUser(user, http.StatusOK)
  2518. assert.NoError(t, err)
  2519. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderNameCrypt}, http.StatusOK)
  2520. assert.NoError(t, err)
  2521. _, err = httpdtest.RemoveFolder(vfs.BaseVirtualFolder{Name: folderNameLocal}, http.StatusOK)
  2522. assert.NoError(t, err)
  2523. _, err = httpdtest.RemoveUser(baseUser, http.StatusOK)
  2524. assert.NoError(t, err)
  2525. err = os.RemoveAll(user.GetHomeDir())
  2526. assert.NoError(t, err)
  2527. err = os.RemoveAll(baseUser.GetHomeDir())
  2528. assert.NoError(t, err)
  2529. err = os.RemoveAll(mappedPathCrypt)
  2530. assert.NoError(t, err)
  2531. err = os.RemoveAll(mappedPathLocal)
  2532. assert.NoError(t, err)
  2533. }
  2534. func TestProxyProtocol(t *testing.T) {
  2535. resp, err := httpclient.Get(fmt.Sprintf("http://%v", httpProxyAddr))
  2536. if assert.NoError(t, err) {
  2537. defer resp.Body.Close()
  2538. assert.Equal(t, http.StatusBadRequest, resp.StatusCode)
  2539. }
  2540. }
  2541. func TestSetProtocol(t *testing.T) {
  2542. conn := common.NewBaseConnection("id", "sshd_exec", "", "", dataprovider.User{BaseUser: sdk.BaseUser{HomeDir: os.TempDir()}})
  2543. conn.SetProtocol(common.ProtocolSCP)
  2544. require.Equal(t, "SCP_id", conn.GetID())
  2545. }
  2546. func TestGetFsError(t *testing.T) {
  2547. u := getTestUser()
  2548. u.FsConfig.Provider = sdk.GCSFilesystemProvider
  2549. u.FsConfig.GCSConfig.Bucket = "test"
  2550. u.FsConfig.GCSConfig.Credentials = kms.NewPlainSecret("invalid JSON for credentials")
  2551. conn := common.NewBaseConnection("", common.ProtocolFTP, "", "", u)
  2552. _, _, err := conn.GetFsAndResolvedPath("/vpath")
  2553. assert.Error(t, err)
  2554. }
  2555. func waitTCPListening(address string) {
  2556. for {
  2557. conn, err := net.Dial("tcp", address)
  2558. if err != nil {
  2559. logger.WarnToConsole("tcp server %v not listening: %v", address, err)
  2560. time.Sleep(100 * time.Millisecond)
  2561. continue
  2562. }
  2563. logger.InfoToConsole("tcp server %v now listening", address)
  2564. conn.Close()
  2565. break
  2566. }
  2567. }
  2568. func checkBasicSFTP(client *sftp.Client) error {
  2569. _, err := client.Getwd()
  2570. if err != nil {
  2571. return err
  2572. }
  2573. _, err = client.ReadDir(".")
  2574. return err
  2575. }
  2576. func getSftpClient(user dataprovider.User) (*ssh.Client, *sftp.Client, error) {
  2577. var sftpClient *sftp.Client
  2578. config := &ssh.ClientConfig{
  2579. User: user.Username,
  2580. HostKeyCallback: func(hostname string, remote net.Addr, key ssh.PublicKey) error {
  2581. return nil
  2582. },
  2583. }
  2584. if user.Password != "" {
  2585. config.Auth = []ssh.AuthMethod{ssh.Password(user.Password)}
  2586. } else {
  2587. config.Auth = []ssh.AuthMethod{ssh.Password(defaultPassword)}
  2588. }
  2589. conn, err := ssh.Dial("tcp", sftpServerAddr, config)
  2590. if err != nil {
  2591. return conn, sftpClient, err
  2592. }
  2593. sftpClient, err = sftp.NewClient(conn)
  2594. if err != nil {
  2595. conn.Close()
  2596. }
  2597. return conn, sftpClient, err
  2598. }
  2599. func getTestUser() dataprovider.User {
  2600. user := dataprovider.User{
  2601. BaseUser: sdk.BaseUser{
  2602. Username: defaultUsername,
  2603. Password: defaultPassword,
  2604. HomeDir: filepath.Join(homeBasePath, defaultUsername),
  2605. Status: 1,
  2606. ExpirationDate: 0,
  2607. },
  2608. }
  2609. user.Permissions = make(map[string][]string)
  2610. user.Permissions["/"] = allPerms
  2611. return user
  2612. }
  2613. func getTestSFTPUser() dataprovider.User {
  2614. u := getTestUser()
  2615. u.Username = defaultSFTPUsername
  2616. u.FsConfig.Provider = sdk.SFTPFilesystemProvider
  2617. u.FsConfig.SFTPConfig.Endpoint = sftpServerAddr
  2618. u.FsConfig.SFTPConfig.Username = defaultUsername
  2619. u.FsConfig.SFTPConfig.Password = kms.NewPlainSecret(defaultPassword)
  2620. return u
  2621. }
  2622. func getCryptFsUser() dataprovider.User {
  2623. u := getTestUser()
  2624. u.FsConfig.Provider = sdk.CryptedFilesystemProvider
  2625. u.FsConfig.CryptConfig.Passphrase = kms.NewPlainSecret(defaultPassword)
  2626. return u
  2627. }
  2628. func writeSFTPFile(name string, size int64, client *sftp.Client) error {
  2629. err := writeSFTPFileNoCheck(name, size, client)
  2630. if err != nil {
  2631. return err
  2632. }
  2633. info, err := client.Stat(name)
  2634. if err != nil {
  2635. return err
  2636. }
  2637. if info.Size() != size {
  2638. return fmt.Errorf("file size mismatch, wanted %v, actual %v", size, info.Size())
  2639. }
  2640. return nil
  2641. }
  2642. func writeSFTPFileNoCheck(name string, size int64, client *sftp.Client) error {
  2643. content := make([]byte, size)
  2644. _, err := rand.Read(content)
  2645. if err != nil {
  2646. return err
  2647. }
  2648. f, err := client.Create(name)
  2649. if err != nil {
  2650. return err
  2651. }
  2652. _, err = io.Copy(f, bytes.NewBuffer(content))
  2653. if err != nil {
  2654. f.Close()
  2655. return err
  2656. }
  2657. return f.Close()
  2658. }
  2659. func getUploadScriptContent(movedPath string) []byte {
  2660. content := []byte("#!/bin/sh\n\n")
  2661. content = append(content, []byte("sleep 1\n")...)
  2662. content = append(content, []byte(fmt.Sprintf("mv ${SFTPGO_ACTION_PATH} %v\n", movedPath))...)
  2663. return content
  2664. }