| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332333333343335333633373338333933403341334233433344334533463347334833493350335133523353335433553356335733583359336033613362336333643365336633673368336933703371337233733374337533763377337833793380338133823383338433853386338733883389339033913392339333943395339633973398339934003401340234033404340534063407340834093410341134123413341434153416341734183419342034213422342334243425342634273428342934303431343234333434343534363437343834393440344134423443344434453446344734483449345034513452345334543455345634573458345934603461346234633464346534663467346834693470347134723473347434753476347734783479348034813482348334843485348634873488348934903491349234933494349534963497349834993500350135023503350435053506350735083509351035113512351335143515351635173518351935203521352235233524352535263527352835293530353135323533353435353536353735383539354035413542354335443545354635473548354935503551355235533554355535563557355835593560356135623563356435653566356735683569357035713572357335743575357635773578357935803581358235833584358535863587358835893590359135923593359435953596359735983599360036013602360336043605360636073608360936103611361236133614361536163617361836193620362136223623362436253626362736283629363036313632363336343635363636373638363936403641364236433644364536463647364836493650365136523653365436553656365736583659366036613662366336643665366636673668366936703671367236733674367536763677367836793680368136823683368436853686368736883689369036913692369336943695369636973698369937003701370237033704370537063707370837093710371137123713371437153716371737183719372037213722372337243725372637273728372937303731373237333734373537363737373837393740374137423743374437453746374737483749375037513752375337543755375637573758375937603761376237633764376537663767376837693770377137723773377437753776377737783779378037813782378337843785378637873788378937903791379237933794379537963797379837993800380138023803380438053806380738083809381038113812381338143815381638173818381938203821382238233824382538263827382838293830383138323833383438353836383738383839384038413842384338443845384638473848384938503851385238533854385538563857385838593860386138623863386438653866386738683869387038713872387338743875387638773878387938803881388238833884388538863887388838893890389138923893389438953896389738983899390039013902390339043905390639073908390939103911391239133914391539163917391839193920392139223923392439253926392739283929393039313932393339343935393639373938393939403941394239433944394539463947394839493950395139523953395439553956395739583959396039613962396339643965396639673968396939703971397239733974397539763977397839793980398139823983398439853986398739883989399039913992399339943995399639973998399940004001400240034004400540064007400840094010401140124013401440154016401740184019402040214022402340244025402640274028402940304031403240334034403540364037403840394040404140424043404440454046404740484049405040514052405340544055405640574058405940604061406240634064406540664067406840694070407140724073407440754076407740784079408040814082408340844085408640874088408940904091409240934094409540964097409840994100410141024103410441054106410741084109411041114112411341144115411641174118411941204121412241234124412541264127412841294130413141324133413441354136413741384139414041414142414341444145414641474148414941504151415241534154415541564157415841594160416141624163416441654166416741684169417041714172417341744175417641774178417941804181418241834184418541864187418841894190419141924193419441954196419741984199420042014202420342044205420642074208420942104211421242134214421542164217421842194220422142224223422442254226422742284229423042314232423342344235423642374238423942404241424242434244424542464247424842494250425142524253425442554256425742584259426042614262426342644265426642674268426942704271427242734274427542764277427842794280428142824283428442854286428742884289429042914292429342944295429642974298429943004301430243034304430543064307430843094310431143124313431443154316431743184319432043214322432343244325432643274328432943304331433243334334433543364337433843394340434143424343434443454346434743484349435043514352435343544355435643574358435943604361436243634364436543664367436843694370437143724373437443754376437743784379438043814382438343844385438643874388438943904391439243934394439543964397439843994400440144024403440444054406440744084409441044114412441344144415441644174418441944204421442244234424442544264427442844294430443144324433443444354436443744384439444044414442444344444445444644474448444944504451445244534454445544564457445844594460446144624463446444654466446744684469447044714472447344744475447644774478447944804481448244834484448544864487448844894490449144924493449444954496449744984499450045014502450345044505450645074508450945104511451245134514451545164517451845194520452145224523452445254526452745284529453045314532453345344535453645374538453945404541454245434544454545464547454845494550455145524553455445554556455745584559456045614562456345644565456645674568456945704571457245734574457545764577457845794580458145824583458445854586458745884589459045914592459345944595459645974598459946004601460246034604460546064607460846094610461146124613461446154616461746184619462046214622462346244625462646274628462946304631463246334634463546364637463846394640464146424643464446454646464746484649465046514652465346544655465646574658465946604661466246634664466546664667466846694670467146724673467446754676467746784679468046814682468346844685468646874688468946904691469246934694469546964697469846994700470147024703470447054706470747084709471047114712471347144715471647174718471947204721472247234724472547264727472847294730473147324733473447354736473747384739474047414742474347444745474647474748474947504751475247534754475547564757475847594760476147624763476447654766476747684769477047714772477347744775477647774778477947804781478247834784478547864787478847894790479147924793479447954796479747984799480048014802480348044805480648074808480948104811481248134814481548164817481848194820482148224823482448254826482748284829483048314832483348344835483648374838483948404841484248434844484548464847484848494850485148524853485448554856485748584859486048614862486348644865486648674868486948704871487248734874487548764877487848794880488148824883488448854886488748884889489048914892489348944895489648974898489949004901490249034904490549064907490849094910491149124913491449154916491749184919492049214922492349244925492649274928492949304931493249334934493549364937493849394940494149424943494449454946494749484949495049514952495349544955495649574958495949604961496249634964496549664967496849694970497149724973497449754976497749784979498049814982498349844985498649874988498949904991499249934994499549964997499849995000500150025003500450055006500750085009501050115012501350145015501650175018501950205021502250235024502550265027502850295030503150325033503450355036503750385039504050415042504350445045504650475048504950505051505250535054505550565057505850595060506150625063506450655066506750685069507050715072507350745075507650775078507950805081508250835084508550865087508850895090509150925093509450955096509750985099510051015102510351045105510651075108510951105111511251135114511551165117511851195120512151225123512451255126512751285129513051315132513351345135513651375138513951405141514251435144514551465147514851495150515151525153515451555156515751585159516051615162516351645165516651675168516951705171517251735174517551765177517851795180518151825183518451855186518751885189519051915192519351945195519651975198519952005201520252035204520552065207520852095210521152125213521452155216521752185219522052215222522352245225522652275228522952305231523252335234523552365237523852395240524152425243524452455246524752485249525052515252525352545255525652575258525952605261526252635264526552665267526852695270527152725273527452755276527752785279528052815282528352845285528652875288528952905291529252935294529552965297529852995300530153025303530453055306530753085309531053115312531353145315531653175318531953205321532253235324532553265327532853295330533153325333533453355336533753385339534053415342534353445345534653475348534953505351535253535354535553565357535853595360536153625363536453655366536753685369537053715372537353745375537653775378537953805381538253835384538553865387538853895390539153925393539453955396539753985399540054015402540354045405540654075408540954105411541254135414541554165417541854195420542154225423542454255426542754285429543054315432543354345435543654375438543954405441544254435444544554465447544854495450545154525453545454555456545754585459546054615462546354645465546654675468546954705471547254735474547554765477547854795480548154825483548454855486548754885489549054915492549354945495549654975498549955005501550255035504550555065507550855095510551155125513551455155516551755185519552055215522552355245525552655275528552955305531553255335534553555365537553855395540554155425543554455455546554755485549555055515552555355545555555655575558555955605561556255635564556555665567556855695570557155725573557455755576557755785579558055815582558355845585558655875588558955905591559255935594559555965597559855995600560156025603560456055606560756085609561056115612561356145615561656175618561956205621562256235624562556265627562856295630563156325633563456355636563756385639564056415642564356445645564656475648564956505651565256535654565556565657565856595660566156625663566456655666566756685669567056715672567356745675567656775678567956805681568256835684568556865687568856895690569156925693569456955696569756985699570057015702570357045705570657075708570957105711571257135714571557165717571857195720572157225723572457255726572757285729573057315732573357345735573657375738573957405741574257435744574557465747574857495750575157525753575457555756575757585759576057615762576357645765576657675768576957705771577257735774577557765777577857795780578157825783578457855786578757885789579057915792579357945795579657975798579958005801580258035804580558065807580858095810581158125813581458155816581758185819582058215822582358245825582658275828582958305831583258335834583558365837583858395840584158425843584458455846584758485849585058515852585358545855585658575858585958605861586258635864586558665867586858695870587158725873587458755876587758785879588058815882588358845885588658875888588958905891589258935894589558965897589858995900590159025903590459055906590759085909591059115912591359145915591659175918591959205921592259235924592559265927592859295930593159325933593459355936593759385939594059415942594359445945594659475948594959505951595259535954595559565957595859595960596159625963596459655966596759685969597059715972597359745975597659775978597959805981598259835984598559865987598859895990599159925993599459955996599759985999600060016002600360046005600660076008600960106011601260136014601560166017601860196020602160226023602460256026602760286029603060316032603360346035603660376038603960406041604260436044604560466047604860496050605160526053605460556056605760586059606060616062606360646065606660676068606960706071607260736074607560766077607860796080608160826083608460856086608760886089609060916092609360946095609660976098609961006101610261036104610561066107610861096110611161126113611461156116611761186119612061216122612361246125612661276128612961306131613261336134613561366137613861396140614161426143614461456146614761486149615061516152615361546155615661576158615961606161616261636164616561666167616861696170617161726173617461756176617761786179618061816182618361846185618661876188618961906191619261936194619561966197619861996200620162026203620462056206620762086209621062116212621362146215621662176218621962206221622262236224622562266227622862296230623162326233623462356236623762386239624062416242624362446245624662476248624962506251625262536254625562566257625862596260626162626263626462656266626762686269627062716272627362746275627662776278627962806281628262836284628562866287628862896290629162926293629462956296629762986299630063016302630363046305630663076308630963106311631263136314631563166317631863196320632163226323632463256326632763286329633063316332633363346335633663376338633963406341634263436344634563466347634863496350635163526353635463556356635763586359636063616362636363646365636663676368636963706371637263736374637563766377637863796380638163826383638463856386638763886389639063916392639363946395639663976398639964006401640264036404640564066407640864096410641164126413641464156416641764186419642064216422642364246425642664276428642964306431643264336434643564366437643864396440644164426443644464456446644764486449645064516452645364546455645664576458645964606461646264636464646564666467646864696470647164726473647464756476647764786479648064816482648364846485648664876488648964906491649264936494 |
- using System.Diagnostics;
- using Renci.SshNet.Common;
- using Renci.SshNet.IntegrationTests.Common;
- using Renci.SshNet.Sftp;
- namespace Renci.SshNet.IntegrationTests
- {
- // TODO: DeleteDirectory (fail + success
- // TODO: DeleteFile (fail + success
- // TODO: Delete (fail + success
- [TestClass]
- public class SftpTests : TestBase
- {
- private IConnectionInfoFactory _connectionInfoFactory;
- private IConnectionInfoFactory _adminConnectionInfoFactory;
- private IRemotePathTransformation _remotePathTransformation;
- [TestInitialize]
- public void SetUp()
- {
- _connectionInfoFactory = new LinuxVMConnectionFactory(SshServerHostName, SshServerPort);
- _adminConnectionInfoFactory = new LinuxAdminConnectionFactory(SshServerHostName, SshServerPort);
- _remotePathTransformation = RemotePathTransformation.ShellQuote;
- }
- [TestMethod]
- [DynamicData(nameof(GetSftpUploadFileFileStreamData), DynamicDataSourceType.Method)]
- public void Sftp_UploadFile_FileStream(int size)
- {
- var file = CreateTempFile(size);
- using (var fs = new FileStream(file, FileMode.Open, FileAccess.Read, FileShare.Read))
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.Delete(remoteFile);
- }
- try
- {
- client.UploadFile(fs, remoteFile);
- using (var memoryStream = new MemoryStream(size))
- {
- DownloadFileRandomMethod(client, remoteFile, memoryStream);
- memoryStream.Position = 0;
- Assert.AreEqual(CreateFileHash(file), CreateHash(memoryStream));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.Delete(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ConnectDisconnect_Serial()
- {
- const int iterations = 100;
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- for (var i = 1; i <= iterations; i++)
- {
- client.Connect();
- client.Disconnect();
- }
- }
- }
- [TestMethod]
- public void Sftp_ConnectDisconnect_Parallel()
- {
- const int iterations = 10;
- const int threads = 5;
- var startEvent = new ManualResetEvent(false);
- var tasks = Enumerable.Range(1, threads).Select(i =>
- {
- return Task.Factory.StartNew(() =>
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- startEvent.WaitOne();
- for (var j = 0; j < iterations; j++)
- {
- client.Connect();
- client.Disconnect();
- }
- }
- });
- }).ToArray();
- startEvent.Set();
- Task.WaitAll(tasks);
- }
- [TestMethod]
- public void Sftp_BeginUploadFile()
- {
- const string content = "SftpBeginUploadFile";
- var expectedByteCount = (ulong)Encoding.ASCII.GetByteCount(content);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.Delete(remoteFile);
- }
- try
- {
- using (var memoryStream = new MemoryStream(Encoding.ASCII.GetBytes(content)))
- {
- IAsyncResult asyncResultCallback = null;
- using var callbackCalled = new ManualResetEventSlim(false);
- var asyncResult = client.BeginUploadFile(memoryStream, remoteFile, ar =>
- {
- asyncResultCallback = ar;
- callbackCalled.Set();
- });
- Assert.IsTrue(asyncResult.AsyncWaitHandle.WaitOne(10000));
- // check async result
- var sftpUploadAsyncResult = asyncResult as SftpUploadAsyncResult;
- Assert.IsNotNull(sftpUploadAsyncResult);
- Assert.IsFalse(sftpUploadAsyncResult.IsUploadCanceled);
- Assert.IsTrue(sftpUploadAsyncResult.IsCompleted);
- Assert.IsFalse(sftpUploadAsyncResult.CompletedSynchronously);
- Assert.AreEqual(expectedByteCount, sftpUploadAsyncResult.UploadedBytes);
- Assert.IsTrue(callbackCalled.Wait(10000));
- // check async result callback
- var sftpUploadAsyncResultCallback = asyncResultCallback as SftpUploadAsyncResult;
- Assert.IsNotNull(sftpUploadAsyncResultCallback);
- Assert.IsFalse(sftpUploadAsyncResultCallback.IsUploadCanceled);
- Assert.IsTrue(sftpUploadAsyncResultCallback.IsCompleted);
- Assert.IsFalse(sftpUploadAsyncResultCallback.CompletedSynchronously);
- Assert.AreEqual(expectedByteCount, sftpUploadAsyncResultCallback.UploadedBytes);
- }
- // check uploaded file
- using (var memoryStream = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, memoryStream);
- memoryStream.Position = 0;
- var remoteContent = Encoding.ASCII.GetString(memoryStream.ToArray());
- Assert.AreEqual(content, remoteContent);
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.Delete(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Create_ExistingFile()
- {
- var encoding = Encoding.UTF8;
- var initialContent = "Gert & Ann & Lisa";
- var newContent1 = "Sofie";
- var newContent1Bytes = GetBytesWithPreamble(newContent1, encoding);
- var newContent2 = "Lisa & Sofie";
- var newContent2Bytes = GetBytesWithPreamble(newContent2, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent);
- #region Write less bytes than the current content, overwriting part of that content
- using (var fs = client.Create(remoteFile))
- using (var sw = new StreamWriter(fs, encoding))
- {
- sw.Write(newContent1);
- }
- var actualContent1 = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(newContent1Bytes, actualContent1);
- #endregion Write less bytes than the current content, overwriting part of that content
- #region Write more bytes than the current content, overwriting and appending to that content
- using (var fs = client.Create(remoteFile))
- using (var sw = new StreamWriter(fs, encoding))
- {
- sw.Write(newContent2);
- }
- var actualContent2 = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(newContent2Bytes, actualContent2);
- #endregion Write more bytes than the current content, overwriting and appending to that content
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Create_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- SftpFileStream fs = null;
- try
- {
- fs = client.Create(remoteFile);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- fs?.Dispose();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Create_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.BufferSize = 512 * 1024;
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var imageStream = GetData("resources.issue #70.png"))
- {
- using (var fs = client.Create(remoteFile))
- {
- imageStream.CopyTo(fs);
- }
- using (var memoryStream = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, memoryStream);
- memoryStream.Position = 0;
- imageStream.Position = 0;
- Assert.AreEqual(CreateHash(imageStream), CreateHash(memoryStream));
- }
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllLines_NoEncoding_ExistingFile()
- {
- var initialContent = "\u0100ert & Ann";
- IEnumerable<string> linesToAppend = new[] { "Forever", "&", "\u0116ver" };
- var expectedContent = initialContent + string.Join(Environment.NewLine, linesToAppend) +
- Environment.NewLine;
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent);
- client.AppendAllLines(remoteFile, linesToAppend);
- var text = client.ReadAllText(remoteFile);
- Assert.AreEqual(expectedContent, text);
- // ensure we didn't write an UTF-8 BOM
- using (var fs = client.OpenRead(remoteFile))
- {
- var firstByte = fs.ReadByte();
- Assert.AreEqual(Encoding.UTF8.GetBytes(expectedContent)[0], firstByte);
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllLines_NoEncoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- IEnumerable<string> linesToAppend = new[] { "\u0139isa", "&", "Sofie" };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.AppendAllLines(remoteFile, linesToAppend);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllLines_NoEncoding_FileDoesNotExist()
- {
- IEnumerable<string> linesToAppend = new[] { "\u0139isa", "&", "Sofie" };
- var expectedContent = string.Join(Environment.NewLine, linesToAppend) + Environment.NewLine;
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.AppendAllLines(remoteFile, linesToAppend);
- var text = client.ReadAllText(remoteFile);
- Assert.AreEqual(expectedContent, text);
- // ensure we didn't write an UTF-8 BOM
- using (var fs = client.OpenRead(remoteFile))
- {
- var firstByte = fs.ReadByte();
- Assert.AreEqual(Encoding.UTF8.GetBytes(expectedContent)[0], firstByte);
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllText_NoEncoding_ExistingFile()
- {
- var initialContent = "\u0100ert & Ann";
- var contentToAppend = "Forever&\u0116ver";
- var expectedContent = initialContent + contentToAppend;
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent);
- client.AppendAllText(remoteFile, contentToAppend);
- var text = client.ReadAllText(remoteFile);
- Assert.AreEqual(expectedContent, text);
- // ensure we didn't write an UTF-8 BOM
- using (var fs = client.OpenRead(remoteFile))
- {
- var firstByte = fs.ReadByte();
- Assert.AreEqual(Encoding.UTF8.GetBytes(expectedContent)[0], firstByte);
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllText_NoEncoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- var contentToAppend = "Forever&\u0116ver";
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.AppendAllText(remoteFile, contentToAppend);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllText_NoEncoding_FileDoesNotExist()
- {
- var contentToAppend = "Forever&\u0116ver";
- var expectedContent = contentToAppend;
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.AppendAllText(remoteFile, contentToAppend);
- var text = client.ReadAllText(remoteFile);
- Assert.AreEqual(expectedContent, text);
- // ensure we didn't write an UTF-8 BOM
- using (var fs = client.OpenRead(remoteFile))
- {
- var firstByte = fs.ReadByte();
- Assert.AreEqual(Encoding.UTF8.GetBytes(expectedContent)[0], firstByte);
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendText_NoEncoding_ExistingFile()
- {
- var initialContent = "\u0100ert & Ann";
- var contentToAppend = "Forever&\u0116ver";
- var expectedContent = initialContent + contentToAppend;
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent);
- using (var sw = client.AppendText(remoteFile))
- {
- sw.Write(contentToAppend);
- }
- var text = client.ReadAllText(remoteFile);
- Assert.AreEqual(expectedContent, text);
- // ensure we didn't write an UTF-8 BOM
- using (var fs = client.OpenRead(remoteFile))
- {
- var firstByte = fs.ReadByte();
- Assert.AreEqual(Encoding.UTF8.GetBytes(expectedContent)[0], firstByte);
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendText_NoEncoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- StreamWriter sw = null;
- try
- {
- sw = client.AppendText(remoteFile);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- sw?.Dispose();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendText_NoEncoding_FileDoesNotExist()
- {
- var contentToAppend = "\u0100ert & Ann";
- var expectedContent = contentToAppend;
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var sw = client.AppendText(remoteFile))
- {
- sw.Write(contentToAppend);
- }
- // ensure we didn't write an UTF-8 BOM
- using (var fs = client.OpenRead(remoteFile))
- {
- var firstByte = fs.ReadByte();
- Assert.AreEqual(Encoding.UTF8.GetBytes(expectedContent)[0], firstByte);
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllLines_Encoding_ExistingFile()
- {
- var initialContent = "\u0100ert & Ann";
- IEnumerable<string> linesToAppend = new[] { "Forever", "&", "\u0116ver" };
- var expectedContent = initialContent + string.Join(Environment.NewLine, linesToAppend) +
- Environment.NewLine;
- var encoding = GetRandomEncoding();
- var expectedBytes = GetBytesWithPreamble(expectedContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent, encoding);
- client.AppendAllLines(remoteFile, linesToAppend, encoding);
- var text = client.ReadAllText(remoteFile, encoding);
- Assert.AreEqual(expectedContent, text);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(expectedBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllLines_Encoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- IEnumerable<string> linesToAppend = new[] { "Forever", "&", "\u0116ver" };
- var encoding = GetRandomEncoding();
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.AppendAllLines(remoteFile, linesToAppend, encoding);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllLines_Encoding_FileDoesNotExist()
- {
- IEnumerable<string> linesToAppend = new[] { "\u0139isa", "&", "Sofie" };
- var expectedContent = string.Join(Environment.NewLine, linesToAppend) + Environment.NewLine;
- var encoding = GetRandomEncoding();
- var expectedBytes = GetBytesWithPreamble(expectedContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.AppendAllLines(remoteFile, linesToAppend, encoding);
- var text = client.ReadAllText(remoteFile, encoding);
- Assert.AreEqual(expectedContent, text);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(expectedBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllText_Encoding_ExistingFile()
- {
- var initialContent = "\u0100ert & Ann";
- var contentToAppend = "Forever&\u0116ver";
- var expectedContent = initialContent + contentToAppend;
- var encoding = GetRandomEncoding();
- var expectedBytes = GetBytesWithPreamble(expectedContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent, encoding);
- client.AppendAllText(remoteFile, contentToAppend, encoding);
- var text = client.ReadAllText(remoteFile, encoding);
- Assert.AreEqual(expectedContent, text);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(expectedBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllText_Encoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- const string contentToAppend = "Forever&\u0116ver";
- var encoding = GetRandomEncoding();
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.AppendAllText(remoteFile, contentToAppend, encoding);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendAllText_Encoding_FileDoesNotExist()
- {
- const string contentToAppend = "Forever&\u0116ver";
- var expectedContent = contentToAppend;
- var encoding = GetRandomEncoding();
- var expectedBytes = GetBytesWithPreamble(expectedContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.AppendAllText(remoteFile, contentToAppend, encoding);
- var text = client.ReadAllText(remoteFile, encoding);
- Assert.AreEqual(expectedContent, text);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(expectedBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendText_Encoding_ExistingFile()
- {
- const string initialContent = "\u0100ert & Ann";
- const string contentToAppend = "Forever&\u0116ver";
- var expectedContent = initialContent + contentToAppend;
- var encoding = GetRandomEncoding();
- var expectedBytes = GetBytesWithPreamble(expectedContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent, encoding);
- using (var sw = client.AppendText(remoteFile, encoding))
- {
- sw.Write(contentToAppend);
- }
- var text = client.ReadAllText(remoteFile, encoding);
- Assert.AreEqual(expectedContent, text);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(expectedBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendText_Encoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- var encoding = GetRandomEncoding();
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- StreamWriter sw = null;
- try
- {
- sw = client.AppendText(remoteFile, encoding);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- sw?.Dispose();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_AppendText_Encoding_FileDoesNotExist()
- {
- var encoding = GetRandomEncoding();
- const string contentToAppend = "\u0100ert & Ann";
- var expectedBytes = GetBytesWithPreamble(contentToAppend, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var sw = client.AppendText(remoteFile, encoding))
- {
- sw.Write(contentToAppend);
- }
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(expectedBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_CreateText_NoEncoding_ExistingFile()
- {
- var encoding = new UTF8Encoding(false, true);
- const string initialContent = "\u0100ert & Ann";
- var initialContentBytes = GetBytesWithPreamble(initialContent, encoding);
- const string newContent = "\u0116ver";
- var newContentBytes = GetBytesWithPreamble(newContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent);
- Assert.AreEqual(initialContentBytes.Length, client.Get(remoteFile).Length);
- using (var sw = client.CreateText(remoteFile))
- {
- sw.Write(newContent);
- }
- // verify that the file was truncated
- Assert.AreEqual(newContentBytes.Length, client.Get(remoteFile).Length);
- var text = client.ReadAllText(remoteFile);
- Assert.AreEqual(newContent, text);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(newContentBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_CreateText_NoEncoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- StreamWriter sw = null;
- try
- {
- sw = client.CreateText(remoteFile);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- sw?.Dispose();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_CreateText_NoEncoding_FileDoesNotExist()
- {
- var encoding = new UTF8Encoding(false, true);
- var initialContent = "\u0100ert & Ann";
- var initialContentBytes = GetBytesWithPreamble(initialContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (client.CreateText(remoteFile))
- {
- }
- // verify that empty file was created
- Assert.IsTrue(client.Exists(remoteFile));
- var file = client.GetAttributes(remoteFile);
- Assert.AreEqual(0, file.Size);
- client.DeleteFile(remoteFile);
- using (var sw = client.CreateText(remoteFile))
- {
- sw.Write(initialContent);
- }
- // verify that content is written to file
- var text = client.ReadAllText(remoteFile);
- Assert.AreEqual(initialContent, text);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(initialContentBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_CreateText_Encoding_ExistingFile()
- {
- var encoding = GetRandomEncoding();
- var initialContent = "\u0100ert & Ann";
- var initialContentBytes = GetBytesWithPreamble(initialContent, encoding);
- var newContent = "\u0116ver";
- var newContentBytes = GetBytesWithPreamble(newContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent, encoding);
- Assert.AreEqual(initialContentBytes.Length, client.Get(remoteFile).Length);
- using (var sw = client.CreateText(remoteFile, encoding))
- {
- sw.Write(newContent);
- }
- // verify that the file was truncated
- Assert.AreEqual(newContentBytes.Length, client.Get(remoteFile).Length);
- var text = client.ReadAllText(remoteFile);
- Assert.AreEqual(newContent, text);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(newContentBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_CreateText_Encoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- var encoding = GetRandomEncoding();
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- StreamWriter sw = null;
- try
- {
- sw = client.CreateText(remoteFile, encoding);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- sw?.Dispose();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_CreateText_Encoding_FileDoesNotExist()
- {
- var encoding = GetRandomEncoding();
- var initialContent = "\u0100ert & Ann";
- var initialContentBytes = GetBytesWithPreamble(initialContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (client.CreateText(remoteFile, encoding))
- {
- }
- // verify that file containing only preamble was created
- Assert.IsTrue(client.Exists(remoteFile));
- var file = client.GetAttributes(remoteFile);
- Assert.AreEqual(encoding.GetPreamble().Length, file.Size);
- client.DeleteFile(remoteFile);
- using (var sw = client.CreateText(remoteFile, encoding))
- {
- sw.Write(initialContent);
- }
- // verify that content is written to file
- var text = client.ReadAllText(remoteFile, encoding);
- Assert.AreEqual(initialContent, text);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(initialContentBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_DownloadFile_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- using (var ms = new MemoryStream())
- {
- try
- {
- client.DownloadFile(remoteFile, ms);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- // ensure file was not created by us
- Assert.IsFalse(client.Exists(remoteFile));
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadAllBytes_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.ReadAllBytes(remoteFile);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- // ensure file was not created by us
- Assert.IsFalse(client.Exists(remoteFile));
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadAllLines_NoEncoding_ExistingFile()
- {
- var encoding = new UTF8Encoding(false, true);
- var lines = new[] { "\u0100ert & Ann", "Forever", "&", "\u0116ver" };
- var linesBytes = GetBytesWithPreamble(string.Join(Environment.NewLine, lines) + Environment.NewLine,
- encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var sw = client.AppendText(remoteFile))
- {
- for (var i = 0; i < lines.Length; i++)
- {
- sw.WriteLine(lines[i]);
- }
- }
- var actualLines = client.ReadAllLines(remoteFile);
- Assert.IsNotNull(actualLines);
- CollectionAssert.AreEqual(lines, actualLines);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadAllLines_NoEncoding_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.ReadAllLines(remoteFile);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- // ensure file was not created by us
- Assert.IsFalse(client.Exists(remoteFile));
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadAllLines_Encoding_ExistingFile()
- {
- var encoding = GetRandomEncoding();
- var lines = new[] { "\u0100ert & Ann", "Forever", "&", "\u0116ver" };
- var linesBytes = GetBytesWithPreamble(string.Join(Environment.NewLine, lines) + Environment.NewLine,
- encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var sw = client.AppendText(remoteFile, encoding))
- {
- for (var i = 0; i < lines.Length; i++)
- {
- sw.WriteLine(lines[i]);
- }
- }
- var actualLines = client.ReadAllLines(remoteFile, encoding);
- Assert.IsNotNull(actualLines);
- CollectionAssert.AreEqual(lines, actualLines);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadAllLines_Encoding_FileDoesNotExist()
- {
- var encoding = GetRandomEncoding();
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.ReadAllLines(remoteFile, encoding);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- // ensure file was not created by us
- Assert.IsFalse(client.Exists(remoteFile));
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadAllText_NoEncoding_ExistingFile()
- {
- var encoding = new UTF8Encoding(false, true);
- var lines = new[] { "\u0100ert & Ann", "Forever", "&", "\u0116ver" };
- var expectedText = string.Join(Environment.NewLine, lines) + Environment.NewLine;
- var expectedBytes = GetBytesWithPreamble(expectedText, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var sw = client.AppendText(remoteFile))
- {
- for (var i = 0; i < lines.Length; i++)
- {
- sw.WriteLine(lines[i]);
- }
- }
- var actualText = client.ReadAllText(remoteFile);
- Assert.AreEqual(expectedText, actualText);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(expectedBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadAllText_NoEncoding_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.ReadAllText(remoteFile);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- // ensure file was not created by us
- Assert.IsFalse(client.Exists(remoteFile));
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadAllText_Encoding_ExistingFile()
- {
- var encoding = GetRandomEncoding();
- var lines = new[] { "\u0100ert & Ann", "Forever", "&", "\u0116ver" };
- var expectedText = string.Join(Environment.NewLine, lines) + Environment.NewLine;
- var expectedBytes = GetBytesWithPreamble(expectedText, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var sw = client.AppendText(remoteFile, encoding))
- {
- for (var i = 0; i < lines.Length; i++)
- {
- sw.WriteLine(lines[i]);
- }
- }
- var actualText = client.ReadAllText(remoteFile, encoding);
- Assert.AreEqual(expectedText, actualText);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(expectedBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadAllText_Encoding_FileDoesNotExist()
- {
- var encoding = GetRandomEncoding();
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.ReadAllText(remoteFile, encoding);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- // ensure file was not created by us
- Assert.IsFalse(client.Exists(remoteFile));
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadLines_NoEncoding_ExistingFile()
- {
- var lines = new[] { "\u0100ert & Ann", "Forever", "&", "\u0116ver" };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var sw = client.AppendText(remoteFile))
- {
- for (var i = 0; i < lines.Length; i++)
- {
- sw.WriteLine(lines[i]);
- }
- }
- var actualLines = client.ReadLines(remoteFile);
- Assert.IsNotNull(actualLines);
- // These two lines together test double enumeration.
- Assert.AreEqual(lines[0], actualLines.First());
- CollectionAssert.AreEqual(lines, actualLines.ToArray());
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- [DataRow(false)]
- [DataRow(true)]
- public void Sftp_ReadLines_FileDoesNotExist(bool encoding)
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- // This exception should bubble up immediately
- var nullEx = encoding
- ? Assert.Throws<ArgumentNullException>(() => client.ReadLines(null, GetRandomEncoding()))
- : Assert.Throws<ArgumentNullException>(() => client.ReadLines(null));
- Assert.AreEqual("path", nullEx.ParamName);
- try
- {
- var ex = Assert.ThrowsExactly<SftpPathNotFoundException>(() =>
- {
- // The PathNotFound exception is permitted to bubble up only upon
- // enumerating.
- var lines = encoding
- ? client.ReadLines(remoteFile, GetRandomEncoding())
- : client.ReadLines(remoteFile);
- using var enumerator = lines.GetEnumerator();
- _ = enumerator.MoveNext();
- });
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- // ensure file was not created by us
- Assert.IsFalse(client.Exists(remoteFile));
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ReadLines_Encoding_ExistingFile()
- {
- var encoding = GetRandomEncoding();
- var lines = new[] { "\u0100ert & Ann", "Forever", "&", "\u0116ver" };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var sw = client.AppendText(remoteFile, encoding))
- {
- for (var i = 0; i < lines.Length; i++)
- {
- sw.WriteLine(lines[i]);
- }
- }
- var actualLines = client.ReadLines(remoteFile, encoding);
- Assert.IsNotNull(actualLines);
- // These two lines together test double enumeration.
- Assert.AreEqual(lines[0], actualLines.First());
- CollectionAssert.AreEqual(lines, actualLines.ToArray());
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllBytes_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- var content = GenerateRandom(size: 5);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllBytes(remoteFile, content);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllBytes_ExistingFile()
- {
- var initialContent = GenerateRandom(size: 13);
- var newContent1 = GenerateRandom(size: 5);
- var newContent2 = GenerateRandom(size: 50000);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var fs = client.Create(remoteFile))
- {
- fs.Write(initialContent, offset: 0, initialContent.Length);
- }
- #region Write less bytes than the current content, overwriting that content
- client.WriteAllBytes(remoteFile, newContent1);
- var actualContent1 = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(newContent1, actualContent1);
- #endregion
- #region Write more bytes than the current content, overwriting and appending to that content
- client.WriteAllBytes(remoteFile, newContent2);
- var actualContent2 = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(newContent2, actualContent2);
- #endregion
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllBytes_FileDoesNotExist()
- {
- var content = GenerateRandom(size: 13);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllBytes(remoteFile, content);
- var actualContent1 = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(content, actualContent1);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_IEnumerable_NoEncoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- IEnumerable<string> linesToWrite = new[] { "Forever", "&", "\u0116ver" };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllLines(remoteFile, linesToWrite);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_IEnumerable_NoEncoding_ExistingFile()
- {
- var encoding = new UTF8Encoding(false, true);
- var initialContent = "\u0100ert & Ann Forever & Ever Lisa & Sofie";
- IEnumerable<string> linesToWrite1 = new[] { "Forever", "&", "\u0116ver" };
- var linesToWrite1Bytes =
- GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite1) + Environment.NewLine, encoding);
- IEnumerable<string> linesToWrite2 = new[] { "Forever", "&", "\u0116ver", "Gert & Ann", "Lisa + Sofie" };
- var linesToWrite2Bytes =
- GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite2) + Environment.NewLine, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- // create initial content
- client.WriteAllText(remoteFile, initialContent);
- #region Write less bytes than the current content, overwriting that content
- client.WriteAllLines(remoteFile, linesToWrite1);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWrite1Bytes, actualBytes);
- #endregion
- #region Write more bytes than the current content, overwriting and appending to that content
- client.WriteAllLines(remoteFile, linesToWrite2);
- actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWrite2Bytes, actualBytes);
- #endregion Write more bytes than the current content, overwriting and appending to that content
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_IEnumerable_NoEncoding_FileDoesNotExist()
- {
- var encoding = new UTF8Encoding(false, true);
- IEnumerable<string> linesToWrite = new[] { "\u0139isa", "&", "Sofie" };
- var linesToWriteBytes = GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite) + Environment.NewLine, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllLines(remoteFile, linesToWrite);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWriteBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_IEnumerable_Encoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- var encoding = GetRandomEncoding();
- IEnumerable<string> linesToWrite = new[] { "Forever", "&", "\u0116ver" };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllLines(remoteFile, linesToWrite, encoding);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_IEnumerable_Encoding_ExistingFile()
- {
- var encoding = GetRandomEncoding();
- const string initialContent = "\u0100ert & Ann Forever & Ever Lisa & Sofie";
- IEnumerable<string> linesToWrite1 = new[] { "Forever", "&", "\u0116ver" };
- var linesToWrite1Bytes =
- GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite1) + Environment.NewLine, encoding);
- IEnumerable<string> linesToWrite2 = new[] { "Forever", "&", "\u0116ver", "Gert & Ann", "Lisa + Sofie" };
- var linesToWrite2Bytes = GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite2) + Environment.NewLine, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- // create initial content
- client.WriteAllText(remoteFile, initialContent, encoding);
- #region Write less bytes than the current content, overwriting that content
- client.WriteAllLines(remoteFile, linesToWrite1, encoding);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWrite1Bytes, actualBytes);
- #endregion
- #region Write more bytes than the current content, overwriting and appending to that content
- client.WriteAllLines(remoteFile, linesToWrite2, encoding);
- actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWrite2Bytes, actualBytes);
- #endregion Write more bytes than the current content, overwriting and appending to that content
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_IEnumerable_Encoding_FileDoesNotExist()
- {
- var encoding = GetRandomEncoding();
- IEnumerable<string> linesToWrite = new[] { "\u0139isa", "&", "Sofie" };
- var linesToWriteBytes = GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite) + Environment.NewLine, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllLines(remoteFile, linesToWrite, encoding);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWriteBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_Array_NoEncoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- var linesToWrite = new[] { "Forever", "&", "\u0116ver" };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllLines(remoteFile, linesToWrite);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_Array_NoEncoding_ExistingFile()
- {
- var encoding = new UTF8Encoding(false, true);
- const string initialContent = "\u0100ert & Ann Forever & Ever Lisa & Sofie";
- var linesToWrite1 = new[] { "Forever", "&", "\u0116ver" };
- var linesToWrite1Bytes = GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite1) + Environment.NewLine, encoding);
- var linesToWrite2 = new[] { "Forever", "&", "\u0116ver", "Gert & Ann", "Lisa + Sofie" };
- var linesToWrite2Bytes = GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite2) + Environment.NewLine, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- // create initial content
- client.WriteAllText(remoteFile, initialContent);
- #region Write less bytes than the current content, overwriting that content
- client.WriteAllLines(remoteFile, linesToWrite1);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWrite1Bytes, actualBytes);
- #endregion
- #region Write more bytes than the current content, overwriting and appending to that content
- client.WriteAllLines(remoteFile, linesToWrite2);
- actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWrite2Bytes, actualBytes);
- #endregion Write more bytes than the current content, overwriting and appending to that content
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_Array_NoEncoding_FileDoesNotExist()
- {
- var encoding = new UTF8Encoding(false, true);
- var linesToWrite = new[] { "\u0139isa", "&", "Sofie" };
- var linesToWriteBytes = GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite) + Environment.NewLine, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllLines(remoteFile, linesToWrite);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWriteBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_Array_Encoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- var encoding = GetRandomEncoding();
- var linesToWrite = new[] { "Forever", "&", "\u0116ver" };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllLines(remoteFile, linesToWrite, encoding);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_Array_Encoding_ExistingFile()
- {
- const string initialContent = "\u0100ert & Ann Forever & Ever Lisa & Sofie";
- var encoding = GetRandomEncoding();
- var linesToWrite1 = new[] { "Forever", "&", "\u0116ver" };
- var linesToWrite1Bytes = GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite1) + Environment.NewLine, encoding);
- var linesToWrite2 = new[] { "Forever", "&", "\u0116ver", "Gert & Ann", "Lisa + Sofie" };
- var linesToWrite2Bytes = GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite2) + Environment.NewLine, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- // create initial content
- client.WriteAllText(remoteFile, initialContent, encoding);
- #region Write less bytes than the current content, overwriting that content
- client.WriteAllLines(remoteFile, linesToWrite1, encoding);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWrite1Bytes, actualBytes);
- #endregion
- #region Write more bytes than the current content, overwriting and appending to that content
- client.WriteAllLines(remoteFile, linesToWrite2, encoding);
- actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWrite2Bytes, actualBytes);
- #endregion
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllLines_Array_Encoding_FileDoesNotExist()
- {
- var encoding = GetRandomEncoding();
- var linesToWrite = new[] { "\u0139isa", "&", "Sofie" };
- var linesToWriteBytes = GetBytesWithPreamble(string.Join(Environment.NewLine, linesToWrite) + Environment.NewLine, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllLines(remoteFile, linesToWrite, encoding);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(linesToWriteBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllText_NoEncoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- const string initialContent = "\u0100ert & Ann Forever & \u0116ver Lisa & Sofie";
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllText_NoEncoding_ExistingFile()
- {
- const string initialContent = "\u0100ert & Ann Forever & \u0116ver Lisa & Sofie";
- const string newContent1 = "For\u0116ver & Ever";
- var encoding = new UTF8Encoding(false, true);
- var newContent1Bytes = GetBytesWithPreamble(newContent1, encoding);
- var newContent2 = "Sofie & Lisa For\u0116ver & Ever with \u0100ert & Ann";
- var newContent2Bytes = GetBytesWithPreamble(newContent2, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent);
- #region Write less bytes than the current content, overwriting that content
- client.WriteAllText(remoteFile, newContent1);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(newContent1Bytes, actualBytes);
- #endregion
- #region Write more bytes than the current content, overwriting and appending to that content
- client.WriteAllText(remoteFile, newContent2);
- actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(newContent2Bytes, actualBytes);
- #endregion Write more bytes than the current content, overwriting and appending to that content
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllText_NoEncoding_FileDoesNotExist()
- {
- const string initialContent = "\u0100ert & Ann Forever & \u0116ver Lisa & Sofie";
- var encoding = new UTF8Encoding(false, true);
- var initialContentBytes = GetBytesWithPreamble(initialContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(initialContentBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllText_Encoding_DirectoryDoesNotExist()
- {
- const string remoteFile = "/home/sshnet/directorydoesnotexist/test";
- var encoding = GetRandomEncoding();
- const string content = "For\u0116ver & Ever";
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, content, encoding);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllText_Encoding_ExistingFile()
- {
- const string initialContent = "\u0100ert & Ann Forever & \u0116ver Lisa & Sofie";
- const string newContent1 = "For\u0116ver & Ever";
- const string newContent2 = "Sofie & Lisa For\u0116ver & Ever with \u0100ert & Ann";
- var encoding = GetRandomEncoding();
- var newContent1Bytes = GetBytesWithPreamble(newContent1, encoding);
- var newContent2Bytes = GetBytesWithPreamble(newContent2, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent, encoding);
- #region Write less bytes than the current content, overwriting that content
- client.WriteAllText(remoteFile, newContent1, encoding);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(newContent1Bytes, actualBytes);
- #endregion
- #region Write more bytes than the current content, overwriting and appending to that content
- client.WriteAllText(remoteFile, newContent2, encoding);
- actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(newContent2Bytes, actualBytes);
- #endregion Write more bytes than the current content, overwriting and appending to that content
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_WriteAllText_Encoding_FileDoesNotExist()
- {
- const string initialContent = "\u0100ert & Ann Forever & \u0116ver Lisa & Sofie";
- var encoding = GetRandomEncoding();
- var initialContentBytes = GetBytesWithPreamble(initialContent, encoding);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, initialContent, encoding);
- var actualBytes = client.ReadAllBytes(remoteFile);
- CollectionAssert.AreEqual(initialContentBytes, actualBytes);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginDownloadFile_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var ms = new MemoryStream())
- {
- var asyncResult = client.BeginDownloadFile(remoteFile, ms);
- try
- {
- client.EndDownloadFile(asyncResult);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteFile}'.", ex.Message);
- Assert.AreEqual(remoteFile, ex.Path);
- // ensure file was not created by us
- Assert.IsFalse(client.Exists(remoteFile));
- }
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginListDirectory_DirectoryDoesNotExist()
- {
- const string remoteDirectory = "/home/sshnet/test123";
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- command.Execute();
- }
- }
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var asyncResult = client.BeginListDirectory(remoteDirectory, null, null);
- try
- {
- client.EndListDirectory(asyncResult);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual($"No such file. Path: '{remoteDirectory}'.", ex.Message);
- Assert.AreEqual(remoteDirectory, ex.Path);
- // ensure directory was not created by us
- Assert.IsFalse(client.Exists(remoteDirectory));
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginUploadFile_InputAndPath_DirectoryDoesNotExist()
- {
- const int size = 50 * 1024 * 1024;
- const string remoteDirectory = "/home/sshnet/test123";
- const string remoteFile = remoteDirectory + "/test";
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- command.Execute();
- }
- }
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var memoryStream = CreateMemoryStream(size);
- memoryStream.Position = 0;
- var asyncResult = client.BeginUploadFile(memoryStream, remoteFile);
- try
- {
- client.EndUploadFile(asyncResult);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException)
- {
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginUploadFile_InputAndPath_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- var uploadMemoryStream = new MemoryStream();
- var sw = new StreamWriter(uploadMemoryStream, Encoding.UTF8);
- sw.Write("Gert & Ann");
- sw.Flush();
- uploadMemoryStream.Position = 0;
- var asyncResult = client.BeginUploadFile(uploadMemoryStream, remoteFile);
- client.EndUploadFile(asyncResult);
- using (var downloadMemoryStream = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloadMemoryStream);
- downloadMemoryStream.Position = 0;
- using (var sr = new StreamReader(downloadMemoryStream, Encoding.UTF8))
- {
- var content = sr.ReadToEnd();
- Assert.AreEqual("Gert & Ann", content);
- }
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginUploadFile_InputAndPath_ExistingFile()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, "Gert & Ann & Lisa");
- var uploadMemoryStream = new MemoryStream();
- var sw = new StreamWriter(uploadMemoryStream, Encoding.UTF8);
- sw.Write("Ann & Gert");
- sw.Flush();
- uploadMemoryStream.Position = 0;
- var asyncResult = client.BeginUploadFile(uploadMemoryStream, remoteFile);
- client.EndUploadFile(asyncResult);
- using (var downloadMemoryStream = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloadMemoryStream);
- downloadMemoryStream.Position = 0;
- using (var sr = new StreamReader(downloadMemoryStream, Encoding.UTF8))
- {
- var content = sr.ReadToEnd();
- Assert.AreEqual("Ann & Gert", content);
- }
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginUploadFile_InputAndPathAndCanOverride_CanOverrideIsFalse_DirectoryDoesNotExist()
- {
- const int size = 50 * 1024 * 1024;
- const string remoteDirectory = "/home/sshnet/test123";
- const string remoteFile = remoteDirectory + "/test";
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- command.Execute();
- }
- }
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var memoryStream = CreateMemoryStream(size);
- memoryStream.Position = 0;
- var asyncResult = client.BeginUploadFile(memoryStream, remoteFile, false, null, null);
- try
- {
- client.EndUploadFile(asyncResult);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException)
- {
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginUploadFile_InputAndPathAndCanOverride_CanOverrideIsFalse_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var uploadMemoryStream = new MemoryStream())
- using (var sw = new StreamWriter(uploadMemoryStream, Encoding.UTF8))
- {
- sw.Write("Gert & Ann");
- sw.Flush();
- uploadMemoryStream.Position = 0;
- var asyncResult = client.BeginUploadFile(uploadMemoryStream, remoteFile, false, null, null);
- client.EndUploadFile(asyncResult);
- }
- using (var downloadMemoryStream = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloadMemoryStream);
- downloadMemoryStream.Position = 0;
- using (var sr = new StreamReader(downloadMemoryStream, Encoding.UTF8))
- {
- var content = sr.ReadToEnd();
- Assert.AreEqual("Gert & Ann", content);
- }
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginUploadFile_InputAndPathAndCanOverride_CanOverrideIsFalse_ExistingFile()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, "Gert & Ann & Lisa");
- var uploadMemoryStream = new MemoryStream();
- var sw = new StreamWriter(uploadMemoryStream, Encoding.UTF8);
- sw.Write("Ann & Gert");
- sw.Flush();
- uploadMemoryStream.Position = 0;
- var asyncResult = client.BeginUploadFile(uploadMemoryStream, remoteFile, false, null, null);
- var ex = Assert.Throws<SftpException>(() => client.EndUploadFile(asyncResult));
- Assert.AreEqual(StatusCode.Failure, ex.StatusCode);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginUploadFile_InputAndPathAndCanOverride_CanOverrideIsTrue_DirectoryDoesNotExist()
- {
- const int size = 50 * 1024 * 1024;
- const string remoteDirectory = "/home/sshnet/test123";
- const string remoteFile = remoteDirectory + "/test";
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- command.Execute();
- }
- }
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var memoryStream = CreateMemoryStream(size);
- memoryStream.Position = 0;
- var asyncResult = client.BeginUploadFile(memoryStream, remoteFile, true, null, null);
- try
- {
- client.EndUploadFile(asyncResult);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException)
- {
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginUploadFile_InputAndPathAndCanOverride_CanOverrideIsTrue_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var uploadMemoryStream = new MemoryStream())
- using (var sw = new StreamWriter(uploadMemoryStream, Encoding.UTF8))
- {
- sw.Write("Gert & Ann");
- sw.Flush();
- uploadMemoryStream.Position = 0;
- var asyncResult = client.BeginUploadFile(uploadMemoryStream, remoteFile, true, null, null);
- client.EndUploadFile(asyncResult);
- }
- using (var downloadMemoryStream = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloadMemoryStream);
- downloadMemoryStream.Position = 0;
- using (var sr = new StreamReader(downloadMemoryStream, Encoding.UTF8))
- {
- var content = sr.ReadToEnd();
- Assert.AreEqual("Gert & Ann", content);
- }
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_BeginUploadFile_InputAndPathAndCanOverride_CanOverrideIsTrue_ExistingFile()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllText(remoteFile, "Gert & Ann & Lisa");
- using (var uploadMemoryStream = new MemoryStream())
- using (var sw = new StreamWriter(uploadMemoryStream, Encoding.UTF8))
- {
- sw.Write("Ann & Gert");
- sw.Flush();
- uploadMemoryStream.Position = 0;
- var asyncResult = client.BeginUploadFile(uploadMemoryStream, remoteFile, true, null, null);
- client.EndUploadFile(asyncResult);
- }
- using (var downloadMemoryStream = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloadMemoryStream);
- downloadMemoryStream.Position = 0;
- using (var sr = new StreamReader(downloadMemoryStream, Encoding.UTF8))
- {
- var content = sr.ReadToEnd();
- Assert.AreEqual("Ann & Gert", content);
- }
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_UploadAndDownloadBigFile()
- {
- const int size = 50 * 1024 * 1024;
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.Delete(remoteFile);
- }
- try
- {
- var memoryStream = CreateMemoryStream(size);
- memoryStream.Position = 0;
- var expectedHash = CreateHash(memoryStream);
- memoryStream.Position = 0;
- client.UploadFile(memoryStream, remoteFile);
- memoryStream.SetLength(0);
- var stopwatch = new Stopwatch();
- stopwatch.Start();
- client.DownloadFile(remoteFile, memoryStream);
- stopwatch.Stop();
- Assert.AreEqual(size, memoryStream.Length);
- memoryStream.Position = 0;
- var actualHash = CreateHash(memoryStream);
- Assert.AreEqual(expectedHash, actualHash);
- Console.WriteLine(@"Elapsed: {0} ms", stopwatch.ElapsedMilliseconds);
- Console.WriteLine(@"Transfer speed: {0:N2} KB/s",
- CalculateTransferSpeed(memoryStream.Length, stopwatch.ElapsedMilliseconds));
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.Delete(remoteFile);
- }
- }
- }
- }
- /// <summary>
- /// Issue 1672
- /// </summary>
- [TestMethod]
- public void Sftp_CurrentWorkingDirectory()
- {
- const string homeDirectory = "/home/sshnet";
- const string otherDirectory = homeDirectory + "/dir";
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- if (client.Exists(otherDirectory))
- {
- client.DeleteDirectory(otherDirectory);
- }
- try
- {
- client.CreateDirectory(otherDirectory);
- client.ChangeDirectory(otherDirectory);
- using (var s = CreateStreamWithContent("A"))
- {
- client.UploadFile(s, "a.txt");
- }
- using (var s = new MemoryStream())
- {
- client.DownloadFile("a.txt", s);
- s.Position = 0;
- var content = Encoding.ASCII.GetString(s.ToArray());
- Assert.AreEqual("A", content);
- }
- Assert.IsTrue(client.Exists(otherDirectory + "/a.txt"));
- client.DeleteFile("a.txt");
- Assert.IsFalse(client.Exists(otherDirectory + "/a.txt"));
- client.DeleteDirectory(".");
- Assert.IsFalse(client.Exists(otherDirectory));
- }
- finally
- {
- if (client.Exists(otherDirectory))
- {
- client.DeleteDirectory(otherDirectory);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Exists()
- {
- const string remoteHome = "/home/sshnet";
- #region Setup
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- #region Clean-up
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/DoesNotExist"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/symlink.to.directory.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/directory.exists"}")
- )
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/symlink.to.file.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -f {remoteHome + "/file.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- #endregion Clean-up
- #region Setup
- using (var command = client.CreateCommand($"touch {remoteHome + "/file.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"mkdir {remoteHome + "/directory.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"ln -s {remoteHome + "/file.exists"} {remoteHome + "/symlink.to.file.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"ln -s {remoteHome + "/directory.exists"} {remoteHome + "/symlink.to.directory.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- #endregion Setup
- }
- #endregion Setup
- #region Assert
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- Assert.IsFalse(client.Exists(remoteHome + "/DoesNotExist"));
- Assert.IsTrue(client.Exists(remoteHome + "/file.exists"));
- Assert.IsTrue(client.Exists(remoteHome + "/symlink.to.file.exists"));
- Assert.IsTrue(client.Exists(remoteHome + "/directory.exists"));
- Assert.IsTrue(client.Exists(remoteHome + "/symlink.to.directory.exists"));
- }
- #endregion Assert
- #region Teardown
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/DoesNotExist"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/symlink.to.directory.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/directory.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/symlink.to.file.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -f {remoteHome + "/file.exists"}"))
- {
- command.Execute();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- }
- #endregion Teardown
- }
- [TestMethod]
- public async Task Sftp_ExistsAsync()
- {
- const string remoteHome = "/home/sshnet";
- #region Setup
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- #region Clean-up
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/DoesNotExist"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/symlink.to.directory.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/directory.exists"}")
- )
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/symlink.to.file.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -f {remoteHome + "/file.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- #endregion Clean-up
- #region Setup
- using (var command = client.CreateCommand($"touch {remoteHome + "/file.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"mkdir {remoteHome + "/directory.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"ln -s {remoteHome + "/file.exists"} {remoteHome + "/symlink.to.file.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"ln -s {remoteHome + "/directory.exists"} {remoteHome + "/symlink.to.directory.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- #endregion Setup
- }
- #endregion Setup
- #region Assert
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- await client.ConnectAsync(default).ConfigureAwait(false);
- Assert.IsFalse(await client.ExistsAsync(remoteHome + "/DoesNotExist"));
- Assert.IsTrue(await client.ExistsAsync(remoteHome + "/file.exists"));
- Assert.IsTrue(await client.ExistsAsync(remoteHome + "/symlink.to.file.exists"));
- Assert.IsTrue(await client.ExistsAsync(remoteHome + "/directory.exists"));
- Assert.IsTrue(await client.ExistsAsync(remoteHome + "/symlink.to.directory.exists"));
- }
- #endregion Assert
- #region Teardown
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/DoesNotExist"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/symlink.to.directory.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/directory.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -Rf {remoteHome + "/symlink.to.file.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- using (var command = client.CreateCommand($"rm -f {remoteHome + "/file.exists"}"))
- {
- await command.ExecuteAsync();
- Assert.AreEqual(0, command.ExitStatus, command.Error);
- }
- }
- #endregion Teardown
- }
- [TestMethod]
- public void Sftp_ListDirectory()
- {
- const string remoteDirectory = "/home/sshnet/test123";
- try
- {
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- client.RunCommand($@"rm -Rf ""{remoteDirectory}""");
- client.RunCommand($@"mkdir -p ""{remoteDirectory}""");
- client.RunCommand($@"mkdir -p ""{remoteDirectory}/sub""");
- client.RunCommand($@"touch ""{remoteDirectory}/file1""");
- client.RunCommand($@"touch ""{remoteDirectory}/file2""");
- }
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- client.ChangeDirectory(remoteDirectory);
- var directoryContent = client.ListDirectory(".").OrderBy(p => p.Name).ToList();
- Assert.AreEqual(5, directoryContent.Count);
- Assert.AreEqual(".", directoryContent[0].Name);
- Assert.AreEqual($"{remoteDirectory}/.", directoryContent[0].FullName);
- Assert.IsTrue(directoryContent[0].IsDirectory);
- Assert.AreEqual("..", directoryContent[1].Name);
- Assert.AreEqual($"{remoteDirectory}/..", directoryContent[1].FullName);
- Assert.IsTrue(directoryContent[1].IsDirectory);
- Assert.AreEqual("file1", directoryContent[2].Name);
- Assert.AreEqual($"{remoteDirectory}/file1", directoryContent[2].FullName);
- Assert.IsFalse(directoryContent[2].IsDirectory);
- Assert.AreEqual("file2", directoryContent[3].Name);
- Assert.AreEqual($"{remoteDirectory}/file2", directoryContent[3].FullName);
- Assert.IsFalse(directoryContent[3].IsDirectory);
- Assert.AreEqual("sub", directoryContent[4].Name);
- Assert.AreEqual($"{remoteDirectory}/sub", directoryContent[4].FullName);
- Assert.IsTrue(directoryContent[4].IsDirectory);
- }
- }
- finally
- {
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- command.Execute();
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_ChangeDirectory_DirectoryDoesNotExist()
- {
- const string remoteDirectory = "/home/sshnet/test123";
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- command.Execute();
- }
- }
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- try
- {
- client.ChangeDirectory(remoteDirectory);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException)
- {
- }
- }
- }
- [TestMethod]
- public async Task Sftp_ChangeDirectory_DirectoryDoesNotExistAsync()
- {
- const string remoteDirectory = "/home/sshnet/test123";
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- await client.ConnectAsync(CancellationToken.None).ConfigureAwait(false);
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- await command.ExecuteAsync(CancellationToken.None).ConfigureAwait(false);
- }
- }
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- try
- {
- await client.ChangeDirectoryAsync(remoteDirectory, CancellationToken.None).ConfigureAwait(false);
- Assert.Fail();
- }
- catch (SftpPathNotFoundException)
- {
- }
- }
- }
- [TestMethod]
- public void Sftp_ChangeDirectory_DirectoryExists()
- {
- const string remoteDirectory = "/home/sshnet/test123";
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- command.Execute();
- }
- using (var command = client.CreateCommand("mkdir -p " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- command.Execute();
- }
- }
- try
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- client.ChangeDirectory(remoteDirectory);
- Assert.AreEqual(remoteDirectory, client.WorkingDirectory);
- using (var uploadStream = CreateMemoryStream(100))
- {
- uploadStream.Position = 0;
- client.UploadFile(uploadStream, "gert.txt");
- uploadStream.Position = 0;
- using (var downloadStream = client.OpenRead(remoteDirectory + "/gert.txt"))
- {
- Assert.AreEqual(CreateHash(uploadStream), CreateHash(downloadStream));
- }
- }
- }
- }
- finally
- {
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- command.Execute();
- }
- }
- }
- }
- [TestMethod]
- public async Task Sftp_ChangeDirectory_DirectoryExistsAsync()
- {
- const string remoteDirectory = "/home/sshnet/test123";
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- await client.ConnectAsync(CancellationToken.None).ConfigureAwait(false);
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- await command.ExecuteAsync(CancellationToken.None).ConfigureAwait(false);
- }
- using (var command = client.CreateCommand("mkdir -p " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- await command.ExecuteAsync(CancellationToken.None).ConfigureAwait(false);
- }
- }
- try
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- await client.ConnectAsync(CancellationToken.None).ConfigureAwait(false);
- await client.ChangeDirectoryAsync(remoteDirectory, CancellationToken.None).ConfigureAwait(false);
- Assert.AreEqual(remoteDirectory, client.WorkingDirectory);
- using (var uploadStream = CreateMemoryStream(100))
- {
- uploadStream.Position = 0;
- await client.UploadFileAsync(uploadStream, "gert.txt").ConfigureAwait(false);
- uploadStream.Position = 0;
- using (var downloadStream = client.OpenRead(remoteDirectory + "/gert.txt"))
- {
- Assert.AreEqual(CreateHash(uploadStream), CreateHash(downloadStream));
- }
- }
- }
- }
- finally
- {
- using (var client = new SshClient(_connectionInfoFactory.Create()))
- {
- await client.ConnectAsync(CancellationToken.None).ConfigureAwait(false);
- using (var command = client.CreateCommand("rm -Rf " + _remotePathTransformation.Transform(remoteDirectory)))
- {
- await command.ExecuteAsync(CancellationToken.None).ConfigureAwait(false);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_SubsystemExecution_Failed()
- {
- var remoteSshdConfig = new RemoteSshd(_adminConnectionInfoFactory).OpenConfig();
- // Disable SFTP subsystem
- remoteSshdConfig.ClearSubsystems()
- .Update()
- .Restart();
- var remoteSshdReconfiguredToDefaultState = false;
- try
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- try
- {
- client.Connect();
- Assert.Fail("Establishing SFTP connection should have failed.");
- }
- catch (SshException ex)
- {
- Assert.IsNull(ex.InnerException);
- Assert.AreEqual("Subsystem 'sftp' could not be executed.", ex.Message);
- }
- // Re-enable SFTP subsystem
- remoteSshdConfig.Reset();
- remoteSshdReconfiguredToDefaultState = true;
- // ensure we can reconnect the same SftpClient instance
- client.Connect();
- // ensure SFTP session is correctly established
- Assert.IsTrue(client.Exists("."));
- }
- }
- finally
- {
- if (!remoteSshdReconfiguredToDefaultState)
- {
- remoteSshdConfig.Reset();
- }
- }
- }
- [TestMethod]
- public void Sftp_SftpFileStream_ReadAndWrite()
- {
- TestReadAndWrite(
- (s, buffer, offset, count) => s.Read(buffer, offset, count),
- (s, buffer, offset, count) => s.Write(buffer, offset, count));
- }
- [TestMethod]
- public void Sftp_SftpFileStream_ReadAndWriteByte()
- {
- TestReadAndWrite(
- read: (s, buffer, offset, count) =>
- {
- int bytesRead = 0;
- int b;
- while (bytesRead < count && (b = s.ReadByte()) != -1)
- {
- buffer[offset + bytesRead] = (byte)b;
- bytesRead++;
- }
- return bytesRead;
- },
- write: (s, buffer, offset, count) =>
- {
- for (int i = 0; i < count; i++)
- {
- s.WriteByte(buffer[offset + i]);
- }
- });
- }
- [TestMethod]
- public void Sftp_SftpFileStream_ReadAndWriteAsync()
- {
- TestReadAndWrite(
- (s, buffer, offset, count) => s.ReadAsync(buffer, offset, count).GetAwaiter().GetResult(),
- (s, buffer, offset, count) => s.WriteAsync(buffer, offset, count).GetAwaiter().GetResult());
- }
- [TestMethod]
- public void Sftp_SftpFileStream_ReadAndWriteBeginEnd()
- {
- TestReadAndWrite(
- (s, buffer, offset, count) => s.EndRead(s.BeginRead(buffer, offset, count, null, null)),
- (s, buffer, offset, count) => s.EndWrite(s.BeginWrite(buffer, offset, count, null, null)));
- }
- #if NET
- [TestMethod]
- public void Sftp_SftpFileStream_ReadAndWriteSpan()
- {
- TestReadAndWrite(
- (s, buffer, offset, count) => s.Read(buffer.AsSpan(offset, count)),
- (s, buffer, offset, count) => s.Write(buffer.AsSpan(offset, count)));
- }
- [TestMethod]
- public void Sftp_SftpFileStream_ReadAndWriteAsyncMemory()
- {
- TestReadAndWrite(
- (s, buffer, offset, count) => s.ReadAsync(buffer.AsMemory(offset, count)).AsTask().GetAwaiter().GetResult(),
- (s, buffer, offset, count) => s.WriteAsync(buffer.AsMemory(offset, count)).AsTask().GetAwaiter().GetResult());
- }
- #endif
- private void TestReadAndWrite(
- Func<SftpFileStream, byte[], int, int, int> read,
- Action<SftpFileStream, byte[], int, int> write)
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var s = client.Open(remoteFile, FileMode.CreateNew, FileAccess.Write))
- {
- Assert.IsFalse(s.CanRead);
- Assert.IsTrue(s.CanWrite);
- write(s, new byte[] { 5, 4, 3, 2, 1 }, 1, 3);
- }
- // switch from read to write mode
- using (var s = client.Open(remoteFile, FileMode.Open, FileAccess.ReadWrite))
- {
- Assert.IsTrue(s.CanRead);
- Assert.IsTrue(s.CanWrite);
- Assert.AreEqual(4, ReadByte(s));
- Assert.AreEqual(3, ReadByte(s));
- Assert.AreEqual(2, s.Position);
- WriteByte(s, 7);
- write(s, new byte[] { 8, 9, 10, 11, 12 }, 1, 3);
- Assert.AreEqual(6, s.Position);
- }
- using (var s = client.Open(remoteFile, FileMode.Open, FileAccess.Read))
- {
- Assert.IsTrue(s.CanRead);
- Assert.IsFalse(s.CanWrite);
- Assert.AreEqual(6, s.Length);
- var buffer = new byte[s.Length];
- Assert.AreEqual(6, read(s, buffer, 0, buffer.Length));
- CollectionAssert.AreEqual(new byte[] { 4, 3, 7, 9, 10, 11 }, buffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, ReadByte(s));
- }
- // switch from read to write mode, and back to read mode and finally
- // append a byte
- using (var s = client.Open(remoteFile, FileMode.Open, FileAccess.ReadWrite))
- {
- Assert.AreEqual(4, ReadByte(s));
- Assert.AreEqual(3, ReadByte(s));
- Assert.AreEqual(7, ReadByte(s));
- write(s, new byte[] { 0, 1, 6, 4 }, 1, 2);
- Assert.AreEqual(11, ReadByte(s));
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, ReadByte(s));
- WriteByte(s, 12);
- }
- // switch from write to read mode, and back to write mode
- using (var s = client.Open(remoteFile, FileMode.Open, FileAccess.ReadWrite))
- {
- WriteByte(s, 5);
- Assert.AreEqual(3, ReadByte(s));
- WriteByte(s, 13);
- Assert.AreEqual(3, s.Position);
- }
- using (var s = client.Open(remoteFile, FileMode.Open, FileAccess.Read))
- {
- Assert.AreEqual(7, s.Length);
- var buffer = new byte[s.Length];
- Assert.AreEqual(7, read(s, buffer, 0, buffer.Length));
- CollectionAssert.AreEqual(new byte[] { 5, 3, 13, 1, 6, 11, 12 }, buffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, ReadByte(s));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- int ReadByte(SftpFileStream s)
- {
- var buffer = new byte[1];
- var bytesRead = read(s, buffer, 0, 1);
- return bytesRead == 0 ? -1 : buffer[0];
- }
- void WriteByte(SftpFileStream s, byte b)
- {
- write(s, [b], 0, 1);
- }
- }
- [TestMethod]
- public void Sftp_SftpFileStream_SetLength_ReduceLength()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var s = client.Open(remoteFile, FileMode.CreateNew, FileAccess.Write))
- {
- s.Write(new byte[] { 5, 4, 3, 2, 1 }, 1, 3);
- }
- // reduce length while in write mode, with data in write buffer, and before
- // current position
- using (var s = client.Open(remoteFile, FileMode.Append, FileAccess.Write))
- {
- s.Position = 3;
- s.Write(new byte[] { 6, 7, 8, 9 }, offset: 0, count: 4);
- Assert.AreEqual(7, s.Position);
- // verify buffer has not yet been flushed
- using (var fs = client.Open(remoteFile, FileMode.Open, FileAccess.Read))
- {
- Assert.AreEqual(4, fs.ReadByte());
- Assert.AreEqual(3, fs.ReadByte());
- Assert.AreEqual(2, fs.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- s.SetLength(5);
- Assert.AreEqual(5, s.Position);
- // verify that buffer was flushed and size has been modified
- using (var fs = client.Open(remoteFile, FileMode.Open, FileAccess.Read))
- {
- Assert.AreEqual(4, fs.ReadByte());
- Assert.AreEqual(3, fs.ReadByte());
- Assert.AreEqual(2, fs.ReadByte());
- Assert.AreEqual(6, fs.ReadByte());
- Assert.AreEqual(7, fs.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- s.WriteByte(1);
- }
- // verify that last byte was correctly written to the file
- using (var s = client.Open(remoteFile, FileMode.Open, FileAccess.Read))
- {
- Assert.AreEqual(6, s.Length);
- var buffer = new byte[s.Length + 2];
- Assert.AreEqual(6, s.Read(buffer, offset: 0, buffer.Length));
- CollectionAssert.AreEqual(new byte[] { 4, 3, 2, 6, 7, 1, 0, 0 }, buffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, s.ReadByte());
- }
- // reduce length while in read mode, but beyond current position
- using (var s = client.Open(remoteFile, FileMode.Open, FileAccess.ReadWrite))
- {
- var buffer = new byte[1];
- Assert.AreEqual(1, s.Read(buffer, offset: 0, buffer.Length));
- CollectionAssert.AreEqual(new byte[] { 4 }, buffer);
- s.SetLength(3);
- using (var w = client.Open(remoteFile, FileMode.Open, FileAccess.Write))
- {
- w.Write(new byte[] { 8, 1, 6, 2 }, offset: 0, count: 4);
- }
- // verify that position was not changed
- Assert.AreEqual(1, s.Position);
- // verify that read buffer was cleared
- Assert.AreEqual(1, s.ReadByte());
- Assert.AreEqual(6, s.ReadByte());
- Assert.AreEqual(2, s.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, s.ReadByte());
- Assert.AreEqual(4, s.Length);
- }
- // reduce length while in read mode, but before current position
- using (var s = client.Open(remoteFile, FileMode.Open, FileAccess.ReadWrite))
- {
- var buffer = new byte[4];
- Assert.AreEqual(4, s.Read(buffer, offset: 0, buffer.Length));
- CollectionAssert.AreEqual(new byte[] { 8, 1, 6, 2 }, buffer);
- Assert.AreEqual(4, s.Position);
- s.SetLength(3);
- // verify that position was moved to last byte
- Assert.AreEqual(3, s.Position);
- using (var w = client.Open(remoteFile, FileMode.Open, FileAccess.Read))
- {
- Assert.AreEqual(3, w.Length);
- Assert.AreEqual(8, w.ReadByte());
- Assert.AreEqual(1, w.ReadByte());
- Assert.AreEqual(6, w.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, w.ReadByte());
- }
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, s.ReadByte());
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_SftpFileStream_Seek_BeyondEndOfFile_SeekOriginBegin()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.BufferSize = 500;
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF but not beyond buffer size
- // do not write anything
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(offset: 3L, SeekOrigin.Begin);
- Assert.AreEqual(3, newPosition);
- Assert.AreEqual(3, fs.Position);
- Assert.AreEqual(1, fs.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(1, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF and beyond buffer size
- // do not write anything
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(offset: 700L, SeekOrigin.Begin);
- Assert.AreEqual(700, newPosition);
- Assert.AreEqual(700, fs.Position);
- Assert.AreEqual(1, fs.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(1, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF but not beyond buffer size
- // write less bytes than buffer size
- var seekOffset = 3L;
- // buffer holding the data that we'll write to the file
- var writeBuffer = GenerateRandom(size: 7);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(seekOffset, SeekOrigin.Begin);
- Assert.AreEqual(seekOffset, newPosition);
- Assert.AreEqual(seekOffset, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- Assert.AreEqual(seekOffset + writeBuffer.Length, fs.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(seekOffset + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- var soughtOverReadBuffer = new byte[seekOffset - 1];
- fs.ReadExactly(soughtOverReadBuffer, offset: 0, soughtOverReadBuffer.Length);
- CollectionAssert.AreEqual(new byte[soughtOverReadBuffer.Length], soughtOverReadBuffer);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF and beyond buffer size
- // write less bytes than buffer size
- seekOffset = 700L;
- // buffer holding the data that we'll write to the file
- writeBuffer = GenerateRandom(size: 4);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(seekOffset, SeekOrigin.Begin);
- Assert.AreEqual(seekOffset, newPosition);
- Assert.AreEqual(seekOffset, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- Assert.AreEqual(seekOffset + writeBuffer.Length, fs.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(seekOffset + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- var soughtOverReadBuffer = new byte[seekOffset - 1];
- fs.ReadExactly(soughtOverReadBuffer, offset: 0, soughtOverReadBuffer.Length);
- CollectionAssert.AreEqual(new byte[soughtOverReadBuffer.Length], soughtOverReadBuffer);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF but not beyond buffer size
- // write more bytes than buffer size
- writeBuffer = GenerateRandom(size: 600);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(offset: 3L, SeekOrigin.Begin);
- Assert.AreEqual(3, newPosition);
- Assert.AreEqual(3, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(3 + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- Assert.AreEqual(0x00, fs.ReadByte());
- Assert.AreEqual(0x00, fs.ReadByte());
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF and beyond buffer size
- // write more bytes than buffer size
- writeBuffer = GenerateRandom(size: 600);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(offset: 550, SeekOrigin.Begin);
- Assert.AreEqual(550, newPosition);
- Assert.AreEqual(550, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(550 + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- var soughtOverReadBuffer = new byte[550 - 1];
- fs.ReadExactly(soughtOverReadBuffer, offset: 0, soughtOverReadBuffer.Length);
- CollectionAssert.AreEqual(new byte[550 - 1], soughtOverReadBuffer);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_SftpFileStream_Seek_BeyondEndOfFile_SeekOriginEnd()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.BufferSize = 500;
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF but not beyond buffer size
- // do not write anything
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(offset: 3L, SeekOrigin.End);
- Assert.AreEqual(4, newPosition);
- Assert.AreEqual(4, fs.Position);
- Assert.AreEqual(1, fs.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(1, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF and beyond buffer size
- // do not write anything
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(offset: 700L, SeekOrigin.End);
- Assert.AreEqual(701, newPosition);
- Assert.AreEqual(701, fs.Position);
- Assert.AreEqual(1, fs.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(1, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF but not beyond buffer size
- // write less bytes than buffer size
- var seekOffset = 3L;
- // buffer holding the data that we'll write to the file
- var writeBuffer = GenerateRandom(size: 7);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(seekOffset, SeekOrigin.End);
- Assert.AreEqual(4, newPosition);
- Assert.AreEqual(4, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- Assert.AreEqual(1 + seekOffset + writeBuffer.Length, fs.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(1 + seekOffset + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- var soughtOverReadBuffer = new byte[seekOffset];
- fs.ReadExactly(soughtOverReadBuffer, offset: 0, soughtOverReadBuffer.Length);
- CollectionAssert.AreEqual(new byte[soughtOverReadBuffer.Length], soughtOverReadBuffer);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF and beyond buffer size
- // write less bytes than buffer size
- seekOffset = 700L;
- // buffer holding the data that we'll write to the file
- writeBuffer = GenerateRandom(size: 4);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(seekOffset, SeekOrigin.End);
- Assert.AreEqual(1 + seekOffset, newPosition);
- Assert.AreEqual(1 + seekOffset, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(1 + seekOffset + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- var soughtOverReadBuffer = new byte[seekOffset];
- fs.ReadExactly(soughtOverReadBuffer, offset: 0, soughtOverReadBuffer.Length);
- CollectionAssert.AreEqual(new byte[soughtOverReadBuffer.Length], soughtOverReadBuffer);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF but not beyond buffer size
- // write more bytes than buffer size
- seekOffset = 3L;
- writeBuffer = GenerateRandom(size: 600);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(seekOffset, SeekOrigin.End);
- Assert.AreEqual(1 + seekOffset, newPosition);
- Assert.AreEqual(1 + seekOffset, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(1 + seekOffset + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- var soughtOverReadBuffer = new byte[seekOffset];
- fs.ReadExactly(soughtOverReadBuffer, offset: 0, soughtOverReadBuffer.Length);
- CollectionAssert.AreEqual(new byte[soughtOverReadBuffer.Length], soughtOverReadBuffer);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- // seek beyond EOF and beyond buffer size
- // write more bytes than buffer size
- seekOffset = 550L;
- writeBuffer = GenerateRandom(size: 600);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(seekOffset, SeekOrigin.End);
- Assert.AreEqual(1 + seekOffset, newPosition);
- Assert.AreEqual(1 + seekOffset, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(1 + seekOffset + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- var soughtOverReadBuffer = new byte[seekOffset];
- fs.ReadExactly(soughtOverReadBuffer, offset: 0, soughtOverReadBuffer.Length);
- CollectionAssert.AreEqual(new byte[soughtOverReadBuffer.Length], soughtOverReadBuffer);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_SftpFileStream_Seek_NegativeOffSet_SeekOriginEnd()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.BufferSize = 500;
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- fs.WriteByte(0x07);
- fs.WriteByte(0x05);
- }
- // seek within file and not beyond buffer size
- // do not write anything
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(offset: -2L, SeekOrigin.End);
- Assert.AreEqual(1, newPosition);
- Assert.AreEqual(1, fs.Position);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(3, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- Assert.AreEqual(0x07, fs.ReadByte());
- Assert.AreEqual(0x05, fs.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // buffer holding the data that we'll write to the file
- var writeBuffer = GenerateRandom(size: (int)client.BufferSize + 200);
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- }
- // seek within EOF and beyond buffer size
- // do not write anything
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(offset: -100L, SeekOrigin.End);
- Assert.AreEqual(600, newPosition);
- Assert.AreEqual(600, fs.Position);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(writeBuffer.Length, fs.Length);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // seek within EOF and within buffer size
- // write less bytes than buffer size
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- var newPosition = fs.Seek(offset: -3, SeekOrigin.End);
- Assert.AreEqual(697, newPosition);
- Assert.AreEqual(697, fs.Position);
- fs.WriteByte(0x01);
- fs.WriteByte(0x05);
- fs.WriteByte(0x04);
- fs.WriteByte(0x07);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(writeBuffer.Length + 1, fs.Length);
- var readBuffer = new byte[writeBuffer.Length - 3];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer.Take(readBuffer.Length), readBuffer);
- Assert.AreEqual(0x01, fs.ReadByte());
- Assert.AreEqual(0x05, fs.ReadByte());
- Assert.AreEqual(0x04, fs.ReadByte());
- Assert.AreEqual(0x07, fs.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- // buffer holding the data that we'll write to the file
- writeBuffer = GenerateRandom(size: (int)client.BufferSize * 4);
- // seek within EOF and beyond buffer size
- // write less bytes than buffer size
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- var newPosition = fs.Seek(offset: -(client.BufferSize * 2), SeekOrigin.End);
- Assert.AreEqual(1000, newPosition);
- Assert.AreEqual(1000, fs.Position);
- fs.WriteByte(0x01);
- fs.WriteByte(0x05);
- fs.WriteByte(0x04);
- fs.WriteByte(0x07);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(writeBuffer.Length, fs.Length);
- // First part of file should not have been touched
- var readBuffer = new byte[(int)client.BufferSize * 2];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer.Take(readBuffer.Length), readBuffer);
- // Check part that should have been updated
- Assert.AreEqual(0x01, fs.ReadByte());
- Assert.AreEqual(0x05, fs.ReadByte());
- Assert.AreEqual(0x04, fs.ReadByte());
- Assert.AreEqual(0x07, fs.ReadByte());
- // Remaining bytes should not have been touched
- readBuffer = new byte[((int)client.BufferSize * 2) - 4];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(
- writeBuffer.Skip(((int)client.BufferSize * 2) + 4).Take(readBuffer.Length).ToArray(),
- readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- /// https://github.com/sshnet/SSH.NET/issues/253
- [TestMethod]
- public void Sftp_SftpFileStream_Seek_Issue253()
- {
- var buf = Encoding.UTF8.GetBytes("123456");
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var ws = client.OpenWrite(remoteFile))
- {
- ws.Write(buf, offset: 0, count: 3);
- }
- using (var ws = client.OpenWrite(remoteFile))
- {
- var newPosition = ws.Seek(offset: 3, SeekOrigin.Begin);
- Assert.AreEqual(3, newPosition);
- Assert.AreEqual(3, ws.Position);
- ws.Write(buf, 3, 3);
- }
- var actual = client.ReadAllText(remoteFile, Encoding.UTF8);
- Assert.AreEqual("123456", actual);
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_SftpFileStream_Seek_WithinReadBuffer()
- {
- var originalContent = GenerateRandom(size: 800);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.BufferSize = 500;
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.Write(originalContent, offset: 0, originalContent.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- var readBuffer = new byte[200];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- var newPosition = fs.Seek(offset: 3L, SeekOrigin.Begin);
- Assert.AreEqual(3L, newPosition);
- Assert.AreEqual(3L, fs.Position);
- }
- client.DeleteFile(remoteFile);
- #region Seek beyond EOF and beyond buffer size do not write anything
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(1, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(offset: 700L, SeekOrigin.Begin);
- Assert.AreEqual(700L, newPosition);
- Assert.AreEqual(700L, fs.Position);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(1, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- #endregion Seek beyond EOF and beyond buffer size do not write anything
- #region Seek beyond EOF but not beyond buffer size and write less bytes than buffer size
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- var seekOffset = 3L;
- var writeBuffer = GenerateRandom(size: 7);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(seekOffset, SeekOrigin.Begin);
- Assert.AreEqual(seekOffset, newPosition);
- Assert.AreEqual(seekOffset, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(seekOffset + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- var soughtOverReadBuffer = new byte[seekOffset - 1];
- fs.ReadExactly(soughtOverReadBuffer, offset: 0, soughtOverReadBuffer.Length);
- CollectionAssert.AreEqual(new byte[soughtOverReadBuffer.Length], soughtOverReadBuffer);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- #endregion Seek beyond EOF but not beyond buffer size and write less bytes than buffer size
- #region Seek beyond EOF and beyond buffer size and write less bytes than buffer size
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- seekOffset = 700L;
- writeBuffer = GenerateRandom(size: 4);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(seekOffset, SeekOrigin.Begin);
- Assert.AreEqual(seekOffset, newPosition);
- Assert.AreEqual(seekOffset, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(seekOffset + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- var soughtOverReadBuffer = new byte[seekOffset - 1];
- fs.ReadExactly(soughtOverReadBuffer, offset: 0, soughtOverReadBuffer.Length);
- CollectionAssert.AreEqual(new byte[soughtOverReadBuffer.Length], soughtOverReadBuffer);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- #endregion Seek beyond EOF and beyond buffer size and write less bytes than buffer size
- #region Seek beyond EOF but not beyond buffer size and write more bytes than buffer size
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- seekOffset = 3L;
- writeBuffer = GenerateRandom(size: 600);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(seekOffset, SeekOrigin.Begin);
- Assert.AreEqual(seekOffset, newPosition);
- Assert.AreEqual(seekOffset, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(seekOffset + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- Assert.AreEqual(0x00, fs.ReadByte());
- Assert.AreEqual(0x00, fs.ReadByte());
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- #endregion Seek beyond EOF but not beyond buffer size and write more bytes than buffer size
- #region Seek beyond EOF and beyond buffer size and write more bytes than buffer size
- // create single-byte file
- using (var fs = client.OpenWrite(remoteFile))
- {
- fs.WriteByte(0x04);
- }
- seekOffset = 550L;
- writeBuffer = GenerateRandom(size: 600);
- using (var fs = client.OpenWrite(remoteFile))
- {
- var newPosition = fs.Seek(seekOffset, SeekOrigin.Begin);
- Assert.AreEqual(seekOffset, newPosition);
- Assert.AreEqual(seekOffset, fs.Position);
- fs.Write(writeBuffer, offset: 0, writeBuffer.Length);
- }
- using (var fs = client.OpenRead(remoteFile))
- {
- Assert.AreEqual(seekOffset + writeBuffer.Length, fs.Length);
- Assert.AreEqual(0x04, fs.ReadByte());
- var soughtOverReadBuffer = new byte[seekOffset - 1];
- fs.ReadExactly(soughtOverReadBuffer, offset: 0, soughtOverReadBuffer.Length);
- CollectionAssert.AreEqual(new byte[seekOffset - 1], soughtOverReadBuffer);
- var readBuffer = new byte[writeBuffer.Length];
- fs.ReadExactly(readBuffer, offset: 0, readBuffer.Length);
- CollectionAssert.AreEqual(writeBuffer, readBuffer);
- // Ensure we've reached end of the stream
- Assert.AreEqual(-1, fs.ReadByte());
- }
- client.DeleteFile(remoteFile);
- #endregion Seek beyond EOF and beyond buffer size and write more bytes than buffer size
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_SftpFileStream_SetLength_FileDoesNotExist()
- {
- var size = new Random().Next(500, 5000);
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- using (var s = client.Open(remoteFile, FileMode.Append, FileAccess.Write))
- {
- s.SetLength(size);
- }
- Assert.IsTrue(client.Exists(remoteFile));
- var attributes = client.GetAttributes(remoteFile);
- Assert.IsTrue(attributes.IsRegularFile);
- Assert.AreEqual(size, attributes.Size);
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(new byte[size]), CreateHash(downloaded));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_Append_Write_ExistingFile()
- {
- const int fileSize = 5 * 1024;
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- using (var input = CreateMemoryStream(fileSize))
- {
- input.Position = 0;
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.UploadFile(input, remoteFile);
- using (var s = client.Open(remoteFile, FileMode.Append, FileAccess.Write))
- {
- Assert.IsFalse(s.CanRead);
- Assert.IsTrue(s.CanWrite);
- var buffer = new byte[] { 0x05, 0x0f, 0x0d, 0x0a, 0x04 };
- s.Write(buffer, offset: 0, buffer.Length);
- input.Write(buffer, offset: 0, buffer.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- input.Position = 0;
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(input), CreateHash(downloaded));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_Append_Write_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- #region Verify if merely opening the file for append creates a zero-byte file
- using (client.Open(remoteFile, FileMode.Append, FileAccess.Write))
- {
- }
- Assert.IsTrue(client.Exists(remoteFile));
- var attributes = client.GetAttributes(remoteFile);
- Assert.IsTrue(attributes.IsRegularFile);
- Assert.AreEqual(0L, attributes.Size);
- #endregion Verify if merely opening the file for append creates it
- client.DeleteFile(remoteFile);
- #region Verify if content is actually written to the file
- var content = GenerateRandom(size: 100);
- using (var s = client.Open(remoteFile, FileMode.Append, FileAccess.Write))
- {
- s.Write(content, offset: 0, content.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(content), CreateHash(downloaded));
- }
- #endregion Verify if content is actually written to the file
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_PathAndMode_ModeIsCreate_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- #region Verify if merely opening the file for create creates a zero-byte file
- using (client.Open(remoteFile, FileMode.Create))
- {
- }
- Assert.IsTrue(client.Exists(remoteFile));
- var attributes = client.GetAttributes(remoteFile);
- Assert.IsTrue(attributes.IsRegularFile);
- Assert.AreEqual(0L, attributes.Size);
- #endregion Verify if merely opening the file for create creates a zero-byte file
- client.DeleteFile(remoteFile);
- #region Verify if content is actually written to the file
- var content = GenerateRandom(size: 100);
- using (var s = client.Open(remoteFile, FileMode.Create))
- {
- Assert.IsTrue(s.CanRead);
- Assert.IsTrue(s.CanWrite);
- s.Write(content, offset: 0, content.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(content), CreateHash(downloaded));
- }
- #endregion Verify if content is actually written to the file
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_PathAndMode_ModeIsCreate_ExistingFile()
- {
- const int fileSize = 5 * 1024;
- var newContent = new byte[] { 0x07, 0x03, 0x02, 0x0b };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- using (var input = CreateMemoryStream(fileSize))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- input.Position = 0;
- client.UploadFile(input, remoteFile);
- using (var stream = client.Open(remoteFile, FileMode.Create))
- {
- // Verify if merely opening the file for create overwrites the file
- var attributes = client.GetAttributes(remoteFile);
- Assert.IsTrue(attributes.IsRegularFile);
- Assert.AreEqual(0L, attributes.Size);
- stream.Write(newContent, offset: 0, newContent.Length);
- stream.Position = 0;
- Assert.AreEqual(CreateHash(newContent), CreateHash(stream));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_PathAndModeAndAccess_ModeIsCreate_AccessIsReadWrite_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- #region Verify if merely opening the file for create creates a zero-byte file
- using (client.Open(remoteFile, FileMode.Create, FileAccess.ReadWrite))
- {
- }
- Assert.IsTrue(client.Exists(remoteFile));
- var attributes = client.GetAttributes(remoteFile);
- Assert.IsTrue(attributes.IsRegularFile);
- Assert.AreEqual(0L, attributes.Size);
- #endregion Verify if merely opening the file for create creates a zero-byte file
- client.DeleteFile(remoteFile);
- #region Verify if content is actually written to the file
- var content = GenerateRandom(size: 100);
- using (var s = client.Open(remoteFile, FileMode.Create, FileAccess.ReadWrite))
- {
- s.Write(content, offset: 0, content.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(content), CreateHash(downloaded));
- }
- #endregion Verify if content is actually written to the file
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_PathAndModeAndAccess_ModeIsCreate_AccessIsReadWrite_ExistingFile()
- {
- const int fileSize = 5 * 1024;
- var newContent = new byte[] { 0x07, 0x03, 0x02, 0x0b };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- using (var input = CreateMemoryStream(fileSize))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- input.Position = 0;
- client.UploadFile(input, remoteFile);
- using (var stream = client.Open(remoteFile, FileMode.Create, FileAccess.ReadWrite))
- {
- // Verify if merely opening the file for create overwrites the file
- var attributes = client.GetAttributes(remoteFile);
- Assert.IsTrue(attributes.IsRegularFile);
- Assert.AreEqual(0L, attributes.Size);
- stream.Write(newContent, offset: 0, newContent.Length);
- stream.Position = 0;
- Assert.AreEqual(CreateHash(newContent), CreateHash(stream));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_PathAndModeAndAccess_ModeIsCreate_AccessIsWrite_ExistingFile()
- {
- // use new content that contains less bytes than original content to
- // verify whether file is first truncated
- var originalContent = new byte[] { 0x05, 0x0f, 0x0d, 0x0a, 0x04 };
- var newContent = new byte[] { 0x07, 0x03, 0x02, 0x0b };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllBytes(remoteFile, originalContent);
- using (var s = client.Open(remoteFile, FileMode.Create, FileAccess.Write))
- {
- s.Write(newContent, offset: 0, newContent.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(newContent), CreateHash(downloaded));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_PathAndModeAndAccess_ModeIsCreate_AccessIsWrite_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- #region Verify if merely opening the file for create creates a zero-byte file
- using (client.Open(remoteFile, FileMode.Create, FileAccess.Write))
- {
- }
- Assert.IsTrue(client.Exists(remoteFile));
- var attributes = client.GetAttributes(remoteFile);
- Assert.IsTrue(attributes.IsRegularFile);
- Assert.AreEqual(0L, attributes.Size);
- #endregion Verify if merely opening the file for create creates a zero-byte file
- client.DeleteFile(remoteFile);
- #region Verify if content is actually written to the file
- var content = GenerateRandom(size: 100);
- using (var s = client.Open(remoteFile, FileMode.Create, FileAccess.Write))
- {
- s.Write(content, offset: 0, content.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(content), CreateHash(downloaded));
- }
- #endregion Verify if content is actually written to the file
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_CreateNew_Write_ExistingFile()
- {
- const int fileSize = 5 * 1024;
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- using (var input = CreateMemoryStream(fileSize))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- input.Position = 0;
- try
- {
- client.UploadFile(input, remoteFile);
- Stream stream = null;
- try
- {
- stream = client.Open(remoteFile, FileMode.CreateNew, FileAccess.Write);
- Assert.Fail();
- }
- catch (SshException)
- {
- }
- finally
- {
- stream?.Dispose();
- }
- // Verify that the file was not modified
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- input.Position = 0;
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(input), CreateHash(downloaded));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_CreateNew_Write_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- #region Verify if merely opening the file creates a zero-byte file
- using (client.Open(remoteFile, FileMode.CreateNew, FileAccess.Write))
- {
- }
- Assert.IsTrue(client.Exists(remoteFile));
- var attributes = client.GetAttributes(remoteFile);
- Assert.IsTrue(attributes.IsRegularFile);
- Assert.AreEqual(0L, attributes.Size);
- #endregion Verify if merely opening the file creates it
- client.DeleteFile(remoteFile);
- #region Verify if content is actually written to the file
- var content = GenerateRandom(size: 100);
- using (var s = client.Open(remoteFile, FileMode.CreateNew, FileAccess.Write))
- {
- s.Write(content, offset: 0, content.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(content), CreateHash(downloaded));
- }
- #endregion Verify if content is actually written to the file
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_Open_Write_ExistingFile()
- {
- // use new content that contains less bytes than original content to
- // verify whether file is first truncated
- var originalContent = new byte[] { 0x05, 0x0f, 0x0d, 0x0a, 0x04 };
- var newContent = new byte[] { 0x07, 0x03, 0x02, 0x0b };
- var expectedContent = new byte[] { 0x07, 0x03, 0x02, 0x0b, 0x04 };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllBytes(remoteFile, originalContent);
- using (var s = client.Open(remoteFile, FileMode.Open, FileAccess.Write))
- {
- s.Write(newContent, offset: 0, newContent.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(expectedContent), CreateHash(downloaded));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_Open_Write_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- Stream stream = null;
- try
- {
- stream = client.Open(remoteFile, FileMode.Open, FileAccess.Write);
- Assert.Fail();
- }
- catch (SshException)
- {
- }
- finally
- {
- stream?.Dispose();
- }
- Assert.IsFalse(client.Exists(remoteFile));
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_OpenOrCreate_Write_ExistingFile()
- {
- // use new content that contains less bytes than original content to
- // verify whether file is first truncated
- var originalContent = new byte[] { 0x05, 0x0f, 0x0d, 0x0a, 0x04 };
- var newContent = new byte[] { 0x07, 0x03, 0x02, 0x0b };
- var expectedContent = new byte[] { 0x07, 0x03, 0x02, 0x0b, 0x04 };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- client.WriteAllBytes(remoteFile, originalContent);
- using (var s = client.Open(remoteFile, FileMode.OpenOrCreate, FileAccess.Write))
- {
- s.Write(newContent, offset: 0, newContent.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(expectedContent), CreateHash(downloaded));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_OpenOrCreate_Write_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- #region Verify if merely opening the file creates a zero-byte file
- using (client.Open(remoteFile, FileMode.OpenOrCreate, FileAccess.Write))
- {
- }
- Assert.IsTrue(client.Exists(remoteFile));
- var attributes = client.GetAttributes(remoteFile);
- Assert.IsTrue(attributes.IsRegularFile);
- Assert.AreEqual(0L, attributes.Size);
- #endregion Verify if merely opening the file creates it
- client.DeleteFile(remoteFile);
- #region Verify if content is actually written to the file
- var content = GenerateRandom(size: 100);
- using (var s = client.Open(remoteFile, FileMode.OpenOrCreate, FileAccess.Write))
- {
- s.Write(content, offset: 0, content.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(content), CreateHash(downloaded));
- }
- #endregion Verify if content is actually written to the file
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_Truncate_Write_ExistingFile()
- {
- const int fileSize = 5 * 1024;
- // use new content that contains less bytes than original content to
- // verify whether file is first truncated
- var originalContent = new byte[] { 0x05, 0x0f, 0x0d, 0x0a, 0x04 };
- var newContent = new byte[] { 0x07, 0x03, 0x02, 0x0b };
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- using (var input = CreateMemoryStream(fileSize))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- input.Position = 0;
- try
- {
- client.WriteAllBytes(remoteFile, originalContent);
- using (var s = client.Open(remoteFile, FileMode.Truncate, FileAccess.Write))
- {
- s.Write(newContent, offset: 0, newContent.Length);
- }
- using (var downloaded = new MemoryStream())
- {
- DownloadFileRandomMethod(client, remoteFile, downloaded);
- input.Position = 0;
- downloaded.Position = 0;
- Assert.AreEqual(CreateHash(newContent), CreateHash(downloaded));
- }
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_Open_Truncate_Write_FileDoesNotExist()
- {
- using (var client = new SftpClient(_connectionInfoFactory.Create()))
- {
- client.Connect();
- var remoteFile = GenerateUniqueRemoteFileName();
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- try
- {
- Stream stream = null;
- try
- {
- stream = client.Open(remoteFile, FileMode.Truncate, FileAccess.Write);
- Assert.Fail();
- }
- catch (SshException)
- {
- }
- Assert.IsFalse(client.Exists(remoteFile));
- }
- finally
- {
- if (client.Exists(remoteFile))
- {
- client.DeleteFile(remoteFile);
- }
- }
- }
- }
- [TestMethod]
- public void Sftp_SetLastAccessTime()
- {
- var testFilePath = "/home/sshnet/test-file.txt";
- var testContent = "File";
- using var client = new SftpClient(_connectionInfoFactory.Create());
- client.Connect();
- using var fileStream = new MemoryStream(Encoding.UTF8.GetBytes(testContent));
- client.UploadFile(fileStream, testFilePath);
- try
- {
- var newTime = new DateTime(1986, 03, 15, 01, 02, 03, 123, DateTimeKind.Local);
- client.SetLastAccessTime(testFilePath, newTime);
- var time = client.GetLastAccessTime(testFilePath);
- DateTimeAssert.AreEqual(newTime.TruncateToWholeSeconds(), time);
- }
- finally
- {
- client.DeleteFile(testFilePath);
- }
- }
- [TestMethod]
- public void Sftp_SetLastAccessTimeUtc()
- {
- var testFilePath = "/home/sshnet/test-file.txt";
- var testContent = "File";
- using var client = new SftpClient(_connectionInfoFactory.Create());
- client.Connect();
- using var fileStream = new MemoryStream(Encoding.UTF8.GetBytes(testContent));
- client.UploadFile(fileStream, testFilePath);
- try
- {
- var newTime = new DateTime(1986, 03, 15, 01, 02, 03, 123, DateTimeKind.Utc);
- client.SetLastAccessTimeUtc(testFilePath, newTime);
- var time = client.GetLastAccessTimeUtc(testFilePath);
- DateTimeAssert.AreEqual(newTime.TruncateToWholeSeconds(), time);
- }
- finally
- {
- client.DeleteFile(testFilePath);
- }
- }
- [TestMethod]
- public void Sftp_SetLastWriteTime()
- {
- var testFilePath = "/home/sshnet/test-file.txt";
- var testContent = "File";
- using var client = new SftpClient(_connectionInfoFactory.Create());
- client.Connect();
- using var fileStream = new MemoryStream(Encoding.UTF8.GetBytes(testContent));
- client.UploadFile(fileStream, testFilePath);
- try
- {
- var newTime = new DateTime(1986, 03, 15, 01, 02, 03, 123, DateTimeKind.Local);
- client.SetLastWriteTime(testFilePath, newTime);
- var time = client.GetLastWriteTime(testFilePath);
- DateTimeAssert.AreEqual(newTime.TruncateToWholeSeconds(), time);
- }
- finally
- {
- client.DeleteFile(testFilePath);
- }
- }
- [TestMethod]
- public void Sftp_SetLastWriteTimeUtc()
- {
- var testFilePath = "/home/sshnet/test-file.txt";
- var testContent = "File";
- using var client = new SftpClient(_connectionInfoFactory.Create());
- client.Connect();
- using var fileStream = new MemoryStream(Encoding.UTF8.GetBytes(testContent));
- client.UploadFile(fileStream, testFilePath);
- try
- {
- var newTime = new DateTime(1986, 03, 15, 01, 02, 03, 123, DateTimeKind.Utc);
- client.SetLastWriteTimeUtc(testFilePath, newTime);
- var time = client.GetLastWriteTimeUtc(testFilePath);
- DateTimeAssert.AreEqual(newTime.TruncateToWholeSeconds(), time);
- }
- finally
- {
- client.DeleteFile(testFilePath);
- }
- }
- [TestMethod]
- public void Sftp_SftpFileStream_Fuzz()
- {
- const int OperationCount = 100;
- const int MaxBufferSize = 1000;
- const int MaxFileSize = 15_000;
- int seed = Environment.TickCount;
- Console.WriteLine("Using seed " + seed);
- var random = new Random(seed);
- using var client = new SftpClient(_connectionInfoFactory.Create())
- {
- BufferSize = 100
- };
- client.Connect();
- // We will perform operations on an SftpFileStream and a local
- // System.IO.FileStream, and check that the results are the same.
- // This could use a MemoryStream for the local side, except for the
- // fact that performing a 0-byte write at a position beyond the length
- // of the MemoryStream causes its length to increase, which is not the
- // case for FileStream. Since we've got 'FileStream' in the name, we
- // check that we align with FileStream's behaviour.
- string remoteFilePath = GenerateUniqueRemoteFileName();
- string localFilePath = Path.GetTempFileName();
- byte[] fileBytes = new byte[1024];
- random.NextBytes(fileBytes);
- File.WriteAllBytes(localFilePath, fileBytes);
- client.WriteAllBytes(remoteFilePath, fileBytes);
- try
- {
- using (var local = File.Open(localFilePath, FileMode.Open, FileAccess.ReadWrite))
- using (var remote = client.Open(remoteFilePath, FileMode.Open, FileAccess.ReadWrite))
- {
- for (int i = 0; i < OperationCount; i++)
- {
- #pragma warning disable IDE0010 // Add missing cases
- int op = random.Next(5);
- switch (op)
- {
- case 0 when local.Length < MaxFileSize: // Write
- {
- var buffer = new byte[random.Next(0, MaxBufferSize)];
- random.NextBytes(buffer);
- int offset = random.Next(0, buffer.Length + 1);
- int count = random.Next(0, buffer.Length - offset + 1);
- remote.Write(buffer, offset, count);
- local.Write(buffer, offset, count);
- break;
- }
- case 1: // Read
- {
- var remoteBuffer = new byte[random.Next(0, MaxBufferSize)];
- var localBuffer = new byte[remoteBuffer.Length];
- int offset = random.Next(0, remoteBuffer.Length + 1);
- int count = random.Next(0, remoteBuffer.Length - offset + 1);
- int remoteRead = ReadExactly(remote, remoteBuffer, offset, count);
- int localRead = ReadExactly(local, localBuffer, offset, count);
- Assert.AreEqual(localRead, remoteRead);
- CollectionAssert.AreEqual(localBuffer, remoteBuffer);
- break;
- }
- case 2 when local.Length < MaxFileSize: // Seek
- {
- int position = (int)local.Position;
- int length = (int)local.Length;
- SeekOrigin origin = (SeekOrigin)random.Next(0, 3);
- long offset = 0;
- switch (origin)
- {
- case SeekOrigin.Begin:
- offset = random.Next(0, length * 2);
- break;
- case SeekOrigin.Current:
- offset = random.Next(-position, position);
- break;
- case SeekOrigin.End:
- offset = random.Next(-length, length);
- break;
- }
- long newPosRemote = remote.Seek(offset, origin);
- long newPosLocal = local.Seek(offset, origin);
- Assert.AreEqual(newPosLocal, newPosRemote);
- Assert.AreEqual(local.Length, remote.Length);
- break;
- }
- case 3: // SetLength
- {
- long newLength = random.Next(0, MaxFileSize);
- remote.SetLength(newLength);
- local.SetLength(newLength);
- Assert.AreEqual(local.Length, remote.Length);
- Assert.AreEqual(local.Position, remote.Position);
- break;
- }
- case 4: // Flush
- {
- remote.Flush();
- local.Flush();
- break;
- }
- }
- #pragma warning restore IDE0010 // Add missing cases
- }
- }
- CollectionAssert.AreEqual(File.ReadAllBytes(localFilePath), client.ReadAllBytes(remoteFilePath));
- }
- finally
- {
- File.Delete(localFilePath);
- if (client.Exists(remoteFilePath))
- {
- client.DeleteFile(remoteFilePath);
- }
- }
- }
- private static IEnumerable<object[]> GetSftpUploadFileFileStreamData()
- {
- yield return new object[] { 0 };
- yield return new object[] { 5 * 1024 * 1024 };
- }
- private static Encoding GetRandomEncoding()
- {
- var random = new Random().Next(1, 4);
- switch (random)
- {
- case 1:
- return Encoding.Unicode;
- case 2:
- return Encoding.UTF8;
- default:
- Debug.Assert(random == 3);
- return Encoding.UTF32;
- }
- }
- private void DownloadFileRandomMethod(SftpClient client, string path, Stream output)
- {
- Console.Write($"Downloading '{path}'");
- var random = new Random().Next(1, 7);
- switch (random)
- {
- case 1:
- Console.WriteLine($" with {nameof(SftpClient.DownloadFile)}");
- client.DownloadFile(path, output);
- break;
- case 2:
- Console.WriteLine($" with {nameof(SftpClient.DownloadFileAsync)}");
- client.DownloadFileAsync(path, output).GetAwaiter().GetResult();
- break;
- case 3:
- Console.WriteLine($" with {nameof(SftpClient.BeginDownloadFile)}");
- client.EndDownloadFile(client.BeginDownloadFile(path, output));
- break;
- case 4:
- Console.WriteLine($" with {nameof(SftpFileStream.CopyTo)}");
- using (var fs = client.OpenRead(path))
- {
- fs.CopyTo(output);
- }
- break;
- case 5:
- Console.WriteLine($" with {nameof(SftpFileStream.CopyToAsync)}");
- using (var fs = client.OpenAsync(path, FileMode.Open, FileAccess.Read, CancellationToken.None).GetAwaiter().GetResult())
- {
- fs.CopyToAsync(output).GetAwaiter().GetResult();
- }
- break;
- default:
- Debug.Assert(random == 6);
- Console.WriteLine($" with {nameof(SftpClient.ReadAllBytes)}");
- byte[] bytes = client.ReadAllBytes(path);
- output.Write(bytes, 0, bytes.Length);
- break;
- }
- }
- private static byte[] GetBytesWithPreamble(string text, Encoding encoding)
- {
- var preamble = encoding.GetPreamble();
- var textBytes = encoding.GetBytes(text);
- if (preamble.Length != 0)
- {
- var textAndPreambleBytes = new byte[preamble.Length + textBytes.Length];
- Buffer.BlockCopy(preamble, srcOffset: 0, textAndPreambleBytes, dstOffset: 0, preamble.Length);
- Buffer.BlockCopy(textBytes, srcOffset: 0, textAndPreambleBytes, preamble.Length, textBytes.Length);
- return textAndPreambleBytes;
- }
- return textBytes;
- }
- private static decimal CalculateTransferSpeed(long length, long elapsedMilliseconds)
- {
- return (length / 1024m) / (elapsedMilliseconds / 1000m);
- }
- /// <summary>
- /// Similar to the netcore ReadExactly but without throwing on end of stream.
- /// </summary>
- private static int ReadExactly(Stream stream, byte[] buffer, int offset, int count)
- {
- int totalRead = 0;
- while (totalRead < count)
- {
- int read = stream.Read(buffer, offset + totalRead, count - totalRead);
- if (read == 0)
- {
- return totalRead;
- }
- totalRead += read;
- }
- return totalRead;
- }
- private static byte[] GenerateRandom(int size)
- {
- var random = new Random();
- var randomContent = new byte[size];
- random.NextBytes(randomContent);
- return randomContent;
- }
- private static Stream CreateStreamWithContent(string content)
- {
- var memoryStream = new MemoryStream();
- var sw = new StreamWriter(memoryStream, Encoding.ASCII, 1024);
- sw.Write(content);
- sw.Flush();
- memoryStream.Position = 0;
- return memoryStream;
- }
- private static string GenerateUniqueRemoteFileName()
- {
- return $"/home/sshnet/{Guid.NewGuid():D}";
- }
- }
- }
|