Campofinale/Campofinale/Database/Database.cs

using Campofinale.Game;
using Campofinale.Game.Character;
using Campofinale.Game.Gacha;
using Campofinale.Game.Inventory;
using Campofinale.Game.MissionSys;
using Campofinale.Game.Spaceship;
using MongoDB.Bson;
using MongoDB.Bson.Serialization.Attributes;
using MongoDB.Driver;
using System.Security.Cryptography;
using System.Text;
using static Campofinale.Resource.ResourceManager;

namespace Campofinale.Database
{
    public class PlayerData
    {
        [BsonId]
        public ulong roleId;
        
        public string accountId;
        public Vector3f position;
        public Vector3f rotation;
        public int curSceneNumId;
        public uint level = 20;
        public uint xp = 0;
        public string nickname = "Endministrator";
        public int teamIndex = 0;
        public List<Team> teams = new List<Team>();
        public ulong totalGuidCount = 1;
        public List<int> unlockedSystems = new();
        public List<ulong> noSpawnAnymore = new();
        public long maxDashEnergy = 250;
        public uint curStamina;
        public long nextRecoverTime;
        public List<Scene> scenes = new();
        public Dictionary<int, List<int>> bitsets = new();
        public PlayerSafeZoneInfo savedSafeZone = new();
        public Gender gender = Gender.GenFemale;
        public Dictionary<int, Item> bag = new();
    }
    public class MissionData
    {
        [BsonId]
        public ulong roleId;
        public List<GameMission> missions = new();
        public List<GameQuest> quests = new();
        public string curMission = "e0m0";
    }
    public class Account
    {
        public string id;
        public string username;
        public string token;
        public string grantToken;

        public static string GenerateAccountId()
        {
            byte[] bytes = new byte[4];
            RandomNumberGenerator.Fill(bytes);

            // Converte i byte in un intero positivo tra 100000000 e 999999999
            int number = BitConverter.ToInt32(bytes, 0) & int.MaxValue;
            number = 100000000 + (number % 900000000);

            return number.ToString();
        }
    }
    public class Database
    {
        private readonly IMongoDatabase _database;

        public Database(string connectionString, string dbName)
        {
            var client = new MongoClient(connectionString);
            
            _database = client.GetDatabase(dbName);
        }
        public List<Mail> LoadMails(ulong roleId)
        {
            return _database.GetCollection<Mail>("mails").Find(c => c.owner == roleId).ToList();
        }
        public MissionData LoadMissionData(ulong roleId)
        {
            return _database.GetCollection<MissionData>("missionsData").Find(c => c.roleId == roleId).FirstOrDefault();
        }
        public List<Character> LoadCharacters(ulong roleId)
        {
            return _database.GetCollection<Character>("avatars").Find(c=>c.owner== roleId).ToList();
        }
        public List<SpaceshipChar> LoadSpaceshipChars(ulong roleId)
        {
            return _database.GetCollection<SpaceshipChar>("spaceship_chars").Find(c => c.owner == roleId).ToList();
        }
        public List<SpaceshipRoom> LoadSpaceshipRooms(ulong roleId)
        {
            return _database.GetCollection<SpaceshipRoom>("spaceship_rooms").Find(c => c.owner == roleId).ToList();
        }
        
