@nlux/langchain - npm Package Compare versions

Comparing version 2.0.8-alpha to 2.0.9-alpha

cjs/langchain.js

@@ -1,1 +0,1 @@
-"use strict";var e=Object.defineProperty,t=(t,r,s)=>((t,r,s)=>r in t?e(t,r,{enumerable:!0,configurable:!0,writable:!0,value:s}):t[r]=s)(t,"symbol"!=typeof r?r+"":r,s);class r extends Error{constructor(e={}){super(e.message),t(this,"exceptionId"),t(this,"message"),t(this,"source"),t(this,"type"),this.message=e.message??"",this.source=e.source,this.type=this.constructor.name,this.exceptionId=e.exceptionId}}class s extends r{}const o=e=>{"string"!=typeof e?e&&"function"==typeof e.toString?console.warn(`[nlux] ${e.toString()}`):console.warn("[nlux]"):console.warn(`[nlux] ${e}`)},n=[],a=e=>{const t=/\/.*\/(invoke|stream)$/g.exec(e);if(!t||t.length<2)return;const r=t[1];return"invoke"===r||"stream"===r?r:void 0},i=e=>{const t=a(e.url),r=e.dataTransferMode,s=t?"stream"===t?"stream":"fetch":void 0;const i=s??e.dataTransferMode??u.defaultDataTransferMode;var h;return r&&s&&r!==s&&(h=`The data transfer mode provided to LangServe adapter does not match the LangServe runnable URL action. When you provide a runnable URL that ends with '/${t}', the data transfer mode is automatically set to '${s}' and the 'dataTransferMode' option should not be provided or should be set to '${s}'`,n.includes(h)||(n.push(h),o(h))),i},h=e=>{const t=e.url;return/\/.*\/(invoke|stream)$/g.test(t)?t.replace(/\/(invoke|stream)$/g,""):t},c=e=>{const t=h(e).replace(/\/$/,""),r=(e=>{const t=e.url,r=a(t);return r||("fetch"===i(e)?"invoke":"stream")})(e);return`${t}/${r}`};class u{constructor(e){this.__instanceId=`${this.info.id}-${"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,(e=>{const t=16*Math.random()|0;return("x"==e?t:3&t|8).toString(16)}))}`,this.__options={...e},this.theDataTransferModeToUse=i(e),this.theHeadersToUse=e.headers||{},this.theUseInputSchemaOptionToUse="boolean"!=typeof e.useInputSchema||e.useInputSchema,this.theEndpointUrlToUse=c(e),this.theRunnableNameToUse=(e=>h(e).replace(/\/$/,"").split("/").pop()||"langserve-runnable")(e),this.theInputSchemaUrlToUse=((e,t)=>`${h(e).replace(/\/$/,"")}/input_schema`)(e),this.init()}get dataTransferMode(){return this.theDataTransferModeToUse}get endpointUrl(){return this.theEndpointUrlToUse}get headers(){return this.theHeadersToUse}get id(){return this.__instanceId}get info(){return{id:"langserve-adapter",capabilities:{chat:!0,fileUpload:!1,textToSpeech:!1,speechToText:!1}}}get inputPreProcessor(){return this.__options.inputPreProcessor}get inputSchema(){return this.theInputSchemaToUse}get outputPreProcessor(){return this.__options.outputPreProcessor}get runnableName(){return this.theRunnableNameToUse}get useInputSchema(){return this.theUseInputSchemaOptionToUse}get inputSchemaUrl(){return this.theInputSchemaUrlToUse}async fetchSchema(e){try{const t=await fetch(e),r=await t.json();return"object"==typeof r&&r?r:void o(`LangServe adapter is unable process schema loaded from: ${e}`)}catch(t){return void o(`LangServe adapter is unable to fetch schema from: ${e}`)}}init(){!this.inputPreProcessor&&this.useInputSchema&&this.fetchSchema(this.inputSchemaUrl).then((e=>{this.theInputSchemaToUse=e}))}getDisplayableMessageFromAiOutput(e){return this.outputPreProcessor?this.outputPreProcessor(e):e}getRequestBody(e,t){if(this.inputPreProcessor){const r=this.inputPreProcessor(e,t);return JSON.stringify({input:r})}if(this.inputSchema){const t=((e,t,r,s)=>{if(!r||"object"!=typeof r.properties)return e;if("object"!=typeof r||!r)return o(`LangServer adapter cannot process the input schema fetched for runnable "${s}". The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string as input.`),e;if("string"===r.type)return e;if("object"===r.type){const t="object"==typeof r.properties&&r.properties?r.properties:{},s=Object.keys(t).filter((e=>e&&"string"==typeof r.properties[e].type)).map((e=>e));if(1===s.length){const t=s[0];return{[t]:e}}o('LangServer adapter cannot find a valid property to match to user input inside the "${runnableName}" input schema. The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string accepted as part of input schema.')}})(e,0,this.inputSchema,this.runnableName);if(void 0!==t)return JSON.stringify({input:t})}return JSON.stringify({input:e})}}u.defaultDataTransferMode="stream";class p extends u{constructor(e){super(e)}async fetchText(e,t){const r=this.getRequestBody(e,t.conversationHistory),s=await fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:r});if(!s.ok)throw new Error(`LangServe runnable returned status code: ${s.status}`);const o=await s.json();if("object"!=typeof o||!o||void 0===o.output)throw new Error('Invalid response from LangServe runnable: Response is not an object or does not contain an "output" property');const n="object"==typeof o&&o?o.output:void 0;return this.getDisplayableMessageFromAiOutput(n)}streamText(e,t,r){throw new s({source:this.constructor.name,message:"Cannot stream text from the fetch adapter!"})}}const d=e=>{const t=/^event:\s+(?<event>[\w]+)((\r?)\n(\r?)data: (?<data>(.|\n)*))?/gm.exec(e);if(!t)return;const{event:r,data:s}=t.groups||{};if(r&&("data"===r||"end"===r))try{return{event:r,data:s?JSON.parse(s):void 0}}catch(e){return o(`LangServe stream adapter failed to parse data for chunk event "${r}" | Data: ${s}`),{event:r,data:void 0}}},m=e=>{if(!e)return[];const t=/(((?<=^)|(?<=\n))event:\s+(\w+))/g,r=[];let s=t.exec(e);for(;s;)r.push(s.index),s=t.exec(e);const o=(t,s)=>{const o=r[s+1]||e.length;return e.substring(t,o)};try{return r.map(o).map(d).filter((e=>void 0!==e)).map((e=>e))}catch(e){return e instanceof Error?e:[]}},l=e=>"object"==typeof e&&null!==e&&e.message?.toLowerCase().includes("connection error")?"NX-NT-001":null;class f extends u{constructor(e){super(e)}async fetchText(e,t){throw new s({source:this.constructor.name,message:"Cannot fetch text using the stream adapter!"})}streamText(e,t,n){const a=this.getRequestBody(e,n.conversationHistory);fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:a}).then((async e=>{if(!e.ok)throw new r({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});if(!e.body)throw new r({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});const s=e.body.getReader(),n=new TextDecoder;let a=!1;for(;!a;){const{value:e,done:r}=await s.read();if(r){a=!0;continue}const i=n.decode(e),h=m(i);if(Array.isArray(h))for(const e of h){if("data"===e.event&&void 0!==e.data){const r=this.getDisplayableMessageFromAiOutput(e.data);"string"==typeof r&&r&&t.next(r)}if("end"===e.event){t.complete(),a=!0;break}}h instanceof Error&&(o(h),t.error(h),a=!0)}})).catch((e=>{o(e),t.error(new s({source:this.constructor.name,message:e.message,exceptionId:l(e)??void 0}))}))}}class g{constructor(e){e&&(this.theDataTransferMode=e.theDataTransferMode,this.theHeaders=e.theHeaders,this.theInputPreProcessor=e.theInputPreProcessor,this.theOutputPreProcessor=e.theOutputPreProcessor,this.theUrl=e.theUrl)}create(){if(!this.theUrl)throw new s({source:this.constructor.name,message:"Unable to create LangServe adapter. URL is missing. Make sure you are calling withUrl() before calling create()."});const e={url:this.theUrl,dataTransferMode:this.theDataTransferMode,headers:this.theHeaders,inputPreProcessor:this.theInputPreProcessor,outputPreProcessor:this.theOutputPreProcessor,useInputSchema:this.theUseInputSchema};return"stream"===i(e)?new f(e):new p(e)}withDataTransferMode(e){if(void 0!==this.theDataTransferMode)throw new s({source:this.constructor.name,message:"Cannot set the data loading mode more than once"});return this.theDataTransferMode=e,this}withHeaders(e){if(void 0!==this.theHeaders)throw new s({source:this.constructor.name,message:"Cannot set the headers option more than once"});return this.theHeaders=e,this}withInputPreProcessor(e){if(void 0!==this.theInputPreProcessor)throw new s({source:this.constructor.name,message:"Cannot set the input pre-processor option more than once"});return this.theInputPreProcessor=e,this}withInputSchema(e){if(void 0!==this.theUseInputSchema)throw new s({source:this.constructor.name,message:"Cannot set the input schema option more than once"});return this.theUseInputSchema=e,this}withOutputPreProcessor(e){if(void 0!==this.theOutputPreProcessor)throw new s({source:this.constructor.name,message:"Cannot set the output pre-processor option more than once"});return this.theOutputPreProcessor=e,this}withUrl(e){if(void 0!==this.theUrl)throw new s({source:this.constructor.name,message:"Cannot set the runnable URL option more than once"});return this.theUrl=e,this}}exports.createChatAdapter=function(){return new g};
+"use strict";var e=Object.defineProperty,t=(t,r,s)=>((t,r,s)=>r in t?e(t,r,{enumerable:!0,configurable:!0,writable:!0,value:s}):t[r]=s)(t,"symbol"!=typeof r?r+"":r,s);class r extends Error{constructor(e={}){super(e.message),t(this,"exceptionId"),t(this,"message"),t(this,"source"),t(this,"type"),this.message=e.message??"",this.source=e.source,this.type=this.constructor.name,this.exceptionId=e.exceptionId}}class s extends r{}const o=e=>{"string"!=typeof e?e&&"function"==typeof e.toString?console.warn(`[nlux] ${e.toString()}`):console.warn("[nlux]"):console.warn(`[nlux] ${e}`)},n=[],a=e=>{const t=/\/.*\/(invoke|stream)$/g.exec(e);if(!t||t.length<2)return;const r=t[1];return"invoke"===r||"stream"===r?r:void 0},i=e=>{const t=a(e.url),r=e.dataTransferMode,s=t?"stream"===t?"stream":"fetch":void 0;const i=s??e.dataTransferMode??u.defaultDataTransferMode;var h;return r&&s&&r!==s&&(h=`The data transfer mode provided to LangServe adapter does not match the LangServe runnable URL action. When you provide a runnable URL that ends with '/${t}', the data transfer mode is automatically set to '${s}' and the 'dataTransferMode' option should not be provided or should be set to '${s}'`,n.includes(h)||(n.push(h),o(h))),i},h=e=>{const t=e.url;return/\/.*\/(invoke|stream)$/g.test(t)?t.replace(/\/(invoke|stream)$/g,""):t},c=e=>{const t=h(e).replace(/\/$/,""),r=(e=>{const t=e.url,r=a(t);return r||("fetch"===i(e)?"invoke":"stream")})(e);return`${t}/${r}`};class u{constructor(e){this.__instanceId=`${this.info.id}-${"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,(e=>{const t=16*Math.random()|0;return("x"==e?t:3&t|8).toString(16)}))}`,this.__options={...e},this.theDataTransferModeToUse=i(e),this.theHeadersToUse=e.headers||{},this.theUseInputSchemaOptionToUse="boolean"!=typeof e.useInputSchema||e.useInputSchema,this.theEndpointUrlToUse=c(e),this.theRunnableNameToUse=(e=>h(e).replace(/\/$/,"").split("/").pop()||"langserve-runnable")(e),this.theInputSchemaUrlToUse=((e,t)=>`${h(e).replace(/\/$/,"")}/input_schema`)(e),this.init()}get dataTransferMode(){return this.theDataTransferModeToUse}get endpointUrl(){return this.theEndpointUrlToUse}get headers(){return this.theHeadersToUse}get id(){return this.__instanceId}get info(){return{id:"langserve-adapter",capabilities:{chat:!0,fileUpload:!1,textToSpeech:!1,speechToText:!1}}}get inputPreProcessor(){return this.__options.inputPreProcessor}get inputSchema(){return this.theInputSchemaToUse}get outputPreProcessor(){return this.__options.outputPreProcessor}get runnableName(){return this.theRunnableNameToUse}get useInputSchema(){return this.theUseInputSchemaOptionToUse}get inputSchemaUrl(){return this.theInputSchemaUrlToUse}async fetchSchema(e){try{const t=await fetch(e),r=await t.json();return"object"==typeof r&&r?r:void o(`LangServe adapter is unable process schema loaded from: ${e}`)}catch(t){return void o(`LangServe adapter is unable to fetch schema from: ${e}`)}}init(){!this.inputPreProcessor&&this.useInputSchema&&this.fetchSchema(this.inputSchemaUrl).then((e=>{this.theInputSchemaToUse=e}))}getDisplayableMessageFromAiOutput(e){return this.outputPreProcessor?this.outputPreProcessor(e):e}getRequestBody(e,t){if(this.inputPreProcessor){const r=this.inputPreProcessor(e,t);return JSON.stringify({input:r})}if(this.inputSchema){const t=((e,t,r,s)=>{if(!r||"object"!=typeof r.properties)return e;if("object"!=typeof r||!r)return o(`LangServer adapter cannot process the input schema fetched for runnable "${s}". The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string as input.`),e;if("string"===r.type)return e;if("object"===r.type){const t="object"==typeof r.properties&&r.properties?r.properties:{},s=Object.keys(t).filter((e=>e&&"string"==typeof r.properties[e].type)).map((e=>e));if(1===s.length){const t=s[0];return{[t]:e}}o('LangServer adapter cannot find a valid property to match to user input inside the "${runnableName}" input schema. The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string accepted as part of input schema.')}})(e,0,this.inputSchema,this.runnableName);if(void 0!==t)return JSON.stringify({input:t})}return JSON.stringify({input:e})}}u.defaultDataTransferMode="stream";class p extends u{constructor(e){super(e)}async fetchText(e,t){const r=this.getRequestBody(e,t.conversationHistory),s=await fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:r});if(!s.ok)throw new Error(`LangServe runnable returned status code: ${s.status}`);const o=await s.json();if("object"!=typeof o||!o||void 0===o.output)throw new Error('Invalid response from LangServe runnable: Response is not an object or does not contain an "output" property');const n="object"==typeof o&&o?o.output:void 0;return this.getDisplayableMessageFromAiOutput(n)}streamText(e,t,r){throw new s({source:this.constructor.name,message:"Cannot stream text from the fetch adapter!"})}}const d=e=>{const t=/^event:\s+(?<event>[\w]+)((\r?)\n(\r?)data: (?<data>(.|\n)*))?/gm.exec(e);if(!t)return;const{event:r,data:s}=t.groups||{};if(r&&("data"===r||"end"===r))try{return{event:r,data:s?JSON.parse(s):void 0}}catch(e){return o(`LangServe stream adapter failed to parse data for chunk event "${r}" | Data: ${s}`),{event:r,data:void 0}}},m=e=>{if(!e)return[];const t=/(((?<=^)|(?<=\n))event:\s+(\w+))/g,r=[];let s=t.exec(e);for(;s;)r.push(s.index),s=t.exec(e);const o=(t,s)=>{const o=r[s+1]||e.length;return e.substring(t,o)};try{return r.map(o).map(d).filter((e=>void 0!==e)).map((e=>e))}catch(e){return e instanceof Error?e:[]}},l=e=>{if("object"==typeof e&&null!==e){const t=e;if(t.message&&"string"==typeof t.message&&t.message.toLowerCase().includes("connection error"))return"connection-error"}return null};class f extends u{constructor(e){super(e)}async fetchText(e,t){throw new s({source:this.constructor.name,message:"Cannot fetch text using the stream adapter!"})}streamText(e,t,n){const a=this.getRequestBody(e,n.conversationHistory);fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:a}).then((async e=>{if(!e.ok)throw new r({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});if(!e.body)throw new r({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});const s=e.body.getReader(),n=new TextDecoder;let a=!1;for(;!a;){const{value:e,done:r}=await s.read();if(r){a=!0;continue}const i=n.decode(e),h=m(i);if(Array.isArray(h))for(const e of h){if("data"===e.event&&void 0!==e.data){const r=this.getDisplayableMessageFromAiOutput(e.data);"string"==typeof r&&r&&t.next(r)}if("end"===e.event){t.complete(),a=!0;break}}h instanceof Error&&(o(h),t.error(h),a=!0)}})).catch((e=>{o(e),t.error(new s({source:this.constructor.name,message:e.message,exceptionId:l(e)??void 0}))}))}}class g{constructor(e){e&&(this.theDataTransferMode=e.theDataTransferMode,this.theHeaders=e.theHeaders,this.theInputPreProcessor=e.theInputPreProcessor,this.theOutputPreProcessor=e.theOutputPreProcessor,this.theUrl=e.theUrl)}create(){if(!this.theUrl)throw new s({source:this.constructor.name,message:"Unable to create LangServe adapter. URL is missing. Make sure you are calling withUrl() before calling create()."});const e={url:this.theUrl,dataTransferMode:this.theDataTransferMode,headers:this.theHeaders,inputPreProcessor:this.theInputPreProcessor,outputPreProcessor:this.theOutputPreProcessor,useInputSchema:this.theUseInputSchema};return"stream"===i(e)?new f(e):new p(e)}withDataTransferMode(e){if(void 0!==this.theDataTransferMode)throw new s({source:this.constructor.name,message:"Cannot set the data loading mode more than once"});return this.theDataTransferMode=e,this}withHeaders(e){if(void 0!==this.theHeaders)throw new s({source:this.constructor.name,message:"Cannot set the headers option more than once"});return this.theHeaders=e,this}withInputPreProcessor(e){if(void 0!==this.theInputPreProcessor)throw new s({source:this.constructor.name,message:"Cannot set the input pre-processor option more than once"});return this.theInputPreProcessor=e,this}withInputSchema(e){if(void 0!==this.theUseInputSchema)throw new s({source:this.constructor.name,message:"Cannot set the input schema option more than once"});return this.theUseInputSchema=e,this}withOutputPreProcessor(e){if(void 0!==this.theOutputPreProcessor)throw new s({source:this.constructor.name,message:"Cannot set the output pre-processor option more than once"});return this.theOutputPreProcessor=e,this}withUrl(e){if(void 0!==this.theUrl)throw new s({source:this.constructor.name,message:"Cannot set the runnable URL option more than once"});return this.theUrl=e,this}}exports.createChatAdapter=function(){return new g};

