@sirutils/driver-scylla - npm Package Compare versions

Comparing version 0.2.2 to 0.2.3

dist/index.js

 // @bun
-import{tagBuilder as E}from"@sirutils/core";var Q=E("@sirutils/driver-scylla"),S={logger:Q("logger"),plugin:Q("plugin"),driver:Q("driver"),resultSet:Q("exec#result-set"),migration:Q("migration"),invalidUpUsage:Q("invalid-up-usage"),invalidDownUsage:Q("invalid-down-usage")};var Z={name:"@sirutils/driver-scylla",version:"0.2.2",type:"module",files:["dist"],exports:{".":{default:"./dist/index.js",types:"./dist/index.d.ts"}},author:"giveerr (https://github.com/giveerr)",homepage:"https://sirutils.com/",repository:{type:"git",url:"https://github.com/sirius-tedarik/sirutils.git"},devDependencies:{"@sirutils/builder":"workspace:*"},dependencies:{"@sirutils/core":"workspace:*","@sirutils/safe-toolbox":"workspace:*","@sirutils/seql":"workspace:*","@sirutils/driver-redis":"workspace:*","cassandra-driver":"^4.7.2"}};import{createPlugin as x,group as g}from"@sirutils/core";import{traverse as c}from"@sirutils/safe-toolbox";import{createAdapter as r}from"@sirutils/seql";import{Client as o,types as h}from"cassandra-driver";import{createLogger as K}from"@sirutils/core";import{extractEnvs as k}from"@sirutils/core";var _=k((p)=>({console:p.CONSOLE||"normal"}));var L=K(S.logger,_.console==="silent"?-999:999);import{Lazy as F,capsule as R,coreTags as q,createActions as M,group as d}from"@sirutils/core";import{proxy as $}from"@sirutils/safe-toolbox";import{INSERT as V,generateCacheKey as m,seqlTags as l}from"@sirutils/seql";var j=M((p)=>{const A=p.lookup("driver-redis");return{exec:(C,...T)=>{return p.api.execWith({cache:!0})(C,...T)},execWith:(C={cache:!1})=>{return R((i,...D)=>{if(!C.cache)return F.from(async()=>{const y=p.api.query(i,...D),O=$(await p.api.$client.execute(y.text,y.values,{prepare:!0}),S.resultSet,!0);if(O.rows)return O.rows.map((w)=>p.api.transformResponse(w)),O.rows;return[]});return F.from(async()=>{const y=p.api.query(i,...D),O=d(()=>m(p.api.$client.keyspace,y));if(O.isOk()){const B=(await A.getJson(O.value))[0];if(B)return B;await A.del(O.value)}if(O.isErr()){if(O.error.name===l.cacheEvicted){let B=[];for await(let W of A.scan(`${p.api.$client.keyspace}#${y.builder.cache.tableName}#*`))for(let f of W){if(y.builder.operations.includes(V))B.push(f),L.info("removed",f);else{const U=f.split("#"),J=U[2];if(U.length>=4&&y.builder.entries.some((X)=>X.key&&J.includes(X.key)))B.push(f),L.info("removed",f);else if(U.length<4)B.push(f),L.info("removed",f)}if(B.length>100)await A.del(...B),B=[]}if(B.length>0)await A.del(...B),B=[]}}const w=$(await p.api.$client.execute(y.text,y.values,{prepare:!0}),S.resultSet,!0);if(!w.rows)w.rows=[];if(O.isOk()){const B=w.rows.map((W)=>p.api.transformResponse(W));await A.setJson([O.value,B])}return w.rows})},`${S.driver}#execWith`,q.createActions)}}},S.driver);import{ProjectError as Y,createActions as u,wrap as v}from"@sirutils/core";import{ulid as s,unique as z}from"@sirutils/safe-toolbox";var{semver:G}=globalThis.Bun;var N=u(async(p)=>{const A=p.lookup("driver-redis");return await p.api.execWith()`CREATE TABLE IF NOT EXISTS ${p.api.table("settings")} (
+import{tagBuilder as E}from"@sirutils/core";var Q=E("@sirutils/driver-scylla"),S={logger:Q("logger"),plugin:Q("plugin"),driver:Q("driver"),resultSet:Q("exec#result-set"),migration:Q("migration"),invalidUpUsage:Q("invalid-up-usage"),invalidDownUsage:Q("invalid-down-usage")};var Z={name:"@sirutils/driver-scylla",version:"0.2.3",type:"module",files:["dist"],exports:{".":{default:"./dist/index.js",types:"./dist/index.d.ts"}},author:"giveerr (https://github.com/giveerr)",homepage:"https://sirutils.com/",repository:{type:"git",url:"https://github.com/sirius-tedarik/sirutils.git"},devDependencies:{"@sirutils/builder":"workspace:*"},dependencies:{"@sirutils/core":"workspace:*","@sirutils/safe-toolbox":"workspace:*","@sirutils/seql":"workspace:*","@sirutils/driver-redis":"workspace:*","cassandra-driver":"^4.7.2"}};import{createPlugin as x,group as g}from"@sirutils/core";import{traverse as c}from"@sirutils/safe-toolbox";import{createAdapter as r}from"@sirutils/seql";import{Client as o,types as h}from"cassandra-driver";import{createLogger as K}from"@sirutils/core";import{extractEnvs as k}from"@sirutils/core";var _=k((p)=>({console:p.CONSOLE||"normal"}));var L=K(S.logger,_.console==="silent"?-999:999);import{Lazy as F,capsule as R,coreTags as q,createActions as M,group as d}from"@sirutils/core";import{proxy as $}from"@sirutils/safe-toolbox";import{INSERT as V,generateCacheKey as m,seqlTags as l}from"@sirutils/seql";var j=M((p)=>{const A=p.lookup("driver-redis");return{exec:(C,...T)=>{return p.api.execWith({cache:!0})(C,...T)},execWith:(C={cache:!1})=>{return R((i,...D)=>{if(!C.cache)return F.from(async()=>{const y=p.api.query(i,...D),O=$(await p.api.$client.execute(y.text,y.values,{prepare:!0}),S.resultSet,!0);if(O.rows)return O.rows.map((w)=>p.api.transformResponse(w)),O.rows;return[]});return F.from(async()=>{const y=p.api.query(i,...D),O=d(()=>m(p.api.$client.keyspace,y));if(O.isOk()){const B=(await A.getJson(O.value))[0];if(B)return B;await A.del(O.value)}if(O.isErr()){if(O.error.name===l.cacheEvicted){let B=[];for await(let W of A.scan(`${p.api.$client.keyspace}#${y.builder.cache.tableName}#*`))for(let f of W){if(y.builder.operations.includes(V))B.push(f),L.info("removed",f);else{const U=f.split("#"),J=U[2];if(U.length>=4&&y.builder.entries.some((X)=>X.key&&J.includes(X.key)))B.push(f),L.info("removed",f);else if(U.length<4)B.push(f),L.info("removed",f)}if(B.length>100)await A.del(...B),B=[]}if(B.length>0)await A.del(...B),B=[]}}const w=$(await p.api.$client.execute(y.text,y.values,{prepare:!0}),S.resultSet,!0);if(!w.rows)w.rows=[];if(O.isOk()){const B=w.rows.map((W)=>p.api.transformResponse(W));await A.setJson([O.value,B])}return w.rows})},`${S.driver}#execWith`,q.createActions)}}},S.driver);import{ProjectError as Y,createActions as u,wrap as v}from"@sirutils/core";import{ulid as s,unique as z}from"@sirutils/safe-toolbox";var{semver:G}=globalThis.Bun;var N=u(async(p)=>{const A=p.lookup("driver-redis");return await p.api.execWith()`CREATE TABLE IF NOT EXISTS ${p.api.table("settings")} (
       id text,
@@ -12,4 +12,4 @@ type text,
             SELECT ${p.api.columns()} FROM ${p.api.table("settings")}
-            WHERE ${p.api.and([{type:"migration",name:D}])} ${p.api.limit(1)}`)[0],O=C.toSorted((P,H)=>G.order(P[1],H[1])).reverse(),w=C.filter((P)=>{return G.order(y?.value??"0.0.0",P[1])>=0&&(T?G.order(P[1],T)===1:!0)}).toSorted((P,H)=>G.order(P[1],H[1])).reverse(),B=C.filter((P)=>{return P[0]===D&&G.order(T??"0.0.0",P[1])>=0&&G.order(y?.value??"0.0.0",P[1])>=0}).toSorted((P,H)=>G.order(P[1],H[1]));if(w.length===0||!y){L.debug(`table: ${D} is already migrated#down`);return}let W=null,f=null;for(let P of w){const H=await P[3]();if(H.isOk()){W=P[1];continue}const I=await P[2]();L.warn(`table: ${D} downgrade failed to version: ${P[1]} and rollback status: ${I.isOk()}`),f=H.error;break}L.warn(`clearing caches for table: ${D} cause: migration.down`);let U=[];for await(let P of A.scan(`${p.api.$client.keyspace}#${D}#*`))if(U.push(...P),U.length>100)await A.del(...U),U=[];if(U.length>0)await A.del(...U),U=[];const J=O.findIndex((P)=>P[1]===W),X=(f&&!W&&J===-1?y.value:void 0)??(f&&!W?O[J]?.at(1):void 0)??(f&&W?O[J+1]?.at(1):void 0)??(B.at(-1)?B.at(-1)[1]:void 0)??"0.0.0";if(await p.api.execWith()`${p.api.update("settings",{value:X})} WHERE ${p.api.and([{id:y.id,type:y.type,name:y.name}])}`,f)return f.throw();L.success(`table: ${D} migrated.down to version: ${X}`)}}},S.migration);var vp=x({name:Z.name,version:Z.version,dependencies:{"driver-redis":"^0.2.2"}},async(p)=>{const A=g(()=>p.lookup("driver-redis"));if(A.isErr())L.error(A),A.error.throw();const C=new o(p.options.client);await C.connect();const T=await r(async()=>({andGrouping:!1,handleRaw:(i)=>i.toString(),parameterPattern:()=>"?",transformData:(i)=>i,transformResponse:(i)=>{return c(i).forEach(function(D){if(D instanceof h.Integer)this.update(+D);else if(D instanceof h.Uuid)this.update(D.toString())}),i}}),S.driver);return L.info("connected to scylla"),{$client:C,...T}},S.plugin).register(j).register(N).lock();export*from"cassandra-driver";export{vp as createScyllaDriver};
+            WHERE ${p.api.and([{type:"migration",name:D}])} ${p.api.limit(1)}`)[0],O=C.toSorted((P,H)=>G.order(P[1],H[1])).reverse(),w=C.filter((P)=>{return G.order(y?.value??"0.0.0",P[1])>=0&&(T?G.order(P[1],T)===1:!0)}).toSorted((P,H)=>G.order(P[1],H[1])).reverse(),B=C.filter((P)=>{return P[0]===D&&G.order(T??"0.0.0",P[1])>=0&&G.order(y?.value??"0.0.0",P[1])>=0}).toSorted((P,H)=>G.order(P[1],H[1]));if(w.length===0||!y){L.debug(`table: ${D} is already migrated#down`);return}let W=null,f=null;for(let P of w){const H=await P[3]();if(H.isOk()){W=P[1];continue}const I=await P[2]();L.warn(`table: ${D} downgrade failed to version: ${P[1]} and rollback status: ${I.isOk()}`),f=H.error;break}L.warn(`clearing caches for table: ${D} cause: migration.down`);let U=[];for await(let P of A.scan(`${p.api.$client.keyspace}#${D}#*`))if(U.push(...P),U.length>100)await A.del(...U),U=[];if(U.length>0)await A.del(...U),U=[];const J=O.findIndex((P)=>P[1]===W),X=(f&&!W&&J===-1?y.value:void 0)??(f&&!W?O[J]?.at(1):void 0)??(f&&W?O[J+1]?.at(1):void 0)??(B.at(-1)?B.at(-1)[1]:void 0)??"0.0.0";if(await p.api.execWith()`${p.api.update("settings",{value:X})} WHERE ${p.api.and([{id:y.id,type:y.type,name:y.name}])}`,f)return f.throw();L.success(`table: ${D} migrated.down to version: ${X}`)}}},S.migration);var vp=x({name:Z.name,version:Z.version,dependencies:{"driver-redis":"^0.2.3"}},async(p)=>{const A=g(()=>p.lookup("driver-redis"));if(A.isErr())L.error(A),A.error.throw();const C=new o(p.options.client);await C.connect();const T=await r(async()=>({andGrouping:!1,handleRaw:(i)=>i.toString(),parameterPattern:()=>"?",transformData:(i)=>i,transformResponse:(i)=>{return c(i).forEach(function(D){if(D instanceof h.Integer)this.update(+D);else if(D instanceof h.Uuid)this.update(D.toString())}),i}}),S.driver);return L.info("connected to scylla"),{$client:C,...T}},S.plugin).register(j).register(N).lock();export*from"cassandra-driver";export{vp as createScyllaDriver};
 
-//# debugId=C6D9F7479C58621664756E2164756E21
+//# debugId=65850EE4A0E820B064756E2164756E21

dist/utils/plugin.js

 // @bun
-import{tagBuilder as q}from"@sirutils/core";var $=q("@sirutils/driver-scylla"),L={logger:$("logger"),plugin:$("plugin"),driver:$("driver"),resultSet:$("exec#result-set"),migration:$("migration"),invalidUpUsage:$("invalid-up-usage"),invalidDownUsage:$("invalid-down-usage")};var I={name:"@sirutils/driver-scylla",version:"0.2.2",type:"module",files:["dist"],exports:{".":{default:"./dist/index.js",types:"./dist/index.d.ts"}},author:"giveerr (https://github.com/giveerr)",homepage:"https://sirutils.com/",repository:{type:"git",url:"https://github.com/sirius-tedarik/sirutils.git"},devDependencies:{"@sirutils/builder":"workspace:*"},dependencies:{"@sirutils/core":"workspace:*","@sirutils/safe-toolbox":"workspace:*","@sirutils/seql":"workspace:*","@sirutils/driver-redis":"workspace:*","cassandra-driver":"^4.7.2"}};import{createPlugin as c,group as i}from"@sirutils/core";import{traverse as s}from"@sirutils/safe-toolbox";import{createAdapter as o}from"@sirutils/seql";import{Client as n,types as T}from"cassandra-driver";import{createLogger as V}from"@sirutils/core";import{extractEnvs as M}from"@sirutils/core";var P=M((f)=>({console:f.CONSOLE||"normal"}));var Z=V(L.logger,P.console==="silent"?-999:999);import{Lazy as w,capsule as S,coreTags as d,createActions as v,group as y}from"@sirutils/core";import{proxy as A}from"@sirutils/safe-toolbox";import{INSERT as m,generateCacheKey as u,seqlTags as x}from"@sirutils/seql";var K=v((f)=>{const Q=f.lookup("driver-redis");return{exec:(H,..._)=>{return f.api.execWith({cache:!0})(H,..._)},execWith:(H={cache:!1})=>{return S((W,...O)=>{if(!H.cache)return w.from(async()=>{const B=f.api.query(W,...O),J=A(await f.api.$client.execute(B.text,B.values,{prepare:!0}),L.resultSet,!0);if(J.rows)return J.rows.map((C)=>f.api.transformResponse(C)),J.rows;return[]});return w.from(async()=>{const B=f.api.query(W,...O),J=y(()=>u(f.api.$client.keyspace,B));if(J.isOk()){const G=(await Q.getJson(J.value))[0];if(G)return G;await Q.del(J.value)}if(J.isErr()){if(J.error.name===x.cacheEvicted){let G=[];for await(let X of Q.scan(`${f.api.$client.keyspace}#${B.builder.cache.tableName}#*`))for(let p of X){if(B.builder.operations.includes(m))G.push(p),Z.info("removed",p);else{const Y=p.split("#"),N=Y[2];if(Y.length>=4&&B.builder.entries.some((j)=>j.key&&N.includes(j.key)))G.push(p),Z.info("removed",p);else if(Y.length<4)G.push(p),Z.info("removed",p)}if(G.length>100)await Q.del(...G),G=[]}if(G.length>0)await Q.del(...G),G=[]}}const C=A(await f.api.$client.execute(B.text,B.values,{prepare:!0}),L.resultSet,!0);if(!C.rows)C.rows=[];if(J.isOk()){const G=C.rows.map((X)=>f.api.transformResponse(X));await Q.setJson([J.value,G])}return C.rows})},`${L.driver}#execWith`,d.createActions)}}},L.driver);import{ProjectError as D,createActions as g,wrap as h}from"@sirutils/core";import{ulid as l,unique as E}from"@sirutils/safe-toolbox";var{semver:F}=globalThis.Bun;var R=g(async(f)=>{const Q=f.lookup("driver-redis");return await f.api.execWith()`CREATE TABLE IF NOT EXISTS ${f.api.table("settings")} (
+import{tagBuilder as q}from"@sirutils/core";var $=q("@sirutils/driver-scylla"),L={logger:$("logger"),plugin:$("plugin"),driver:$("driver"),resultSet:$("exec#result-set"),migration:$("migration"),invalidUpUsage:$("invalid-up-usage"),invalidDownUsage:$("invalid-down-usage")};var I={name:"@sirutils/driver-scylla",version:"0.2.3",type:"module",files:["dist"],exports:{".":{default:"./dist/index.js",types:"./dist/index.d.ts"}},author:"giveerr (https://github.com/giveerr)",homepage:"https://sirutils.com/",repository:{type:"git",url:"https://github.com/sirius-tedarik/sirutils.git"},devDependencies:{"@sirutils/builder":"workspace:*"},dependencies:{"@sirutils/core":"workspace:*","@sirutils/safe-toolbox":"workspace:*","@sirutils/seql":"workspace:*","@sirutils/driver-redis":"workspace:*","cassandra-driver":"^4.7.2"}};import{createPlugin as c,group as i}from"@sirutils/core";import{traverse as s}from"@sirutils/safe-toolbox";import{createAdapter as o}from"@sirutils/seql";import{Client as n,types as T}from"cassandra-driver";import{createLogger as V}from"@sirutils/core";import{extractEnvs as M}from"@sirutils/core";var P=M((f)=>({console:f.CONSOLE||"normal"}));var Z=V(L.logger,P.console==="silent"?-999:999);import{Lazy as w,capsule as S,coreTags as d,createActions as v,group as y}from"@sirutils/core";import{proxy as A}from"@sirutils/safe-toolbox";import{INSERT as m,generateCacheKey as u,seqlTags as x}from"@sirutils/seql";var K=v((f)=>{const Q=f.lookup("driver-redis");return{exec:(H,..._)=>{return f.api.execWith({cache:!0})(H,..._)},execWith:(H={cache:!1})=>{return S((W,...O)=>{if(!H.cache)return w.from(async()=>{const B=f.api.query(W,...O),J=A(await f.api.$client.execute(B.text,B.values,{prepare:!0}),L.resultSet,!0);if(J.rows)return J.rows.map((C)=>f.api.transformResponse(C)),J.rows;return[]});return w.from(async()=>{const B=f.api.query(W,...O),J=y(()=>u(f.api.$client.keyspace,B));if(J.isOk()){const G=(await Q.getJson(J.value))[0];if(G)return G;await Q.del(J.value)}if(J.isErr()){if(J.error.name===x.cacheEvicted){let G=[];for await(let X of Q.scan(`${f.api.$client.keyspace}#${B.builder.cache.tableName}#*`))for(let p of X){if(B.builder.operations.includes(m))G.push(p),Z.info("removed",p);else{const Y=p.split("#"),N=Y[2];if(Y.length>=4&&B.builder.entries.some((j)=>j.key&&N.includes(j.key)))G.push(p),Z.info("removed",p);else if(Y.length<4)G.push(p),Z.info("removed",p)}if(G.length>100)await Q.del(...G),G=[]}if(G.length>0)await Q.del(...G),G=[]}}const C=A(await f.api.$client.execute(B.text,B.values,{prepare:!0}),L.resultSet,!0);if(!C.rows)C.rows=[];if(J.isOk()){const G=C.rows.map((X)=>f.api.transformResponse(X));await Q.setJson([J.value,G])}return C.rows})},`${L.driver}#execWith`,d.createActions)}}},L.driver);import{ProjectError as D,createActions as g,wrap as h}from"@sirutils/core";import{ulid as l,unique as E}from"@sirutils/safe-toolbox";var{semver:F}=globalThis.Bun;var R=g(async(f)=>{const Q=f.lookup("driver-redis");return await f.api.execWith()`CREATE TABLE IF NOT EXISTS ${f.api.table("settings")} (
       id text,
@@ -12,4 +12,4 @@ type text,
             SELECT ${f.api.columns()} FROM ${f.api.table("settings")}
-            WHERE ${f.api.and([{type:"migration",name:O}])} ${f.api.limit(1)}`)[0],J=H.toSorted((U,z)=>F.order(U[1],z[1])).reverse(),C=H.filter((U)=>{return F.order(B?.value??"0.0.0",U[1])>=0&&(_?F.order(U[1],_)===1:!0)}).toSorted((U,z)=>F.order(U[1],z[1])).reverse(),G=H.filter((U)=>{return U[0]===O&&F.order(_??"0.0.0",U[1])>=0&&F.order(B?.value??"0.0.0",U[1])>=0}).toSorted((U,z)=>F.order(U[1],z[1]));if(C.length===0||!B){Z.debug(`table: ${O} is already migrated#down`);return}let X=null,p=null;for(let U of C){const z=await U[3]();if(z.isOk()){X=U[1];continue}const k=await U[2]();Z.warn(`table: ${O} downgrade failed to version: ${U[1]} and rollback status: ${k.isOk()}`),p=z.error;break}Z.warn(`clearing caches for table: ${O} cause: migration.down`);let Y=[];for await(let U of Q.scan(`${f.api.$client.keyspace}#${O}#*`))if(Y.push(...U),Y.length>100)await Q.del(...Y),Y=[];if(Y.length>0)await Q.del(...Y),Y=[];const N=J.findIndex((U)=>U[1]===X),j=(p&&!X&&N===-1?B.value:void 0)??(p&&!X?J[N]?.at(1):void 0)??(p&&X?J[N+1]?.at(1):void 0)??(G.at(-1)?G.at(-1)[1]:void 0)??"0.0.0";if(await f.api.execWith()`${f.api.update("settings",{value:j})} WHERE ${f.api.and([{id:B.id,type:B.type,name:B.name}])}`,p)return p.throw();Z.success(`table: ${O} migrated.down to version: ${j}`)}}},L.migration);var Kf=c({name:I.name,version:I.version,dependencies:{"driver-redis":"^0.2.2"}},async(f)=>{const Q=i(()=>f.lookup("driver-redis"));if(Q.isErr())Z.error(Q),Q.error.throw();const H=new n(f.options.client);await H.connect();const _=await o(async()=>({andGrouping:!1,handleRaw:(W)=>W.toString(),parameterPattern:()=>"?",transformData:(W)=>W,transformResponse:(W)=>{return s(W).forEach(function(O){if(O instanceof T.Integer)this.update(+O);else if(O instanceof T.Uuid)this.update(O.toString())}),W}}),L.driver);return Z.info("connected to scylla"),{$client:H,..._}},L.plugin).register(K).register(R).lock();export{Kf as createScyllaDriver};
+            WHERE ${f.api.and([{type:"migration",name:O}])} ${f.api.limit(1)}`)[0],J=H.toSorted((U,z)=>F.order(U[1],z[1])).reverse(),C=H.filter((U)=>{return F.order(B?.value??"0.0.0",U[1])>=0&&(_?F.order(U[1],_)===1:!0)}).toSorted((U,z)=>F.order(U[1],z[1])).reverse(),G=H.filter((U)=>{return U[0]===O&&F.order(_??"0.0.0",U[1])>=0&&F.order(B?.value??"0.0.0",U[1])>=0}).toSorted((U,z)=>F.order(U[1],z[1]));if(C.length===0||!B){Z.debug(`table: ${O} is already migrated#down`);return}let X=null,p=null;for(let U of C){const z=await U[3]();if(z.isOk()){X=U[1];continue}const k=await U[2]();Z.warn(`table: ${O} downgrade failed to version: ${U[1]} and rollback status: ${k.isOk()}`),p=z.error;break}Z.warn(`clearing caches for table: ${O} cause: migration.down`);let Y=[];for await(let U of Q.scan(`${f.api.$client.keyspace}#${O}#*`))if(Y.push(...U),Y.length>100)await Q.del(...Y),Y=[];if(Y.length>0)await Q.del(...Y),Y=[];const N=J.findIndex((U)=>U[1]===X),j=(p&&!X&&N===-1?B.value:void 0)??(p&&!X?J[N]?.at(1):void 0)??(p&&X?J[N+1]?.at(1):void 0)??(G.at(-1)?G.at(-1)[1]:void 0)??"0.0.0";if(await f.api.execWith()`${f.api.update("settings",{value:j})} WHERE ${f.api.and([{id:B.id,type:B.type,name:B.name}])}`,p)return p.throw();Z.success(`table: ${O} migrated.down to version: ${j}`)}}},L.migration);var Kf=c({name:I.name,version:I.version,dependencies:{"driver-redis":"^0.2.3"}},async(f)=>{const Q=i(()=>f.lookup("driver-redis"));if(Q.isErr())Z.error(Q),Q.error.throw();const H=new n(f.options.client);await H.connect();const _=await o(async()=>({andGrouping:!1,handleRaw:(W)=>W.toString(),parameterPattern:()=>"?",transformData:(W)=>W,transformResponse:(W)=>{return s(W).forEach(function(O){if(O instanceof T.Integer)this.update(+O);else if(O instanceof T.Uuid)this.update(O.toString())}),W}}),L.driver);return Z.info("connected to scylla"),{$client:H,..._}},L.plugin).register(K).register(R).lock();export{Kf as createScyllaDriver};
 
-//# debugId=F407555800BDE4B864756E2164756E21
+//# debugId=35D893DEF97E9E1C64756E2164756E21

package.json

 {
   "name": "@sirutils/driver-scylla",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "type": "module",
@@ -21,11 +21,11 @@ "files": [
   "devDependencies": {
-    "@sirutils/builder": "0.2.2"
+    "@sirutils/builder": "0.2.3"
   },
   "dependencies": {
     "cassandra-driver": "^4.7.2",
-    "@sirutils/core": "0.2.2",
-    "@sirutils/safe-toolbox": "0.2.2",
-    "@sirutils/seql": "0.2.2",
-    "@sirutils/driver-redis": "0.2.2"
+    "@sirutils/core": "0.2.3",
+    "@sirutils/seql": "0.2.3",
+    "@sirutils/safe-toolbox": "0.2.3",
+    "@sirutils/driver-redis": "0.2.3"
   }
 }

No alert changes

No metric changes

Dependency changes

• + Added@sirutils/core@0.2.3(transitive)

• + Added@sirutils/driver-redis@0.2.3(transitive)

• + Added@sirutils/safe-toolbox@0.2.3(transitive)

• + Added@sirutils/seql@0.2.3(transitive)

• - Removed@sirutils/core@0.2.2(transitive)

• - Removed@sirutils/driver-redis@0.2.2(transitive)

• - Removed@sirutils/safe-toolbox@0.2.2(transitive)

• - Removed@sirutils/seql@0.2.2(transitive)

• Updated@sirutils/core@0.2.3

• Updated@sirutils/driver-redis@0.2.3

• Updated@sirutils/safe-toolbox@0.2.3

• Updated@sirutils/seql@0.2.3