RUNTIME Quickstart Guide

// handler.js - Content moderation with AI
import { WaveRuntime } from '@wave/runtime';

export const config = {
  trigger: 'stream.started',
  timeout: 30000,
  memory: '256MB',
  retries: 3
};

export async function handler(event, ctx) {
  const { streamId, creatorId, settings } = event.data;

  ctx.logger.info(`Processing stream ${streamId} for creator ${creatorId}`);

  // Get creator preferences from VAULT
  const preferences = await ctx.vault.get(`creator:${creatorId}:preferences`);

  // Enable AI moderation if configured
  if (preferences?.autoModeration) {
    await ctx.edge.process({
      streamId,
      effects: ['content-detection', 'profanity-filter'],
      sensitivity: preferences.moderationLevel || 'medium',
      webhook: `${process.env.APP_URL}/api/webhooks/moderation`
    });
  }

  // Initialize viewer analytics
  await ctx.state.set(`stream:${streamId}:stats`, {
    startedAt: new Date().toISOString(),
    peakViewers: 0,
    totalViews: 0,
    chatMessages: 0,
    donations: 0
  });

  // Record to PULSE analytics
  await ctx.analytics.record({
    event: 'stream_initialized',
    streamId,
    creatorId,
    settings,
    timestamp: Date.now()
  });

  return {
    success: true,
    moderationEnabled: preferences?.autoModeration ?? false,
    streamId
  };
}