esm/langchain.js

@@ -1,1 +0,1 @@
-var e=Object.defineProperty,t=(t,r,s)=>((t,r,s)=>r in t?e(t,r,{enumerable:!0,configurable:!0,writable:!0,value:s}):t[r]=s)(t,"symbol"!=typeof r?r+"":r,s);class r extends Error{constructor(e={}){super(e.message),t(this,"exceptionId"),t(this,"message"),t(this,"source"),t(this,"type"),this.message=e.message??"",this.source=e.source,this.type=this.constructor.name,this.exceptionId=e.exceptionId}}class s extends r{}const o=e=>{"string"!=typeof e?e&&"function"==typeof e.toString?console.warn(`[nlux] ${e.toString()}`):console.warn("[nlux]"):console.warn(`[nlux] ${e}`)},n=[],a=e=>{const t=/\/.*\/(invoke|stream)$/g.exec(e);if(!t||t.length<2)return;const r=t[1];return"invoke"===r||"stream"===r?r:void 0},i=e=>{const t=a(e.url),r=e.dataTransferMode,s=t?"stream"===t?"stream":"fetch":void 0;const i=s??e.dataTransferMode??u.defaultDataTransferMode;var h;return r&&s&&r!==s&&(h=`The data transfer mode provided to LangServe adapter does not match the LangServe runnable URL action. When you provide a runnable URL that ends with '/${t}', the data transfer mode is automatically set to '${s}' and the 'dataTransferMode' option should not be provided or should be set to '${s}'`,n.includes(h)||(n.push(h),o(h))),i},h=e=>{const t=e.url;return/\/.*\/(invoke|stream)$/g.test(t)?t.replace(/\/(invoke|stream)$/g,""):t},c=e=>{const t=h(e).replace(/\/$/,""),r=(e=>{const t=e.url,r=a(t);return r||("fetch"===i(e)?"invoke":"stream")})(e);return`${t}/${r}`};class u{constructor(e){this.__instanceId=`${this.info.id}-${"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,(e=>{const t=16*Math.random()|0;return("x"==e?t:3&t|8).toString(16)}))}`,this.__options={...e},this.theDataTransferModeToUse=i(e),this.theHeadersToUse=e.headers||{},this.theUseInputSchemaOptionToUse="boolean"!=typeof e.useInputSchema||e.useInputSchema,this.theEndpointUrlToUse=c(e),this.theRunnableNameToUse=(e=>h(e).replace(/\/$/,"").split("/").pop()||"langserve-runnable")(e),this.theInputSchemaUrlToUse=((e,t)=>`${h(e).replace(/\/$/,"")}/input_schema`)(e),this.init()}get dataTransferMode(){return this.theDataTransferModeToUse}get endpointUrl(){return this.theEndpointUrlToUse}get headers(){return this.theHeadersToUse}get id(){return this.__instanceId}get info(){return{id:"langserve-adapter",capabilities:{chat:!0,fileUpload:!1,textToSpeech:!1,speechToText:!1}}}get inputPreProcessor(){return this.__options.inputPreProcessor}get inputSchema(){return this.theInputSchemaToUse}get outputPreProcessor(){return this.__options.outputPreProcessor}get runnableName(){return this.theRunnableNameToUse}get useInputSchema(){return this.theUseInputSchemaOptionToUse}get inputSchemaUrl(){return this.theInputSchemaUrlToUse}async fetchSchema(e){try{const t=await fetch(e),r=await t.json();return"object"==typeof r&&r?r:void o(`LangServe adapter is unable process schema loaded from: ${e}`)}catch(t){return void o(`LangServe adapter is unable to fetch schema from: ${e}`)}}init(){!this.inputPreProcessor&&this.useInputSchema&&this.fetchSchema(this.inputSchemaUrl).then((e=>{this.theInputSchemaToUse=e}))}getDisplayableMessageFromAiOutput(e){return this.outputPreProcessor?this.outputPreProcessor(e):e}getRequestBody(e,t){if(this.inputPreProcessor){const r=this.inputPreProcessor(e,t);return JSON.stringify({input:r})}if(this.inputSchema){const t=((e,t,r,s)=>{if(!r||"object"!=typeof r.properties)return e;if("object"!=typeof r||!r)return o(`LangServer adapter cannot process the input schema fetched for runnable "${s}". The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string as input.`),e;if("string"===r.type)return e;if("object"===r.type){const t="object"==typeof r.properties&&r.properties?r.properties:{},s=Object.keys(t).filter((e=>e&&"string"==typeof r.properties[e].type)).map((e=>e));if(1===s.length){const t=s[0];return{[t]:e}}o('LangServer adapter cannot find a valid property to match to user input inside the "${runnableName}" input schema. The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string accepted as part of input schema.')}})(e,0,this.inputSchema,this.runnableName);if(void 0!==t)return JSON.stringify({input:t})}return JSON.stringify({input:e})}}u.defaultDataTransferMode="stream";class p extends u{constructor(e){super(e)}async fetchText(e,t){const r=this.getRequestBody(e,t.conversationHistory),s=await fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:r});if(!s.ok)throw new Error(`LangServe runnable returned status code: ${s.status}`);const o=await s.json();if("object"!=typeof o||!o||void 0===o.output)throw new Error('Invalid response from LangServe runnable: Response is not an object or does not contain an "output" property');const n="object"==typeof o&&o?o.output:void 0;return this.getDisplayableMessageFromAiOutput(n)}streamText(e,t,r){throw new s({source:this.constructor.name,message:"Cannot stream text from the fetch adapter!"})}}const d=e=>{const t=/^event:\s+(?<event>[\w]+)((\r?)\n(\r?)data: (?<data>(.|\n)*))?/gm.exec(e);if(!t)return;const{event:r,data:s}=t.groups||{};if(r&&("data"===r||"end"===r))try{return{event:r,data:s?JSON.parse(s):void 0}}catch(e){return o(`LangServe stream adapter failed to parse data for chunk event "${r}" | Data: ${s}`),{event:r,data:void 0}}},m=e=>{if(!e)return[];const t=/(((?<=^)|(?<=\n))event:\s+(\w+))/g,r=[];let s=t.exec(e);for(;s;)r.push(s.index),s=t.exec(e);const o=(t,s)=>{const o=r[s+1]||e.length;return e.substring(t,o)};try{return r.map(o).map(d).filter((e=>void 0!==e)).map((e=>e))}catch(e){return e instanceof Error?e:[]}},l=e=>"object"==typeof e&&null!==e&&e.message?.toLowerCase().includes("connection error")?"NX-NT-001":null;class f extends u{constructor(e){super(e)}async fetchText(e,t){throw new s({source:this.constructor.name,message:"Cannot fetch text using the stream adapter!"})}streamText(e,t,n){const a=this.getRequestBody(e,n.conversationHistory);fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:a}).then((async e=>{if(!e.ok)throw new r({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});if(!e.body)throw new r({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});const s=e.body.getReader(),n=new TextDecoder;let a=!1;for(;!a;){const{value:e,done:r}=await s.read();if(r){a=!0;continue}const i=n.decode(e),h=m(i);if(Array.isArray(h))for(const e of h){if("data"===e.event&&void 0!==e.data){const r=this.getDisplayableMessageFromAiOutput(e.data);"string"==typeof r&&r&&t.next(r)}if("end"===e.event){t.complete(),a=!0;break}}h instanceof Error&&(o(h),t.error(h),a=!0)}})).catch((e=>{o(e),t.error(new s({source:this.constructor.name,message:e.message,exceptionId:l(e)??void 0}))}))}}class g{constructor(e){e&&(this.theDataTransferMode=e.theDataTransferMode,this.theHeaders=e.theHeaders,this.theInputPreProcessor=e.theInputPreProcessor,this.theOutputPreProcessor=e.theOutputPreProcessor,this.theUrl=e.theUrl)}create(){if(!this.theUrl)throw new s({source:this.constructor.name,message:"Unable to create LangServe adapter. URL is missing. Make sure you are calling withUrl() before calling create()."});const e={url:this.theUrl,dataTransferMode:this.theDataTransferMode,headers:this.theHeaders,inputPreProcessor:this.theInputPreProcessor,outputPreProcessor:this.theOutputPreProcessor,useInputSchema:this.theUseInputSchema};return"stream"===i(e)?new f(e):new p(e)}withDataTransferMode(e){if(void 0!==this.theDataTransferMode)throw new s({source:this.constructor.name,message:"Cannot set the data loading mode more than once"});return this.theDataTransferMode=e,this}withHeaders(e){if(void 0!==this.theHeaders)throw new s({source:this.constructor.name,message:"Cannot set the headers option more than once"});return this.theHeaders=e,this}withInputPreProcessor(e){if(void 0!==this.theInputPreProcessor)throw new s({source:this.constructor.name,message:"Cannot set the input pre-processor option more than once"});return this.theInputPreProcessor=e,this}withInputSchema(e){if(void 0!==this.theUseInputSchema)throw new s({source:this.constructor.name,message:"Cannot set the input schema option more than once"});return this.theUseInputSchema=e,this}withOutputPreProcessor(e){if(void 0!==this.theOutputPreProcessor)throw new s({source:this.constructor.name,message:"Cannot set the output pre-processor option more than once"});return this.theOutputPreProcessor=e,this}withUrl(e){if(void 0!==this.theUrl)throw new s({source:this.constructor.name,message:"Cannot set the runnable URL option more than once"});return this.theUrl=e,this}}const v=function(){return new g};export{v as createChatAdapter};
+var e=Object.defineProperty,t=(t,r,s)=>((t,r,s)=>r in t?e(t,r,{enumerable:!0,configurable:!0,writable:!0,value:s}):t[r]=s)(t,"symbol"!=typeof r?r+"":r,s);class r extends Error{constructor(e={}){super(e.message),t(this,"exceptionId"),t(this,"message"),t(this,"source"),t(this,"type"),this.message=e.message??"",this.source=e.source,this.type=this.constructor.name,this.exceptionId=e.exceptionId}}class s extends r{}const o=e=>{"string"!=typeof e?e&&"function"==typeof e.toString?console.warn(`[nlux] ${e.toString()}`):console.warn("[nlux]"):console.warn(`[nlux] ${e}`)},n=[],a=e=>{const t=/\/.*\/(invoke|stream)$/g.exec(e);if(!t||t.length<2)return;const r=t[1];return"invoke"===r||"stream"===r?r:void 0},i=e=>{const t=a(e.url),r=e.dataTransferMode,s=t?"stream"===t?"stream":"fetch":void 0;const i=s??e.dataTransferMode??u.defaultDataTransferMode;var h;return r&&s&&r!==s&&(h=`The data transfer mode provided to LangServe adapter does not match the LangServe runnable URL action. When you provide a runnable URL that ends with '/${t}', the data transfer mode is automatically set to '${s}' and the 'dataTransferMode' option should not be provided or should be set to '${s}'`,n.includes(h)||(n.push(h),o(h))),i},h=e=>{const t=e.url;return/\/.*\/(invoke|stream)$/g.test(t)?t.replace(/\/(invoke|stream)$/g,""):t},c=e=>{const t=h(e).replace(/\/$/,""),r=(e=>{const t=e.url,r=a(t);return r||("fetch"===i(e)?"invoke":"stream")})(e);return`${t}/${r}`};class u{constructor(e){this.__instanceId=`${this.info.id}-${"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,(e=>{const t=16*Math.random()|0;return("x"==e?t:3&t|8).toString(16)}))}`,this.__options={...e},this.theDataTransferModeToUse=i(e),this.theHeadersToUse=e.headers||{},this.theUseInputSchemaOptionToUse="boolean"!=typeof e.useInputSchema||e.useInputSchema,this.theEndpointUrlToUse=c(e),this.theRunnableNameToUse=(e=>h(e).replace(/\/$/,"").split("/").pop()||"langserve-runnable")(e),this.theInputSchemaUrlToUse=((e,t)=>`${h(e).replace(/\/$/,"")}/input_schema`)(e),this.init()}get dataTransferMode(){return this.theDataTransferModeToUse}get endpointUrl(){return this.theEndpointUrlToUse}get headers(){return this.theHeadersToUse}get id(){return this.__instanceId}get info(){return{id:"langserve-adapter",capabilities:{chat:!0,fileUpload:!1,textToSpeech:!1,speechToText:!1}}}get inputPreProcessor(){return this.__options.inputPreProcessor}get inputSchema(){return this.theInputSchemaToUse}get outputPreProcessor(){return this.__options.outputPreProcessor}get runnableName(){return this.theRunnableNameToUse}get useInputSchema(){return this.theUseInputSchemaOptionToUse}get inputSchemaUrl(){return this.theInputSchemaUrlToUse}async fetchSchema(e){try{const t=await fetch(e),r=await t.json();return"object"==typeof r&&r?r:void o(`LangServe adapter is unable process schema loaded from: ${e}`)}catch(t){return void o(`LangServe adapter is unable to fetch schema from: ${e}`)}}init(){!this.inputPreProcessor&&this.useInputSchema&&this.fetchSchema(this.inputSchemaUrl).then((e=>{this.theInputSchemaToUse=e}))}getDisplayableMessageFromAiOutput(e){return this.outputPreProcessor?this.outputPreProcessor(e):e}getRequestBody(e,t){if(this.inputPreProcessor){const r=this.inputPreProcessor(e,t);return JSON.stringify({input:r})}if(this.inputSchema){const t=((e,t,r,s)=>{if(!r||"object"!=typeof r.properties)return e;if("object"!=typeof r||!r)return o(`LangServer adapter cannot process the input schema fetched for runnable "${s}". The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string as input.`),e;if("string"===r.type)return e;if("object"===r.type){const t="object"==typeof r.properties&&r.properties?r.properties:{},s=Object.keys(t).filter((e=>e&&"string"==typeof r.properties[e].type)).map((e=>e));if(1===s.length){const t=s[0];return{[t]:e}}o('LangServer adapter cannot find a valid property to match to user input inside the "${runnableName}" input schema. The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string accepted as part of input schema.')}})(e,0,this.inputSchema,this.runnableName);if(void 0!==t)return JSON.stringify({input:t})}return JSON.stringify({input:e})}}u.defaultDataTransferMode="stream";class p extends u{constructor(e){super(e)}async fetchText(e,t){const r=this.getRequestBody(e,t.conversationHistory),s=await fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:r});if(!s.ok)throw new Error(`LangServe runnable returned status code: ${s.status}`);const o=await s.json();if("object"!=typeof o||!o||void 0===o.output)throw new Error('Invalid response from LangServe runnable: Response is not an object or does not contain an "output" property');const n="object"==typeof o&&o?o.output:void 0;return this.getDisplayableMessageFromAiOutput(n)}streamText(e,t,r){throw new s({source:this.constructor.name,message:"Cannot stream text from the fetch adapter!"})}}const d=e=>{const t=/^event:\s+(?<event>[\w]+)((\r?)\n(\r?)data: (?<data>(.|\n)*))?/gm.exec(e);if(!t)return;const{event:r,data:s}=t.groups||{};if(r&&("data"===r||"end"===r))try{return{event:r,data:s?JSON.parse(s):void 0}}catch(e){return o(`LangServe stream adapter failed to parse data for chunk event "${r}" | Data: ${s}`),{event:r,data:void 0}}},m=e=>{if(!e)return[];const t=/(((?<=^)|(?<=\n))event:\s+(\w+))/g,r=[];let s=t.exec(e);for(;s;)r.push(s.index),s=t.exec(e);const o=(t,s)=>{const o=r[s+1]||e.length;return e.substring(t,o)};try{return r.map(o).map(d).filter((e=>void 0!==e)).map((e=>e))}catch(e){return e instanceof Error?e:[]}},l=e=>{if("object"==typeof e&&null!==e){const t=e;if(t.message&&"string"==typeof t.message&&t.message.toLowerCase().includes("connection error"))return"connection-error"}return null};class f extends u{constructor(e){super(e)}async fetchText(e,t){throw new s({source:this.constructor.name,message:"Cannot fetch text using the stream adapter!"})}streamText(e,t,n){const a=this.getRequestBody(e,n.conversationHistory);fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:a}).then((async e=>{if(!e.ok)throw new r({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});if(!e.body)throw new r({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});const s=e.body.getReader(),n=new TextDecoder;let a=!1;for(;!a;){const{value:e,done:r}=await s.read();if(r){a=!0;continue}const i=n.decode(e),h=m(i);if(Array.isArray(h))for(const e of h){if("data"===e.event&&void 0!==e.data){const r=this.getDisplayableMessageFromAiOutput(e.data);"string"==typeof r&&r&&t.next(r)}if("end"===e.event){t.complete(),a=!0;break}}h instanceof Error&&(o(h),t.error(h),a=!0)}})).catch((e=>{o(e),t.error(new s({source:this.constructor.name,message:e.message,exceptionId:l(e)??void 0}))}))}}class g{constructor(e){e&&(this.theDataTransferMode=e.theDataTransferMode,this.theHeaders=e.theHeaders,this.theInputPreProcessor=e.theInputPreProcessor,this.theOutputPreProcessor=e.theOutputPreProcessor,this.theUrl=e.theUrl)}create(){if(!this.theUrl)throw new s({source:this.constructor.name,message:"Unable to create LangServe adapter. URL is missing. Make sure you are calling withUrl() before calling create()."});const e={url:this.theUrl,dataTransferMode:this.theDataTransferMode,headers:this.theHeaders,inputPreProcessor:this.theInputPreProcessor,outputPreProcessor:this.theOutputPreProcessor,useInputSchema:this.theUseInputSchema};return"stream"===i(e)?new f(e):new p(e)}withDataTransferMode(e){if(void 0!==this.theDataTransferMode)throw new s({source:this.constructor.name,message:"Cannot set the data loading mode more than once"});return this.theDataTransferMode=e,this}withHeaders(e){if(void 0!==this.theHeaders)throw new s({source:this.constructor.name,message:"Cannot set the headers option more than once"});return this.theHeaders=e,this}withInputPreProcessor(e){if(void 0!==this.theInputPreProcessor)throw new s({source:this.constructor.name,message:"Cannot set the input pre-processor option more than once"});return this.theInputPreProcessor=e,this}withInputSchema(e){if(void 0!==this.theUseInputSchema)throw new s({source:this.constructor.name,message:"Cannot set the input schema option more than once"});return this.theUseInputSchema=e,this}withOutputPreProcessor(e){if(void 0!==this.theOutputPreProcessor)throw new s({source:this.constructor.name,message:"Cannot set the output pre-processor option more than once"});return this.theOutputPreProcessor=e,this}withUrl(e){if(void 0!==this.theUrl)throw new s({source:this.constructor.name,message:"Cannot set the runnable URL option more than once"});return this.theUrl=e,this}}const v=function(){return new g};export{v as createChatAdapter};

