برمجة لعبة سباق مثل Need for Speed باستخدام Flutter وPython

import 'package:flame/game.dart';
import 'package:flame/components.dart';
import 'package:flutter/services.dart';
import 'package:flame_forge2d/flame_forge2d.dart'; // استيراد مكتبة الفيزياء
import 'package:flame_audio/flame_audio.dart'; // لاستيراد الصوتيات
import 'dart:math'; // لدوال الرياضيات مثل cos و sin

// ملاحظة: لاستخدام KeyboardEvents، يجب أن يكون التطبيق قابلاً للتركيز (Focusable)
// في Flutter Web أو Desktop. للتحكم باللمس على الموبايل، سيتم إضافة جزء لاحق.

class CarGame extends Forge2DGame with KeyboardEvents, HasGameRef { // استخدام Forge2DGame للفيزياء
  late CarBody playerCar; // سيارة اللاعب
  double carSpeed = 0;
  double carAngle = 0;

  @override
  Future<void> onLoad() async {
    await super.onLoad(); // استدعاء onLoad الأساسي لـ Forge2DGame

    // تحميل صورة السيارة وإضافتها كـ SpriteComponent داخل CarBody
    // سنقوم بإنشاء CarBody وإضافتها كجسم فيزيائي
    playerCar = CarBody(position: size / 2);
    add(playerCar);

    // إضافة الجدران/حدود المسار كأجسام فيزيائية ثابتة
    add(Ground(gameRef.screenToWorld(Vector2(size.x / 2, size.y)))); // أسفل الشاشة
    add(Ground(gameRef.screenToWorld(Vector2(size.x / 2, 0))));    // أعلى الشاشة
    add(Ground(gameRef.screenToWorld(Vector2(0, size.y / 2)), isVertical: true)); // يسار الشاشة
    add(Ground(gameRef.screenToWorld(Vector2(size.x, size.y / 2)), isVertical: true)); // يمين الشاشة

    // يمكنك استبدال الجدران البسيطة بـ SpriteComponent للطريق نفسه وجدران مرئية.

    // تحميل وتشغيل صوت المحرك
    FlameAudio.audioCache.loadAll(['engine_loop.mp3']);
    FlameAudio.loop('engine_loop.mp3'); // يبدأ صوت المحرك بالتكرار
  }

  // كلاس يمثل جسم السيارة الفيزيائي
  class CarBody extends BodyComponent {
    late SpriteComponent carSprite;
    final Vector2 initialPosition;

    CarBody({required this.initialPosition}) : super(renderBody: false); // لا نرسم الجسم الفيزيائي

    @override
    Future<void> onLoad() async {
      await super.onLoad();
      carSprite = SpriteComponent()
        ..sprite = await gameRef.loadSprite('car.png')
        ..size = Vector2(64, 128) // حجم السيارة
        ..anchor = Anchor.center; // مرسى الـ sprite في المنتصف ليتوافق مع الجسم الفيزيائي
      add(carSprite);
    }

    @override
    Body createBody() {
      final bodyDef = BodyDef(
        position: initialPosition,
        type: BodyType.dynamic, // السيارة جسم ديناميكي (يتحرك ويتفاعل)
        linearDamping: 0.8, // مقاومة حركة خطية لتقليل السرعة تدريجياً
        angularDamping: 0.8, // مقاومة حركة دورانية
      );

      final shape = PolygonShape()..setAsBox(carSprite.size.x / 2 / worldToScreen, carSprite.size.y / 2 / worldToScreen);

      final fixtureDef = FixtureDef(shape, density: 1.0, friction: 0.8, restitution: 0.1); // الكثافة، الاحتكاك، الارتداد

      return world.createBody(bodyDef)..createFixture(fixtureDef);
    }

    @override
    void update(double dt) {
      super.update(dt);
      carSprite.position = body.position * worldToScreen; // تحديث موقع الـ sprite ليتبع الجسم الفيزيائي
      carSprite.angle = body.angle; // تحديث زاوية الـ sprite لتتبع الجسم الفيزيائي
    }
  }

  // كلاس يمثل الأرض أو الجدران الثابتة
  class Ground extends BodyComponent {
    final Vector2 _position;
    final bool isVertical;

    Ground(this._position, {this.isVertical = false});

