// Bước 1: Phân tích đầu vào
export const analyzeInput = async (event) => {
  const analysis = await performAnalysis(event.input);
  await saveState(event.workflowId, { step: 'analysis', result: analysis, nextStep: 'generate' });
  await triggerNextStep(event.workflowId);
  return { status: 'processing', workflowId: event.workflowId };
};

export const chatAgent = async (event) => {
  const context = await redis.get(`chat:${event.userId}`);
  const response = await generateResponse(event.message, context);
  await redis.setex(`chat:${event.userId}`, 3600, { messages: [...context.messages, event.message, response], lastActivity: Date.now() });
  return response;
};

FROM public.ecr.aws/lambda/python:3.9
COPY models/ ${LAMBDA_TASK_ROOT}/models/
COPY requirements.txt .
RUN pip install -r requirements.txt
COPY app.py ${LAMBDA_TASK_ROOT}
CMD ["app.lambda_handler"]

export const keepWarm = async () => {
  const modelExists = await checkModelAvailability();
  if (!modelExists) {
    await downloadAndCacheModel();
  }
  return { status: 'model ready' };
};

export const aiRouter = async (event) => {
  const complexity = analyzeRequestComplexity(event);
  if (complexity.simple) {
    return await processServerless(event);
  } else {
    return await queueForContainerProcessing(event);
  }
};