import { fromApiKey } from '@auvy-synapse/client'

export async function createSynapseClient() {
  return fromApiKey(process.env.AUVY_API_KEY!)
}

import { fromApiKey } from '@auvy-synapse/client'

const auvy = await fromApiKey()
const { job_id } = await auvy.receptors.invoke('my-workspace', 'support-bot', {
  message: 'Summarize open incidents',
  stream: true,
})

for await (const chunk of auvy.receptors.createStream(job_id)) {
  if (chunk.type === 'token' && chunk.token) process.stdout.write(chunk.token)
}

const auvy = await fromApiKey()
const { items } = await auvy.resources.browse({ kinds: ['asset'], limit: 20 })
const asset = await auvy.resourceStore.assets.get(items[0].id)

import { connectFromSession } from '@auvy-synapse/connect-client'

const connect = connectFromSession({ getAccessToken: () => session.access_token })

const { redirectUrl, connectionRequestId } = await connect.link(integrationId, {
  callbackUrl: `${origin}/integrations/callback`,
})
// redirect user, then on callback:
await connect.completeLink(integrationId, {
  connectionRequestId,
  query: callbackParams,
})
const tools = await connect.tools(integrationId)

import { connectRunTool } from '@auvy-synapse/connect-client/server'

const result = await connectRunTool({
  workspaceId,
  userId,
  integrationId,
  toolName: 'slack_post_message',
  toolConfig: { channel: 'C123', text: 'Done' },
  resultFormat: 'json',
})

const auvy = await fromApiKey()
const pending = await auvy.interventions.list({ status: 'pending' })
await auvy.interventions.respond(pending[0].id, {
  action: 'approve',
  comment: 'Ship it',
})

const auvy = await fromApiKey()
await auvy.voice.prewarmSttVocabulary()
const defaults = await auvy.voice.sttVocabularyDefaults()