Skip to content

Commit

Permalink
Separate messages endpoint
Browse files Browse the repository at this point in the history
  • Loading branch information
sam-lippert committed Dec 14, 2023
1 parent 9d513c4 commit b889ea1
Showing 1 changed file with 16 additions and 14 deletions.
30 changes: 16 additions & 14 deletions worker.js
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ api.get('/favicon.ico', () => {
api.get('/assistants', requiresAuth, async (req, env) => {
const openai = new OpenAI({ apiKey: env.OPENAI_API_KEY })
const assistants = await openai.beta.assistants.list()
console.log({ assistants })
return assistants
})
api.get('/assistants/:assistantId', requiresAuth, async (req, env) => {
Expand All @@ -41,22 +40,27 @@ api.get('/assistants/:assistantId', requiresAuth, async (req, env) => {
model,
})
: await openai.beta.assistants.retrieve(assistantId)
console.log({ assistant })
return assistant
})
api.get('/threads/:threadId', requiresAuth, async (req, env) => {
const {
ctx: {
headers: { host },
},
} = req
console.log({ host })
const openai = new OpenAI({ apiKey: env.OPENAI_API_KEY })
const { threadId } = req.params
const thread = threadId === 'new' ? await openai.beta.threads.create() : await openai.beta.threads.messages.list(threadId)
console.log({ thread })
const url = new URL(`threads/${threadId}`, 'https://gpt.do')
return thread.data ? { ...thread, url } : { data: thread, url }
const thread = threadId === 'new' ? await openai.beta.threads.create() : await openai.beta.threads.retrieve(threadId)
const endpoints = {
thread: new URL(`threads/${threadId}`, 'https://gpt.do'),
messages: new URL(`threads/${threadId}/messages`, 'https://gpt.do'),
}
return { endpoints, data: thread }
})
api.get('/threads/:threadId/messages', requiresAuth, async (req, env) => {
const openai = new OpenAI({ apiKey: env.OPENAI_API_KEY })
const { threadId } = req.params
const messages = await openai.beta.threads.messages.list(threadId)
const endpoints = {
thread: new URL(`threads/${threadId}`, 'https://gpt.do'),
messages: new URL(`threads/${threadId}/messages`, 'https://gpt.do'),
}
return { endpoints, ...messages }
})
api.get('/threads/:threadId/run/:runId?', requiresAuth, async (req, env) => {
const openai = new OpenAI({ apiKey: env.OPENAI_API_KEY })
Expand All @@ -68,7 +72,6 @@ api.get('/threads/:threadId/run/:runId?', requiresAuth, async (req, env) => {
assistant_id,
instructions,
})
console.log({ run })
return run
})
api.get('/threads/:threadId/:message', requiresAuth, async (req, env) => {
Expand All @@ -78,7 +81,6 @@ api.get('/threads/:threadId/:message', requiresAuth, async (req, env) => {
role: 'user',
content,
})
console.log({ message })
return message
})

Expand Down

0 comments on commit b889ea1

Please sign in to comment.