Official Plugins

pnpm add @betagors/yama-postgres

plugins:
  - name: "@betagors/yama-postgres"
    config:
      url: ${DATABASE_URL}
      pool:
        min: 2
        max: 10

pnpm add @betagors/yama-pglite

plugins:
  - name: "@betagors/yama-pglite"
    config:
      dataDir: ./data

pnpm add @betagors/yama-s3

plugins:
  - name: "@betagors/yama-s3"
    config:
      bucket: ${S3_BUCKET}
      region: ${AWS_REGION}
      accessKeyId: ${AWS_ACCESS_KEY_ID}
      secretAccessKey: ${AWS_SECRET_ACCESS_KEY}

export async function uploadFile(context: HandlerContext) {
  const { s3 } = context.services;
  
  const result = await s3.upload({
    key: 'uploads/file.pdf',
    body: context.request.body,
    contentType: 'application/pdf',
  });
  
  return { url: result.url };
}

pnpm add @betagors/yama-redis

plugins:
  - name: "@betagors/yama-redis"
    config:
      url: ${REDIS_URL}

export async function getData(context: HandlerContext) {
  const { redis } = context.services;
  
  // Check cache
  const cached = await redis.get('my-key');
  if (cached) return JSON.parse(cached);
  
  // Fetch and cache
  const data = await fetchExpensiveData();
  await redis.set('my-key', JSON.stringify(data), 'EX', 3600);
  
  return data;
}

pnpm add @betagors/yama-realtime

plugins:
  - name: "@betagors/yama-realtime"
    config:
      path: /ws

export async function createTodo(context: HandlerContext) {
  const { realtime } = context.services;
  
  const todo = await context.db.query(
    'INSERT INTO todos (title) VALUES ($1) RETURNING *',
    [context.request.body.title]
  );
  
  // Broadcast to connected clients
  await realtime.broadcast('todos', {
    type: 'created',
    data: todo[0],
  });
  
  return todo[0];
}