From a56add0ffc82ad0e9d15a1759a931c7b332fe134 Mon Sep 17 00:00:00 2001 From: Orion Kindel Date: Wed, 22 May 2024 15:49:12 -0500 Subject: [PATCH] fix: update node-stream-pipes --- spago.lock | 6 +++--- spago.yaml | 2 +- src/Pipes.Postgres.purs | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/spago.lock b/spago.lock index 6db3e56..2ebc7ba 100644 --- a/spago.lock +++ b/spago.lock @@ -23,7 +23,7 @@ workspace: - newtype: ">=5.0.0 <6.0.0" - node-buffer: ">=9.0.0 <10.0.0" - node-event-emitter: ">=3.0.0 <4.0.0" - - node-stream-pipes: ">=1.2.3 <2.0.0" + - node-stream-pipes: ">=1.5.0 <2.0.0" - node-streams: ">=9.0.0 <10.0.0" - nullable: ">=6.0.0 <7.0.0" - parallel: ">=6.0.0 <7.0.0" @@ -728,8 +728,8 @@ packages: - unsafe-coerce node-stream-pipes: type: registry - version: 1.2.3 - integrity: sha256-lXD3x6+p72uBrRHGHrob2jrrBDakhhZE9O9EYE4aFiE= + version: 1.5.0 + integrity: sha256-kca0MJ8Pz4tXNpaw7CdysyNAgdbb8yqH1FhOoYbRm5s= dependencies: - aff - arrays diff --git a/spago.yaml b/spago.yaml index d47b597..5984f69 100644 --- a/spago.yaml +++ b/spago.yaml @@ -33,7 +33,7 @@ package: - newtype: ">=5.0.0 <6.0.0" - node-buffer: ">=9.0.0 <10.0.0" - node-event-emitter: ">=3.0.0 <4.0.0" - - node-stream-pipes: ">=1.2.3 <2.0.0" + - node-stream-pipes: ">=1.5.0 <2.0.0" - node-streams: ">=9.0.0 <10.0.0" - nullable: ">=6.0.0 <7.0.0" - parallel: ">=6.0.0 <7.0.0" diff --git a/src/Pipes.Postgres.purs b/src/Pipes.Postgres.purs index 7b3f53a..38bceae 100644 --- a/src/Pipes.Postgres.purs +++ b/src/Pipes.Postgres.purs @@ -39,7 +39,7 @@ stdin q = do pure Nothing releaseOnEOS (Just a) = pure (Just a) - pipe = Pipes.mapM releaseOnEOS >-> fromWritable (O.fromBufferWritable stream) + pipe = Pipes.mapM releaseOnEOS >-> fromWritable (O.unsafeFromBufferWritable stream) err e = do liftAff $ void $ Client.exec "rollback" client liftEffect $ Pool.release pool client @@ -62,4 +62,4 @@ stdout q = do let releaseOnEOS Nothing = liftEffect $ Pool.release pool client $> Nothing releaseOnEOS (Just a) = pure (Just a) - fromReadable (O.fromBufferReadable stream) >-> Pipes.mapM releaseOnEOS + fromReadable (O.unsafeFromBufferReadable stream) >-> Pipes.mapM releaseOnEOS