mirror of
https://github.com/ArthurDanjou/artagents.git
synced 2026-01-14 12:14:40 +01:00
lint code
This commit is contained in:
@@ -1,12 +1,12 @@
|
||||
import type { Message } from 'ai'
|
||||
import { appendResponseMessages, appendClientMessage, streamText } from 'ai'
|
||||
import { appendClientMessage, appendResponseMessages, streamText } from 'ai'
|
||||
import { createWorkersAI } from 'workers-ai-provider'
|
||||
import { loadChat } from '~~/server/utils/chat'
|
||||
|
||||
export default defineEventHandler(async (event) => {
|
||||
const { id, message, model, agent } = await readBody(event)
|
||||
|
||||
console.log(model, agent)
|
||||
console.log(model, agent) //TODO: remove
|
||||
|
||||
const workersAI = createWorkersAI({ binding: hubAI() })
|
||||
|
||||
@@ -14,7 +14,7 @@ export default defineEventHandler(async (event) => {
|
||||
|
||||
const messages = appendClientMessage({
|
||||
messages: previousMessages,
|
||||
message
|
||||
message,
|
||||
})
|
||||
|
||||
const result = streamText({
|
||||
@@ -28,10 +28,10 @@ export default defineEventHandler(async (event) => {
|
||||
id,
|
||||
messages: appendResponseMessages({
|
||||
messages,
|
||||
responseMessages: response.messages
|
||||
})
|
||||
responseMessages: response.messages,
|
||||
}),
|
||||
})
|
||||
}
|
||||
},
|
||||
})
|
||||
|
||||
result.consumeStream()
|
||||
@@ -48,8 +48,8 @@ async function saveChat({ id, messages }: { id: string, messages: Message[] }) {
|
||||
body: {
|
||||
file: {
|
||||
name: `${id}.json`,
|
||||
content: JSON.stringify(messages, null, 2)
|
||||
}
|
||||
}
|
||||
content: JSON.stringify(messages, null, 2),
|
||||
},
|
||||
},
|
||||
})
|
||||
}
|
||||
|
||||
@@ -7,7 +7,7 @@ export default eventHandler(async (event) => {
|
||||
const stream = await hubBlob().serve(event, `chats/${pathname}.json`)
|
||||
|
||||
if (!(stream instanceof ReadableStream)) {
|
||||
throw new Error('Le stream n\'est pas valide')
|
||||
throw new TypeError('Le stream n\'est pas valide')
|
||||
}
|
||||
|
||||
const read = await streamToText(stream)
|
||||
|
||||
@@ -8,11 +8,11 @@ export default eventHandler(async (event) => {
|
||||
|
||||
ensureBlob(file, {
|
||||
maxSize: '1MB',
|
||||
types: ['application/jsonml+json', 'application/json']
|
||||
types: ['application/jsonml+json', 'application/json'],
|
||||
})
|
||||
|
||||
return hubBlob().put(file.name, file, {
|
||||
addRandomSuffix: false,
|
||||
prefix: 'chats'
|
||||
prefix: 'chats',
|
||||
})
|
||||
})
|
||||
|
||||
@@ -1,9 +1,9 @@
|
||||
import { z } from 'zod'
|
||||
import { useValidatedBody } from 'h3-zod'
|
||||
import { z } from 'zod'
|
||||
|
||||
export default eventHandler(async (event) => {
|
||||
const { pathname } = await useValidatedBody(event, {
|
||||
pathname: z.string()
|
||||
pathname: z.string(),
|
||||
})
|
||||
|
||||
await hubBlob().del(pathname)
|
||||
|
||||
@@ -8,11 +8,11 @@ export default eventHandler(async (event) => {
|
||||
|
||||
ensureBlob(file, {
|
||||
maxSize: '1MB',
|
||||
types: ['image', 'pdf', 'application/pdf']
|
||||
types: ['image', 'pdf', 'application/pdf'],
|
||||
})
|
||||
|
||||
return hubBlob().put(file.name, file, {
|
||||
addRandomSuffix: false,
|
||||
prefix: 'files'
|
||||
prefix: 'files',
|
||||
})
|
||||
})
|
||||
|
||||
Reference in New Issue
Block a user