Method execute

src/ExampleService.ts:80–158

(context: RequestContext, eventQueue: EventQueue)

  }

  async execute(context: RequestContext, eventQueue: EventQueue): Promise<void> {
    const task = context.currentTask;

    if (!task) {
      throw new Error('No task found in context');
    }
    console.log('✅ Payment verified, processing request...');

    // Extract user message from the context
    const userMessage = context.message?.parts
      ?.filter((part: any) => part.kind === 'text')
      .map((part: any) => part.text)
      .join(' ') || 'Hello';

    console.log(`📝 User request: ${userMessage}`);

    try {
      // Call OpenAI API to process the request
      // REPLACE THIS with your own service logic
      const completion = await this.openai.chat.completions.create({
        model: this.model,
        messages: [
          {
            role: 'system',
            content: 'You are a helpful AI assistant. Provide concise and accurate responses.',
          },
          {
            role: 'user',
            content: userMessage,
          },
        ],
        temperature: this.temperature,
        max_tokens: this.maxTokens,
        ...(this.provider === 'eigenai' && this.seed !== undefined
          ? { seed: this.seed }
          : {}),
      });

      const response = completion.choices[0]?.message?.content || 'No response generated';

      console.log(`🤖 Service response: ${response}`);

      // Update task with the response
      task.status.state = TaskState.COMPLETED;
      task.status.message = {
        messageId: `msg-${Date.now()}`,
        role: 'agent',
        parts: [
          {
            kind: 'text',
            text: response,
          },
        ],
      };

      // Enqueue the completed task
      await eventQueue.enqueueEvent(task);