フロントエンドを接続する

import { generateClient } from 'aws-amplify/data';
import { type Schema } from '../amplify/data/resource'

const client = generateClient<Schema>();

// 1. 会話を作成
const { data: chat, errors } = await client.conversations.chat.create();

// 2. アシスタント応答を購読
const subscription = chat.onStreamEvent({
  next: (event) => {
    // アシスタント応答ストリームイベントを処理
    console.log(event);
  },
  error: (error) => {
    // エラーを処理
    console.error(error);
  },
});

// 3. 会話にメッセージを送信
const { data: message, errors } = await chat.sendMessage('Hello, world!');

const { data: chat, errors } = await client.conversations.chat.create();

/**
会話データの例
{
  id: '123e4567-e89b-12d3-a456-426614174000',
  createdAt: '2024-01-01T00:00:00.000Z',
  updatedAt: '2024-01-01T00:00:00.000Z',
}
*/

const { data: chat, errors } = await client.conversations.chat.create({
  name: 'My conversation',
  metadata: {
    value: '1234567890',
  },
});

/**
会話データの例
{
  id: '123e4567-e89b-12d3-a456-426614174000',
  name: 'My conversation',
  metadata: {
    value: '1234567890',
  },
  createdAt: '2024-01-01T00:00:00.000Z',
  updatedAt: '2024-01-01T00:00:00.000Z',
}
*/

const id = '123e4567-e89b-12d3-a456-426614174000';
const { data: chat, errors } = await client.conversations.chat.get({ id });

/**
会話データの例
{
  id: '123e4567-e89b-12d3-a456-426614174000',
  createdAt: '2024-01-01T00:00:00.000Z',
  updatedAt: '2024-01-01T00:00:00.000Z',
}
*/

const { data: chat, errors } = await client.conversations.chat.list();

/**
会話データの例
{
  items: [
    {
      id: '123e4567-e89b-12d3-a456-426614174000',
      createdAt: '2024-01-01T00:00:00.000Z',
      updatedAt: '2024-01-01T00:00:00.000Z',
    },
    ...
  ],
  nextToken: '...',
}
*/

const { data: chat, errors } = await client.conversations.chat.list({
  limit: 10,
  nextToken: '...',
});

const id = '123e4567-e89b-12d3-a456-426614174000';
const { data: chat, errors } = await client.conversations.chat.update({
  id,
  name: 'My updated conversation',
});

/**
会話データの例
{
  id: '123e4567-e89b-12d3-a456-426614174000',
  name: 'My updated conversation',
  createdAt: '2024-01-01T00:00:00.000Z',
  updatedAt: '2024-01-02T00:00:00.000Z',
}
*/

const id = '123e4567-e89b-12d3-a456-426614174000';
const { data: chat, errors } = await client.conversations.chat.delete({ id });

const { data: message, errors } = await chat.sendMessage('Hello, world!');

/**
メッセージデータの例
{
  id: '98765432-dcba-4321-9876-543210987654',
  conversationId: '123e4567-e89b-12d3-a456-426614174000',
  content: 'Hello, world!',
  role: 'user',
  createdAt: '2024-01-01T00:00:00.000Z',
}
*/

const { data: message, errors } = await chat.sendMessage({
  content: [
    {
      image: {
        format: 'png',
        source: {
          bytes: new Uint8Array([1, 2, 3]),
        },
      },
    },
  ],
});

const { data: message, errors } = await chat.sendMessage({
  content: [
    {
      text: 'describe the image in detail',
    },
    {
      image: {
        format: 'png',
        source: {
          bytes: new Uint8Array([1, 2, 3]),
        },
      },
    },
  ],
});

const { data: message, errors } = await chat.sendMessage({
  content: [{ text: 'Hello, world!' }],
  aiContext: {
    user: {
      name: "Dan"
    }
  },
});

const { data: message, errors } = await conversation.sendMessage({
  content: [
    {
      text: "I'd like to make a chocolate cake for my friend with a gluten intolerance. What ingredients do I need?",
    },
  ],
  toolConfiguration: {
    tools: {
      generateRecipe: {
        description: "List ingredients needed for a recipe",
        inputSchema: {
          json: {
            type: "object",
            properties: {
              ingredients: {
                type: "array",
                items: { type: "string" },
              },
            },
          },
        },
      },
    },
  },
});

const subscription = conversation.onStreamEvent({
  next: (event) => {
    console.log(event);
  },
  error: (error) => {
    console.error(error);
  },
});

// 後で...
subscription.unsubscribe();

const { data: messages, errors } = await conversation.listMessages();

const { data: messages, errors } = await conversation.listMessages({
  limit: 10,
  nextToken: '...',
});