    @override
    Body createBody() {
      final bodyDef = BodyDef(
        position: _position,
        type: BodyType.static, // الجسم ثابت لا يتحرك بفعل الفيزياء
      );

      Shape shape;
      if (isVertical) {
        shape = PolygonShape()..setAsBox(0.1, 1000); // جدار رأسي رفيع وطويل
      } else {
        shape = PolygonShape()..setAsBox(1000, 0.1); // جدار أفقي رفيع وطويل
      }

      return world.createBody(bodyDef)..createFixture(FixtureDef(shape));
    }
  }

  // التحكم بالسيارة (سلوك قياسي)
  @override
  KeyEventResult onKeyEvent(RawKeyEvent event, Set<LogicalKeyboardKey> keysPressed) {
    final movementForce = 200.0;
    final turningTorque = 50.0;

    if (keysPressed.contains(LogicalKeyboardKey.arrowUp)) {
      playerCar.body.applyForceToCenter(playerCar.body.linearVelocity.normalized() * movementForce);
      // أو استخدام قوة في اتجاه الأمام
      // playerCar.body.applyLinearImpulse(playerCar.body.getTransform().q.asVector2() * movementForce * dt);
    }
    if (keysPressed.contains(LogicalKeyboardKey.arrowDown)) {
      playerCar.body.applyForceToCenter(-playerCar.body.linearVelocity.normalized() * movementForce / 2);
    }
    if (keysPressed.contains(LogicalKeyboardKey.arrowLeft)) {
      playerCar.body.applyTorque(turningTorque); // تطبيق عزم دوران
    }
    if (keysPressed.contains(LogicalKeyboardKey.arrowRight)) {
      playerCar.body.applyTorque(-turningTorque);
    }

    // لتشغيل الدخان فقط عند التسارع أو الانزلاق
    if (keysPressed.contains(LogicalKeyboardKey.arrowUp) && playerCar.body.linearVelocity.length > 5) {
      // add a smoke effect here
    }

    return KeyEventResult.handled;
  }
}

from fastapi import FastAPI, WebSocket, WebSocketDisconnect
from typing import List, Dict
import json
import asyncio # لاستخدام async/await في Python

app = FastAPI()

class ConnectionManager:
    def __init__(self):
        self.active_connections: List[WebSocket] = []
        self.player_states: Dict[str, Dict] = {} # لتخزين حالة كل لاعب (مثلاً: {"player_id": {"x": ..., "y": ..., "angle": ...}})
        self.next_player_id = 0 # لتوليد معرفات فريدة للاعبين

    async def connect(self, websocket: WebSocket):
        await websocket.accept()
        player_id = f"player_{self.next_player_id}"
        self.next_player_id += 1
        self.active_connections.append(websocket)
        self.player_states[player_id] = {"id": player_id, "x": 0, "y": 0, "angle": 0} # حالة ابتدائية

        # إرسال ID اللاعب الخاص به إلى العميل
        await websocket.send_text(json.dumps({"type": "player_id", "id": player_id}))
        # بث الحالة الأولية لجميع اللاعبين الجدد
        await self.broadcast_game_state()
        print(f"[NEW CONNECTION] Player {player_id} connected. Total: {len(self.active_connections)}")

    def disconnect(self, websocket: WebSocket):
        player_id_to_remove = None
        for pid, conn in zip(self.player_states.keys(), self.active_connections):
            if conn == websocket:
                player_id_to_remove = pid
                break
        if player_id_to_remove:
            self.active_connections.remove(websocket)
            self.player_states.pop(player_id_to_remove, None)
            print(f"[DISCONNECT] Player {player_id_to_remove} disconnected. Total: {len(self.active_connections)}")
            asyncio.create_task(self.broadcast_game_state()) # بث حالة اللعبة بعد قطع الاتصال

    async def send_personal_message(self, message: str, websocket: WebSocket):
        await websocket.send_text(message)

    async def broadcast_game_state(self):
        # يرسل حالة جميع اللاعبين إلى جميع العملاء
        message = json.dumps({"type": "game_state", "players": list(self.player_states.values())})
        for connection in self.active_connections:
            await connection.send_text(message)

manager = ConnectionManager()

