using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using TumblrSpammer.Tumblr;
using System.Threading.Tasks;

namespace TumblrSpammer
{
    class TumblrSpammer
    {

        private TextWriter urlsWriter;
        private TextWriter emailsWriter;

        private int done = 0;

        public TumblrSpammer()
        {
            Action<object> doWork = (object obj) =>
            {

                WorkerPreferences prefs = (WorkerPreferences)obj;

                try
                {
                    TumblrAccount account = new TumblrAccount();

                    if (account.Login(prefs.Email, prefs.Password))
                    {
                        Console.WriteLine("Successfully logged into " + prefs.Email + " posting..");
                        account.PostText(prefs.Msg.Title, prefs.Msg.Body, prefs.Msg.Tags);

                        lock (urlsWriter)
                        {
                            urlsWriter.WriteLine(account.TumblrURL);
                            urlsWriter.Flush();
                        }

                        // snag them mobile emails
                        foreach (string email in account.GetMobileEmails())
                        {
                            lock (emailsWriter)
                            {
                                emailsWriter.WriteLine(email);
                            }
                        }

                        lock (emailsWriter)
                        {
                            emailsWriter.Flush();
                        }

                    }
                    else
                    {
                        Console.WriteLine("login on account "+prefs.Email+" failed! wrong username / password");
                    }
                }
                catch (Exception e)
                {
                    Console.WriteLine("Couldn't post on account "+prefs.Email+" due to error.");
                }

                done++;

            };

            urlsWriter = new StreamWriter("urls.txt");
            emailsWriter = new StreamWriter("emails.txt");

            string row;
            string[] parts;
            TextReader tr = new StreamReader("accounts.txt");

            Message[] msgs = Messages.GetMessages();

            Random r = new Random();

            int total = 0;
            while ((row = tr.ReadLine()) != null)
            {
                parts = row.Split(':');
                if (parts.Length < 2) continue;

                WorkerPreferences prefs = new WorkerPreferences();
                prefs.Email = parts[0];
                prefs.Password = parts[1];

                prefs.Msg = msgs[r.Next(0, msgs.Length)];

                Task.Factory.StartNew(doWork, prefs);
                total++;
            }

            // block until done
            while (done != total) continue;

            Console.WriteLine("Done Nigguh");

            emailsWriter.Close();
            urlsWriter.Close();

            tr.Close();

        }

    }

}