Compare commits
9 Commits
Author | SHA1 | Date | |
---|---|---|---|
d52e6ae67d | |||
b9745a1869 | |||
af3b61cf74 | |||
8666876879 | |||
b78168307b | |||
bbd8770205 | |||
28bb13dc0c | |||
3a24c2c4bd | |||
8244ac6eb0 |
1
.serena/.gitignore
vendored
Normal file
1
.serena/.gitignore
vendored
Normal file
@@ -0,0 +1 @@
|
|||||||
|
/cache
|
67
.serena/project.yml
Normal file
67
.serena/project.yml
Normal file
@@ -0,0 +1,67 @@
|
|||||||
|
# language of the project (csharp, python, rust, java, typescript, go, cpp, or ruby)
|
||||||
|
# * For C, use cpp
|
||||||
|
# * For JavaScript, use typescript
|
||||||
|
# Special requirements:
|
||||||
|
# * csharp: Requires the presence of a .sln file in the project folder.
|
||||||
|
language: typescript
|
||||||
|
|
||||||
|
# whether to use the project's gitignore file to ignore files
|
||||||
|
# Added on 2025-04-07
|
||||||
|
ignore_all_files_in_gitignore: true
|
||||||
|
# list of additional paths to ignore
|
||||||
|
# same syntax as gitignore, so you can use * and **
|
||||||
|
# Was previously called `ignored_dirs`, please update your config if you are using that.
|
||||||
|
# Added (renamed) on 2025-04-07
|
||||||
|
ignored_paths: []
|
||||||
|
|
||||||
|
# whether the project is in read-only mode
|
||||||
|
# If set to true, all editing tools will be disabled and attempts to use them will result in an error
|
||||||
|
# Added on 2025-04-18
|
||||||
|
read_only: false
|
||||||
|
|
||||||
|
# list of tool names to exclude. We recommend not excluding any tools, see the readme for more details.
|
||||||
|
# Below is the complete list of tools for convenience.
|
||||||
|
# To make sure you have the latest list of tools, and to view their descriptions,
|
||||||
|
# execute `uv run scripts/print_tool_overview.py`.
|
||||||
|
#
|
||||||
|
# * `activate_project`: Activates a project by name.
|
||||||
|
# * `check_onboarding_performed`: Checks whether project onboarding was already performed.
|
||||||
|
# * `create_text_file`: Creates/overwrites a file in the project directory.
|
||||||
|
# * `delete_lines`: Deletes a range of lines within a file.
|
||||||
|
# * `delete_memory`: Deletes a memory from Serena's project-specific memory store.
|
||||||
|
# * `execute_shell_command`: Executes a shell command.
|
||||||
|
# * `find_referencing_code_snippets`: Finds code snippets in which the symbol at the given location is referenced.
|
||||||
|
# * `find_referencing_symbols`: Finds symbols that reference the symbol at the given location (optionally filtered by type).
|
||||||
|
# * `find_symbol`: Performs a global (or local) search for symbols with/containing a given name/substring (optionally filtered by type).
|
||||||
|
# * `get_current_config`: Prints the current configuration of the agent, including the active and available projects, tools, contexts, and modes.
|
||||||
|
# * `get_symbols_overview`: Gets an overview of the top-level symbols defined in a given file.
|
||||||
|
# * `initial_instructions`: Gets the initial instructions for the current project.
|
||||||
|
# Should only be used in settings where the system prompt cannot be set,
|
||||||
|
# e.g. in clients you have no control over, like Claude Desktop.
|
||||||
|
# * `insert_after_symbol`: Inserts content after the end of the definition of a given symbol.
|
||||||
|
# * `insert_at_line`: Inserts content at a given line in a file.
|
||||||
|
# * `insert_before_symbol`: Inserts content before the beginning of the definition of a given symbol.
|
||||||
|
# * `list_dir`: Lists files and directories in the given directory (optionally with recursion).
|
||||||
|
# * `list_memories`: Lists memories in Serena's project-specific memory store.
|
||||||
|
# * `onboarding`: Performs onboarding (identifying the project structure and essential tasks, e.g. for testing or building).
|
||||||
|
# * `prepare_for_new_conversation`: Provides instructions for preparing for a new conversation (in order to continue with the necessary context).
|
||||||
|
# * `read_file`: Reads a file within the project directory.
|
||||||
|
# * `read_memory`: Reads the memory with the given name from Serena's project-specific memory store.
|
||||||
|
# * `remove_project`: Removes a project from the Serena configuration.
|
||||||
|
# * `replace_lines`: Replaces a range of lines within a file with new content.
|
||||||
|
# * `replace_symbol_body`: Replaces the full definition of a symbol.
|
||||||
|
# * `restart_language_server`: Restarts the language server, may be necessary when edits not through Serena happen.
|
||||||
|
# * `search_for_pattern`: Performs a search for a pattern in the project.
|
||||||
|
# * `summarize_changes`: Provides instructions for summarizing the changes made to the codebase.
|
||||||
|
# * `switch_modes`: Activates modes by providing a list of their names
|
||||||
|
# * `think_about_collected_information`: Thinking tool for pondering the completeness of collected information.
|
||||||
|
# * `think_about_task_adherence`: Thinking tool for determining whether the agent is still on track with the current task.
|
||||||
|
# * `think_about_whether_you_are_done`: Thinking tool for determining whether the task is truly completed.
|
||||||
|
# * `write_memory`: Writes a named memory (for future reference) to Serena's project-specific memory store.
|
||||||
|
excluded_tools: []
|
||||||
|
|
||||||
|
# initial prompt for the project. It will always be given to the LLM upon activating the project
|
||||||
|
# (contrary to the memories, which are loaded on demand).
|
||||||
|
initial_prompt: ""
|
||||||
|
|
||||||
|
project_name: "smartai"
|
30
changelog.md
30
changelog.md
@@ -1,5 +1,35 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
|
## 2025-10-10 - 0.7.7 - fix(MultiModalModel)
|
||||||
|
Lazy-load SmartPdf and guard document processing across providers; ensure SmartPdf is initialized only when needed
|
||||||
|
|
||||||
|
- Make SmartPdf lazy-loaded: smartpdfInstance is now nullable and no longer started automatically in start()
|
||||||
|
- Add ensureSmartpdfReady() to initialize and start SmartPdf on demand before document processing
|
||||||
|
- Providers updated (OpenAI, Anthropic, Ollama, xAI) to call ensureSmartpdfReady() and use the smartpdfInstance for PDF -> image conversion
|
||||||
|
- stop() now cleans up and nullifies smartpdfInstance to release resources
|
||||||
|
- Avoids starting a browser/process unless document() is actually used (reduces unnecessary resource usage)
|
||||||
|
- Add local Claude permissions file (.claude/settings.local.json) for tooling/configuration
|
||||||
|
|
||||||
|
## 2025-10-09 - 0.7.6 - fix(provider.elevenlabs)
|
||||||
|
Provide default ElevenLabs TTS voice fallback and add local tool/project configs
|
||||||
|
|
||||||
|
- ElevenLabsProvider: fallback to Samara voice id ('19STyYD15bswVz51nqLf') when no voiceId or defaultVoiceId is provided — avoids throwing an error on TTS calls.
|
||||||
|
- ElevenLabsProvider: continue to use 'eleven_v3' as the default model for TTS.
|
||||||
|
- Add .claude/settings.local.json with expanded allowed permissions for local tooling and web search.
|
||||||
|
- Add .serena/project.yml and .serena/.gitignore to include Serena project configuration and ignore cache.
|
||||||
|
|
||||||
|
## 2025-10-08 - 0.7.5 - fix(provider.elevenlabs)
|
||||||
|
Update ElevenLabs default TTS model to eleven_v3 and add local Claude permissions file
|
||||||
|
|
||||||
|
- Changed default ElevenLabs modelId from 'eleven_multilingual_v2' to 'eleven_v3' in ts/provider.elevenlabs.ts to use the newer/default TTS model.
|
||||||
|
- Added .claude/settings.local.json with a permissions allow-list for local Claude tooling and CI tasks.
|
||||||
|
|
||||||
|
## 2025-10-03 - 0.7.4 - fix(provider.anthropic)
|
||||||
|
Use image/png for embedded PDF images in Anthropic provider and add local Claude settings for development permissions
|
||||||
|
|
||||||
|
- AnthropicProvider: change media_type from 'image/jpeg' to 'image/png' when embedding images extracted from PDFs to ensure correct format in Anthropic requests.
|
||||||
|
- Add .claude/settings.local.json with development/testing permissions for local Claude usage (shell commands, webfetch, websearch, test/run tasks).
|
||||||
|
|
||||||
## 2025-10-03 - 0.7.3 - fix(tests)
|
## 2025-10-03 - 0.7.3 - fix(tests)
|
||||||
Add extensive provider/feature tests and local Claude CI permissions
|
Add extensive provider/feature tests and local Claude CI permissions
|
||||||
|
|
||||||
|
17
package.json
17
package.json
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@push.rocks/smartai",
|
"name": "@push.rocks/smartai",
|
||||||
"version": "0.7.3",
|
"version": "0.7.7",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "SmartAi is a versatile TypeScript library designed to facilitate integration and interaction with various AI models, offering functionalities for chat, audio generation, document processing, and vision tasks.",
|
"description": "SmartAi is a versatile TypeScript library designed to facilitate integration and interaction with various AI models, offering functionalities for chat, audio generation, document processing, and vision tasks.",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
@@ -15,22 +15,23 @@
|
|||||||
"buildDocs": "(tsdoc)"
|
"buildDocs": "(tsdoc)"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@git.zone/tsbuild": "^2.6.4",
|
"@git.zone/tsbuild": "^2.6.8",
|
||||||
"@git.zone/tsbundle": "^2.5.1",
|
"@git.zone/tsbundle": "^2.5.1",
|
||||||
"@git.zone/tsrun": "^1.3.3",
|
"@git.zone/tsrun": "^1.3.3",
|
||||||
"@git.zone/tstest": "^2.3.2",
|
"@git.zone/tstest": "^2.3.8",
|
||||||
"@push.rocks/qenv": "^6.1.0",
|
"@push.rocks/qenv": "^6.1.3",
|
||||||
"@push.rocks/tapbundle": "^6.0.3",
|
"@push.rocks/tapbundle": "^6.0.3",
|
||||||
"@types/node": "^22.15.17"
|
"@types/node": "^22.15.17",
|
||||||
|
"typescript": "^5.9.3"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@anthropic-ai/sdk": "^0.59.0",
|
"@anthropic-ai/sdk": "^0.65.0",
|
||||||
"@push.rocks/smartarray": "^1.1.0",
|
"@push.rocks/smartarray": "^1.1.0",
|
||||||
"@push.rocks/smartfile": "^11.2.5",
|
"@push.rocks/smartfile": "^11.2.7",
|
||||||
"@push.rocks/smartpath": "^6.0.0",
|
"@push.rocks/smartpath": "^6.0.0",
|
||||||
"@push.rocks/smartpdf": "^4.1.1",
|
"@push.rocks/smartpdf": "^4.1.1",
|
||||||
"@push.rocks/smartpromise": "^4.2.3",
|
"@push.rocks/smartpromise": "^4.2.3",
|
||||||
"@push.rocks/smartrequest": "^4.2.1",
|
"@push.rocks/smartrequest": "^4.3.1",
|
||||||
"@push.rocks/webstream": "^1.0.10",
|
"@push.rocks/webstream": "^1.0.10",
|
||||||
"openai": "^5.12.2"
|
"openai": "^5.12.2"
|
||||||
},
|
},
|
||||||
|
2602
pnpm-lock.yaml
generated
2602
pnpm-lock.yaml
generated
File diff suppressed because it is too large
Load Diff
27
readme.md
27
readme.md
@@ -5,7 +5,7 @@
|
|||||||
[](https://www.typescriptlang.org/)
|
[](https://www.typescriptlang.org/)
|
||||||
[](https://opensource.org/licenses/MIT)
|
[](https://opensource.org/licenses/MIT)
|
||||||
|
|
||||||
SmartAI unifies the world's leading AI providers - OpenAI, Anthropic, Perplexity, Ollama, Groq, XAI, and Exo - under a single, elegant TypeScript interface. Build AI applications at lightning speed without vendor lock-in.
|
SmartAI unifies the world's leading AI providers - OpenAI, Anthropic, Perplexity, Ollama, Groq, XAI, Exo, and ElevenLabs - under a single, elegant TypeScript interface. Build AI applications at lightning speed without vendor lock-in.
|
||||||
|
|
||||||
## 🎯 Why SmartAI?
|
## 🎯 Why SmartAI?
|
||||||
|
|
||||||
@@ -28,7 +28,11 @@ import { SmartAi } from '@push.rocks/smartai';
|
|||||||
// Initialize with your favorite providers
|
// Initialize with your favorite providers
|
||||||
const ai = new SmartAi({
|
const ai = new SmartAi({
|
||||||
openaiToken: 'sk-...',
|
openaiToken: 'sk-...',
|
||||||
anthropicToken: 'sk-ant-...'
|
anthropicToken: 'sk-ant-...',
|
||||||
|
elevenlabsToken: 'sk-...',
|
||||||
|
elevenlabs: {
|
||||||
|
defaultVoiceId: '19STyYD15bswVz51nqLf' // Optional: Samara voice
|
||||||
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
await ai.start();
|
await ai.start();
|
||||||
@@ -49,6 +53,7 @@ Choose the right provider for your use case:
|
|||||||
|----------|:----:|:---------:|:---:|:------:|:---------:|:--------:|:------:|------------|
|
|----------|:----:|:---------:|:---:|:------:|:---------:|:--------:|:------:|------------|
|
||||||
| **OpenAI** | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | • gpt-image-1<br>• DALL-E 3<br>• Deep research API |
|
| **OpenAI** | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ | • gpt-image-1<br>• DALL-E 3<br>• Deep research API |
|
||||||
| **Anthropic** | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | • Claude Sonnet 4.5<br>• Superior reasoning<br>• Web search API |
|
| **Anthropic** | ✅ | ✅ | ❌ | ✅ | ✅ | ✅ | ❌ | • Claude Sonnet 4.5<br>• Superior reasoning<br>• Web search API |
|
||||||
|
| **ElevenLabs** | ❌ | ❌ | ✅ | ❌ | ❌ | ❌ | ❌ | • Premium TTS<br>• 70+ languages<br>• Natural voices |
|
||||||
| **Ollama** | ✅ | ✅ | ❌ | ✅ | ✅ | ❌ | ❌ | • 100% local<br>• Privacy-first<br>• No API costs |
|
| **Ollama** | ✅ | ✅ | ❌ | ✅ | ✅ | ❌ | ❌ | • 100% local<br>• Privacy-first<br>• No API costs |
|
||||||
| **XAI** | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ | ❌ | • Grok models<br>• Real-time data<br>• Uncensored |
|
| **XAI** | ✅ | ✅ | ❌ | ❌ | ✅ | ❌ | ❌ | • Grok models<br>• Real-time data<br>• Uncensored |
|
||||||
| **Perplexity** | ✅ | ✅ | ❌ | ❌ | ❌ | ✅ | ❌ | • Web-aware<br>• Research-focused<br>• Sonar Pro models |
|
| **Perplexity** | ✅ | ✅ | ❌ | ❌ | ❌ | ✅ | ❌ | • Web-aware<br>• Research-focused<br>• Sonar Pro models |
|
||||||
@@ -105,13 +110,27 @@ while (true) {
|
|||||||
|
|
||||||
### 🎙️ Text-to-Speech
|
### 🎙️ Text-to-Speech
|
||||||
|
|
||||||
Generate natural voices with OpenAI:
|
Generate natural voices with OpenAI or ElevenLabs:
|
||||||
|
|
||||||
```typescript
|
```typescript
|
||||||
|
// OpenAI TTS
|
||||||
const audioStream = await ai.openaiProvider.audio({
|
const audioStream = await ai.openaiProvider.audio({
|
||||||
message: 'Welcome to the future of AI development!'
|
message: 'Welcome to the future of AI development!'
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// ElevenLabs TTS - Premium quality, natural voices (uses v3 by default)
|
||||||
|
const elevenLabsAudio = await ai.elevenlabsProvider.audio({
|
||||||
|
message: 'Experience the most lifelike text to speech technology.',
|
||||||
|
voiceId: '19STyYD15bswVz51nqLf', // Optional: Samara voice
|
||||||
|
modelId: 'eleven_v3', // Optional: defaults to eleven_v3 (70+ languages, most expressive)
|
||||||
|
voiceSettings: { // Optional: fine-tune voice characteristics
|
||||||
|
stability: 0.5, // 0-1: Speech consistency
|
||||||
|
similarity_boost: 0.8, // 0-1: Voice similarity to original
|
||||||
|
style: 0.0, // 0-1: Expressiveness (higher = more expressive)
|
||||||
|
use_speaker_boost: true // Enhanced clarity
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
// Stream directly to speakers
|
// Stream directly to speakers
|
||||||
audioStream.pipe(speakerOutput);
|
audioStream.pipe(speakerOutput);
|
||||||
|
|
||||||
@@ -548,6 +567,7 @@ npm install @push.rocks/smartai
|
|||||||
export OPENAI_API_KEY=sk-...
|
export OPENAI_API_KEY=sk-...
|
||||||
export ANTHROPIC_API_KEY=sk-ant-...
|
export ANTHROPIC_API_KEY=sk-ant-...
|
||||||
export PERPLEXITY_API_KEY=pplx-...
|
export PERPLEXITY_API_KEY=pplx-...
|
||||||
|
export ELEVENLABS_API_KEY=sk-...
|
||||||
# ... etc
|
# ... etc
|
||||||
```
|
```
|
||||||
|
|
||||||
@@ -574,6 +594,7 @@ export PERPLEXITY_API_KEY=pplx-...
|
|||||||
| **Complex Reasoning** | Anthropic | Superior logical thinking, safer outputs |
|
| **Complex Reasoning** | Anthropic | Superior logical thinking, safer outputs |
|
||||||
| **Research & Facts** | Perplexity | Web-aware, provides citations |
|
| **Research & Facts** | Perplexity | Web-aware, provides citations |
|
||||||
| **Deep Research** | OpenAI | Deep Research API with comprehensive analysis |
|
| **Deep Research** | OpenAI | Deep Research API with comprehensive analysis |
|
||||||
|
| **Premium TTS** | ElevenLabs | Most natural voices, 70+ languages, superior quality (v3) |
|
||||||
| **Speed Critical** | Groq | 10x faster inference, sub-second responses |
|
| **Speed Critical** | Groq | 10x faster inference, sub-second responses |
|
||||||
| **Privacy Critical** | Ollama | 100% local, no data leaves your servers |
|
| **Privacy Critical** | Ollama | 100% local, no data leaves your servers |
|
||||||
| **Real-time Data** | XAI | Access to current information |
|
| **Real-time Data** | XAI | Access to current information |
|
||||||
|
54
test/test.audio.elevenlabs.ts
Normal file
54
test/test.audio.elevenlabs.ts
Normal file
@@ -0,0 +1,54 @@
|
|||||||
|
import { expect, tap } from '@push.rocks/tapbundle';
|
||||||
|
import * as qenv from '@push.rocks/qenv';
|
||||||
|
import * as smartfile from '@push.rocks/smartfile';
|
||||||
|
|
||||||
|
const testQenv = new qenv.Qenv('./', './.nogit/');
|
||||||
|
|
||||||
|
import * as smartai from '../ts/index.js';
|
||||||
|
|
||||||
|
let testSmartai: smartai.SmartAi;
|
||||||
|
|
||||||
|
tap.test('ElevenLabs Audio: should create a smartai instance with ElevenLabs provider', async () => {
|
||||||
|
testSmartai = new smartai.SmartAi({
|
||||||
|
elevenlabsToken: await testQenv.getEnvVarOnDemand('ELEVENLABS_TOKEN'),
|
||||||
|
elevenlabs: {
|
||||||
|
defaultVoiceId: '19STyYD15bswVz51nqLf',
|
||||||
|
},
|
||||||
|
});
|
||||||
|
await testSmartai.start();
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('ElevenLabs Audio: should create audio response', async () => {
|
||||||
|
const audioStream = await testSmartai.elevenlabsProvider.audio({
|
||||||
|
message: 'Welcome to SmartAI, the unified interface for the world\'s leading artificial intelligence providers. SmartAI brings together OpenAI, Anthropic, Perplexity, and ElevenLabs under a single elegant TypeScript API. Whether you need text generation, vision analysis, document processing, or premium text-to-speech capabilities, SmartAI provides a consistent and powerful interface for all your AI needs. Build intelligent applications at lightning speed without vendor lock-in.',
|
||||||
|
});
|
||||||
|
const chunks: Uint8Array[] = [];
|
||||||
|
for await (const chunk of audioStream) {
|
||||||
|
chunks.push(chunk as Uint8Array);
|
||||||
|
}
|
||||||
|
const audioBuffer = Buffer.concat(chunks);
|
||||||
|
await smartfile.fs.toFs(audioBuffer, './.nogit/testoutput_elevenlabs.mp3');
|
||||||
|
console.log(`Audio Buffer length: ${audioBuffer.length}`);
|
||||||
|
expect(audioBuffer.length).toBeGreaterThan(0);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('ElevenLabs Audio: should create audio with custom voice', async () => {
|
||||||
|
const audioStream = await testSmartai.elevenlabsProvider.audio({
|
||||||
|
message: 'Testing with a different voice.',
|
||||||
|
voiceId: 'JBFqnCBsd6RMkjVDRZzb',
|
||||||
|
});
|
||||||
|
const chunks: Uint8Array[] = [];
|
||||||
|
for await (const chunk of audioStream) {
|
||||||
|
chunks.push(chunk as Uint8Array);
|
||||||
|
}
|
||||||
|
const audioBuffer = Buffer.concat(chunks);
|
||||||
|
await smartfile.fs.toFs(audioBuffer, './.nogit/testoutput_elevenlabs_custom.mp3');
|
||||||
|
console.log(`Audio Buffer length (custom voice): ${audioBuffer.length}`);
|
||||||
|
expect(audioBuffer.length).toBeGreaterThan(0);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('ElevenLabs Audio: should stop the smartai instance', async () => {
|
||||||
|
await testSmartai.stop();
|
||||||
|
});
|
||||||
|
|
||||||
|
export default tap.start();
|
@@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@push.rocks/smartai',
|
name: '@push.rocks/smartai',
|
||||||
version: '0.7.3',
|
version: '0.7.7',
|
||||||
description: 'SmartAi is a versatile TypeScript library designed to facilitate integration and interaction with various AI models, offering functionalities for chat, audio generation, document processing, and vision tasks.'
|
description: 'SmartAi is a versatile TypeScript library designed to facilitate integration and interaction with various AI models, offering functionalities for chat, audio generation, document processing, and vision tasks.'
|
||||||
}
|
}
|
||||||
|
@@ -111,19 +111,30 @@ export interface ImageResponse {
|
|||||||
export abstract class MultiModalModel {
|
export abstract class MultiModalModel {
|
||||||
/**
|
/**
|
||||||
* SmartPdf instance for document processing
|
* SmartPdf instance for document processing
|
||||||
* Shared across all methods that need PDF functionality
|
* Lazy-loaded only when PDF processing is needed to avoid starting browser unnecessarily
|
||||||
*/
|
*/
|
||||||
protected smartpdfInstance: plugins.smartpdf.SmartPdf;
|
protected smartpdfInstance: plugins.smartpdf.SmartPdf | null = null;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Ensures SmartPdf instance is initialized and ready
|
||||||
|
* Call this before using smartpdfInstance in document processing methods
|
||||||
|
*/
|
||||||
|
protected async ensureSmartpdfReady(): Promise<void> {
|
||||||
|
if (!this.smartpdfInstance) {
|
||||||
|
this.smartpdfInstance = new plugins.smartpdf.SmartPdf();
|
||||||
|
await this.smartpdfInstance.start();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Initializes the model and any necessary resources
|
* Initializes the model and any necessary resources
|
||||||
* Should be called before using any other methods
|
* Should be called before using any other methods
|
||||||
*/
|
*/
|
||||||
public async start(): Promise<void> {
|
public async start(): Promise<void> {
|
||||||
this.smartpdfInstance = new plugins.smartpdf.SmartPdf();
|
// SmartPdf is now lazy-loaded only when needed for PDF processing
|
||||||
await this.smartpdfInstance.start();
|
// This avoids starting a browser unless document() method is actually used
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Cleans up any resources used by the model
|
* Cleans up any resources used by the model
|
||||||
* Should be called when the model is no longer needed
|
* Should be called when the model is no longer needed
|
||||||
@@ -131,6 +142,7 @@ export abstract class MultiModalModel {
|
|||||||
public async stop(): Promise<void> {
|
public async stop(): Promise<void> {
|
||||||
if (this.smartpdfInstance) {
|
if (this.smartpdfInstance) {
|
||||||
await this.smartpdfInstance.stop();
|
await this.smartpdfInstance.stop();
|
||||||
|
this.smartpdfInstance = null;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -96,6 +96,18 @@ export class Conversation {
|
|||||||
return conversation;
|
return conversation;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public static async createWithElevenlabs(smartaiRefArg: SmartAi) {
|
||||||
|
if (!smartaiRefArg.elevenlabsProvider) {
|
||||||
|
throw new Error('ElevenLabs provider not available');
|
||||||
|
}
|
||||||
|
const conversation = new Conversation(smartaiRefArg, {
|
||||||
|
processFunction: async (input) => {
|
||||||
|
return '' // TODO implement proper streaming
|
||||||
|
}
|
||||||
|
});
|
||||||
|
return conversation;
|
||||||
|
}
|
||||||
|
|
||||||
// INSTANCE
|
// INSTANCE
|
||||||
smartaiRef: SmartAi
|
smartaiRef: SmartAi
|
||||||
private systemMessage: string;
|
private systemMessage: string;
|
||||||
|
@@ -1,6 +1,7 @@
|
|||||||
import { Conversation } from './classes.conversation.js';
|
import { Conversation } from './classes.conversation.js';
|
||||||
import * as plugins from './plugins.js';
|
import * as plugins from './plugins.js';
|
||||||
import { AnthropicProvider } from './provider.anthropic.js';
|
import { AnthropicProvider } from './provider.anthropic.js';
|
||||||
|
import { ElevenLabsProvider } from './provider.elevenlabs.js';
|
||||||
import { OllamaProvider } from './provider.ollama.js';
|
import { OllamaProvider } from './provider.ollama.js';
|
||||||
import { OpenAiProvider } from './provider.openai.js';
|
import { OpenAiProvider } from './provider.openai.js';
|
||||||
import { PerplexityProvider } from './provider.perplexity.js';
|
import { PerplexityProvider } from './provider.perplexity.js';
|
||||||
@@ -15,6 +16,7 @@ export interface ISmartAiOptions {
|
|||||||
perplexityToken?: string;
|
perplexityToken?: string;
|
||||||
groqToken?: string;
|
groqToken?: string;
|
||||||
xaiToken?: string;
|
xaiToken?: string;
|
||||||
|
elevenlabsToken?: string;
|
||||||
exo?: {
|
exo?: {
|
||||||
baseUrl?: string;
|
baseUrl?: string;
|
||||||
apiKey?: string;
|
apiKey?: string;
|
||||||
@@ -24,9 +26,13 @@ export interface ISmartAiOptions {
|
|||||||
model?: string;
|
model?: string;
|
||||||
visionModel?: string;
|
visionModel?: string;
|
||||||
};
|
};
|
||||||
|
elevenlabs?: {
|
||||||
|
defaultVoiceId?: string;
|
||||||
|
defaultModelId?: string;
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
export type TProvider = 'openai' | 'anthropic' | 'perplexity' | 'ollama' | 'exo' | 'groq' | 'xai';
|
export type TProvider = 'openai' | 'anthropic' | 'perplexity' | 'ollama' | 'exo' | 'groq' | 'xai' | 'elevenlabs';
|
||||||
|
|
||||||
export class SmartAi {
|
export class SmartAi {
|
||||||
public options: ISmartAiOptions;
|
public options: ISmartAiOptions;
|
||||||
@@ -38,6 +44,7 @@ export class SmartAi {
|
|||||||
public exoProvider: ExoProvider;
|
public exoProvider: ExoProvider;
|
||||||
public groqProvider: GroqProvider;
|
public groqProvider: GroqProvider;
|
||||||
public xaiProvider: XAIProvider;
|
public xaiProvider: XAIProvider;
|
||||||
|
public elevenlabsProvider: ElevenLabsProvider;
|
||||||
|
|
||||||
constructor(optionsArg: ISmartAiOptions) {
|
constructor(optionsArg: ISmartAiOptions) {
|
||||||
this.options = optionsArg;
|
this.options = optionsArg;
|
||||||
@@ -74,6 +81,14 @@ export class SmartAi {
|
|||||||
});
|
});
|
||||||
await this.xaiProvider.start();
|
await this.xaiProvider.start();
|
||||||
}
|
}
|
||||||
|
if (this.options.elevenlabsToken) {
|
||||||
|
this.elevenlabsProvider = new ElevenLabsProvider({
|
||||||
|
elevenlabsToken: this.options.elevenlabsToken,
|
||||||
|
defaultVoiceId: this.options.elevenlabs?.defaultVoiceId,
|
||||||
|
defaultModelId: this.options.elevenlabs?.defaultModelId,
|
||||||
|
});
|
||||||
|
await this.elevenlabsProvider.start();
|
||||||
|
}
|
||||||
if (this.options.ollama) {
|
if (this.options.ollama) {
|
||||||
this.ollamaProvider = new OllamaProvider({
|
this.ollamaProvider = new OllamaProvider({
|
||||||
baseUrl: this.options.ollama.baseUrl,
|
baseUrl: this.options.ollama.baseUrl,
|
||||||
@@ -107,6 +122,9 @@ export class SmartAi {
|
|||||||
if (this.xaiProvider) {
|
if (this.xaiProvider) {
|
||||||
await this.xaiProvider.stop();
|
await this.xaiProvider.stop();
|
||||||
}
|
}
|
||||||
|
if (this.elevenlabsProvider) {
|
||||||
|
await this.elevenlabsProvider.stop();
|
||||||
|
}
|
||||||
if (this.ollamaProvider) {
|
if (this.ollamaProvider) {
|
||||||
await this.ollamaProvider.stop();
|
await this.ollamaProvider.stop();
|
||||||
}
|
}
|
||||||
@@ -134,6 +152,8 @@ export class SmartAi {
|
|||||||
return Conversation.createWithGroq(this);
|
return Conversation.createWithGroq(this);
|
||||||
case 'xai':
|
case 'xai':
|
||||||
return Conversation.createWithXai(this);
|
return Conversation.createWithXai(this);
|
||||||
|
case 'elevenlabs':
|
||||||
|
return Conversation.createWithElevenlabs(this);
|
||||||
default:
|
default:
|
||||||
throw new Error('Provider not available');
|
throw new Error('Provider not available');
|
||||||
}
|
}
|
||||||
|
@@ -7,3 +7,4 @@ export * from './provider.groq.js';
|
|||||||
export * from './provider.ollama.js';
|
export * from './provider.ollama.js';
|
||||||
export * from './provider.xai.js';
|
export * from './provider.xai.js';
|
||||||
export * from './provider.exo.js';
|
export * from './provider.exo.js';
|
||||||
|
export * from './provider.elevenlabs.js';
|
||||||
|
@@ -192,11 +192,14 @@ export class AnthropicProvider extends MultiModalModel {
|
|||||||
pdfDocuments: Uint8Array[];
|
pdfDocuments: Uint8Array[];
|
||||||
messageHistory: ChatMessage[];
|
messageHistory: ChatMessage[];
|
||||||
}): Promise<{ message: any }> {
|
}): Promise<{ message: any }> {
|
||||||
|
// Ensure SmartPdf is initialized before processing documents
|
||||||
|
await this.ensureSmartpdfReady();
|
||||||
|
|
||||||
// Convert PDF documents to images using SmartPDF
|
// Convert PDF documents to images using SmartPDF
|
||||||
let documentImageBytesArray: Uint8Array[] = [];
|
let documentImageBytesArray: Uint8Array[] = [];
|
||||||
|
|
||||||
for (const pdfDocument of optionsArg.pdfDocuments) {
|
for (const pdfDocument of optionsArg.pdfDocuments) {
|
||||||
const documentImageArray = await this.smartpdfInstance.convertPDFToPngBytes(pdfDocument);
|
const documentImageArray = await this.smartpdfInstance!.convertPDFToPngBytes(pdfDocument);
|
||||||
documentImageBytesArray = documentImageBytesArray.concat(documentImageArray);
|
documentImageBytesArray = documentImageBytesArray.concat(documentImageArray);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -220,7 +223,7 @@ export class AnthropicProvider extends MultiModalModel {
|
|||||||
type: 'image',
|
type: 'image',
|
||||||
source: {
|
source: {
|
||||||
type: 'base64',
|
type: 'base64',
|
||||||
media_type: 'image/jpeg',
|
media_type: 'image/png',
|
||||||
data: Buffer.from(imageBytes).toString('base64')
|
data: Buffer.from(imageBytes).toString('base64')
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
114
ts/provider.elevenlabs.ts
Normal file
114
ts/provider.elevenlabs.ts
Normal file
@@ -0,0 +1,114 @@
|
|||||||
|
import * as plugins from './plugins.js';
|
||||||
|
|
||||||
|
import { MultiModalModel } from './abstract.classes.multimodal.js';
|
||||||
|
import type {
|
||||||
|
ChatOptions,
|
||||||
|
ChatResponse,
|
||||||
|
ResearchOptions,
|
||||||
|
ResearchResponse,
|
||||||
|
ImageGenerateOptions,
|
||||||
|
ImageEditOptions,
|
||||||
|
ImageResponse
|
||||||
|
} from './abstract.classes.multimodal.js';
|
||||||
|
|
||||||
|
export interface IElevenLabsProviderOptions {
|
||||||
|
elevenlabsToken: string;
|
||||||
|
defaultVoiceId?: string;
|
||||||
|
defaultModelId?: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface IElevenLabsVoiceSettings {
|
||||||
|
stability?: number;
|
||||||
|
similarity_boost?: number;
|
||||||
|
style?: number;
|
||||||
|
use_speaker_boost?: boolean;
|
||||||
|
}
|
||||||
|
|
||||||
|
export class ElevenLabsProvider extends MultiModalModel {
|
||||||
|
private options: IElevenLabsProviderOptions;
|
||||||
|
private baseUrl: string = 'https://api.elevenlabs.io/v1';
|
||||||
|
|
||||||
|
constructor(optionsArg: IElevenLabsProviderOptions) {
|
||||||
|
super();
|
||||||
|
this.options = optionsArg;
|
||||||
|
}
|
||||||
|
|
||||||
|
public async start() {
|
||||||
|
await super.start();
|
||||||
|
}
|
||||||
|
|
||||||
|
public async stop() {
|
||||||
|
await super.stop();
|
||||||
|
}
|
||||||
|
|
||||||
|
public async chat(optionsArg: ChatOptions): Promise<ChatResponse> {
|
||||||
|
throw new Error('ElevenLabs does not support chat functionality. This provider is specialized for text-to-speech only.');
|
||||||
|
}
|
||||||
|
|
||||||
|
public async chatStream(input: ReadableStream<Uint8Array>): Promise<ReadableStream<string>> {
|
||||||
|
throw new Error('ElevenLabs does not support chat streaming functionality. This provider is specialized for text-to-speech only.');
|
||||||
|
}
|
||||||
|
|
||||||
|
public async audio(optionsArg: {
|
||||||
|
message: string;
|
||||||
|
voiceId?: string;
|
||||||
|
modelId?: string;
|
||||||
|
voiceSettings?: IElevenLabsVoiceSettings;
|
||||||
|
}): Promise<NodeJS.ReadableStream> {
|
||||||
|
// Use Samara voice as default fallback
|
||||||
|
const voiceId = optionsArg.voiceId || this.options.defaultVoiceId || '19STyYD15bswVz51nqLf';
|
||||||
|
|
||||||
|
const modelId = optionsArg.modelId || this.options.defaultModelId || 'eleven_v3';
|
||||||
|
|
||||||
|
const url = `${this.baseUrl}/text-to-speech/${voiceId}`;
|
||||||
|
|
||||||
|
const requestBody: any = {
|
||||||
|
text: optionsArg.message,
|
||||||
|
model_id: modelId,
|
||||||
|
};
|
||||||
|
|
||||||
|
if (optionsArg.voiceSettings) {
|
||||||
|
requestBody.voice_settings = optionsArg.voiceSettings;
|
||||||
|
}
|
||||||
|
|
||||||
|
const response = await plugins.smartrequest.SmartRequest.create()
|
||||||
|
.url(url)
|
||||||
|
.header('xi-api-key', this.options.elevenlabsToken)
|
||||||
|
.json(requestBody)
|
||||||
|
.autoDrain(false)
|
||||||
|
.post();
|
||||||
|
|
||||||
|
if (!response.ok) {
|
||||||
|
const errorText = await response.text();
|
||||||
|
throw new Error(`ElevenLabs API error: ${response.status} ${response.statusText} - ${errorText}`);
|
||||||
|
}
|
||||||
|
|
||||||
|
const nodeStream = response.streamNode();
|
||||||
|
return nodeStream;
|
||||||
|
}
|
||||||
|
|
||||||
|
public async vision(optionsArg: { image: Buffer; prompt: string }): Promise<string> {
|
||||||
|
throw new Error('ElevenLabs does not support vision functionality. This provider is specialized for text-to-speech only.');
|
||||||
|
}
|
||||||
|
|
||||||
|
public async document(optionsArg: {
|
||||||
|
systemMessage: string;
|
||||||
|
userMessage: string;
|
||||||
|
pdfDocuments: Uint8Array[];
|
||||||
|
messageHistory: any[];
|
||||||
|
}): Promise<{ message: any }> {
|
||||||
|
throw new Error('ElevenLabs does not support document processing. This provider is specialized for text-to-speech only.');
|
||||||
|
}
|
||||||
|
|
||||||
|
public async research(optionsArg: ResearchOptions): Promise<ResearchResponse> {
|
||||||
|
throw new Error('ElevenLabs does not support research capabilities. This provider is specialized for text-to-speech only.');
|
||||||
|
}
|
||||||
|
|
||||||
|
public async imageGenerate(optionsArg: ImageGenerateOptions): Promise<ImageResponse> {
|
||||||
|
throw new Error('ElevenLabs does not support image generation. This provider is specialized for text-to-speech only.');
|
||||||
|
}
|
||||||
|
|
||||||
|
public async imageEdit(optionsArg: ImageEditOptions): Promise<ImageResponse> {
|
||||||
|
throw new Error('ElevenLabs does not support image editing. This provider is specialized for text-to-speech only.');
|
||||||
|
}
|
||||||
|
}
|
@@ -216,11 +216,14 @@ export class OllamaProvider extends MultiModalModel {
|
|||||||
pdfDocuments: Uint8Array[];
|
pdfDocuments: Uint8Array[];
|
||||||
messageHistory: ChatMessage[];
|
messageHistory: ChatMessage[];
|
||||||
}): Promise<{ message: any }> {
|
}): Promise<{ message: any }> {
|
||||||
|
// Ensure SmartPdf is initialized before processing documents
|
||||||
|
await this.ensureSmartpdfReady();
|
||||||
|
|
||||||
// Convert PDF documents to images using SmartPDF
|
// Convert PDF documents to images using SmartPDF
|
||||||
let documentImageBytesArray: Uint8Array[] = [];
|
let documentImageBytesArray: Uint8Array[] = [];
|
||||||
|
|
||||||
for (const pdfDocument of optionsArg.pdfDocuments) {
|
for (const pdfDocument of optionsArg.pdfDocuments) {
|
||||||
const documentImageArray = await this.smartpdfInstance.convertPDFToPngBytes(pdfDocument);
|
const documentImageArray = await this.smartpdfInstance!.convertPDFToPngBytes(pdfDocument);
|
||||||
documentImageBytesArray = documentImageBytesArray.concat(documentImageArray);
|
documentImageBytesArray = documentImageBytesArray.concat(documentImageArray);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -173,11 +173,14 @@ export class OpenAiProvider extends MultiModalModel {
|
|||||||
content: any;
|
content: any;
|
||||||
}[];
|
}[];
|
||||||
}) {
|
}) {
|
||||||
|
// Ensure SmartPdf is initialized before processing documents
|
||||||
|
await this.ensureSmartpdfReady();
|
||||||
|
|
||||||
let pdfDocumentImageBytesArray: Uint8Array[] = [];
|
let pdfDocumentImageBytesArray: Uint8Array[] = [];
|
||||||
|
|
||||||
// Convert each PDF into one or more image byte arrays.
|
// Convert each PDF into one or more image byte arrays.
|
||||||
for (const pdfDocument of optionsArg.pdfDocuments) {
|
for (const pdfDocument of optionsArg.pdfDocuments) {
|
||||||
const documentImageArray = await this.smartpdfInstance.convertPDFToPngBytes(pdfDocument);
|
const documentImageArray = await this.smartpdfInstance!.convertPDFToPngBytes(pdfDocument);
|
||||||
pdfDocumentImageBytesArray = pdfDocumentImageBytesArray.concat(documentImageArray);
|
pdfDocumentImageBytesArray = pdfDocumentImageBytesArray.concat(documentImageArray);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -149,11 +149,14 @@ export class XAIProvider extends MultiModalModel {
|
|||||||
pdfDocuments: Uint8Array[];
|
pdfDocuments: Uint8Array[];
|
||||||
messageHistory: { role: string; content: string; }[];
|
messageHistory: { role: string; content: string; }[];
|
||||||
}): Promise<{ message: any }> {
|
}): Promise<{ message: any }> {
|
||||||
|
// Ensure SmartPdf is initialized before processing documents
|
||||||
|
await this.ensureSmartpdfReady();
|
||||||
|
|
||||||
// First convert PDF documents to images
|
// First convert PDF documents to images
|
||||||
let pdfDocumentImageBytesArray: Uint8Array[] = [];
|
let pdfDocumentImageBytesArray: Uint8Array[] = [];
|
||||||
|
|
||||||
for (const pdfDocument of optionsArg.pdfDocuments) {
|
for (const pdfDocument of optionsArg.pdfDocuments) {
|
||||||
const documentImageArray = await this.smartpdfInstance.convertPDFToPngBytes(pdfDocument);
|
const documentImageArray = await this.smartpdfInstance!.convertPDFToPngBytes(pdfDocument);
|
||||||
pdfDocumentImageBytesArray = pdfDocumentImageBytesArray.concat(documentImageArray);
|
pdfDocumentImageBytesArray = pdfDocumentImageBytesArray.concat(documentImageArray);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user