        public List<Item> LoadInventoryItems(ulong roleId)
        {
            return _database.GetCollection<Item>("items").Find(c => c.owner == roleId).ToList();
        }
        public void AddGachaTransaction(GachaTransaction transaction)
        {
            if (transaction._id == ObjectId.Empty)
            {
                transaction._id = ObjectId.GenerateNewId();
            }
            var collection = _database.GetCollection<GachaTransaction>("gachas");
            //These transactions never need to be changed
            collection.InsertOne(transaction);
        }
        public List<GachaTransaction> LoadGachaTransaction(ulong roleId, string templateId)
        {
            return _database.GetCollection<GachaTransaction>("gachas").Find(c => c.ownerId== roleId && c.gachaTemplateId==templateId).ToList();
        }
        public static string GenerateToken(int length)
        {
            const string chars = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
            Random random = new Random();
            StringBuilder result = new StringBuilder(length);

            for (int i = 0; i < length; i++)
            {
                result.Append(chars[random.Next(chars.Length)]);
            }

            return result.ToString();
        }
        public void SavePlayerData(Player player)
        {
            PlayerData data = new()
            {
                accountId = player.accountId,
                curSceneNumId = player.curSceneNumId,
                level = player.level,
                nickname = player.nickname,
                position = player.position,
                rotation = player.rotation,
                roleId = player.roleId,
                teams = player.teams,
                xp = player.xp,
                totalGuidCount = player.random.v,
                teamIndex = player.teamIndex,
                unlockedSystems = player.unlockedSystems,
                maxDashEnergy = player.maxDashEnergy,
                curStamina = player.curStamina,
                nextRecoverTime = player.nextRecoverTime,
                noSpawnAnymore = player.noSpawnAnymore,
                scenes=player.sceneManager.scenes,
                bitsets=player.bitsetManager.bitsets,
                savedSafeZone = player.savedSaveZone,
                gender=player.gender,
                bag=player.inventoryManager.items.bag
            };
            UpsertPlayerData(data);
        }
        public (string,int) CreateAccount(string username)
        {
            Account exist = GetAccountByUsername(username);
            if (exist != null)
            {
                Logger.Print($"Cannot created account with username: {username} beecause it already exist.");
                return ($"Cannot created account with username: {username} beecause it already exist.",1);
            }
            Account account = new()
            {
                username = username,
                id = Account.GenerateAccountId(),
                token= GenerateToken(22),
                grantToken = GenerateToken(192)
            };
            UpsertAccount(account);
            Logger.Print($"Account with username: {username} created with Account UID: {account.id}");
            return ($"Account with username: {username} created with Account UID: {account.id}",0);
        }
        public void UpsertPlayerData(PlayerData player)
        {
            var collection = _database.GetCollection<PlayerData>("players");

            var filter = 
                Builders<PlayerData>.Filter.Eq(p => p.roleId,player.roleId)
                &
                Builders<PlayerData>.Filter.Eq(p => p.accountId, player.accountId);

            collection.ReplaceOne(
                filter,
                player,
                new ReplaceOptions { IsUpsert = true }
            );
        }
        public void UpsertMissionData(MissionData data)
        {
            var collection = _database.GetCollection<MissionData>("missionsData");

            var filter =
                Builders<MissionData>.Filter.Eq(p => p.roleId, data.roleId);

            collection.ReplaceOne(
                filter,
                data,
                new ReplaceOptions { IsUpsert = true }
            );
        }
        public void UpsertAccount(Account player)
        {
            var collection = _database.GetCollection<Account>("accounts");

            var filter =
                Builders<Account>.Filter.Eq(p => p.id, player.id)
                &
                Builders<Account>.Filter.Eq(p => p.token, player.token);

           collection.ReplaceOne(
                filter,
                player,
                new ReplaceOptions { IsUpsert = true }
            );
        }
        public void UpsertSpaceshipChar(SpaceshipChar character)
        {
            if (character._id == ObjectId.Empty)
            {
                character._id = ObjectId.GenerateNewId();
            }
            var collection = _database.GetCollection<SpaceshipChar>("spaceship_chars");

            var filter =
                Builders<SpaceshipChar>.Filter.Eq(c => c.id, character.id)
                &
                Builders<SpaceshipChar>.Filter.Eq(c => c.owner, character.owner);

            var result = collection.ReplaceOne(
                filter,
                character,
                new ReplaceOptions { IsUpsert = true }
            );
        }
        public void UpsertSpaceshipRoom(SpaceshipRoom room)
        {
            if (room._id == ObjectId.Empty)
            {
                room._id = ObjectId.GenerateNewId();
            }
            var collection = _database.GetCollection<SpaceshipRoom>("spaceship_rooms");

            var filter =
                Builders<SpaceshipRoom>.Filter.Eq(c => c.id, room.id)
                &
                Builders<SpaceshipRoom>.Filter.Eq(c => c.owner, room.owner);

            var result = collection.ReplaceOne(
                filter,
                room,
                new ReplaceOptions { IsUpsert = true }
            );
        }
        public void UpsertCharacter(Character character)
        {
            if (character._id == ObjectId.Empty)
            {
                character._id = ObjectId.GenerateNewId();
            }
            var collection = _database.GetCollection<Character>("avatars");

            var filter = 
                Builders<Character>.Filter.Eq(c => c.guid, character.guid)
                &
                Builders<Character>.Filter.Eq(c => c.owner, character.owner);

            var result=collection.ReplaceOne(
                filter,
                character,
                new ReplaceOptions { IsUpsert = true }
            );
        }
        public void UpsertMail(Mail mail)
        {
            if (mail._id == ObjectId.Empty)
            {
                mail._id = ObjectId.GenerateNewId();
            }
            var collection = _database.GetCollection<Mail>("mails");

            var filter =
                Builders<Mail>.Filter.Eq(c => c.guid, mail.guid)
                &
                Builders<Mail>.Filter.Eq(c => c.owner, mail.owner);

            var result = collection.ReplaceOne(
                filter,
                mail,
                new ReplaceOptions { IsUpsert = true }
            );
        }
        public void UpsertItem(Item item)
        {
            if (item._id == ObjectId.Empty)
            {
                item._id = ObjectId.GenerateNewId();
            }
            var collection = _database.GetCollection<Item>("items");

            var filter =
                Builders<Item>.Filter.Eq(c => c.guid, item.guid)
                &
                Builders<Item>.Filter.Eq(c => c.owner, item.owner);

            var result = collection.ReplaceOne(
                filter,
                item,
                new ReplaceOptions { IsUpsert = true }
            );

        }
        public void DeleteItem(Item item)
        {
            
            var collection = _database.GetCollection<Item>("items");

            var filter =
                Builders<Item>.Filter.Eq(c => c.guid, item.guid)
                &
                Builders<Item>.Filter.Eq(c => c.owner, item.owner);

            var result = collection.DeleteOne(
                filter
            );
        }
        public void DeleteCharacter(Character character)
        {
            
            var collection = _database.GetCollection<Character>("avatars");

            var filter =
                Builders<Character>.Filter.Eq(c => c.guid, character.guid)
                &
                Builders<Character>.Filter.Eq(c => c.owner, character.owner);

            var result = collection.DeleteOne(
                filter
            );
        }
        public string GrantCode(Account account)
        {
            account.grantToken = GenerateToken(192);
            UpsertAccount(account);
            return account.grantToken;
        }
        public Account GetAccountByToken(string token)
        {
            try
            {
                return _database.GetCollection<Account>("accounts").Find(p => p.token == token).ToList().FirstOrDefault();
            }
            catch (Exception e)
            {
                Logger.PrintError("Error: " + e.Message);
                return null;
            }
        }
        public Account GetAccountByTokenGrant(string token)
        {
            try
            {
                return _database.GetCollection<Account>("accounts").Find(p => p.grantToken == token).ToList().FirstOrDefault();
            }
            catch (Exception e)
            {
                Logger.PrintError("Error: " + e.Message);
                return null;
            }
        }
        public Account GetAccountByUsername(string username)
        {
            try
            {
                return _database.GetCollection<Account>("accounts").Find(p => p.username == username).ToList().FirstOrDefault();
            }
            catch (Exception e)
            {
                Logger.PrintError("Error: "+e.Message);
                return null;
            }
        }
        public PlayerData GetPlayerById(string id)
        {
            try
            {
                return _database.GetCollection<PlayerData>("players").Find(p => p.accountId == id).ToList().FirstOrDefault();
            }
            catch(Exception e)
            {
                Logger.PrintError("Error occured while loading Player with account id: " + id+" ERROR:\n"+e.Message);
                return null;
            }
        }


    }
}