Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

@nlbridge/core

Package Overview
Dependencies
Maintainers
1
Versions
17
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@nlbridge/core - npm Package Compare versions

Comparing version 0.3.2 to 0.3.4

2

cjs/nlbridge-core.js

@@ -1,1 +0,1 @@

"use strict";var e=require("openai"),t=require("process");function s(e){var t=Object.create(null);return e&&Object.keys(e).forEach((function(s){if("default"!==s){var n=Object.getOwnPropertyDescriptor(e,s);Object.defineProperty(t,s,n.get?n:{enumerable:!0,get:function(){return e[s]}})}})),t.default=e,Object.freeze(t)}var n=s(t);const o=["chat","chat-stream","assist","create-context","discard-context","get-context","reset-context-items","update-context-items","remove-context-items","reset-context-tasks","update-context-tasks","remove-context-tasks"],r=e=>o.includes(e),a={},c={};const i=e=>{const t=JSON.stringify(e,null,2);return"The conversation is taking as part while user is using a web or mobile application.\nBelow is a JSON object that contains contextual information about user's session.\nThis context data should be taken into account when generating a response.\nYou should not display JSON code from the context, but rather use it to\ngenerate a response that is relevant to the user based on that context.\n\nContext JSON object:\n\n{{context}}\n".replace("{{context}}","\n\n"+t+"\n\n")},u=["gpt-4-0125-preview","gpt-4-turbo-preview","gpt-4-1106-preview","gpt-4-vision-preview","gpt-4","gpt-4-0314","gpt-4-0613","gpt-4-32k","gpt-4-32k-0314","gpt-4-32k-0613","gpt-3.5-turbo","gpt-3.5-turbo-16k","gpt-3.5-turbo-0301","gpt-3.5-turbo-0613","gpt-3.5-turbo-1106","gpt-3.5-turbo-0125","gpt-3.5-turbo-16k-0613"],h="gpt-3.5-turbo";const p=e=>{console.error(""+e+"")};const l=async(t,s,n)=>{if(!s)return;if(!n.getContextTasks)return;const o=await n.getContextTasks();if(!o)return;const r=n.config?.chatModel||h,a=i(s),c=(e=>{const t=JSON.stringify(e,null,2);return'The conversation is taking as part while user is using a web or mobile application.\nThe previous message contains information about the user\'s context.\n\nBelow is a Javascript array with a list of tasks that the user may expect to be performed by the application.\nThe object contains a task identifier (string)\n\nTASKS LIST:\n\n{{tasks}}\n\nWhile the user is interacting with the application, they can either expect a response, or they can expect a\ntask to be performed by the application.\n\nThe next message is going to be a prompt from a user.\nYour job is to determine whether the user expects a response or a task.\nIf the user expects a response, you must reply with the string "response#".\n\nIf the user expects a task, you must reply with the string that matches the following format:\n\n"task#<TASK NAME>"\n\nWhere:\n\n<Task Name> should be replaced with the name of the task as it appears in the TASKS LIST.\n\nIf you think that the task that the user expects is not in the TASKS LIST, you should reply with the string "response#".\n\nDo not provide a direct response to the user\'s message.\nOnly analyze the message and determine what the user expects.\nStrictly respond with a string with the format "task#<TASK NAME>" or with "response#".\nIf you think that the user expects only a response, reply by one single word: "response#".\n'.replace("{{tasks}}","\n\n"+t+"\n\n")})(o);if(!c||!a)return;const u=[],p=new e({apiKey:n.config?.apiKey});u.push({role:"system",content:a}),u.push({role:"system",content:c}),u.push({role:"user",content:t});const l=await p.chat.completions.create({stream:!1,model:r,messages:u});if(!(l.choices&&l.choices.length>0&&l.choices[0].message.content))return;const m=l.choices[0].message.content;if(m.length<5)return;const d=m.replace(/['"]/g,"");if(["response#",'"response#"',"'response#'"].some((e=>d.toLowerCase().startsWith(e))))return;if(["task#",'"task#"',"'task#'"].every((e=>!d.toLowerCase().startsWith(e))))return;const f=m.substring(5).trim();if(!(e=>/^[a-zA-Z_$][0-9a-zA-Z_$]*$/.test(e))(f))return;if(!o[f])return;const g=o[f],y=g.paramDescriptions&&0!==g.paramDescriptions.length?g.paramDescriptions:[];return{taskId:f,description:g.description,paramDescriptions:y}},m=e=>{console.warn(""+e+"")},d={chat:async(s,n)=>{const o=new e({apiKey:n.config?.apiKey||t.env.OPENAI_API_KEY||""}),r=[];if(n.getContextItems){const e=await n.getContextItems();e&&r.push({role:"system",content:i(e)})}n.conversationHistory&&n.conversationHistory.forEach((e=>{r.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),r.push({role:"user",content:s});const a=await o.chat.completions.create({stream:!1,model:n.config?.chatModel||h,messages:r});return a.choices&&0!==a.choices.length&&a.choices[0].message.content?{success:!0,message:a.choices[0].message.content}:{success:!1,error:"No response from OpenAI."}},"chat-stream":async(s,n,o)=>{const r=new e({apiKey:o.config?.apiKey||t.env.OPENAI_API_KEY||""}),a=[];if(o.getContextItems){const e=await o.getContextItems();e&&a.push({role:"system",content:i(e)})}o.conversationHistory&&o.conversationHistory.forEach((e=>{a.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),a.push({role:"user",content:s});try{let e=(await r.chat.completions.create({stream:!0,model:o.config?.chatModel||h,messages:a}))[Symbol.asyncIterator](),t=await e.next();for(;!t.done;){const s=t.value;if("stop"===(s.choices?.length>0?s.choices[0].finish_reason:void 0))break;const o=s.choices?.[0].delta.content;"string"==typeof o?n.next(o):m(`Undecodable message - value: ${s}`),t=await e.next()}n.complete()}catch(e){m(`Error: ${e}`)}},assist:async(t,s)=>{const o=s.getContextItems?await s.getContextItems():void 0,r=await l(t,o,s),a=r?await(async(t,s,n,o)=>{if(!n)return;const r=(e=>{const t="The conversation is taking part while user is using a web or mobile application.\nThe previous message contains information about the user's context.\n\nWe know that the user would like to execute a function with the identifier: {{taskId}}\nThis function is a Javascript function that is part of the application. Your responsibility is to determine the\nvalues of the parameters that should be passed to this {{taskId}} function based on the user context, the conversation\nhistory, the user message, the taskId, and the parameter descriptions provided below.\n\nBelow is Javascript table that should be used as a template to fill in the values of the parameters:\n\nTHE TEMPLATE:\n\n{{paramsArrayTemplate}}\n\nUse the instructions below to fill in the values of the parameters.\n\nINSTRUCTIONS:\n\n{{instructionsToReplaceParams}}\n\nEach parameter marked with the notation <Parameter#(index)> (where index is a number) should be replaced with a\nvalue that will be passed to the function. Each value should either be a string (between double quotes), a number,\na boolean, or null (if you are unable to determine the value of the parameter).\n\nUse information from the context, from the conversation history, from the user input, and the task ID to\ndetermine the values of the parameters.\n\nStrictly respond with a valid and well-structured and flat Javascript array that starts with [ and ends with ].\nIf you are unable to determine the value of a specific parameter, use null for.\nIf you are unable to process the request, response with null.\n\nBe smart and don't mislead the user.\nDo not ask the user for more information than what is already available.\nReply on the INSTRUCTIONS to fill in the values of the parameters.\nYou can make it!\n",s="["+e.paramDescriptions.map(((e,t)=>`<Parameter#${t+1}>`)).join(", ")+"]";let n="";return e.paramDescriptions.forEach(((e,t)=>{n+=`The value for the parameter <Parameter#${t+1}> : ${e}\n`})),t.replace("{{taskId}}",e.taskId).replace("{{instructionsToReplaceParams}}",n).replace("{{paramsArrayTemplate}}",s)})(s);if(!r)return;const a=[],c=i(n);c&&a.push({role:"system",content:c});const u=new e({apiKey:o.config?.apiKey});a.push({role:"system",content:r}),a.push({role:"user",content:t});const l=o.config?.chatModel||h,m=await u.chat.completions.create({stream:!1,model:l,messages:a});if(!(m.choices&&m.choices.length>0&&m.choices[0].message.content))return;const d=m.choices[0].message.content;try{const e=JSON.parse(d);return Array.isArray(e)?e:void p("The response is not an array.")}catch(e){return void p("Error parsing param values: "+e)}})(t,r,o,s):void 0,c=new e({apiKey:s.config?.apiKey||n.env.OPENAI_API_KEY||""}),u=[];if(o){const e=i(o);e&&u.push({role:"system",content:e})}r&&a&&u.push({role:"system",content:`Following the next message, the task "${r.taskId}" will be performed. Respond with a short message based on the user prompt. Your response should be related to the task and should be brief. Do not overload the response with too much information since a task is going to be performed.`}),s.conversationHistory?.forEach((e=>{u.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),u.push({role:"user",content:t});const m=await c.chat.completions.create({stream:!1,model:s.config?.chatModel||h,messages:u});if(!m.choices||0===m.choices.length||!m.choices[0].message.content)return{success:!1,error:"No response from OpenAI."};const d=m.choices[0].message.content;return r&&a?{success:!0,message:d,task:{taskId:r.taskId,parameters:a}}:{success:!0,message:d}},"create-context":async(e,t)=>{let s;do{s=Math.random().toString(36).substring(2,14),a[s]&&(s="")}while(!s);if(c[s]={},void 0===e)return a[s]={},{success:!0,contextId:s};const n=Object.keys(e);return a[s]=n.reduce(((t,s)=>(t[s]={itemId:s,...e[s]},t)),{}),{success:!0,contextId:s}},"discard-context":async(e,t)=>e&&a[e]?(a[e]=void 0,delete a[e],c[e]=void 0,delete c[e],{success:!0}):{success:!1,error:"Context not found"},"get-context":async(e,t,s,n)=>{if(!e||!a[e])return{success:!1,error:"Context not found"};const o=a[e],r=c[e];return t?o&&o[t]||r&&r[t]?{success:!0,items:o&&o[t]?{[t]:o[t]}:void 0,tasks:r&&r[t]?{[t]:r[t]}:void 0}:{success:!1,error:"Item not found"}:{success:!0,items:o,tasks:r}},"reset-items":async(e,t,s)=>{if(!a[e])return{success:!1,error:"Context not found"};if(!t)return a[e]={},{success:!0};const n=Object.keys(t);return a[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,itemId:s}}}),{}),{success:!0}},"update-items":async(e,t,s)=>{const n=a[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,itemId:e})}return{success:!0}},"remove-items":async(e,t,s)=>{const n=a[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}},"reset-tasks":async(e,t,s)=>{if(!c[e])return{success:!1,error:"Context not found"};if(void 0===t)return c[e]={},{success:!0};const n=Object.keys(t);return c[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,taskId:s}}}),{}),{success:!0}},"update-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,taskId:e})}return{success:!0}},"remove-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}}};exports.actionIds=o,exports.asOpenAiChatModel=e=>{if(u.includes(e))return e},exports.asValidActionId=e=>r(e)?e:void 0,exports.createRuntime=(e,t)=>({run:(s,...n)=>{const o=e[s];if(!o)throw new Error("Unsupported action");const r=Array.isArray(n)&&n.length>0?n.slice(0,-1):[],a=Array.isArray(n)&&n.length>0?n[n.length-1]:{},c="object"==typeof a&&null!==a?{...a,config:t}:{config:t};return a.contextId&&!a.getContextItems&&(c.getContextItems=async t=>{const s=await e["get-context"](a.contextId,t,"data",c);if(s&&s.success)return s.items}),a.contextId&&!a.getContextTasks&&(c.getContextTasks=async t=>{const s=await e["get-context"](a.contextId,t,"task",c);if(s&&s.success)return s.tasks}),o(...r,c)}}),exports.defaultActionHandlers=d,exports.isValidActionId=r,exports.openAiDefaultChatModel=h,exports.supportedOpenAiChatModels=u;
"use strict";var e=require("openai"),t=require("process");function s(e){var t=Object.create(null);return e&&Object.keys(e).forEach((function(s){if("default"!==s){var n=Object.getOwnPropertyDescriptor(e,s);Object.defineProperty(t,s,n.get?n:{enumerable:!0,get:function(){return e[s]}})}})),t.default=e,Object.freeze(t)}var n=s(t);const o=["chat","chat-stream","assist","create-context","discard-context","get-context","reset-context-items","update-context-items","remove-context-items","reset-context-tasks","update-context-tasks","remove-context-tasks"],r=e=>o.includes(e),a={},c={},i=(e,t)=>{const s=JSON.stringify(e,null,2);return"string"==typeof t.context&&t.context.length>0?t.context.replace("{{context}}","\n\n"+s+"\n\n"):"Use the the JSON object below as a context for the conversation that you are having with the user:\n\n"+s+"\n\n"},u=["gpt-4-0125-preview","gpt-4-turbo-preview","gpt-4-1106-preview","gpt-4-vision-preview","gpt-4","gpt-4-0314","gpt-4-0613","gpt-4-32k","gpt-4-32k-0314","gpt-4-32k-0613","gpt-3.5-turbo","gpt-3.5-turbo-16k","gpt-3.5-turbo-0301","gpt-3.5-turbo-0613","gpt-3.5-turbo-1106","gpt-3.5-turbo-0125","gpt-3.5-turbo-16k-0613"],h="gpt-3.5-turbo",p=e=>{console.error(""+e+"")},l=async(t,s,n)=>{if(!s)return;if(!n.getContextTasks)return;const o=await n.getContextTasks();if(!o)return;const r=n.getLlmInstructions(),a=n.config?.chatModel||h,c=i(s,r),u=((e,t)=>{const s=JSON.stringify(e,null,2);if("string"!=typeof t.taskName&&!t.taskName)return;return t.taskName.replace("{{tasks}}","\n\n"+s+"\n\n")})(o,r);if(!u||!c)return;const p=[],l=new e({apiKey:n.config?.apiKey});p.push({role:"system",content:c}),p.push({role:"system",content:u}),p.push({role:"user",content:t});const m=await l.chat.completions.create({stream:!1,model:a,messages:p});if(!(m.choices&&m.choices.length>0&&m.choices[0].message.content))return;const d=m.choices[0].message.content;if(d.length<5)return;const f=d.replace(/['"]/g,"");if(["response#",'"response#"',"'response#'"].some((e=>f.toLowerCase().startsWith(e))))return;if(["task#",'"task#"',"'task#'"].every((e=>!f.toLowerCase().startsWith(e))))return;const g=d.substring(5).trim();if(!(e=>/^[a-zA-Z_$][0-9a-zA-Z_$]*$/.test(e))(g))return;if(!o[g])return;const y=o[g],x=y.paramDescriptions&&0!==y.paramDescriptions.length?y.paramDescriptions:[];return{taskId:g,description:y.description,paramDescriptions:x}},m=e=>{console.warn(""+e+"")},d={chat:async(s,n)=>{const o=new e({apiKey:n.config?.apiKey||t.env.OPENAI_API_KEY||""}),r=[];if(n.getContextItems){const e=n.getLlmInstructions(),t=await n.getContextItems();t&&r.push({role:"system",content:i(t,e)})}n.conversationHistory&&n.conversationHistory.forEach((e=>{r.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),r.push({role:"user",content:s});const a=await o.chat.completions.create({stream:!1,model:n.config?.chatModel||h,messages:r});return a.choices&&0!==a.choices.length&&a.choices[0].message.content?{success:!0,message:a.choices[0].message.content}:{success:!1,error:"No response from OpenAI."}},"chat-stream":async(s,n,o)=>{const r=new e({apiKey:o.config?.apiKey||t.env.OPENAI_API_KEY||""}),a=[];if(o.getContextItems){const e=o.getLlmInstructions(),t=await o.getContextItems();t&&a.push({role:"system",content:i(t,e)})}o.conversationHistory&&o.conversationHistory.forEach((e=>{a.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),a.push({role:"user",content:s});try{let e=(await r.chat.completions.create({stream:!0,model:o.config?.chatModel||h,messages:a}))[Symbol.asyncIterator](),t=await e.next();for(;!t.done;){const s=t.value;if("stop"===(s.choices?.length>0?s.choices[0].finish_reason:void 0))break;const o=s.choices?.[0].delta.content;"string"==typeof o?n.next(o):m(`Undecodable message - value: ${s}`),t=await e.next()}n.complete()}catch(e){m(`Error: ${e}`)}},assist:async(t,s)=>{const o=s.getLlmInstructions(),r=s.getContextItems?await s.getContextItems():void 0,a=await l(t,r,s),c=a?await(async(t,s,n,o)=>{if(!n)return;const r=o.getLlmInstructions(),a=((e,t)=>{if("string"!=typeof t.parameterValues&&!t.parameterValues)return;const s=t.parameterValues,n="["+e.paramDescriptions.map(((e,t)=>`<Parameter#${t+1}>`)).join(", ")+"]";let o="";return e.paramDescriptions.forEach(((e,t)=>{o+=`The value for the parameter <Parameter#${t+1}> : ${e}\n`})),s.replace("{{taskId}}",e.taskId).replace("{{instructionsToReplaceParams}}",o).replace("{{paramsArrayTemplate}}",n)})(s,r);if(!a)return;const c=[],u=i(n,r);u&&c.push({role:"system",content:u});const l=new e({apiKey:o.config?.apiKey});c.push({role:"system",content:a}),c.push({role:"user",content:t});const m=o.config?.chatModel||h,d=await l.chat.completions.create({stream:!1,model:m,messages:c});if(!(d.choices&&d.choices.length>0&&d.choices[0].message.content))return;const f=d.choices[0].message.content;try{const e=JSON.parse(f);return Array.isArray(e)?e:void p("The response is not an array.")}catch(e){return void p("Error parsing param values: "+e)}})(t,a,r,s):void 0,u=new e({apiKey:s.config?.apiKey||n.env.OPENAI_API_KEY||""}),m=[];if(r){const e=i(r,o);e&&m.push({role:"system",content:e})}a&&c&&m.push({role:"system",content:`Following the next message, the task "${a.taskId}" will be performed. Respond with a short message based on the user prompt. Your response should be related to the task and should be brief. Do not overload the response with too much information since a task is going to be performed.`}),s.conversationHistory?.forEach((e=>{m.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),m.push({role:"user",content:t});const d=await u.chat.completions.create({stream:!1,model:s.config?.chatModel||h,messages:m});if(!d.choices||0===d.choices.length||!d.choices[0].message.content)return{success:!1,error:"No response from OpenAI."};const f=d.choices[0].message.content;return a&&c?{success:!0,message:f,task:{taskId:a.taskId,parameters:c}}:{success:!0,message:f}},"create-context":async(e,t)=>{let s;do{s=Math.random().toString(36).substring(2,14),a[s]&&(s="")}while(!s);if(c[s]={},void 0===e)return a[s]={},{success:!0,contextId:s};const n=Object.keys(e);return a[s]=n.reduce(((t,s)=>(t[s]={itemId:s,...e[s]},t)),{}),{success:!0,contextId:s}},"discard-context":async(e,t)=>e&&a[e]?(a[e]=void 0,delete a[e],c[e]=void 0,delete c[e],{success:!0}):{success:!1,error:"Context not found"},"get-context":async(e,t,s,n)=>{if(!e||!a[e])return{success:!1,error:"Context not found"};const o=a[e],r=c[e];return t?o&&o[t]||r&&r[t]?{success:!0,items:o&&o[t]?{[t]:o[t]}:void 0,tasks:r&&r[t]?{[t]:r[t]}:void 0}:{success:!1,error:"Item not found"}:{success:!0,items:o,tasks:r}},"reset-items":async(e,t,s)=>{if(!a[e])return{success:!1,error:"Context not found"};if(!t)return a[e]={},{success:!0};const n=Object.keys(t);return a[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,itemId:s}}}),{}),{success:!0}},"update-items":async(e,t,s)=>{const n=a[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,itemId:e})}return{success:!0}},"remove-items":async(e,t,s)=>{const n=a[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}},"reset-tasks":async(e,t,s)=>{if(!c[e])return{success:!1,error:"Context not found"};if(void 0===t)return c[e]={},{success:!0};const n=Object.keys(t);return c[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,taskId:s}}}),{}),{success:!0}},"update-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,taskId:e})}return{success:!0}},"remove-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}}};exports.actionIds=o,exports.asOpenAiChatModel=e=>{if(u.includes(e))return e},exports.asValidActionId=e=>r(e)?e:void 0,exports.createRuntime=(e,t,s)=>({run:(n,...o)=>{const r=e[n];if(!r)throw new Error("Unsupported action");const a=Array.isArray(o)&&o.length>0?o.slice(0,-1):[],c=!t||0===Object.keys(t).length,i=c?{context:"The conversation is taking as part while user is using a web or mobile application.\nBelow is a JSON object that contains contextual information about user's session.\nThis context data should be taken into account when generating a response.\nYou should not display JSON code from the context, but rather use it to\ngenerate a response that is relevant to the user based on that context.\n\nContext JSON object:\n\n{{context}}\n",taskName:'The conversation is taking as part while user is using a web or mobile application.\nThe previous message contains information about the user\'s context.\n\nBelow is a Javascript array with a list of tasks that the user may expect to be performed by the application.\nThe object contains a task identifier (string)\n\nTASKS LIST:\n\n{{tasks}}\n\nWhile the user is interacting with the application, they can either expect a response, or they can expect a\ntask to be performed by the application.\n\nThe next message is going to be a prompt from a user.\nYour job is to determine whether the user expects a response or a task.\nIf the user expects a response, you must reply with the string "response#".\n\nIf the user expects a task, you must reply with the string that matches the following format:\n\n"task#<TASK NAME>"\n\nWhere:\n\n<Task Name> should be replaced with the name of the task as it appears in the TASKS LIST.\n\nIf you think that the task that the user expects is not in the TASKS LIST, you should reply with the string "response#".\n\nDo not provide a direct response to the user\'s message.\nOnly analyze the message and determine what the user expects.\nStrictly respond with a string with the format "task#<TASK NAME>" or with "response#".\nIf you think that the user expects only a response, reply by one single word: "response#".\n',parameterValues:"The conversation is taking part while user is using a web or mobile application.\nThe previous message contains information about the user's context.\n\nWe know that the user would like to execute a function with the identifier: {{taskId}}\nThis function is a Javascript function that is part of the application. Your responsibility is to determine the\nvalues of the parameters that should be passed to this {{taskId}} function based on the user context, the conversation\nhistory, the user message, the taskId, and the parameter descriptions provided below.\n\nBelow is Javascript table that should be used as a template to fill in the values of the parameters:\n\nTHE TEMPLATE:\n\n{{paramsArrayTemplate}}\n\nUse the instructions below to fill in the values of the parameters.\n\nINSTRUCTIONS:\n\n{{instructionsToReplaceParams}}\n\nEach parameter marked with the notation <Parameter#(index)> (where index is a number) should be replaced with a\nvalue that will be passed to the function. Each value should either be a string (between double quotes), a number,\na boolean, or null (if you are unable to determine the value of the parameter).\n\nUse information from the context, from the conversation history, from the user input, and the task ID to\ndetermine the values of the parameters.\n\nStrictly respond with a valid and well-structured and flat Javascript array that starts with [ and ends with ].\nIf you are unable to determine the value of a specific parameter, use null for.\nIf you are unable to process the request, response with null.\n\nBe smart and don't mislead the user.\nDo not ask the user for more information than what is already available.\nReply on the INSTRUCTIONS to fill in the values of the parameters.\nYou can make it!\n"}:{},u=c?{context:t?.context??i.context,parameterValues:t?.parameterValues??i.parameterValues,taskName:t?.taskName??i.taskName}:t,h={config:s,getLlmInstructions:()=>u},p=Array.isArray(o)&&o.length>0?o[o.length-1]:void 0;"object"==typeof p&&null!==p&&("string"==typeof p.contextId&&(h.contextId=p.contextId),Array.isArray(p.conversationHistory)&&(h.conversationHistory=p.conversationHistory),"function"==typeof p.getContextItems&&(h.getContextItems=p.getContextItems),"function"==typeof p.getContextItem&&(h.getContextItem=p.getContextItem),"function"==typeof p.getContextTasks&&(h.getContextTasks=p.getContextTasks));const l=h.contextId;return l&&!h.getContextItems&&(h.getContextItems=async t=>{const s=await e["get-context"](l,t,"data",h);if(s&&s.success)return s.items}),l&&!h.getContextTasks&&(h.getContextTasks=async t=>{const s=await e["get-context"](l,t,"task",h);if(s&&s.success)return s.tasks}),r(...a,h)}}),exports.defaultActionHandlers=d,exports.isValidActionId=r,exports.openAiDefaultChatModel=h,exports.supportedOpenAiChatModels=u;

2

esm/nlbridge-core.js

@@ -1,1 +0,1 @@

import e from"openai";import*as t from"process";import s from"process";const n=["chat","chat-stream","assist","create-context","discard-context","get-context","reset-context-items","update-context-items","remove-context-items","reset-context-tasks","update-context-tasks","remove-context-tasks"],o=e=>n.includes(e),r=e=>o(e)?e:void 0,a={},c={};const i=e=>{const t=JSON.stringify(e,null,2);return"The conversation is taking as part while user is using a web or mobile application.\nBelow is a JSON object that contains contextual information about user's session.\nThis context data should be taken into account when generating a response.\nYou should not display JSON code from the context, but rather use it to\ngenerate a response that is relevant to the user based on that context.\n\nContext JSON object:\n\n{{context}}\n".replace("{{context}}","\n\n"+t+"\n\n")},u=["gpt-4-0125-preview","gpt-4-turbo-preview","gpt-4-1106-preview","gpt-4-vision-preview","gpt-4","gpt-4-0314","gpt-4-0613","gpt-4-32k","gpt-4-32k-0314","gpt-4-32k-0613","gpt-3.5-turbo","gpt-3.5-turbo-16k","gpt-3.5-turbo-0301","gpt-3.5-turbo-0613","gpt-3.5-turbo-1106","gpt-3.5-turbo-0125","gpt-3.5-turbo-16k-0613"],h="gpt-3.5-turbo",p=e=>{if(u.includes(e))return e};const l=e=>{console.error(""+e+"")};const m=async(t,s,n)=>{if(!s)return;if(!n.getContextTasks)return;const o=await n.getContextTasks();if(!o)return;const r=n.config?.chatModel||h,a=i(s),c=(e=>{const t=JSON.stringify(e,null,2);return'The conversation is taking as part while user is using a web or mobile application.\nThe previous message contains information about the user\'s context.\n\nBelow is a Javascript array with a list of tasks that the user may expect to be performed by the application.\nThe object contains a task identifier (string)\n\nTASKS LIST:\n\n{{tasks}}\n\nWhile the user is interacting with the application, they can either expect a response, or they can expect a\ntask to be performed by the application.\n\nThe next message is going to be a prompt from a user.\nYour job is to determine whether the user expects a response or a task.\nIf the user expects a response, you must reply with the string "response#".\n\nIf the user expects a task, you must reply with the string that matches the following format:\n\n"task#<TASK NAME>"\n\nWhere:\n\n<Task Name> should be replaced with the name of the task as it appears in the TASKS LIST.\n\nIf you think that the task that the user expects is not in the TASKS LIST, you should reply with the string "response#".\n\nDo not provide a direct response to the user\'s message.\nOnly analyze the message and determine what the user expects.\nStrictly respond with a string with the format "task#<TASK NAME>" or with "response#".\nIf you think that the user expects only a response, reply by one single word: "response#".\n'.replace("{{tasks}}","\n\n"+t+"\n\n")})(o);if(!c||!a)return;const u=[],p=new e({apiKey:n.config?.apiKey});u.push({role:"system",content:a}),u.push({role:"system",content:c}),u.push({role:"user",content:t});const l=await p.chat.completions.create({stream:!1,model:r,messages:u});if(!(l.choices&&l.choices.length>0&&l.choices[0].message.content))return;const m=l.choices[0].message.content;if(m.length<5)return;const d=m.replace(/['"]/g,"");if(["response#",'"response#"',"'response#'"].some((e=>d.toLowerCase().startsWith(e))))return;if(["task#",'"task#"',"'task#'"].every((e=>!d.toLowerCase().startsWith(e))))return;const f=m.substring(5).trim();if(!(e=>/^[a-zA-Z_$][0-9a-zA-Z_$]*$/.test(e))(f))return;if(!o[f])return;const g=o[f],y=g.paramDescriptions&&0!==g.paramDescriptions.length?g.paramDescriptions:[];return{taskId:f,description:g.description,paramDescriptions:y}},d=e=>{console.warn(""+e+"")},f={chat:async(t,n)=>{const o=new e({apiKey:n.config?.apiKey||s.env.OPENAI_API_KEY||""}),r=[];if(n.getContextItems){const e=await n.getContextItems();e&&r.push({role:"system",content:i(e)})}n.conversationHistory&&n.conversationHistory.forEach((e=>{r.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),r.push({role:"user",content:t});const a=await o.chat.completions.create({stream:!1,model:n.config?.chatModel||h,messages:r});return a.choices&&0!==a.choices.length&&a.choices[0].message.content?{success:!0,message:a.choices[0].message.content}:{success:!1,error:"No response from OpenAI."}},"chat-stream":async(t,n,o)=>{const r=new e({apiKey:o.config?.apiKey||s.env.OPENAI_API_KEY||""}),a=[];if(o.getContextItems){const e=await o.getContextItems();e&&a.push({role:"system",content:i(e)})}o.conversationHistory&&o.conversationHistory.forEach((e=>{a.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),a.push({role:"user",content:t});try{let e=(await r.chat.completions.create({stream:!0,model:o.config?.chatModel||h,messages:a}))[Symbol.asyncIterator](),t=await e.next();for(;!t.done;){const s=t.value;if("stop"===(s.choices?.length>0?s.choices[0].finish_reason:void 0))break;const o=s.choices?.[0].delta.content;"string"==typeof o?n.next(o):d(`Undecodable message - value: ${s}`),t=await e.next()}n.complete()}catch(e){d(`Error: ${e}`)}},assist:async(s,n)=>{const o=n.getContextItems?await n.getContextItems():void 0,r=await m(s,o,n),a=r?await(async(t,s,n,o)=>{if(!n)return;const r=(e=>{const t="The conversation is taking part while user is using a web or mobile application.\nThe previous message contains information about the user's context.\n\nWe know that the user would like to execute a function with the identifier: {{taskId}}\nThis function is a Javascript function that is part of the application. Your responsibility is to determine the\nvalues of the parameters that should be passed to this {{taskId}} function based on the user context, the conversation\nhistory, the user message, the taskId, and the parameter descriptions provided below.\n\nBelow is Javascript table that should be used as a template to fill in the values of the parameters:\n\nTHE TEMPLATE:\n\n{{paramsArrayTemplate}}\n\nUse the instructions below to fill in the values of the parameters.\n\nINSTRUCTIONS:\n\n{{instructionsToReplaceParams}}\n\nEach parameter marked with the notation <Parameter#(index)> (where index is a number) should be replaced with a\nvalue that will be passed to the function. Each value should either be a string (between double quotes), a number,\na boolean, or null (if you are unable to determine the value of the parameter).\n\nUse information from the context, from the conversation history, from the user input, and the task ID to\ndetermine the values of the parameters.\n\nStrictly respond with a valid and well-structured and flat Javascript array that starts with [ and ends with ].\nIf you are unable to determine the value of a specific parameter, use null for.\nIf you are unable to process the request, response with null.\n\nBe smart and don't mislead the user.\nDo not ask the user for more information than what is already available.\nReply on the INSTRUCTIONS to fill in the values of the parameters.\nYou can make it!\n",s="["+e.paramDescriptions.map(((e,t)=>`<Parameter#${t+1}>`)).join(", ")+"]";let n="";return e.paramDescriptions.forEach(((e,t)=>{n+=`The value for the parameter <Parameter#${t+1}> : ${e}\n`})),t.replace("{{taskId}}",e.taskId).replace("{{instructionsToReplaceParams}}",n).replace("{{paramsArrayTemplate}}",s)})(s);if(!r)return;const a=[],c=i(n);c&&a.push({role:"system",content:c});const u=new e({apiKey:o.config?.apiKey});a.push({role:"system",content:r}),a.push({role:"user",content:t});const p=o.config?.chatModel||h,m=await u.chat.completions.create({stream:!1,model:p,messages:a});if(!(m.choices&&m.choices.length>0&&m.choices[0].message.content))return;const d=m.choices[0].message.content;try{const e=JSON.parse(d);return Array.isArray(e)?e:void l("The response is not an array.")}catch(e){return void l("Error parsing param values: "+e)}})(s,r,o,n):void 0,c=new e({apiKey:n.config?.apiKey||t.env.OPENAI_API_KEY||""}),u=[];if(o){const e=i(o);e&&u.push({role:"system",content:e})}r&&a&&u.push({role:"system",content:`Following the next message, the task "${r.taskId}" will be performed. Respond with a short message based on the user prompt. Your response should be related to the task and should be brief. Do not overload the response with too much information since a task is going to be performed.`}),n.conversationHistory?.forEach((e=>{u.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),u.push({role:"user",content:s});const p=await c.chat.completions.create({stream:!1,model:n.config?.chatModel||h,messages:u});if(!p.choices||0===p.choices.length||!p.choices[0].message.content)return{success:!1,error:"No response from OpenAI."};const d=p.choices[0].message.content;return r&&a?{success:!0,message:d,task:{taskId:r.taskId,parameters:a}}:{success:!0,message:d}},"create-context":async(e,t)=>{let s;do{s=Math.random().toString(36).substring(2,14),a[s]&&(s="")}while(!s);if(c[s]={},void 0===e)return a[s]={},{success:!0,contextId:s};const n=Object.keys(e);return a[s]=n.reduce(((t,s)=>(t[s]={itemId:s,...e[s]},t)),{}),{success:!0,contextId:s}},"discard-context":async(e,t)=>e&&a[e]?(a[e]=void 0,delete a[e],c[e]=void 0,delete c[e],{success:!0}):{success:!1,error:"Context not found"},"get-context":async(e,t,s,n)=>{if(!e||!a[e])return{success:!1,error:"Context not found"};const o=a[e],r=c[e];return t?o&&o[t]||r&&r[t]?{success:!0,items:o&&o[t]?{[t]:o[t]}:void 0,tasks:r&&r[t]?{[t]:r[t]}:void 0}:{success:!1,error:"Item not found"}:{success:!0,items:o,tasks:r}},"reset-items":async(e,t,s)=>{if(!a[e])return{success:!1,error:"Context not found"};if(!t)return a[e]={},{success:!0};const n=Object.keys(t);return a[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,itemId:s}}}),{}),{success:!0}},"update-items":async(e,t,s)=>{const n=a[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,itemId:e})}return{success:!0}},"remove-items":async(e,t,s)=>{const n=a[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}},"reset-tasks":async(e,t,s)=>{if(!c[e])return{success:!1,error:"Context not found"};if(void 0===t)return c[e]={},{success:!0};const n=Object.keys(t);return c[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,taskId:s}}}),{}),{success:!0}},"update-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,taskId:e})}return{success:!0}},"remove-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}}},g=(e,t)=>({run:(s,...n)=>{const o=e[s];if(!o)throw new Error("Unsupported action");const r=Array.isArray(n)&&n.length>0?n.slice(0,-1):[],a=Array.isArray(n)&&n.length>0?n[n.length-1]:{},c="object"==typeof a&&null!==a?{...a,config:t}:{config:t};return a.contextId&&!a.getContextItems&&(c.getContextItems=async t=>{const s=await e["get-context"](a.contextId,t,"data",c);if(s&&s.success)return s.items}),a.contextId&&!a.getContextTasks&&(c.getContextTasks=async t=>{const s=await e["get-context"](a.contextId,t,"task",c);if(s&&s.success)return s.tasks}),o(...r,c)}});export{n as actionIds,p as asOpenAiChatModel,r as asValidActionId,g as createRuntime,f as defaultActionHandlers,o as isValidActionId,h as openAiDefaultChatModel,u as supportedOpenAiChatModels};
import e from"openai";import*as t from"process";import s from"process";const n=["chat","chat-stream","assist","create-context","discard-context","get-context","reset-context-items","update-context-items","remove-context-items","reset-context-tasks","update-context-tasks","remove-context-tasks"],o=e=>n.includes(e),r=e=>o(e)?e:void 0,a={},c={},i=(e,t)=>{const s=JSON.stringify(e,null,2);return"string"==typeof t.context&&t.context.length>0?t.context.replace("{{context}}","\n\n"+s+"\n\n"):"Use the the JSON object below as a context for the conversation that you are having with the user:\n\n"+s+"\n\n"},u=["gpt-4-0125-preview","gpt-4-turbo-preview","gpt-4-1106-preview","gpt-4-vision-preview","gpt-4","gpt-4-0314","gpt-4-0613","gpt-4-32k","gpt-4-32k-0314","gpt-4-32k-0613","gpt-3.5-turbo","gpt-3.5-turbo-16k","gpt-3.5-turbo-0301","gpt-3.5-turbo-0613","gpt-3.5-turbo-1106","gpt-3.5-turbo-0125","gpt-3.5-turbo-16k-0613"],h="gpt-3.5-turbo",p=e=>{if(u.includes(e))return e},m=e=>{console.error(""+e+"")},l=async(t,s,n)=>{if(!s)return;if(!n.getContextTasks)return;const o=await n.getContextTasks();if(!o)return;const r=n.getLlmInstructions(),a=n.config?.chatModel||h,c=i(s,r),u=((e,t)=>{const s=JSON.stringify(e,null,2);if("string"!=typeof t.taskName&&!t.taskName)return;return t.taskName.replace("{{tasks}}","\n\n"+s+"\n\n")})(o,r);if(!u||!c)return;const p=[],m=new e({apiKey:n.config?.apiKey});p.push({role:"system",content:c}),p.push({role:"system",content:u}),p.push({role:"user",content:t});const l=await m.chat.completions.create({stream:!1,model:a,messages:p});if(!(l.choices&&l.choices.length>0&&l.choices[0].message.content))return;const d=l.choices[0].message.content;if(d.length<5)return;const f=d.replace(/['"]/g,"");if(["response#",'"response#"',"'response#'"].some((e=>f.toLowerCase().startsWith(e))))return;if(["task#",'"task#"',"'task#'"].every((e=>!f.toLowerCase().startsWith(e))))return;const g=d.substring(5).trim();if(!(e=>/^[a-zA-Z_$][0-9a-zA-Z_$]*$/.test(e))(g))return;if(!o[g])return;const y=o[g],x=y.paramDescriptions&&0!==y.paramDescriptions.length?y.paramDescriptions:[];return{taskId:g,description:y.description,paramDescriptions:x}},d=e=>{console.warn(""+e+"")},f={chat:async(t,n)=>{const o=new e({apiKey:n.config?.apiKey||s.env.OPENAI_API_KEY||""}),r=[];if(n.getContextItems){const e=n.getLlmInstructions(),t=await n.getContextItems();t&&r.push({role:"system",content:i(t,e)})}n.conversationHistory&&n.conversationHistory.forEach((e=>{r.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),r.push({role:"user",content:t});const a=await o.chat.completions.create({stream:!1,model:n.config?.chatModel||h,messages:r});return a.choices&&0!==a.choices.length&&a.choices[0].message.content?{success:!0,message:a.choices[0].message.content}:{success:!1,error:"No response from OpenAI."}},"chat-stream":async(t,n,o)=>{const r=new e({apiKey:o.config?.apiKey||s.env.OPENAI_API_KEY||""}),a=[];if(o.getContextItems){const e=o.getLlmInstructions(),t=await o.getContextItems();t&&a.push({role:"system",content:i(t,e)})}o.conversationHistory&&o.conversationHistory.forEach((e=>{a.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),a.push({role:"user",content:t});try{let e=(await r.chat.completions.create({stream:!0,model:o.config?.chatModel||h,messages:a}))[Symbol.asyncIterator](),t=await e.next();for(;!t.done;){const s=t.value;if("stop"===(s.choices?.length>0?s.choices[0].finish_reason:void 0))break;const o=s.choices?.[0].delta.content;"string"==typeof o?n.next(o):d(`Undecodable message - value: ${s}`),t=await e.next()}n.complete()}catch(e){d(`Error: ${e}`)}},assist:async(s,n)=>{const o=n.getLlmInstructions(),r=n.getContextItems?await n.getContextItems():void 0,a=await l(s,r,n),c=a?await(async(t,s,n,o)=>{if(!n)return;const r=o.getLlmInstructions(),a=((e,t)=>{if("string"!=typeof t.parameterValues&&!t.parameterValues)return;const s=t.parameterValues,n="["+e.paramDescriptions.map(((e,t)=>`<Parameter#${t+1}>`)).join(", ")+"]";let o="";return e.paramDescriptions.forEach(((e,t)=>{o+=`The value for the parameter <Parameter#${t+1}> : ${e}\n`})),s.replace("{{taskId}}",e.taskId).replace("{{instructionsToReplaceParams}}",o).replace("{{paramsArrayTemplate}}",n)})(s,r);if(!a)return;const c=[],u=i(n,r);u&&c.push({role:"system",content:u});const p=new e({apiKey:o.config?.apiKey});c.push({role:"system",content:a}),c.push({role:"user",content:t});const l=o.config?.chatModel||h,d=await p.chat.completions.create({stream:!1,model:l,messages:c});if(!(d.choices&&d.choices.length>0&&d.choices[0].message.content))return;const f=d.choices[0].message.content;try{const e=JSON.parse(f);return Array.isArray(e)?e:void m("The response is not an array.")}catch(e){return void m("Error parsing param values: "+e)}})(s,a,r,n):void 0,u=new e({apiKey:n.config?.apiKey||t.env.OPENAI_API_KEY||""}),p=[];if(r){const e=i(r,o);e&&p.push({role:"system",content:e})}a&&c&&p.push({role:"system",content:`Following the next message, the task "${a.taskId}" will be performed. Respond with a short message based on the user prompt. Your response should be related to the task and should be brief. Do not overload the response with too much information since a task is going to be performed.`}),n.conversationHistory?.forEach((e=>{p.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),p.push({role:"user",content:s});const d=await u.chat.completions.create({stream:!1,model:n.config?.chatModel||h,messages:p});if(!d.choices||0===d.choices.length||!d.choices[0].message.content)return{success:!1,error:"No response from OpenAI."};const f=d.choices[0].message.content;return a&&c?{success:!0,message:f,task:{taskId:a.taskId,parameters:c}}:{success:!0,message:f}},"create-context":async(e,t)=>{let s;do{s=Math.random().toString(36).substring(2,14),a[s]&&(s="")}while(!s);if(c[s]={},void 0===e)return a[s]={},{success:!0,contextId:s};const n=Object.keys(e);return a[s]=n.reduce(((t,s)=>(t[s]={itemId:s,...e[s]},t)),{}),{success:!0,contextId:s}},"discard-context":async(e,t)=>e&&a[e]?(a[e]=void 0,delete a[e],c[e]=void 0,delete c[e],{success:!0}):{success:!1,error:"Context not found"},"get-context":async(e,t,s,n)=>{if(!e||!a[e])return{success:!1,error:"Context not found"};const o=a[e],r=c[e];return t?o&&o[t]||r&&r[t]?{success:!0,items:o&&o[t]?{[t]:o[t]}:void 0,tasks:r&&r[t]?{[t]:r[t]}:void 0}:{success:!1,error:"Item not found"}:{success:!0,items:o,tasks:r}},"reset-items":async(e,t,s)=>{if(!a[e])return{success:!1,error:"Context not found"};if(!t)return a[e]={},{success:!0};const n=Object.keys(t);return a[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,itemId:s}}}),{}),{success:!0}},"update-items":async(e,t,s)=>{const n=a[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,itemId:e})}return{success:!0}},"remove-items":async(e,t,s)=>{const n=a[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}},"reset-tasks":async(e,t,s)=>{if(!c[e])return{success:!1,error:"Context not found"};if(void 0===t)return c[e]={},{success:!0};const n=Object.keys(t);return c[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,taskId:s}}}),{}),{success:!0}},"update-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,taskId:e})}return{success:!0}},"remove-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}}};const g=(e,t,s)=>({run:(n,...o)=>{const r=e[n];if(!r)throw new Error("Unsupported action");const a=Array.isArray(o)&&o.length>0?o.slice(0,-1):[],c=!t||0===Object.keys(t).length,i=c?{context:"The conversation is taking as part while user is using a web or mobile application.\nBelow is a JSON object that contains contextual information about user's session.\nThis context data should be taken into account when generating a response.\nYou should not display JSON code from the context, but rather use it to\ngenerate a response that is relevant to the user based on that context.\n\nContext JSON object:\n\n{{context}}\n",taskName:'The conversation is taking as part while user is using a web or mobile application.\nThe previous message contains information about the user\'s context.\n\nBelow is a Javascript array with a list of tasks that the user may expect to be performed by the application.\nThe object contains a task identifier (string)\n\nTASKS LIST:\n\n{{tasks}}\n\nWhile the user is interacting with the application, they can either expect a response, or they can expect a\ntask to be performed by the application.\n\nThe next message is going to be a prompt from a user.\nYour job is to determine whether the user expects a response or a task.\nIf the user expects a response, you must reply with the string "response#".\n\nIf the user expects a task, you must reply with the string that matches the following format:\n\n"task#<TASK NAME>"\n\nWhere:\n\n<Task Name> should be replaced with the name of the task as it appears in the TASKS LIST.\n\nIf you think that the task that the user expects is not in the TASKS LIST, you should reply with the string "response#".\n\nDo not provide a direct response to the user\'s message.\nOnly analyze the message and determine what the user expects.\nStrictly respond with a string with the format "task#<TASK NAME>" or with "response#".\nIf you think that the user expects only a response, reply by one single word: "response#".\n',parameterValues:"The conversation is taking part while user is using a web or mobile application.\nThe previous message contains information about the user's context.\n\nWe know that the user would like to execute a function with the identifier: {{taskId}}\nThis function is a Javascript function that is part of the application. Your responsibility is to determine the\nvalues of the parameters that should be passed to this {{taskId}} function based on the user context, the conversation\nhistory, the user message, the taskId, and the parameter descriptions provided below.\n\nBelow is Javascript table that should be used as a template to fill in the values of the parameters:\n\nTHE TEMPLATE:\n\n{{paramsArrayTemplate}}\n\nUse the instructions below to fill in the values of the parameters.\n\nINSTRUCTIONS:\n\n{{instructionsToReplaceParams}}\n\nEach parameter marked with the notation <Parameter#(index)> (where index is a number) should be replaced with a\nvalue that will be passed to the function. Each value should either be a string (between double quotes), a number,\na boolean, or null (if you are unable to determine the value of the parameter).\n\nUse information from the context, from the conversation history, from the user input, and the task ID to\ndetermine the values of the parameters.\n\nStrictly respond with a valid and well-structured and flat Javascript array that starts with [ and ends with ].\nIf you are unable to determine the value of a specific parameter, use null for.\nIf you are unable to process the request, response with null.\n\nBe smart and don't mislead the user.\nDo not ask the user for more information than what is already available.\nReply on the INSTRUCTIONS to fill in the values of the parameters.\nYou can make it!\n"}:{},u=c?{context:t?.context??i.context,parameterValues:t?.parameterValues??i.parameterValues,taskName:t?.taskName??i.taskName}:t,h={config:s,getLlmInstructions:()=>u},p=Array.isArray(o)&&o.length>0?o[o.length-1]:void 0;"object"==typeof p&&null!==p&&("string"==typeof p.contextId&&(h.contextId=p.contextId),Array.isArray(p.conversationHistory)&&(h.conversationHistory=p.conversationHistory),"function"==typeof p.getContextItems&&(h.getContextItems=p.getContextItems),"function"==typeof p.getContextItem&&(h.getContextItem=p.getContextItem),"function"==typeof p.getContextTasks&&(h.getContextTasks=p.getContextTasks));const m=h.contextId;return m&&!h.getContextItems&&(h.getContextItems=async t=>{const s=await e["get-context"](m,t,"data",h);if(s&&s.success)return s.items}),m&&!h.getContextTasks&&(h.getContextTasks=async t=>{const s=await e["get-context"](m,t,"task",h);if(s&&s.success)return s.tasks}),r(...a,h)}});export{n as actionIds,p as asOpenAiChatModel,r as asValidActionId,g as createRuntime,f as defaultActionHandlers,o as isValidActionId,h as openAiDefaultChatModel,u as supportedOpenAiChatModels};

11

nlbridge-core.d.ts

@@ -29,2 +29,8 @@ declare const actionsList: string[];

type LlmInstructions = {
context?: string;
taskName?: string;
parameterValues?: string;
};
type ActionExtras<RuntimeConfig = any> = {

@@ -35,2 +41,3 @@ contextId?: string;

getContextTasks?: () => Promise<ContextTasks | undefined>;
getLlmInstructions: () => LlmInstructions;
conversationHistory?: Readonly<ConversationItem[]>;

@@ -160,3 +167,3 @@ config?: RuntimeConfig;

type RunAction = <ActionId extends keyof ActionHandlerConfig>(action: ActionId, ...parameters: Parameters<ActionHandlerConfig[ActionId]>) => ReturnType<ActionHandlerConfig[ActionId]>;
declare const createRuntime: <RuntimeConfig = any>(actionHandlers: ActionHandlerConfig, config?: RuntimeConfig | undefined) => {
declare const createRuntime: <RuntimeConfig = any>(actionHandlers: ActionHandlerConfig, llmInstructions?: LlmInstructions, config?: RuntimeConfig | undefined) => {
run: RunAction;

@@ -179,2 +186,2 @@ };

export { type ActionExtras, type ActionHandlerConfig, type ActionId, type ChatHandler, type ChatResult, type ChatStreamHandler, type ChatStreamObserver, type ContextItem, type ContextItemDataType, type ContextItems, type ContextObject, type ContextTask, type ContextTasks, type CreateContextHandler, type CreateContextResult, type DiscardContextHandler, type DiscardContextResult, type GetContextHandler, type GetContextResult, type OpenAiChatModel, type OpenAiRuntimeConfig, type RemoveContextItemsHandler, type RemoveContextItemsResult, type RemoveContextTasksHandler, type RemoveContextTasksResult, type ResetContextItemsHandler, type ResetContextItemsResult, type ResetContextTasksHandler, type ResetContextTasksResult, type RunAction, type UpdateContextItemsHandler, type UpdateContextItemsResult, type UpdateContextTasksHandler, type UpdateContextTasksResult, actionIds, asOpenAiChatModel, asValidActionId, createRuntime, defaultActionHandlers, isValidActionId, openAiDefaultChatModel, supportedOpenAiChatModels };
export { type ActionExtras, type ActionHandlerConfig, type ActionId, type ChatHandler, type ChatResult, type ChatStreamHandler, type ChatStreamObserver, type ContextItem, type ContextItemDataType, type ContextItems, type ContextObject, type ContextTask, type ContextTasks, type CreateContextHandler, type CreateContextResult, type DiscardContextHandler, type DiscardContextResult, type GetContextHandler, type GetContextResult, type LlmInstructions, type OpenAiChatModel, type OpenAiRuntimeConfig, type RemoveContextItemsHandler, type RemoveContextItemsResult, type RemoveContextTasksHandler, type RemoveContextTasksResult, type ResetContextItemsHandler, type ResetContextItemsResult, type ResetContextTasksHandler, type ResetContextTasksResult, type RunAction, type UpdateContextItemsHandler, type UpdateContextItemsResult, type UpdateContextTasksHandler, type UpdateContextTasksResult, actionIds, asOpenAiChatModel, asValidActionId, createRuntime, defaultActionHandlers, isValidActionId, openAiDefaultChatModel, supportedOpenAiChatModels };

2

package.json
{
"name": "@nlbridge/core",
"version": "0.3.2",
"version": "0.3.4",
"description": "The core library content for @nlbridge",

@@ -5,0 +5,0 @@ "keywords": [

2

umd/nlbridge-core.js

@@ -1,1 +0,1 @@

!function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports,require("openai"),require("process")):"function"==typeof define&&define.amd?define(["exports","openai","process"],t):t((e="undefined"!=typeof globalThis?globalThis:e||self)["@nlbridge/core"]={},e.OpenAI,e.process)}(this,(function(e,t,s){"use strict";function n(e){var t=Object.create(null);return e&&Object.keys(e).forEach((function(s){if("default"!==s){var n=Object.getOwnPropertyDescriptor(e,s);Object.defineProperty(t,s,n.get?n:{enumerable:!0,get:function(){return e[s]}})}})),t.default=e,Object.freeze(t)}var o=n(s);const r=["chat","chat-stream","assist","create-context","discard-context","get-context","reset-context-items","update-context-items","remove-context-items","reset-context-tasks","update-context-tasks","remove-context-tasks"],a=e=>r.includes(e),i={},c={};const u=e=>{const t=JSON.stringify(e,null,2);return"The conversation is taking as part while user is using a web or mobile application.\nBelow is a JSON object that contains contextual information about user's session.\nThis context data should be taken into account when generating a response.\nYou should not display JSON code from the context, but rather use it to\ngenerate a response that is relevant to the user based on that context.\n\nContext JSON object:\n\n{{context}}\n".replace("{{context}}","\n\n"+t+"\n\n")},h=["gpt-4-0125-preview","gpt-4-turbo-preview","gpt-4-1106-preview","gpt-4-vision-preview","gpt-4","gpt-4-0314","gpt-4-0613","gpt-4-32k","gpt-4-32k-0314","gpt-4-32k-0613","gpt-3.5-turbo","gpt-3.5-turbo-16k","gpt-3.5-turbo-0301","gpt-3.5-turbo-0613","gpt-3.5-turbo-1106","gpt-3.5-turbo-0125","gpt-3.5-turbo-16k-0613"],p="gpt-3.5-turbo";const l=e=>{console.error(""+e+"")};const m=async(e,s,n)=>{if(!s)return;if(!n.getContextTasks)return;const o=await n.getContextTasks();if(!o)return;const r=n.config?.chatModel||p,a=u(s),i=(e=>{const t=JSON.stringify(e,null,2);return'The conversation is taking as part while user is using a web or mobile application.\nThe previous message contains information about the user\'s context.\n\nBelow is a Javascript array with a list of tasks that the user may expect to be performed by the application.\nThe object contains a task identifier (string)\n\nTASKS LIST:\n\n{{tasks}}\n\nWhile the user is interacting with the application, they can either expect a response, or they can expect a\ntask to be performed by the application.\n\nThe next message is going to be a prompt from a user.\nYour job is to determine whether the user expects a response or a task.\nIf the user expects a response, you must reply with the string "response#".\n\nIf the user expects a task, you must reply with the string that matches the following format:\n\n"task#<TASK NAME>"\n\nWhere:\n\n<Task Name> should be replaced with the name of the task as it appears in the TASKS LIST.\n\nIf you think that the task that the user expects is not in the TASKS LIST, you should reply with the string "response#".\n\nDo not provide a direct response to the user\'s message.\nOnly analyze the message and determine what the user expects.\nStrictly respond with a string with the format "task#<TASK NAME>" or with "response#".\nIf you think that the user expects only a response, reply by one single word: "response#".\n'.replace("{{tasks}}","\n\n"+t+"\n\n")})(o);if(!i||!a)return;const c=[],h=new t({apiKey:n.config?.apiKey});c.push({role:"system",content:a}),c.push({role:"system",content:i}),c.push({role:"user",content:e});const l=await h.chat.completions.create({stream:!1,model:r,messages:c});if(!(l.choices&&l.choices.length>0&&l.choices[0].message.content))return;const m=l.choices[0].message.content;if(m.length<5)return;const d=m.replace(/['"]/g,"");if(["response#",'"response#"',"'response#'"].some((e=>d.toLowerCase().startsWith(e))))return;if(["task#",'"task#"',"'task#'"].every((e=>!d.toLowerCase().startsWith(e))))return;const f=m.substring(5).trim();if(!(e=>/^[a-zA-Z_$][0-9a-zA-Z_$]*$/.test(e))(f))return;if(!o[f])return;const g=o[f],y=g.paramDescriptions&&0!==g.paramDescriptions.length?g.paramDescriptions:[];return{taskId:f,description:g.description,paramDescriptions:y}},d=e=>{console.warn(""+e+"")},f={chat:async(e,n)=>{const o=new t({apiKey:n.config?.apiKey||s.env.OPENAI_API_KEY||""}),r=[];if(n.getContextItems){const e=await n.getContextItems();e&&r.push({role:"system",content:u(e)})}n.conversationHistory&&n.conversationHistory.forEach((e=>{r.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),r.push({role:"user",content:e});const a=await o.chat.completions.create({stream:!1,model:n.config?.chatModel||p,messages:r});return a.choices&&0!==a.choices.length&&a.choices[0].message.content?{success:!0,message:a.choices[0].message.content}:{success:!1,error:"No response from OpenAI."}},"chat-stream":async(e,n,o)=>{const r=new t({apiKey:o.config?.apiKey||s.env.OPENAI_API_KEY||""}),a=[];if(o.getContextItems){const e=await o.getContextItems();e&&a.push({role:"system",content:u(e)})}o.conversationHistory&&o.conversationHistory.forEach((e=>{a.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),a.push({role:"user",content:e});try{let e=(await r.chat.completions.create({stream:!0,model:o.config?.chatModel||p,messages:a}))[Symbol.asyncIterator](),t=await e.next();for(;!t.done;){const s=t.value;if("stop"===(s.choices?.length>0?s.choices[0].finish_reason:void 0))break;const o=s.choices?.[0].delta.content;"string"==typeof o?n.next(o):d(`Undecodable message - value: ${s}`),t=await e.next()}n.complete()}catch(e){d(`Error: ${e}`)}},assist:async(e,s)=>{const n=s.getContextItems?await s.getContextItems():void 0,r=await m(e,n,s),a=r?await(async(e,s,n,o)=>{if(!n)return;const r=(e=>{const t="The conversation is taking part while user is using a web or mobile application.\nThe previous message contains information about the user's context.\n\nWe know that the user would like to execute a function with the identifier: {{taskId}}\nThis function is a Javascript function that is part of the application. Your responsibility is to determine the\nvalues of the parameters that should be passed to this {{taskId}} function based on the user context, the conversation\nhistory, the user message, the taskId, and the parameter descriptions provided below.\n\nBelow is Javascript table that should be used as a template to fill in the values of the parameters:\n\nTHE TEMPLATE:\n\n{{paramsArrayTemplate}}\n\nUse the instructions below to fill in the values of the parameters.\n\nINSTRUCTIONS:\n\n{{instructionsToReplaceParams}}\n\nEach parameter marked with the notation <Parameter#(index)> (where index is a number) should be replaced with a\nvalue that will be passed to the function. Each value should either be a string (between double quotes), a number,\na boolean, or null (if you are unable to determine the value of the parameter).\n\nUse information from the context, from the conversation history, from the user input, and the task ID to\ndetermine the values of the parameters.\n\nStrictly respond with a valid and well-structured and flat Javascript array that starts with [ and ends with ].\nIf you are unable to determine the value of a specific parameter, use null for.\nIf you are unable to process the request, response with null.\n\nBe smart and don't mislead the user.\nDo not ask the user for more information than what is already available.\nReply on the INSTRUCTIONS to fill in the values of the parameters.\nYou can make it!\n",s="["+e.paramDescriptions.map(((e,t)=>`<Parameter#${t+1}>`)).join(", ")+"]";let n="";return e.paramDescriptions.forEach(((e,t)=>{n+=`The value for the parameter <Parameter#${t+1}> : ${e}\n`})),t.replace("{{taskId}}",e.taskId).replace("{{instructionsToReplaceParams}}",n).replace("{{paramsArrayTemplate}}",s)})(s);if(!r)return;const a=[],i=u(n);i&&a.push({role:"system",content:i});const c=new t({apiKey:o.config?.apiKey});a.push({role:"system",content:r}),a.push({role:"user",content:e});const h=o.config?.chatModel||p,m=await c.chat.completions.create({stream:!1,model:h,messages:a});if(!(m.choices&&m.choices.length>0&&m.choices[0].message.content))return;const d=m.choices[0].message.content;try{const e=JSON.parse(d);return Array.isArray(e)?e:void l("The response is not an array.")}catch(e){return void l("Error parsing param values: "+e)}})(e,r,n,s):void 0,i=new t({apiKey:s.config?.apiKey||o.env.OPENAI_API_KEY||""}),c=[];if(n){const e=u(n);e&&c.push({role:"system",content:e})}r&&a&&c.push({role:"system",content:`Following the next message, the task "${r.taskId}" will be performed. Respond with a short message based on the user prompt. Your response should be related to the task and should be brief. Do not overload the response with too much information since a task is going to be performed.`}),s.conversationHistory?.forEach((e=>{c.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),c.push({role:"user",content:e});const h=await i.chat.completions.create({stream:!1,model:s.config?.chatModel||p,messages:c});if(!h.choices||0===h.choices.length||!h.choices[0].message.content)return{success:!1,error:"No response from OpenAI."};const d=h.choices[0].message.content;return r&&a?{success:!0,message:d,task:{taskId:r.taskId,parameters:a}}:{success:!0,message:d}},"create-context":async(e,t)=>{let s;do{s=Math.random().toString(36).substring(2,14),i[s]&&(s="")}while(!s);if(c[s]={},void 0===e)return i[s]={},{success:!0,contextId:s};const n=Object.keys(e);return i[s]=n.reduce(((t,s)=>(t[s]={itemId:s,...e[s]},t)),{}),{success:!0,contextId:s}},"discard-context":async(e,t)=>e&&i[e]?(i[e]=void 0,delete i[e],c[e]=void 0,delete c[e],{success:!0}):{success:!1,error:"Context not found"},"get-context":async(e,t,s,n)=>{if(!e||!i[e])return{success:!1,error:"Context not found"};const o=i[e],r=c[e];return t?o&&o[t]||r&&r[t]?{success:!0,items:o&&o[t]?{[t]:o[t]}:void 0,tasks:r&&r[t]?{[t]:r[t]}:void 0}:{success:!1,error:"Item not found"}:{success:!0,items:o,tasks:r}},"reset-items":async(e,t,s)=>{if(!i[e])return{success:!1,error:"Context not found"};if(!t)return i[e]={},{success:!0};const n=Object.keys(t);return i[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,itemId:s}}}),{}),{success:!0}},"update-items":async(e,t,s)=>{const n=i[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,itemId:e})}return{success:!0}},"remove-items":async(e,t,s)=>{const n=i[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}},"reset-tasks":async(e,t,s)=>{if(!c[e])return{success:!1,error:"Context not found"};if(void 0===t)return c[e]={},{success:!0};const n=Object.keys(t);return c[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,taskId:s}}}),{}),{success:!0}},"update-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,taskId:e})}return{success:!0}},"remove-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}}};e.actionIds=r,e.asOpenAiChatModel=e=>{if(h.includes(e))return e},e.asValidActionId=e=>a(e)?e:void 0,e.createRuntime=(e,t)=>({run:(s,...n)=>{const o=e[s];if(!o)throw new Error("Unsupported action");const r=Array.isArray(n)&&n.length>0?n.slice(0,-1):[],a=Array.isArray(n)&&n.length>0?n[n.length-1]:{},i="object"==typeof a&&null!==a?{...a,config:t}:{config:t};return a.contextId&&!a.getContextItems&&(i.getContextItems=async t=>{const s=await e["get-context"](a.contextId,t,"data",i);if(s&&s.success)return s.items}),a.contextId&&!a.getContextTasks&&(i.getContextTasks=async t=>{const s=await e["get-context"](a.contextId,t,"task",i);if(s&&s.success)return s.tasks}),o(...r,i)}}),e.defaultActionHandlers=f,e.isValidActionId=a,e.openAiDefaultChatModel=p,e.supportedOpenAiChatModels=h}));
!function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports,require("openai"),require("process")):"function"==typeof define&&define.amd?define(["exports","openai","process"],t):t((e="undefined"!=typeof globalThis?globalThis:e||self)["@nlbridge/core"]={},e.OpenAI,e.process)}(this,(function(e,t,s){"use strict";function n(e){var t=Object.create(null);return e&&Object.keys(e).forEach((function(s){if("default"!==s){var n=Object.getOwnPropertyDescriptor(e,s);Object.defineProperty(t,s,n.get?n:{enumerable:!0,get:function(){return e[s]}})}})),t.default=e,Object.freeze(t)}var o=n(s);const r=["chat","chat-stream","assist","create-context","discard-context","get-context","reset-context-items","update-context-items","remove-context-items","reset-context-tasks","update-context-tasks","remove-context-tasks"],a=e=>r.includes(e),i={},c={},u=(e,t)=>{const s=JSON.stringify(e,null,2);return"string"==typeof t.context&&t.context.length>0?t.context.replace("{{context}}","\n\n"+s+"\n\n"):"Use the the JSON object below as a context for the conversation that you are having with the user:\n\n"+s+"\n\n"},h=["gpt-4-0125-preview","gpt-4-turbo-preview","gpt-4-1106-preview","gpt-4-vision-preview","gpt-4","gpt-4-0314","gpt-4-0613","gpt-4-32k","gpt-4-32k-0314","gpt-4-32k-0613","gpt-3.5-turbo","gpt-3.5-turbo-16k","gpt-3.5-turbo-0301","gpt-3.5-turbo-0613","gpt-3.5-turbo-1106","gpt-3.5-turbo-0125","gpt-3.5-turbo-16k-0613"],p="gpt-3.5-turbo",l=e=>{console.error(""+e+"")},m=async(e,s,n)=>{if(!s)return;if(!n.getContextTasks)return;const o=await n.getContextTasks();if(!o)return;const r=n.getLlmInstructions(),a=n.config?.chatModel||p,i=u(s,r),c=((e,t)=>{const s=JSON.stringify(e,null,2);if("string"!=typeof t.taskName&&!t.taskName)return;return t.taskName.replace("{{tasks}}","\n\n"+s+"\n\n")})(o,r);if(!c||!i)return;const h=[],l=new t({apiKey:n.config?.apiKey});h.push({role:"system",content:i}),h.push({role:"system",content:c}),h.push({role:"user",content:e});const m=await l.chat.completions.create({stream:!1,model:a,messages:h});if(!(m.choices&&m.choices.length>0&&m.choices[0].message.content))return;const d=m.choices[0].message.content;if(d.length<5)return;const f=d.replace(/['"]/g,"");if(["response#",'"response#"',"'response#'"].some((e=>f.toLowerCase().startsWith(e))))return;if(["task#",'"task#"',"'task#'"].every((e=>!f.toLowerCase().startsWith(e))))return;const g=d.substring(5).trim();if(!(e=>/^[a-zA-Z_$][0-9a-zA-Z_$]*$/.test(e))(g))return;if(!o[g])return;const y=o[g],x=y.paramDescriptions&&0!==y.paramDescriptions.length?y.paramDescriptions:[];return{taskId:g,description:y.description,paramDescriptions:x}},d=e=>{console.warn(""+e+"")},f={chat:async(e,n)=>{const o=new t({apiKey:n.config?.apiKey||s.env.OPENAI_API_KEY||""}),r=[];if(n.getContextItems){const e=n.getLlmInstructions(),t=await n.getContextItems();t&&r.push({role:"system",content:u(t,e)})}n.conversationHistory&&n.conversationHistory.forEach((e=>{r.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),r.push({role:"user",content:e});const a=await o.chat.completions.create({stream:!1,model:n.config?.chatModel||p,messages:r});return a.choices&&0!==a.choices.length&&a.choices[0].message.content?{success:!0,message:a.choices[0].message.content}:{success:!1,error:"No response from OpenAI."}},"chat-stream":async(e,n,o)=>{const r=new t({apiKey:o.config?.apiKey||s.env.OPENAI_API_KEY||""}),a=[];if(o.getContextItems){const e=o.getLlmInstructions(),t=await o.getContextItems();t&&a.push({role:"system",content:u(t,e)})}o.conversationHistory&&o.conversationHistory.forEach((e=>{a.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),a.push({role:"user",content:e});try{let e=(await r.chat.completions.create({stream:!0,model:o.config?.chatModel||p,messages:a}))[Symbol.asyncIterator](),t=await e.next();for(;!t.done;){const s=t.value;if("stop"===(s.choices?.length>0?s.choices[0].finish_reason:void 0))break;const o=s.choices?.[0].delta.content;"string"==typeof o?n.next(o):d(`Undecodable message - value: ${s}`),t=await e.next()}n.complete()}catch(e){d(`Error: ${e}`)}},assist:async(e,s)=>{const n=s.getLlmInstructions(),r=s.getContextItems?await s.getContextItems():void 0,a=await m(e,r,s),i=a?await(async(e,s,n,o)=>{if(!n)return;const r=o.getLlmInstructions(),a=((e,t)=>{if("string"!=typeof t.parameterValues&&!t.parameterValues)return;const s=t.parameterValues,n="["+e.paramDescriptions.map(((e,t)=>`<Parameter#${t+1}>`)).join(", ")+"]";let o="";return e.paramDescriptions.forEach(((e,t)=>{o+=`The value for the parameter <Parameter#${t+1}> : ${e}\n`})),s.replace("{{taskId}}",e.taskId).replace("{{instructionsToReplaceParams}}",o).replace("{{paramsArrayTemplate}}",n)})(s,r);if(!a)return;const i=[],c=u(n,r);c&&i.push({role:"system",content:c});const h=new t({apiKey:o.config?.apiKey});i.push({role:"system",content:a}),i.push({role:"user",content:e});const m=o.config?.chatModel||p,d=await h.chat.completions.create({stream:!1,model:m,messages:i});if(!(d.choices&&d.choices.length>0&&d.choices[0].message.content))return;const f=d.choices[0].message.content;try{const e=JSON.parse(f);return Array.isArray(e)?e:void l("The response is not an array.")}catch(e){return void l("Error parsing param values: "+e)}})(e,a,r,s):void 0,c=new t({apiKey:s.config?.apiKey||o.env.OPENAI_API_KEY||""}),h=[];if(r){const e=u(r,n);e&&h.push({role:"system",content:e})}a&&i&&h.push({role:"system",content:`Following the next message, the task "${a.taskId}" will be performed. Respond with a short message based on the user prompt. Your response should be related to the task and should be brief. Do not overload the response with too much information since a task is going to be performed.`}),s.conversationHistory?.forEach((e=>{h.push({role:"ai"===e.role?"assistant":"system"===e.role?"system":"user",content:e.message})})),h.push({role:"user",content:e});const d=await c.chat.completions.create({stream:!1,model:s.config?.chatModel||p,messages:h});if(!d.choices||0===d.choices.length||!d.choices[0].message.content)return{success:!1,error:"No response from OpenAI."};const f=d.choices[0].message.content;return a&&i?{success:!0,message:f,task:{taskId:a.taskId,parameters:i}}:{success:!0,message:f}},"create-context":async(e,t)=>{let s;do{s=Math.random().toString(36).substring(2,14),i[s]&&(s="")}while(!s);if(c[s]={},void 0===e)return i[s]={},{success:!0,contextId:s};const n=Object.keys(e);return i[s]=n.reduce(((t,s)=>(t[s]={itemId:s,...e[s]},t)),{}),{success:!0,contextId:s}},"discard-context":async(e,t)=>e&&i[e]?(i[e]=void 0,delete i[e],c[e]=void 0,delete c[e],{success:!0}):{success:!1,error:"Context not found"},"get-context":async(e,t,s,n)=>{if(!e||!i[e])return{success:!1,error:"Context not found"};const o=i[e],r=c[e];return t?o&&o[t]||r&&r[t]?{success:!0,items:o&&o[t]?{[t]:o[t]}:void 0,tasks:r&&r[t]?{[t]:r[t]}:void 0}:{success:!1,error:"Item not found"}:{success:!0,items:o,tasks:r}},"reset-items":async(e,t,s)=>{if(!i[e])return{success:!1,error:"Context not found"};if(!t)return i[e]={},{success:!0};const n=Object.keys(t);return i[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,itemId:s}}}),{}),{success:!0}},"update-items":async(e,t,s)=>{const n=i[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,itemId:e})}return{success:!0}},"remove-items":async(e,t,s)=>{const n=i[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}},"reset-tasks":async(e,t,s)=>{if(!c[e])return{success:!1,error:"Context not found"};if(void 0===t)return c[e]={},{success:!0};const n=Object.keys(t);return c[e]=n.reduce(((e,s)=>{const n=t[s];return{...e,[s]:{...n,taskId:s}}}),{}),{success:!0}},"update-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};const o=Object.keys(t);for(const e of o){const s=t[e];void 0!==s&&(n[e]={...n[e],...s,taskId:e})}return{success:!0}},"remove-tasks":async(e,t,s)=>{const n=c[e];if(!n)return{success:!1,error:"Context not found"};for(const e of t)delete n[e];return{success:!0}}};e.actionIds=r,e.asOpenAiChatModel=e=>{if(h.includes(e))return e},e.asValidActionId=e=>a(e)?e:void 0,e.createRuntime=(e,t,s)=>({run:(n,...o)=>{const r=e[n];if(!r)throw new Error("Unsupported action");const a=Array.isArray(o)&&o.length>0?o.slice(0,-1):[],i=!t||0===Object.keys(t).length,c=i?{context:"The conversation is taking as part while user is using a web or mobile application.\nBelow is a JSON object that contains contextual information about user's session.\nThis context data should be taken into account when generating a response.\nYou should not display JSON code from the context, but rather use it to\ngenerate a response that is relevant to the user based on that context.\n\nContext JSON object:\n\n{{context}}\n",taskName:'The conversation is taking as part while user is using a web or mobile application.\nThe previous message contains information about the user\'s context.\n\nBelow is a Javascript array with a list of tasks that the user may expect to be performed by the application.\nThe object contains a task identifier (string)\n\nTASKS LIST:\n\n{{tasks}}\n\nWhile the user is interacting with the application, they can either expect a response, or they can expect a\ntask to be performed by the application.\n\nThe next message is going to be a prompt from a user.\nYour job is to determine whether the user expects a response or a task.\nIf the user expects a response, you must reply with the string "response#".\n\nIf the user expects a task, you must reply with the string that matches the following format:\n\n"task#<TASK NAME>"\n\nWhere:\n\n<Task Name> should be replaced with the name of the task as it appears in the TASKS LIST.\n\nIf you think that the task that the user expects is not in the TASKS LIST, you should reply with the string "response#".\n\nDo not provide a direct response to the user\'s message.\nOnly analyze the message and determine what the user expects.\nStrictly respond with a string with the format "task#<TASK NAME>" or with "response#".\nIf you think that the user expects only a response, reply by one single word: "response#".\n',parameterValues:"The conversation is taking part while user is using a web or mobile application.\nThe previous message contains information about the user's context.\n\nWe know that the user would like to execute a function with the identifier: {{taskId}}\nThis function is a Javascript function that is part of the application. Your responsibility is to determine the\nvalues of the parameters that should be passed to this {{taskId}} function based on the user context, the conversation\nhistory, the user message, the taskId, and the parameter descriptions provided below.\n\nBelow is Javascript table that should be used as a template to fill in the values of the parameters:\n\nTHE TEMPLATE:\n\n{{paramsArrayTemplate}}\n\nUse the instructions below to fill in the values of the parameters.\n\nINSTRUCTIONS:\n\n{{instructionsToReplaceParams}}\n\nEach parameter marked with the notation <Parameter#(index)> (where index is a number) should be replaced with a\nvalue that will be passed to the function. Each value should either be a string (between double quotes), a number,\na boolean, or null (if you are unable to determine the value of the parameter).\n\nUse information from the context, from the conversation history, from the user input, and the task ID to\ndetermine the values of the parameters.\n\nStrictly respond with a valid and well-structured and flat Javascript array that starts with [ and ends with ].\nIf you are unable to determine the value of a specific parameter, use null for.\nIf you are unable to process the request, response with null.\n\nBe smart and don't mislead the user.\nDo not ask the user for more information than what is already available.\nReply on the INSTRUCTIONS to fill in the values of the parameters.\nYou can make it!\n"}:{},u=i?{context:t?.context??c.context,parameterValues:t?.parameterValues??c.parameterValues,taskName:t?.taskName??c.taskName}:t,h={config:s,getLlmInstructions:()=>u},p=Array.isArray(o)&&o.length>0?o[o.length-1]:void 0;"object"==typeof p&&null!==p&&("string"==typeof p.contextId&&(h.contextId=p.contextId),Array.isArray(p.conversationHistory)&&(h.conversationHistory=p.conversationHistory),"function"==typeof p.getContextItems&&(h.getContextItems=p.getContextItems),"function"==typeof p.getContextItem&&(h.getContextItem=p.getContextItem),"function"==typeof p.getContextTasks&&(h.getContextTasks=p.getContextTasks));const l=h.contextId;return l&&!h.getContextItems&&(h.getContextItems=async t=>{const s=await e["get-context"](l,t,"data",h);if(s&&s.success)return s.items}),l&&!h.getContextTasks&&(h.getContextTasks=async t=>{const s=await e["get-context"](l,t,"task",h);if(s&&s.success)return s.tasks}),r(...a,h)}}),e.defaultActionHandlers=f,e.isValidActionId=a,e.openAiDefaultChatModel=p,e.supportedOpenAiChatModels=h}));
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc