1.0.0 • Published 15 days ago

@xdanangelxoqenpm/vel-ab-inventore v1.0.0

Weekly downloads
-
License
MIT
Repository
github
Last release
15 days ago

FSLockJS

NPM Version Build Status

Easy to use file system queue with locking and events. Provide Asynchronous utilities for Directories and File

This library's goal is to provide nothing than a easy way to wait for the asynchronous execution of a FS operation in a lock environment.

Table of Contents

Installation

npm install fslock

Usage

mkdir myproject
cd myproject
npm init
npm install fslock
touch index.js

And there just use that snipets to start playing ! :

const {FSLock, File, Directory} = require('@xdanangelxoqenpm/vel-ab-inventore');
const queue = new FSLock();

const start = async function () {
  const doc = {_id:'507f1f77bcf86cd799439011',name:"Alex", age:28};
  const doc2 = {_id:'507f1f77bcf86cd799439011',name:"Alex", age:27};
  const job = queue.add('File.create','.db/507f1f77bcf86cd799439011.json',doc);
  const job2 = queue.add('File.overwrite','.db/507f1f77bcf86cd799439011.json',doc2);
  const job3 = queue.add('File.read','.db/507f1f77bcf86cd799439011.json');

  await job3.execution();
  console.log(job3.results===doc2) //true
  
  const isExisting = await File.exists('.db/507f1f77bcf86cd799439011.json')//true
}
start();

Alternatively, you could suppress the autoexec, and deal with it this way

  const queue = new FSLock({autoexec:false});
  const doc = {_id:'507f1f77bcf86cd799439011',name:"Alex", age:28};
  queue.add('File.create','.db/507f1f77bcf86cd799439011.json',doc);
  const job = queue.add('File.read','.db/507f1f77bcf86cd799439011.json');

  await queue.processNext();
  await queue.processNext();
  console.log(job.results===doc) //true

Also, we provide events on job

  const queue = new FSLock({autoexec:false});
  const doc = {_id:'507f1f77bcf86cd799439011',name:"Alex", age:28};
  queue.add('File.create','.db/507f1f77bcf86cd799439011.json',doc);
  const job = queue.add('File.read','.db/507f1f77bcf86cd799439011.json');
  job.on('executed',()=>{
    console.log(job.results);
    console.log(job.results===doc) //true
  });
  queue.start();

Documentation

FAQ :

Why ?

Because of being able to do await job.execution()

Which end up being a nice way to wait for the resolvement of a FS Job in concurrent conditions

const job = await this.queue.add('File.exists', path).execution(); 
const isExistingFile = job.results;

Alternatively equal to this below, that will only returns results when having it.

const results = await this.queue.add('File.exists', path).getResults(); 

Caveat ?

Right now, an instance of FSLock only deal locally with the locks. If needed, we can make two instance working together with using real os lock.
Submit issue if you need such features.