package.json

 {
   "name": "@nlux/langchain",
-  "version": "2.0.8-alpha",
+  "version": "2.0.9-alpha",
   "description": "The LangChain adapters for nlux, the javascript library for building conversational AI interfaces.",
@@ -62,3 +62,3 @@ "keywords": [
   "dependencies": {
-    "@nlux/core": "2.0.8-alpha"
+    "@nlux/core": "2.0.9-alpha"
   },
@@ -65,0 +65,0 @@ "peerDependencies": {},

umd/langchain.js

@@ -1,1 +0,1 @@
-!function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports):"function"==typeof define&&define.amd?define(["exports"],t):t((e="undefined"!=typeof globalThis?globalThis:e||self)["@nlux/langchain"]={})}(this,(function(e){"use strict";var t=Object.defineProperty,r=(e,r,s)=>((e,r,s)=>r in e?t(e,r,{enumerable:!0,configurable:!0,writable:!0,value:s}):e[r]=s)(e,"symbol"!=typeof r?r+"":r,s);class s extends Error{constructor(e={}){super(e.message),r(this,"exceptionId"),r(this,"message"),r(this,"source"),r(this,"type"),this.message=e.message??"",this.source=e.source,this.type=this.constructor.name,this.exceptionId=e.exceptionId}}class o extends s{}const n=e=>{"string"!=typeof e?e&&"function"==typeof e.toString?console.warn(`[nlux] ${e.toString()}`):console.warn("[nlux]"):console.warn(`[nlux] ${e}`)},a=[],i=e=>{const t=/\/.*\/(invoke|stream)$/g.exec(e);if(!t||t.length<2)return;const r=t[1];return"invoke"===r||"stream"===r?r:void 0},h=e=>{const t=i(e.url),r=e.dataTransferMode,s=t?"stream"===t?"stream":"fetch":void 0;const o=s??e.dataTransferMode??p.defaultDataTransferMode;var h;return r&&s&&r!==s&&(h=`The data transfer mode provided to LangServe adapter does not match the LangServe runnable URL action. When you provide a runnable URL that ends with '/${t}', the data transfer mode is automatically set to '${s}' and the 'dataTransferMode' option should not be provided or should be set to '${s}'`,a.includes(h)||(a.push(h),n(h))),o},c=e=>{const t=e.url;return/\/.*\/(invoke|stream)$/g.test(t)?t.replace(/\/(invoke|stream)$/g,""):t},u=e=>{const t=c(e).replace(/\/$/,""),r=(e=>{const t=e.url,r=i(t);return r||("fetch"===h(e)?"invoke":"stream")})(e);return`${t}/${r}`};class p{constructor(e){this.__instanceId=`${this.info.id}-${"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,(e=>{const t=16*Math.random()|0;return("x"==e?t:3&t|8).toString(16)}))}`,this.__options={...e},this.theDataTransferModeToUse=h(e),this.theHeadersToUse=e.headers||{},this.theUseInputSchemaOptionToUse="boolean"!=typeof e.useInputSchema||e.useInputSchema,this.theEndpointUrlToUse=u(e),this.theRunnableNameToUse=(e=>c(e).replace(/\/$/,"").split("/").pop()||"langserve-runnable")(e),this.theInputSchemaUrlToUse=((e,t)=>`${c(e).replace(/\/$/,"")}/input_schema`)(e),this.init()}get dataTransferMode(){return this.theDataTransferModeToUse}get endpointUrl(){return this.theEndpointUrlToUse}get headers(){return this.theHeadersToUse}get id(){return this.__instanceId}get info(){return{id:"langserve-adapter",capabilities:{chat:!0,fileUpload:!1,textToSpeech:!1,speechToText:!1}}}get inputPreProcessor(){return this.__options.inputPreProcessor}get inputSchema(){return this.theInputSchemaToUse}get outputPreProcessor(){return this.__options.outputPreProcessor}get runnableName(){return this.theRunnableNameToUse}get useInputSchema(){return this.theUseInputSchemaOptionToUse}get inputSchemaUrl(){return this.theInputSchemaUrlToUse}async fetchSchema(e){try{const t=await fetch(e),r=await t.json();return"object"==typeof r&&r?r:void n(`LangServe adapter is unable process schema loaded from: ${e}`)}catch(t){return void n(`LangServe adapter is unable to fetch schema from: ${e}`)}}init(){!this.inputPreProcessor&&this.useInputSchema&&this.fetchSchema(this.inputSchemaUrl).then((e=>{this.theInputSchemaToUse=e}))}getDisplayableMessageFromAiOutput(e){return this.outputPreProcessor?this.outputPreProcessor(e):e}getRequestBody(e,t){if(this.inputPreProcessor){const r=this.inputPreProcessor(e,t);return JSON.stringify({input:r})}if(this.inputSchema){const t=((e,t,r,s)=>{if(!r||"object"!=typeof r.properties)return e;if("object"!=typeof r||!r)return n(`LangServer adapter cannot process the input schema fetched for runnable "${s}". The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string as input.`),e;if("string"===r.type)return e;if("object"===r.type){const t="object"==typeof r.properties&&r.properties?r.properties:{},s=Object.keys(t).filter((e=>e&&"string"==typeof r.properties[e].type)).map((e=>e));if(1===s.length){const t=s[0];return{[t]:e}}n('LangServer adapter cannot find a valid property to match to user input inside the "${runnableName}" input schema. The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string accepted as part of input schema.')}})(e,0,this.inputSchema,this.runnableName);if(void 0!==t)return JSON.stringify({input:t})}return JSON.stringify({input:e})}}p.defaultDataTransferMode="stream";class d extends p{constructor(e){super(e)}async fetchText(e,t){const r=this.getRequestBody(e,t.conversationHistory),s=await fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:r});if(!s.ok)throw new Error(`LangServe runnable returned status code: ${s.status}`);const o=await s.json();if("object"!=typeof o||!o||void 0===o.output)throw new Error('Invalid response from LangServe runnable: Response is not an object or does not contain an "output" property');const n="object"==typeof o&&o?o.output:void 0;return this.getDisplayableMessageFromAiOutput(n)}streamText(e,t,r){throw new o({source:this.constructor.name,message:"Cannot stream text from the fetch adapter!"})}}const m=e=>{const t=/^event:\s+(?<event>[\w]+)((\r?)\n(\r?)data: (?<data>(.|\n)*))?/gm.exec(e);if(!t)return;const{event:r,data:s}=t.groups||{};if(r&&("data"===r||"end"===r))try{return{event:r,data:s?JSON.parse(s):void 0}}catch(e){return n(`LangServe stream adapter failed to parse data for chunk event "${r}" | Data: ${s}`),{event:r,data:void 0}}},l=e=>{if(!e)return[];const t=/(((?<=^)|(?<=\n))event:\s+(\w+))/g,r=[];let s=t.exec(e);for(;s;)r.push(s.index),s=t.exec(e);const o=(t,s)=>{const o=r[s+1]||e.length;return e.substring(t,o)};try{return r.map(o).map(m).filter((e=>void 0!==e)).map((e=>e))}catch(e){return e instanceof Error?e:[]}},f=e=>"object"==typeof e&&null!==e&&e.message?.toLowerCase().includes("connection error")?"NX-NT-001":null;class g extends p{constructor(e){super(e)}async fetchText(e,t){throw new o({source:this.constructor.name,message:"Cannot fetch text using the stream adapter!"})}streamText(e,t,r){const a=this.getRequestBody(e,r.conversationHistory);fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:a}).then((async e=>{if(!e.ok)throw new s({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});if(!e.body)throw new s({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});const r=e.body.getReader(),o=new TextDecoder;let a=!1;for(;!a;){const{value:e,done:s}=await r.read();if(s){a=!0;continue}const i=o.decode(e),h=l(i);if(Array.isArray(h))for(const e of h){if("data"===e.event&&void 0!==e.data){const r=this.getDisplayableMessageFromAiOutput(e.data);"string"==typeof r&&r&&t.next(r)}if("end"===e.event){t.complete(),a=!0;break}}h instanceof Error&&(n(h),t.error(h),a=!0)}})).catch((e=>{n(e),t.error(new o({source:this.constructor.name,message:e.message,exceptionId:f(e)??void 0}))}))}}class v{constructor(e){e&&(this.theDataTransferMode=e.theDataTransferMode,this.theHeaders=e.theHeaders,this.theInputPreProcessor=e.theInputPreProcessor,this.theOutputPreProcessor=e.theOutputPreProcessor,this.theUrl=e.theUrl)}create(){if(!this.theUrl)throw new o({source:this.constructor.name,message:"Unable to create LangServe adapter. URL is missing. Make sure you are calling withUrl() before calling create()."});const e={url:this.theUrl,dataTransferMode:this.theDataTransferMode,headers:this.theHeaders,inputPreProcessor:this.theInputPreProcessor,outputPreProcessor:this.theOutputPreProcessor,useInputSchema:this.theUseInputSchema};return"stream"===h(e)?new g(e):new d(e)}withDataTransferMode(e){if(void 0!==this.theDataTransferMode)throw new o({source:this.constructor.name,message:"Cannot set the data loading mode more than once"});return this.theDataTransferMode=e,this}withHeaders(e){if(void 0!==this.theHeaders)throw new o({source:this.constructor.name,message:"Cannot set the headers option more than once"});return this.theHeaders=e,this}withInputPreProcessor(e){if(void 0!==this.theInputPreProcessor)throw new o({source:this.constructor.name,message:"Cannot set the input pre-processor option more than once"});return this.theInputPreProcessor=e,this}withInputSchema(e){if(void 0!==this.theUseInputSchema)throw new o({source:this.constructor.name,message:"Cannot set the input schema option more than once"});return this.theUseInputSchema=e,this}withOutputPreProcessor(e){if(void 0!==this.theOutputPreProcessor)throw new o({source:this.constructor.name,message:"Cannot set the output pre-processor option more than once"});return this.theOutputPreProcessor=e,this}withUrl(e){if(void 0!==this.theUrl)throw new o({source:this.constructor.name,message:"Cannot set the runnable URL option more than once"});return this.theUrl=e,this}}e.createChatAdapter=function(){return new v}}));
+!function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports):"function"==typeof define&&define.amd?define(["exports"],t):t((e="undefined"!=typeof globalThis?globalThis:e||self)["@nlux/langchain"]={})}(this,(function(e){"use strict";var t=Object.defineProperty,r=(e,r,s)=>((e,r,s)=>r in e?t(e,r,{enumerable:!0,configurable:!0,writable:!0,value:s}):e[r]=s)(e,"symbol"!=typeof r?r+"":r,s);class s extends Error{constructor(e={}){super(e.message),r(this,"exceptionId"),r(this,"message"),r(this,"source"),r(this,"type"),this.message=e.message??"",this.source=e.source,this.type=this.constructor.name,this.exceptionId=e.exceptionId}}class o extends s{}const n=e=>{"string"!=typeof e?e&&"function"==typeof e.toString?console.warn(`[nlux] ${e.toString()}`):console.warn("[nlux]"):console.warn(`[nlux] ${e}`)},a=[],i=e=>{const t=/\/.*\/(invoke|stream)$/g.exec(e);if(!t||t.length<2)return;const r=t[1];return"invoke"===r||"stream"===r?r:void 0},h=e=>{const t=i(e.url),r=e.dataTransferMode,s=t?"stream"===t?"stream":"fetch":void 0;const o=s??e.dataTransferMode??p.defaultDataTransferMode;var h;return r&&s&&r!==s&&(h=`The data transfer mode provided to LangServe adapter does not match the LangServe runnable URL action. When you provide a runnable URL that ends with '/${t}', the data transfer mode is automatically set to '${s}' and the 'dataTransferMode' option should not be provided or should be set to '${s}'`,a.includes(h)||(a.push(h),n(h))),o},c=e=>{const t=e.url;return/\/.*\/(invoke|stream)$/g.test(t)?t.replace(/\/(invoke|stream)$/g,""):t},u=e=>{const t=c(e).replace(/\/$/,""),r=(e=>{const t=e.url,r=i(t);return r||("fetch"===h(e)?"invoke":"stream")})(e);return`${t}/${r}`};class p{constructor(e){this.__instanceId=`${this.info.id}-${"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,(e=>{const t=16*Math.random()|0;return("x"==e?t:3&t|8).toString(16)}))}`,this.__options={...e},this.theDataTransferModeToUse=h(e),this.theHeadersToUse=e.headers||{},this.theUseInputSchemaOptionToUse="boolean"!=typeof e.useInputSchema||e.useInputSchema,this.theEndpointUrlToUse=u(e),this.theRunnableNameToUse=(e=>c(e).replace(/\/$/,"").split("/").pop()||"langserve-runnable")(e),this.theInputSchemaUrlToUse=((e,t)=>`${c(e).replace(/\/$/,"")}/input_schema`)(e),this.init()}get dataTransferMode(){return this.theDataTransferModeToUse}get endpointUrl(){return this.theEndpointUrlToUse}get headers(){return this.theHeadersToUse}get id(){return this.__instanceId}get info(){return{id:"langserve-adapter",capabilities:{chat:!0,fileUpload:!1,textToSpeech:!1,speechToText:!1}}}get inputPreProcessor(){return this.__options.inputPreProcessor}get inputSchema(){return this.theInputSchemaToUse}get outputPreProcessor(){return this.__options.outputPreProcessor}get runnableName(){return this.theRunnableNameToUse}get useInputSchema(){return this.theUseInputSchemaOptionToUse}get inputSchemaUrl(){return this.theInputSchemaUrlToUse}async fetchSchema(e){try{const t=await fetch(e),r=await t.json();return"object"==typeof r&&r?r:void n(`LangServe adapter is unable process schema loaded from: ${e}`)}catch(t){return void n(`LangServe adapter is unable to fetch schema from: ${e}`)}}init(){!this.inputPreProcessor&&this.useInputSchema&&this.fetchSchema(this.inputSchemaUrl).then((e=>{this.theInputSchemaToUse=e}))}getDisplayableMessageFromAiOutput(e){return this.outputPreProcessor?this.outputPreProcessor(e):e}getRequestBody(e,t){if(this.inputPreProcessor){const r=this.inputPreProcessor(e,t);return JSON.stringify({input:r})}if(this.inputSchema){const t=((e,t,r,s)=>{if(!r||"object"!=typeof r.properties)return e;if("object"!=typeof r||!r)return n(`LangServer adapter cannot process the input schema fetched for runnable "${s}". The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string as input.`),e;if("string"===r.type)return e;if("object"===r.type){const t="object"==typeof r.properties&&r.properties?r.properties:{},s=Object.keys(t).filter((e=>e&&"string"==typeof r.properties[e].type)).map((e=>e));if(1===s.length){const t=s[0];return{[t]:e}}n('LangServer adapter cannot find a valid property to match to user input inside the "${runnableName}" input schema. The user message will be sent to LangServe endpoint as is without transformations. To override this behavior, you can either set the "useInputSchema" option to false, or provide a custom input pre-processor via the "inputPreProcessor" option, or update your endpoint and input schema to have an object with a single string property or a string accepted as part of input schema.')}})(e,0,this.inputSchema,this.runnableName);if(void 0!==t)return JSON.stringify({input:t})}return JSON.stringify({input:e})}}p.defaultDataTransferMode="stream";class d extends p{constructor(e){super(e)}async fetchText(e,t){const r=this.getRequestBody(e,t.conversationHistory),s=await fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:r});if(!s.ok)throw new Error(`LangServe runnable returned status code: ${s.status}`);const o=await s.json();if("object"!=typeof o||!o||void 0===o.output)throw new Error('Invalid response from LangServe runnable: Response is not an object or does not contain an "output" property');const n="object"==typeof o&&o?o.output:void 0;return this.getDisplayableMessageFromAiOutput(n)}streamText(e,t,r){throw new o({source:this.constructor.name,message:"Cannot stream text from the fetch adapter!"})}}const m=e=>{const t=/^event:\s+(?<event>[\w]+)((\r?)\n(\r?)data: (?<data>(.|\n)*))?/gm.exec(e);if(!t)return;const{event:r,data:s}=t.groups||{};if(r&&("data"===r||"end"===r))try{return{event:r,data:s?JSON.parse(s):void 0}}catch(e){return n(`LangServe stream adapter failed to parse data for chunk event "${r}" | Data: ${s}`),{event:r,data:void 0}}},l=e=>{if(!e)return[];const t=/(((?<=^)|(?<=\n))event:\s+(\w+))/g,r=[];let s=t.exec(e);for(;s;)r.push(s.index),s=t.exec(e);const o=(t,s)=>{const o=r[s+1]||e.length;return e.substring(t,o)};try{return r.map(o).map(m).filter((e=>void 0!==e)).map((e=>e))}catch(e){return e instanceof Error?e:[]}},f=e=>{if("object"==typeof e&&null!==e){const t=e;if(t.message&&"string"==typeof t.message&&t.message.toLowerCase().includes("connection error"))return"connection-error"}return null};class g extends p{constructor(e){super(e)}async fetchText(e,t){throw new o({source:this.constructor.name,message:"Cannot fetch text using the stream adapter!"})}streamText(e,t,r){const a=this.getRequestBody(e,r.conversationHistory);fetch(this.endpointUrl,{method:"POST",headers:{...this.headers,"Content-Type":"application/json"},body:a}).then((async e=>{if(!e.ok)throw new s({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});if(!e.body)throw new s({source:this.constructor.name,message:`LangServe runnable returned status code: ${e.status}`});const r=e.body.getReader(),o=new TextDecoder;let a=!1;for(;!a;){const{value:e,done:s}=await r.read();if(s){a=!0;continue}const i=o.decode(e),h=l(i);if(Array.isArray(h))for(const e of h){if("data"===e.event&&void 0!==e.data){const r=this.getDisplayableMessageFromAiOutput(e.data);"string"==typeof r&&r&&t.next(r)}if("end"===e.event){t.complete(),a=!0;break}}h instanceof Error&&(n(h),t.error(h),a=!0)}})).catch((e=>{n(e),t.error(new o({source:this.constructor.name,message:e.message,exceptionId:f(e)??void 0}))}))}}class v{constructor(e){e&&(this.theDataTransferMode=e.theDataTransferMode,this.theHeaders=e.theHeaders,this.theInputPreProcessor=e.theInputPreProcessor,this.theOutputPreProcessor=e.theOutputPreProcessor,this.theUrl=e.theUrl)}create(){if(!this.theUrl)throw new o({source:this.constructor.name,message:"Unable to create LangServe adapter. URL is missing. Make sure you are calling withUrl() before calling create()."});const e={url:this.theUrl,dataTransferMode:this.theDataTransferMode,headers:this.theHeaders,inputPreProcessor:this.theInputPreProcessor,outputPreProcessor:this.theOutputPreProcessor,useInputSchema:this.theUseInputSchema};return"stream"===h(e)?new g(e):new d(e)}withDataTransferMode(e){if(void 0!==this.theDataTransferMode)throw new o({source:this.constructor.name,message:"Cannot set the data loading mode more than once"});return this.theDataTransferMode=e,this}withHeaders(e){if(void 0!==this.theHeaders)throw new o({source:this.constructor.name,message:"Cannot set the headers option more than once"});return this.theHeaders=e,this}withInputPreProcessor(e){if(void 0!==this.theInputPreProcessor)throw new o({source:this.constructor.name,message:"Cannot set the input pre-processor option more than once"});return this.theInputPreProcessor=e,this}withInputSchema(e){if(void 0!==this.theUseInputSchema)throw new o({source:this.constructor.name,message:"Cannot set the input schema option more than once"});return this.theUseInputSchema=e,this}withOutputPreProcessor(e){if(void 0!==this.theOutputPreProcessor)throw new o({source:this.constructor.name,message:"Cannot set the output pre-processor option more than once"});return this.theOutputPreProcessor=e,this}withUrl(e){if(void 0!==this.theUrl)throw new o({source:this.constructor.name,message:"Cannot set the runnable URL option more than once"});return this.theUrl=e,this}}e.createChatAdapter=function(){return new v}}));

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

37596

increased by0.61%

Lines of code

216

increased by0.47%

Dependency changes

• + Added@nlux/core@2.0.9-alpha(transitive)

• - Removed@nlux/core@2.0.8-alpha(transitive)

• Updated@nlux/core@2.0.9-alpha