Skip to content

Commit

Permalink
ai sdk
Browse files Browse the repository at this point in the history
  • Loading branch information
aboutphilippe committed Oct 6, 2024
1 parent 33c1794 commit fea29f6
Show file tree
Hide file tree
Showing 32 changed files with 303 additions and 334 deletions.
2 changes: 1 addition & 1 deletion azure-speech/functions/speech.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { FunctionFailure, log } from "@restackio/restack-sdk-ts/function";
import { FunctionFailure, log } from "@restackio/ai/function";
import { azureSpeechClient } from "../utils/client";
import * as sdk from "microsoft-cognitiveservices-speech-sdk";
import { Buffer } from "node:buffer";
Expand Down
4 changes: 2 additions & 2 deletions azure-speech/service.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import Restack, { ServiceInput } from "@restackio/restack-sdk-ts";
import { rpmToSecond } from "@restackio/restack-sdk-ts/utils";
import Restack, { ServiceInput } from "@restackio/ai";
import { rpmToSecond } from "@restackio/ai/utils";
import { azureSpeech } from "./functions";
import { azureSpeechTaskQueue } from "./taskQueue";

Expand Down
2 changes: 1 addition & 1 deletion cartesia/functions/ttsBytes.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { FunctionFailure, log } from "@restackio/restack-sdk-ts/function";
import { FunctionFailure, log } from "@restackio/ai/function";
import "dotenv/config";

