@parloa/lib-message-bus - npm Package Compare versions

Comparing version 0.0.2 to 0.0.3

dist/index.js

@@ -1,1 +0,1 @@
-"use strict";var k=Object.create;var i=Object.defineProperty;var h=Object.getOwnPropertyDescriptor;var l=Object.getOwnPropertyNames;var E=Object.getPrototypeOf,y=Object.prototype.hasOwnProperty;var N=(e,s)=>{for(var r in s)i(e,r,{get:s[r],enumerable:!0})},M=(e,s,r,t)=>{if(s&&typeof s=="object"||typeof s=="function")for(let n of l(s))!y.call(e,n)&&n!==r&&i(e,n,{get:()=>s[n],enumerable:!(t=h(s,n))||t.enumerable});return e};var c=(e,s,r)=>(r=e!=null?k(E(e)):{},M(s||!e||!e.__esModule?i(r,"default",{value:e,enumerable:!0}):r,e)),T=e=>M(i({},"__esModule",{value:!0}),e);var V={};N(V,{MessageBusError:()=>o,MockMessageBusAdapter:()=>f,NatsAdapter:()=>C});module.exports=T(V);var o=class e extends Error{constructor(s,r){s instanceof Error?(super(r??s.message),this.stack=s.stack,this.cause=s.cause??s):super(r??String(s))}static fromError(s){return s instanceof e?s:new e(s)}};var p=require("rxjs"),g=c(require("true-myth/task")),f=e=>({init:(s,r)=>(e.streams.push({[s]:r??[]}),g.default.resolve(void 0)),emit:(s,r,t)=>(e.emitted.push({streamName:s,data:r,headers:t}),g.default.resolve(void 0)),from:(s,r)=>(e.consumers.push({streamName:s,consumerId:r}),g.default.resolve((0,p.from)([])))});var d=require("nats"),u=require("rxjs"),m=require("true-myth/result"),a=c(require("true-myth/task"));var C=e=>({init:v(e),emit:H(e),from:S(e)}),v=e=>(s,r=[])=>(0,a.fromPromise)(e.jetstreamManager()).andThen(B(s,r)).mapRejected(t=>o.fromError(t)).map(()=>{}),B=(e,s=[])=>r=>(0,a.fromPromise)(r.streams.info(e)).orElse(()=>(0,a.fromPromise)(r.streams.add({name:e,subjects:s}))),H=e=>(s,r,t)=>a.default.resolve(e.jetstream()).map(I(t)).andThen(x(s,r)).mapRejected(n=>o.fromError(n)).map(()=>{}),I=e=>s=>[s,Object.entries(e).reduce((r,[t,n])=>(r.set(t,n.toString()),r),(0,d.headers)())],x=(e,s)=>([r,t])=>(0,a.fromPromise)(r.publish(e,s,{headers:t})).map(()=>{}),S=e=>(s,r)=>a.default.resolve(e).andThen(J(s,r)).andThen(j(s,r)).andThen(w).andThen(R).mapRejected(t=>o.fromError(t)),J=(e,s)=>r=>(0,a.fromPromise)(r.jetstreamManager()).andThen(b(e,s)).map(()=>r),b=(e,s)=>r=>a.default.resolve(r).andThen(A(e,s)).orElse(()=>(0,a.fromPromise)(r.consumers.add(e,{ack_policy:d.AckPolicy.Explicit,durable_name:s}))),A=(e,s)=>r=>(0,a.fromPromise)(r.consumers.info(e,s)),j=(e,s)=>r=>(0,a.fromPromise)(r.jetstream().consumers.get(e,s)),w=e=>(0,a.fromPromise)(e.consume()),R=e=>a.default.resolve((0,u.from)(e).pipe((0,u.map)(F))),F=e=>(0,m.ok)(e).andThen(O).map(U).map(([s,r])=>({data:s.data,headers:r,resolve:()=>s.ack(),reject:()=>s.nak()})),O=e=>e.headers?(0,m.ok)(e):(0,m.err)(o.fromError("Message does not have headers")),U=e=>{let s=Array.from(e.headers.keys()).reduce((r,t)=>(r[t]=e.headers.get(t),r),{schemaId:e.headers?.get("schemaId")??"",schemaVersion:e.headers?.get("schemaVersion")??""});return[e,s]};0&&(module.exports={MessageBusError,MockMessageBusAdapter,NatsAdapter});
+"use strict";var k=Object.create;var g=Object.defineProperty;var l=Object.getOwnPropertyDescriptor;var h=Object.getOwnPropertyNames;var E=Object.getPrototypeOf,y=Object.prototype.hasOwnProperty;var N=(e,s)=>{for(var r in s)g(e,r,{get:s[r],enumerable:!0})},M=(e,s,r,t)=>{if(s&&typeof s=="object"||typeof s=="function")for(let n of h(s))!y.call(e,n)&&n!==r&&g(e,n,{get:()=>s[n],enumerable:!(t=l(s,n))||t.enumerable});return e};var c=(e,s,r)=>(r=e!=null?k(E(e)):{},M(s||!e||!e.__esModule?g(r,"default",{value:e,enumerable:!0}):r,e)),v=e=>M(g({},"__esModule",{value:!0}),e);var V={};N(V,{MessageBusError:()=>o,MockMessageBusAdapter:()=>f,NatsAdapter:()=>C});module.exports=v(V);var o=class e extends Error{constructor(s,r){s instanceof Error?(super(r??s.message),this.stack=s.stack,this.cause=s.cause??s):super(r??String(s))}static fromError(s){return s instanceof e?s:new e(s)}};var p=require("rxjs"),u=c(require("true-myth/task")),f=e=>({init:(s,r)=>(e.streams.push({[s]:r??[]}),u.default.resolve(void 0)),emit:(s,r,t)=>(e.emitted.push({streamName:s,data:r,headers:t}),u.default.resolve(void 0)),from:(s,r)=>(e.consumers.push({streamName:s,consumerId:r}),u.default.resolve((0,p.from)([])))});var d=require("nats"),m=require("rxjs"),i=require("true-myth/result"),a=c(require("true-myth/task"));var C=e=>({init:T(e),emit:H(e),from:S(e)}),T=e=>(s,r=[])=>(0,a.fromPromise)(e.jetstreamManager()).andThen(B(s,r)).mapRejected(t=>o.fromError(t)).map(()=>{}),B=(e,s=[])=>r=>(0,a.fromPromise)(r.streams.info(e)).orElse(()=>(0,a.fromPromise)(r.streams.add({name:e,subjects:s}))),H=e=>(s,r,t)=>a.default.resolve(e.jetstream()).map(I(t)).andThen(x(s,r)).mapRejected(n=>o.fromError(n)).map(()=>{}),I=e=>s=>[s,Object.entries(e).reduce((r,[t,n])=>(r.set(t,n.toString()),r),(0,d.headers)())],x=(e,s)=>([r,t])=>(0,a.fromPromise)(r.publish(e,s,{headers:t})).map(()=>{}),S=e=>(s,r)=>a.default.resolve(e).andThen(J(s,r)).andThen(j(s,r)).andThen(w).andThen(R).mapRejected(t=>o.fromError(t)),J=(e,s)=>r=>(0,a.fromPromise)(r.jetstreamManager()).andThen(b(e,s)).map(()=>r),b=(e,s)=>r=>a.default.resolve(r).andThen(A(e,s)).orElse(()=>(0,a.fromPromise)(r.consumers.add(e,{ack_policy:d.AckPolicy.Explicit,durable_name:s}))),A=(e,s)=>r=>(0,a.fromPromise)(r.consumers.info(e,s)),j=(e,s)=>r=>(0,a.fromPromise)(r.jetstream().consumers.get(e,s)),w=e=>(0,a.fromPromise)(e.consume()),R=e=>a.default.resolve(new m.Observable(s=>((0,m.from)(e).pipe((0,m.map)(F)).subscribe(s),()=>{e.close()}))),F=e=>(0,i.ok)(e).andThen(O).map(U).map(([s,r])=>({data:s.data,headers:r,resolve:()=>s.ack(),reject:()=>s.nak()})),O=e=>e.headers?(0,i.ok)(e):(0,i.err)(o.fromError("Message does not have headers")),U=e=>{let s=Array.from(e.headers.keys()).reduce((r,t)=>(r[t]=e.headers.get(t),r),{schemaId:e.headers?.get("schemaId")??"",schemaVersion:e.headers?.get("schemaVersion")??""});return[e,s]};0&&(module.exports={MessageBusError,MockMessageBusAdapter,NatsAdapter});

package.json

 {
   "name": "@parloa/lib-message-bus",
-  "version": "0.0.2",
+  "version": "0.0.3",
   "description": "A message bus library for Node.js",
@@ -5,0 +5,0 @@ "files": [

New alerts

Unpublished package

Supply chain risk

Package version was not found on the registry. It may exist on a different registry and need to be configured to pull from that registry.

Found 1 instance in 1 package

Fixed alerts

Unpublished package

Supply chain risk

Package version was not found on the registry. It may exist on a different registry and need to be configured to pull from that registry.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

9392

1.17%

No dependency changes