@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
    await manager.connect(websocket)
    player_id = None # لتخزين معرف اللاعب بعد الاتصال
    try:
        # البحث عن معرف اللاعب المرتبط بهذا الـ websocket
        for pid, conn in zip(manager.player_states.keys(), manager.active_connections):
            if conn == websocket:
                player_id = pid
                break

        while True:
            data = await websocket.receive_text()
            if player_id:
                player_update = json.loads(data)
                # تحديث حالة اللاعب في الخادم
                manager.player_states[player_id].update(player_update)
                # بث الحالة الجديدة لجميع اللاعبين
                await manager.broadcast_game_state()
    except WebSocketDisconnect:
        manager.disconnect(websocket)
    except Exception as e:
        print(f"WebSocket Error: {e}")
        manager.disconnect(websocket)

# لتشغيل الخادم:
# 1. تأكد من تثبيت FastAPI و uvicorn و websockets:
#    pip install fastapi uvicorn websockets
# 2. شغل الخادم من مجلد 'python_server' باستخدام:
#    uvicorn server:app --reload --ws websockets

// في بداية ملف car_game.dart، تأكد من استيراد هذه المكتبات:
import 'package:flame/game.dart';
import 'package:flame/components.dart';
import 'package:flutter/services.dart';
import 'package:flame_forge2d/flame_forge2d.dart';
import 'package:flame_audio/flame_audio.dart';
import 'dart:math';
import 'package:flame/particles.dart'; // لاستيراد نظام الجسيمات
import 'package:flame/effects.dart'; // لتأثيرات حركة الجسيمات
import 'package:flutter/material.dart'; // لاستخدام الألوان في Paint

// ... (بقية كود CarGame class والمتغيرات مثل playerCar)

class CarGame extends Forge2DGame with KeyboardEvents, HasGameRef {
  late CarBody playerCar; // سيارة اللاعب
  // ... (بقية المتغيرات مثل multiplayerClient و otherPlayers)

  // لا نحتاج لـ `late TimerComponent smokeTimer;` هنا في هذا الدمج
  // لأننا سنتعامل مع إضافة وإزالة تأثيرات الدخان مباشرة عند الحاجة.

  @override
  Future<void> onLoad() async {
    await super.onLoad();

    // تحميل صورة السيارة وإضافتها كـ SpriteComponent داخل CarBody
    playerCar = CarBody(position: gameRef.screenToWorld(size / 2)); // استخدام gameRef.screenToWorld لتحويل من بكسل إلى وحدة فيزياء
    add(playerCar);

    // إضافة الجدران/حدود المسار كأجسام فيزيائية ثابتة
    add(Ground(gameRef.screenToWorld(Vector2(size.x / 2, size.y))));
    add(Ground(gameRef.screenToWorld(Vector2(size.x / 2, 0))));
    add(Ground(gameRef.screenToWorld(Vector2(0, size.y / 2)), isVertical: true));
    add(Ground(gameRef.screenToWorld(Vector2(size.x, size.y / 2)), isVertical: true));

    // تحميل وتشغيل صوت المحرك
    await FlameAudio.audioCache.loadAll(['engine_loop.mp3', 'smoke_1.png']); // تحميل صورة الدخان أيضاً
    FlameAudio.loop('engine_loop.mp3'); // يبدأ صوت المحرك بالتكرار

    // ... (بقية كود onLoad مثل تهيئة MultiplayerClient)
  }

  @override
  KeyEventResult onKeyEvent(RawKeyEvent event, Set<LogicalKeyboardKey> keysPressed) {
    // ... (كود التحكم بالسيارة باستخدام applyForceToCenter أو applyTorque)
    return KeyEventResult.handled;
  }

  @override
  void update(double dt) {
    super.update(dt);
    // ... (كود إرسال حالة اللاعب إلى الخادم)

    // تفعيل الدخان عند التسارع الشديد أو الانزلاق
    // يمكن ضبط القيم (linearVelocity.length > 10) حسب الحاجة
    if (keysPressed.contains(LogicalKeyboardKey.arrowUp) && playerCar.body.linearVelocity.length > 5) {
      // إضافة تأثير الدخان خلف السيارة
      // يتم تحديد موقع الدخان بحيث يظهر من خلف السيارة (بناءً على اتجاهها)
      final smokePosition = playerCar.body.position * worldToScreen -
                            (playerCar.carSprite.size.y / 2) * playerCar.body.getTransform().q.asVector2();

      add(SmokeParticleEffect(position: smokePosition));
    }
  }