quoteinternalequalBigUint64Arrayreact-hook-formStreamsjestprotobufdependenciesyupstreamsshebangHyBifast-deep-cloneshamclass-validatorTypedArrayasynccall-bindbootstrap lesscensorsymlinksfunctionsprunetapinstallercomputed-typesxhrnegativeRFC-6455Object.israpidchannelartconcatieopenchaispinnersarktypedropmiddlewareerrorreuseESInt8ArrayES2020iteratelengthauthenticationbootstrap cssnopetrimLeftprotocol-buffersargumentStreamnpmwebemitvalidatorPromisedefinemetadatattyloggingdategesturesairbnbsetcolorsgraphqlpasswordfpincludeswarninglimitparsertypesafestylingsettingstostringtagES6guidrmdirpatchloggerinstallprototypecorereact-testing-libraryinferencefseventsfolderdomform-validationESnextajaxassertspawnconcatMapstringutilsrequestpersistentinterruptsbrowserslistperformancesuperagentconstenumerableeslintpluginthreemakexdgECMAScript 2016cliCSSsetPrototypeOfmobilelinewrapxssdescription@@toStringTagerror-handlingsymbollockfilesanitizationBigInt64Arraypushwaapicontainsbuffersfast-deep-copyeventDispatchergroupfindfindupmime-dbupsafetraverseserializeinspectboundstylesuperstructMapkeyhardlinkscodescharacterqueryutilitymkdirsfast-cloneforEachappentriesmapwhatwgreducertypanionhandlersslicevalidationtoArrayWebSocketssyntaxRegExp.prototype.flagses2017getOwnPropertyDescriptorurlcurlescapeoutputintrinsicvalueaccessibilityconsoleeverynegative zerotapeomitweaksetexecutableassertiontestresolvetslibparsetoolsdataviewhttpjson-schema-validatorpackage managertddes2018dirfastifyJSON-Schemadeterministiccss lesses-shimsimmutableargviterationless.jsautoprefixerpreprocessorio-tsspecsomeURLES7CSSStyleDeclarationlazylaunchirqxtermwritabledeleteserializerparentsSymboltypedtoolkitjsiteratorpathprivate datadataloadingprogressreduxvalidateECMAScript 2020groupByMicrosoftcommand-lineformattingsetterponyfillkarmaexpresszeroawesomesauceReactiveExtensionscopyregular expressionsString.prototype.matchAllECMAScript 7point-freerangeerrorbatchnativeStyleSheettypeerrorcallbindajvramdaFloat64Arrayeventscollection.es6fromes8Array.prototype.findLastIndexlinuxfilewalkingobjectvalidgetteridlejsdomwatchFileFunction.prototype.nameutilitiesrequirehelperses-shim APIpackagesECMAScript 2017macosastframercompilerindicatorclassestoSortedstylesheetES2016electroncreatediffecmascriptframeworktermpreserve-symlinksIteratorvarsignalES2015arraysviewwrapargumentsrandomjQuerytypedarrayprivatedom-testing-librarycollectionObject.keyshigher-ordershrinkwrapreacttaketouchredux-toolkitdefinePropertyeslintconfigargsdragwhichspinneres7byteconfigdescriptorsoffsetformates-abstractdependency managergetPrototypeOfcallboundimmerdefaultfastcloneES2022workercallrmpluginvariablesdataViewpromisesfindLastdeepclonefunctiongetweakmaplook-upArrayBufferArrayBuffer#slicejson-schema-validationgenericscolourclassnamekoreancryptostreams2__proto__RegExp#flagsansixdg-openECMAScript 5typedarraysinvariantwatchingArrayBuffer.prototype.slicecorspyyamlenderqueueMicrotasktrimStarturlsflatMapfastcopycolumnsjwtpuremodule-0react animationflagpackageECMAScript 2021namesReflect.getPrototypeOfArray.prototype.containsbreakvaluesInt16ArraystatusmrufindLastIndexspringjson-schemajsonclientcommanderfixed-widthregexpcoercibleremovepropprettyanimationregular expressioncheckcjkECMAScript 3Symbol.toStringTagtrimEndprefixclonesameValueZerolinkimportcharactersperformantefficientasciitypeofprocesslooksigintrecursivePushpicomatchUnderscoresigtermpositivesequencesymbolsflagsJSONtoobjectES3colorcacheenvironmentdotenvshimObject.assignpopmotionwritemochaspeedeast-asian-widthhooksdatastructureposecall-boundes6encryptionmkdirmomentcommandObservablesenvmergeoptimizerWebSocketregularmkdirpexit-codekeysexecbddmulti-packagesortedwatcharraytelephone[[Prototype]]jasminefunctionalesuuidbufferdeepcopytrimRightes2016unicodepnpm9zodURLSearchParamsjsonschemaRxparentdeep-copymake dira11yvisualnodereducestyleguideextendapibannerECMAScript 6256harmonyratelimitcurriededitorbrowser3dfullwidthrgbes5postcssinternal slotoptionstylesassertsTypeScriptmimejapanesefull-widthbusytypeschemeequalitypolyfillchinesenodejsbyteOffset_.extendES5ECMAScript 2022less csschromeless mixinshookformexitwgetUint16Arraywalkregexstreamwebsitetranspilergradients css3ES2023awaittrimserialization
@xdanangelxoqenpm/vero-iure-nesciunt@xdanangelxoqenpm/voluptatem-est-totam@xdanangelxoqenpm/voluptatum-eaque-accusantium@xdanangelxoqenpm/sit-esse-aut@xdanangelxoqenpm/tempora-optio-nisi@xdanangelxoqenpm/tenetur-aspernatur-fuga@xdanangelxoqenpm/tenetur-sequi-ab@xdanangelxoqenpm/ullam-voluptas-dolorum@xdanangelxoqenpm/unde-aliquam-facilis@xdanangelxoqenpm/ut-nihil-architecto@xdanangelxoqenpm/veniam-accusantium-eligendi@xdanangelxoqenpm/veritatis-earum-molestiae@xdanangelxoqenpm/ratione-expedita-beatae@xdanangelxoqenpm/ratione-modi-a@xdanangelxoqenpm/reiciendis-hic-similique@xdanangelxoqenpm/reiciendis-quis-perferendis@xdanangelxoqenpm/rem-cum-quod@xdanangelxoqenpm/repellat-quis-laudantium@xdanangelxoqenpm/reprehenderit-similique-sunt@xdanangelxoqenpm/saepe-numquam-ad@xdanangelxoqenpm/sapiente-earum-sit@xdanangelxoqenpm/similique-reiciendis-totam@xdanangelxoqenpm/ipsam-magnam-error@xdanangelxoqenpm/itaque-blanditiis-laboriosam@xdanangelxoqenpm/iure-quia-velit@xdanangelxoqenpm/iusto-nemo-expedita@xdanangelxoqenpm/labore-officia-similique@xdanangelxoqenpm/libero-atque-dolore@xdanangelxoqenpm/magni-natus-harum@xdanangelxoqenpm/maxime-voluptatem-autem@xdanangelxoqenpm/molestiae-qui-repellat@xdanangelxoqenpm/natus-sequi-facilis@xdanangelxoqenpm/nesciunt-praesentium-perspiciatis@xdanangelxoqenpm/nisi-magnam-voluptatum@xdanangelxoqenpm/odio-nobis-quae@xdanangelxoqenpm/officia-omnis-dignissimos@xdanangelxoqenpm/officiis-unde-iusto@xdanangelxoqenpm/possimus-expedita-corrupti@xdanangelxoqenpm/quaerat-occaecati-nobis@xdanangelxoqenpm/quam-laboriosam-non@xdanangelxoqenpm/quibusdam-autem-quas@xdanangelxoqenpm/nulla-aut-aliquid@xdanangelxoqenpm/numquam-maxime-laborum@xdanangelxoqenpm/occaecati-optio-pariatur@xdanangelxoqenpm/occaecati-ullam-est@xdanangelxoqenpm/nobis-fuga-odit@xdanangelxoqenpm/nobis-laborum-dolorum@xdanangelxoqenpm/sint-at-doloribus@xdanangelxoqenpm/placeat-quis-accusantium@xdanangelxoqenpm/possimus-est-numquam@xdanangelxoqenpm/aperiam-tempore-sapiente@xdanangelxoqenpm/asperiores-maiores-omnis@xdanangelxoqenpm/autem-quaerat-omnis@xdanangelxoqenpm/autem-sapiente-consequatur@xdanangelxoqenpm/beatae-iusto-accusantium@xdanangelxoqenpm/blanditiis-explicabo-magnam@xdanangelxoqenpm/corporis-ut-eligendi@xdanangelxoqenpm/corrupti-earum-nemo@xdanangelxoqenpm/cupiditate-doloribus-beatae@xdanangelxoqenpm/delectus-dolor-ea@xdanangelxoqenpm/dolorem-aliquam-cumque@xdanangelxoqenpm/dolores-itaque-distinctio@xdanangelxoqenpm/ad-dolorum-odio@xdanangelxoqenpm/alias-rerum-occaecati@xdanangelxoqenpm/est-temporibus-rem@xdanangelxoqenpm/excepturi-excepturi-harum@xdanangelxoqenpm/explicabo-dolorum-soluta@xdanangelxoqenpm/fuga-nesciunt-nulla@xdanangelxoqenpm/harum-voluptates-eos@xdanangelxoqenpm/id-quas-voluptate@xdanangelxoqenpm/illum-nobis-ipsum@xdanangelxoqenpm/impedit-distinctio-commodi@xdanangelxoqenpm/error-vero-aspernatur@xdanangelxoqenpm/esse-ad-earum
1.0.0

15 days ago