export async function cartesiaTtsBytes({
Expand Down
4 changes: 2 additions & 2 deletions cartesia/service.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import Restack, { ServiceInput } from "@restackio/restack-sdk-ts";
import { rpmToSecond } from "@restackio/restack-sdk-ts/utils";
import Restack, { ServiceInput } from "@restackio/ai";
import { rpmToSecond } from "@restackio/ai/utils";
import { cartesiaTtsBytes } from "./functions";
import { cartesiaTaskQueue } from "./taskQueue";

Expand Down
2 changes: 1 addition & 1 deletion deepgram/functions/listen.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { FunctionFailure, log } from "@restackio/restack-sdk-ts/function";
import { FunctionFailure, log } from "@restackio/ai/function";
import { Buffer } from "node:buffer";
import { deepgramClient } from "../utils/client";
import { PrerecordedSchema } from "@deepgram/sdk";
Expand Down
2 changes: 1 addition & 1 deletion deepgram/functions/speak.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { FunctionFailure, log } from "@restackio/restack-sdk-ts/function";
import { FunctionFailure, log } from "@restackio/ai/function";
import { Buffer } from "node:buffer";
import { deepgramClient } from "../utils/client";
import { SpeakSchema } from "@deepgram/sdk";
Expand Down
2 changes: 1 addition & 1 deletion deepgram/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
"build": "npm run clean && tsc"
},
"dependencies": {
"@deepgram/sdk": "^3.5.1"
"@deepgram/sdk": "^3.8.0"
},
"files": [
"dist"
Expand Down
4 changes: 2 additions & 2 deletions deepgram/service.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import Restack, { ServiceInput } from "@restackio/restack-sdk-ts";
import { rpmToSecond } from "@restackio/restack-sdk-ts/utils";
import Restack, { ServiceInput } from "@restackio/ai";
import { rpmToSecond } from "@restackio/ai/utils";
import { deepgramListen, deepgramSpeak } from "./functions";
import { deepgramTaskQueue } from "./taskQueue";

Expand Down
2 changes: 1 addition & 1 deletion elevenlabs/functions/convert.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { FunctionFailure, log } from "@restackio/restack-sdk-ts/function";
import { FunctionFailure, log } from "@restackio/ai/function";
import { ElevenLabs } from "elevenlabs/index";

import { elevenlabsClient } from "../utils/client";
Expand Down
2 changes: 1 addition & 1 deletion elevenlabs/service.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import Restack, { ServiceInput } from "@restackio/restack-sdk-ts";
import Restack, { ServiceInput } from "@restackio/ai";
import { elevenlabsConvert } from "./functions";
import { elevenlabsTaskQueue } from "./taskQueue";

Expand Down
2 changes: 1 addition & 1 deletion fal/functions/run.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { FunctionFailure, log } from "@restackio/restack-sdk-ts/function";
import { FunctionFailure, log } from "@restackio/ai/function";
import "dotenv/config";
import { falClient } from "../utils/client";

Expand Down
2 changes: 1 addition & 1 deletion fal/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
"build": "npm run clean && tsc"
},
"dependencies": {
"@fal-ai/serverless-client": "^0.14.2"
"@fal-ai/serverless-client": "^0.14.3"
},
"files": [
"dist"
Expand Down
2 changes: 1 addition & 1 deletion fal/service.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import Restack, { ServiceInput } from "@restackio/restack-sdk-ts";
import Restack, { ServiceInput } from "@restackio/ai";
import { falTaskQueue } from "./taskQueue";
import { falRun } from "./functions";

Expand Down
2 changes: 1 addition & 1 deletion linear/functions/createComment.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { FunctionFailure, log } from "@restackio/restack-sdk-ts/function";
import { FunctionFailure, log } from "@restackio/ai/function";
import { CommentCreateInput } from "@linear/sdk/dist/_generated_documents";
import { linearClient } from "../utils/client";

Expand Down
2 changes: 1 addition & 1 deletion linear/functions/createIssue.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { FunctionFailure, log } from "@restackio/restack-sdk-ts/function";
import { FunctionFailure, log } from "@restackio/ai/function";
import { IssueCreateInput } from "@linear/sdk/dist/_generated_documents";
import { linearClient } from "../utils/client";

Expand Down
4 changes: 2 additions & 2 deletions linear/service.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import Restack, { ServiceInput } from "@restackio/restack-sdk-ts";
import { rpmToSecond } from "@restackio/restack-sdk-ts/utils";
import Restack, { ServiceInput } from "@restackio/ai";
import { rpmToSecond } from "@restackio/ai/utils";
import { linearTaskQueue } from "./taskQueue";
import { linearCreateComment, linearCreateIssue } from "./functions";

Expand Down
2 changes: 1 addition & 1 deletion lumaai/functions/generate.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { log } from "@restackio/restack-sdk-ts/function";
import { log } from "@restackio/ai/function";
import LumaAI from "lumaai";
import { lumaaiClient } from "../utils/client";

Expand Down
4 changes: 2 additions & 2 deletions lumaai/service.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import Restack, { ServiceInput } from "@restackio/restack-sdk-ts";
import { rpmToSecond } from "@restackio/restack-sdk-ts/utils";
import Restack, { ServiceInput } from "@restackio/ai";
import { rpmToSecond } from "@restackio/ai/utils";
import {
lumaaiGenerate,
lumaaiGetGeneration,
Expand Down
2 changes: 1 addition & 1 deletion lumaai/utils/client.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
import LumaAI from "lumaai";
import "dotenv/config";
import { FunctionFailure } from "@restackio/restack-sdk-ts/function"; // Import FunctionFailure
import { FunctionFailure } from "@restackio/ai/function"; // Import FunctionFailure

let clientLumaai: LumaAI;

Expand Down
2 changes: 1 addition & 1 deletion openai/functions/chat/completionsBase.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { FunctionFailure, log } from "@restackio/restack-sdk-ts/function";
import { FunctionFailure, log } from "@restackio/ai/function";
import { ChatCompletionCreateParamsNonStreaming } from "openai/resources/chat/completions";
import { openaiClient } from "../../utils/client";
import { openaiCost, Price } from "../../utils/cost";
Expand Down
6 changes: 3 additions & 3 deletions openai/functions/chat/completionsStream.ts
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
import OpenAI from "openai/index";
import { ChatCompletionChunk } from "openai/resources/chat/completions";

import Restack from "@restackio/restack-sdk-ts";
import { currentWorkflow, log } from "@restackio/restack-sdk-ts/function";
import Restack from "@restackio/ai";
import { currentWorkflow, log } from "@restackio/ai/function";

import { StreamEvent, ToolCallEvent } from "../../types/events";

import { aggregateStreamChunks } from "../../utils/aggregateStream";
import { mergeToolCalls } from "../../utils/mergeToolCalls";
import { openaiClient } from "../../utils/client";
import { openaiCost, Price } from "../../utils/cost";
import { SendWorkflowEvent } from "@restackio/restack-sdk-ts/event";
import { SendWorkflowEvent } from "@restackio/ai/event";
import { ChatModel } from "openai/resources/index";

export async function openaiChatCompletionsStream({
Expand Down
26 changes: 13 additions & 13 deletions openai/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -10,31 +10,31 @@
"build": "npm run clean && tsc"
},
"dependencies": {
"openai": "^4.60.1"
"openai": "^4.67.1"
},
"files": [
"dist"
],
"exports": {
".": {
"import": "./dist/service.js",
"require": "./dist/service.js",
"types": "./dist/service.d.ts"
"import": "./dist/service.js",
"require": "./dist/service.js",
"types": "./dist/service.d.ts"
},
"./taskQueue": {
"import": "./dist/taskQueue.js",
"require": "./dist/taskQueue.js",
"types": "./dist/taskQueue.d.ts"
"import": "./dist/taskQueue.js",
"require": "./dist/taskQueue.js",
"types": "./dist/taskQueue.d.ts"
},
"./functions": {
"import": "./dist/functions/index.js",
"require": "./dist/functions/index.js",
"types": "./dist/functions/index.ts"
"import": "./dist/functions/index.js",
"require": "./dist/functions/index.js",
"types": "./dist/functions/index.ts"
},
"./workflows": {
"import": "./dist/workflows/index.js",
"require": "./dist/workflows/index.js",
"types": "./dist/workflows/index.ts"
"import": "./dist/workflows/index.js",
"require": "./dist/workflows/index.js",
"types": "./dist/workflows/index.ts"
},
"./types": {
"import": "./dist/types/index.js",
Expand Down
4 changes: 2 additions & 2 deletions openai/service.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import Restack, { ServiceInput } from "@restackio/restack-sdk-ts";
import { rpmToSecond } from "@restackio/restack-sdk-ts/utils";
import Restack, { ServiceInput } from "@restackio/ai";
import { rpmToSecond } from "@restackio/ai/utils";
import {
openaiChatCompletionsBase,
openaiChatCompletionsStream,
Expand Down
10 changes: 5 additions & 5 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -10,11 +10,11 @@
"*"
],
"dependencies": {
"@restackio/restack-sdk-ts": "^0.0.74"
"@restackio/ai": "^0.0.75"
},
"devDependencies": {
"typescript": "^4.9.5",
"nodemon": "^2.0.12",
"ts-node": "^10.9.2"
"nodemon": "^2.0.22",
"ts-node": "^10.9.2",
"typescript": "^4.9.5"
}
}
}
Loading

0 comments on commit fea29f6

Please sign in to comment.