using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data.SqlClient;

namespace TCPserver
{
    class UpitZaBazu
    {
        private string identitetPoruke;
        private string poruka;
        private string[] elementiPoruke;
        private string upit;
        SqlDataReader reader;


        public UpitZaBazu(string item, string poruka)
        {
            identitetPoruke = item;
            this.poruka = poruka;
        }

        public List<string> dohvatiElementeIzPoruke()

        {
            List<string> result = new List<string>();
            if (identitetPoruke == "LOGIN")
            {
                result = StvoriLoginUpit();
                return result;
            }

            if (identitetPoruke == "REGISTER")
            {
                result = StvoriRegisterUpit();
                return result;
            }
            return result;
        }

        private List<string> StvoriLoginUpit()
        {
            List<string> podaciKorisnik = new List<string>();
            elementiPoruke = poruka.Split(',');
            upit = "Select * from Korisnici where username = '" + elementiPoruke[1] + "' and password = '" + elementiPoruke[2] + "'";
            Baza.OtvaranjeKonekcijeSBazom();
            reader = Baza.IzvrsavanjeUpita(upit);
            if (reader.HasRows)
            {
                while (reader.Read())
                {
                    Console.WriteLine("Podaci o uspjesnoj prijavi: ");
                    Console.WriteLine("{0}\t{1}", reader.GetString(0),
                        reader.GetString(1));
                    for (int i = 0; i < reader.FieldCount; i++)
                    {
                        podaciKorisnik.Add(reader[i].ToString());
                    }
                }
            }
            else
            {
                Console.WriteLine("Neuspjesna prijava");
            }

            return podaciKorisnik;
        }
    }
}