  // كلاس لتمثيل جسم السيارة الفيزيائي
  class CarBody extends BodyComponent {
    late SpriteComponent carSprite;
    final Vector2 initialPosition;

    CarBody({required this.initialPosition}) : super(renderBody: false);

    @override
    Future<void> onLoad() async {
      await super.onLoad();
      carSprite = SpriteComponent()
        ..sprite = await gameRef.loadSprite('car.png')
        ..size = Vector2(64, 128)
        ..anchor = Anchor.center;
      add(carSprite);
    }

    @override
    Body createBody() {
      // ... (كود createBody لـ CarBody)
      final bodyDef = BodyDef(
        position: initialPosition,
        type: BodyType.dynamic,
        linearDamping: 0.8,
        angularDamping: 0.8,
      );

      final shape = PolygonShape()..setAsBox(carSprite.size.x / 2 / worldToScreen, carSprite.size.y / 2 / worldToScreen);

      final fixtureDef = FixtureDef(shape, density: 1.0, friction: 0.8, restitution: 0.1);

      return world.createBody(bodyDef)..createFixture(fixtureDef);
    }

    @override
    void update(double dt) {
      super.update(dt);
      carSprite.position = body.position * worldToScreen;
      carSprite.angle = body.angle;
    }
  }

  // كلاس لتمثيل الأرض أو الجدران الثابتة
  class Ground extends BodyComponent {
    // ... (كود Ground class)
    final Vector2 _position;
    final bool isVertical;

    Ground(this._position, {this.isVertical = false});

    @override
    Body createBody() {
      final bodyDef = BodyDef(
        position: _position,
        type: BodyType.static,
      );

      Shape shape;
      if (isVertical) {
        shape = PolygonShape()..setAsBox(0.1, gameRef.screenToWorld(gameRef.size).y / 2);
      } else {
        shape = PolygonShape()..setAsBox(gameRef.screenToWorld(gameRef.size).x / 2, 0.1);
      }

      return world.createBody(bodyDef)..createFixture(FixtureDef(shape));
    }
  }

  // كلاس لتمثيل سيارة لاعب آخر
  class OtherCarBody extends BodyComponent {
    // ... (كود OtherCarBody class)
    late SpriteComponent carSprite;
    final Vector2 initialPosition;

    OtherCarBody({required this.initialPosition}) : super(renderBody: false);

    @override
    Future<void> onLoad() async {
      await super.onLoad();
      carSprite = SpriteComponent()
        ..sprite = await gameRef.loadSprite('car.png')
        ..size = Vector2(64, 128)
        ..anchor = Anchor.center;
      add(carSprite);
    }

    @override
    Body createBody() {
      final bodyDef = BodyDef(
        position: initialPosition,
        type: BodyType.kinematic,
      );
      final shape = PolygonShape()..setAsBox(carSprite.size.x / 2 / worldToScreen, carSprite.size.y / 2 / worldToScreen);
      return world.createBody(bodyDef)..createFixture(FixtureDef(shape));
    }

    @override
    void update(double dt) {
      super.update(dt);
      carSprite.position = body.position * worldToScreen;
      carSprite.angle = body.angle;
    }
  }

  // كلاس تأثير الدخان (يتم تعريفه خارج كلاس CarGame)
  class SmokeParticleEffect extends ParticleComponent {
    SmokeParticleEffect({required Vector2 position})
        : super(
            position: position,
            // استخدام Particle.generate لإنشاء دفعة من الجسيمات
            particle: Particle.generate(
              count: 3, // عدد أقل للجسيمات في كل دفعة لجعلها خفيفة
              lifespan: 0.8, // عمر الجسيمات أقصر
              generator: (i) => AcceleratedParticle(
                position: Vector2.zero(), // تبدأ من مركز المكون
                speed: Vector2.random() * 30 - Vector2(15, 15), // سرعة عشوائية بسيطة
                acceleration: Vector2(0, -30), // تتصاعد للأعلى ببطء (Y-axis هو الأعلى في Flame)
                child: SpriteParticle(
                  sprite: Flame.images.fromCache('smoke_1.png'), // استخدام الصورة المحملة مسبقًا
                  size: Vector2(15, 15), // حجم أصغر للجسيمات
                  paint: Paint()..color = Colors.white.withOpacity(0.4), // لون الدخان وشفافيته
                ),
              ),
            ),
          );
  }
}