libsql-stateless
Advanced tools
Comparing version 2.5.9 to 2.5.10
@@ -14,10 +14,17 @@ "use strict"; | ||
else | ||
return { isOk: false, err: await (async () => { | ||
try { | ||
return await res.clone().json(); | ||
return { isOk: false, err: { | ||
kind: "libsqlPipelineResErr", | ||
error_data: { | ||
server_message: await (async () => { | ||
try { | ||
return await res.clone().json(); | ||
} | ||
catch { | ||
return await res.text(); | ||
} | ||
})(), | ||
http_status_code: res.status, | ||
http_status_text: res.statusText | ||
} | ||
catch { | ||
return await res.text(); | ||
} | ||
})() }; | ||
} }; | ||
} | ||
@@ -49,6 +56,9 @@ /** | ||
else | ||
return { isOk: false, err: resu.error }; //has to be StreamResErr | ||
return { isOk: false, err: { | ||
kind: "libsqlStreamResErrData", | ||
error_data: resu.error | ||
} }; //has to be StreamResErr | ||
} | ||
else | ||
return { isOk: false, err: res.err }; //PipelineResErr or StreamResErrData | ||
return res; //PipelineResErr or StreamResErrData | ||
} | ||
@@ -81,6 +91,9 @@ exports.libsqlExecute = libsqlExecute; | ||
else | ||
return { isOk: false, err: resu.error }; //has to be StreamResErr | ||
return { isOk: false, err: { | ||
kind: "libsqlStreamResErrData", | ||
error_data: resu.error | ||
} }; //has to be StreamResErr | ||
} | ||
else | ||
return { isOk: false, err: res.err }; //PipelineResErr or StreamResErrData | ||
return res; //PipelineResErr or StreamResErrData | ||
} | ||
@@ -87,0 +100,0 @@ exports.libsqlBatch = libsqlBatch; |
@@ -1,2 +0,2 @@ | ||
import { libsqlBatchReqStep, libsqlBatchStreamResOkData, libsqlConfig, libsqlPipelineResErr, libsqlResult, libsqlSQLStatement, libsqlStatementResOkData, libsqlStreamResErrData } from "./types"; | ||
import { libsqlBatchReqStep, libsqlBatchStreamResOkData, libsqlConfig, libsqlError, libsqlResult, libsqlSQLStatement, libsqlStatementResOkData } from "./types"; | ||
/** | ||
@@ -8,3 +8,3 @@ * @async | ||
*/ | ||
export declare function libsqlExecute(conf: libsqlConfig, stmt: libsqlSQLStatement): Promise<libsqlResult<libsqlStatementResOkData, libsqlStreamResErrData | libsqlPipelineResErr>>; | ||
export declare function libsqlExecute(conf: libsqlConfig, stmt: libsqlSQLStatement): Promise<libsqlResult<libsqlStatementResOkData, libsqlError>>; | ||
/** | ||
@@ -16,3 +16,3 @@ * @async | ||
*/ | ||
export declare function libsqlBatch(conf: libsqlConfig, batch_steps: Array<libsqlBatchReqStep>): Promise<libsqlResult<libsqlBatchStreamResOkData, libsqlStreamResErrData | libsqlPipelineResErr>>; | ||
export declare function libsqlBatch(conf: libsqlConfig, batch_steps: Array<libsqlBatchReqStep>): Promise<libsqlResult<libsqlBatchStreamResOkData, libsqlError>>; | ||
/** | ||
@@ -19,0 +19,0 @@ * @async |
@@ -11,10 +11,17 @@ async function hranaFetch(s) { | ||
else | ||
return { isOk: false, err: await (async () => { | ||
try { | ||
return await res.clone().json(); | ||
return { isOk: false, err: { | ||
kind: "libsqlPipelineResErr", | ||
error_data: { | ||
server_message: await (async () => { | ||
try { | ||
return await res.clone().json(); | ||
} | ||
catch { | ||
return await res.text(); | ||
} | ||
})(), | ||
http_status_code: res.status, | ||
http_status_text: res.statusText | ||
} | ||
catch { | ||
return await res.text(); | ||
} | ||
})() }; | ||
} }; | ||
} | ||
@@ -46,6 +53,9 @@ /** | ||
else | ||
return { isOk: false, err: resu.error }; //has to be StreamResErr | ||
return { isOk: false, err: { | ||
kind: "libsqlStreamResErrData", | ||
error_data: resu.error | ||
} }; //has to be StreamResErr | ||
} | ||
else | ||
return { isOk: false, err: res.err }; //PipelineResErr or StreamResErrData | ||
return res; //PipelineResErr or StreamResErrData | ||
} | ||
@@ -77,6 +87,9 @@ /** | ||
else | ||
return { isOk: false, err: resu.error }; //has to be StreamResErr | ||
return { isOk: false, err: { | ||
kind: "libsqlStreamResErrData", | ||
error_data: resu.error | ||
} }; //has to be StreamResErr | ||
} | ||
else | ||
return { isOk: false, err: res.err }; //PipelineResErr or StreamResErrData | ||
return res; //PipelineResErr or StreamResErrData | ||
} | ||
@@ -83,0 +96,0 @@ /** |
@@ -12,2 +12,10 @@ export type libsqlResult<T, E> = { | ||
}; | ||
export type libsqlError = { | ||
kind: "libsqlPipelineResErr" | "libsqlStreamResErrData"; | ||
error_data: libsqlStreamResErrData | { | ||
server_message: libsqlPipelineResErr; | ||
http_status_code: number; | ||
http_status_text: string; | ||
}; | ||
}; | ||
export type libsqlPipelineReq = { | ||
@@ -72,3 +80,3 @@ baton: string | null; | ||
message: string; | ||
code?: string | null; | ||
code?: string; | ||
}; | ||
@@ -75,0 +83,0 @@ export type libsqlSQLValue = { |
{ | ||
"name": "libsql-stateless", | ||
"version": "2.5.9", | ||
"version": "2.5.10", | ||
"homepage": "https://github.com/DaBigBlob/libsql-stateless#readme", | ||
@@ -58,2 +58,3 @@ "repository": { | ||
"test": "bun run _tests/test2.ts", | ||
"perf": "bun run _tests/perf.ts", | ||
"clean": "npm run prebuild", | ||
@@ -60,0 +61,0 @@ "prod": "npm publish && npm run clean" |
@@ -23,3 +23,3 @@ # libsql-stateless | ||
```sh | ||
$ npm i libsql-stateless | ||
$ npm i libsql-stateless #pnpm, yarn, etc. | ||
# or | ||
@@ -26,0 +26,0 @@ $ bun add libsql-stateless |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
17877
391