/**
 * @file src/megacmdcommonutils.cpp
 * @brief MEGAcmd: Auxiliary methods
 *
 * (c) 2013 by Mega Limited, Auckland, New Zealand
 *
 * This file is part of the MEGAcmd.
 *
 * MEGAcmd is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 *
 * @copyright Simplified (2-clause) BSD License.
 *
 * You should have received a copy of the license along with this
 * program.
 */

#include "megacmdcommonutils.h"

#ifdef _WIN32
#include <Shlwapi.h> //PathAppend
#include <Shellapi.h> //CommandLineToArgvW
#include <windows.h> //GetUserName
#include <Lmcons.h> //UNLEN
#else
#include <sys/ioctl.h> // console size
#include <sys/socket.h>
#include <sys/un.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#endif

#include <cstring>
#include <iomanip>
#include <fstream>
#include <string.h>
#include <algorithm>
#include <sstream>
#include <limits.h>
#include <iterator>

#include <regex> //split
#include <random>

namespace megacmd {
using namespace std;

std::string errorCodeStr(const std::error_code& ec)
{
    return ec ? "(error: " + ec.message() + ")" : "";
}

bool canWrite(string path)
{
#ifdef _WIN32
    // TODO: Check permissions
    return true;
#else
    if (access(path.c_str(), W_OK) == 0)
    {
        return true;
    }
    return false;
#endif
}

bool isPublicLink(const string &link)
{
    //Old format:
    //https://mega.nz/#!ph!key
    //https://mega.nz/#F!ph!key

    //new format:
    //https://mega.nz/file/ph#key
    //https://mega.nz/folder/ph#key
    if (( link.find("http") == 0 ) && ( link.find("#") != string::npos || link.find("/file/") != string::npos || link.find("/folder/") != string::npos))
    {
        return true;
    }
    return false;
}

bool isEncryptedLink(string link)
{
    if (( link.find("http") == 0 ) && ( link.find("#") != string::npos ) && (link.substr(link.find("#"),3) == "#P!") )
    {
        return true;
    }
    return false;
}

string getPublicLinkHandle(const string &link)
{
    size_t posFolder = string::npos;
    size_t posLastSep = link.rfind("?");
    if (posLastSep == string::npos )
    {
        string rest = link;
        int count = 0;
        size_t posExc = rest.find_first_of("!");
        while ( posExc != string::npos && (posExc +1) < rest.size())
        {
            count++;
            if (count <= 3 )
            {
                posLastSep += posExc + 1;
            }

            rest = rest.substr(posExc + 1);
            posExc = rest.find("!");
        }

        if (count != 3)
        {
            posLastSep = string::npos;
        }
    }

    if (posLastSep == string::npos )
    {
        posFolder = link.find("/folder/");
    }

    if (posFolder != string::npos)
    {
        posLastSep = link.rfind("/file/");
        if (posLastSep != string::npos)
        {
            posLastSep += strlen("/file/")-1;
        }
        else
        {
            posLastSep = link.rfind("/folder/");
            if (posLastSep != string::npos && posFolder != posLastSep)
            {
                posLastSep += strlen("/folder/")-1;
            }
            else
            {
                return string();
            }
        }
    }

    if (( posLastSep == string::npos ) || !( posLastSep + 1 < link.length()))
    {
        return string();
    }
    else
    {
        return link.substr(posLastSep+1);
    }
}

string getPublicLinkObjectId(const string &link)
{
//    current format:
//    https://mega.nz/#!ph!key
//    https://mega.nz/#F!ph!key
//    https://mega.nz/#F!ph!key!handle (folder inside a folder link)
//    https://mega.nz/#F!ph!key?handle (file inside a folder link)

//    new format:
//    https://mega.nz/file/ph#key
//    https://mega.nz/folder/ph#key
//    https://mega.nz/folder/ph#key/folder/handle (folder inside a folder link)
//    https://mega.nz/folder/ph#key/file/handle (file inside a folder link)


    size_t postBeginingOfPH = string::npos;
    string remmaining;
    const char *sep;

    enum typeOfSeparator { NEWFOLDER, NEWFILE, OLDFOLDER, OLDFILE };
    auto separators = {"/folder/", "/file/", "#F!", "#!"};
    int iSeparator = 0;
    for (auto &w : separators)
    {
        postBeginingOfPH = link.find(w);
        if (postBeginingOfPH != string::npos)
        {
            postBeginingOfPH += strlen(w);
            sep = w;

            break;
        }
        iSeparator++;
    }
    if (postBeginingOfPH == string::npos)
    {
        return string();
    }

    remmaining = link.substr(postBeginingOfPH);

    size_t postEndOfPH = string::npos;
    for (auto &w : {"#", "/", "!"})
    {
        postEndOfPH = remmaining.find(w);
        if (postEndOfPH != string::npos)
        {
            postEndOfPH += strlen(w);
            sep = w;
            break;
        }
    }

    if (postEndOfPH == string::npos || postEndOfPH == 0)
    {
        return remmaining;
    }


    string ph = remmaining.substr(0, postEndOfPH - 1);

    string handle;

    if (postEndOfPH >= remmaining.size())
    {
        return ph;
    }

    remmaining = remmaining.substr(postEndOfPH - 1);


    size_t postBeginingOfHandle = string::npos;
    if (iSeparator == NEWFOLDER || iSeparator == NEWFILE)
    {

        for (auto &w : {"/folder/", "/file/"})
        {
            postBeginingOfHandle = remmaining.find(w);
            if (postBeginingOfHandle != string::npos)
            {
                postBeginingOfHandle += strlen(w);
                handle = remmaining.substr(postBeginingOfHandle);
                break;
            }
        }
    }
    else //old style
    {
        //  remmaining could be:
        //  !key!handle (folder inside a folder link)
        //  !key?handle (file inside a folder link)
        size_t posLastSep = remmaining.rfind("?"); //for folder handles we just check for ? presence

        if (posLastSep == string::npos ) // for file handles, we ensure there are 2 extra !
        {
            string rest = remmaining;
            int count = 0;
            size_t posExc = rest.find("!");
            while ( posExc != string::npos && (posExc +1) < rest.size())
            {
                count++;
                if (count <= 2 )
                {
                    posLastSep += posExc + 1;
                }

                rest = rest.substr(posExc + 1);
                posExc = rest.find("!");
            }

            if (count != 2)
            {
                posLastSep = string::npos;
            }
        }

        if (( posLastSep != string::npos ) && ( posLastSep + 1 < remmaining.size()))
        {
            handle = remmaining.substr(posLastSep+1);

        }
    }


    if (handle.empty())
    {
        return ph;
    }
    else
    {
        return ph.append("_").append(handle);
    }
}
bool hasWildCards(string &what)
{
    return what.find('*') != string::npos || what.find('?') != string::npos;
}


string generateRandomAlphaNumericString(size_t len)
{
    static const std::string alphabet =
        "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
        "abcdefghijklmnopqrstuvwxyz"
        "0123456789";

    thread_local static std::mt19937 generator(std::random_device{}());
    thread_local static std::uniform_int_distribution<> distribution(0, alphabet.size() - 1);

    std::string randomString;
    randomString.reserve(len);
    for (size_t i = 0; i < len; ++i)
    {
        randomString += alphabet[distribution(generator)];
    }
    return randomString;
}

std::vector<std::string> split(const std::string& input, const std::string& pattern)
{
    size_t start = 0, end;
    std::vector<std::string> tokens;

    if (input.size())
    {
        if (pattern.size())
        {
            do
            {
                end = input.find(pattern, start);
                std::string token = input.substr(start, end - start);
                if (token.size())
                {
                    tokens.push_back(token);
                }
                start = end + pattern.size();

            } while (end != std::string::npos);
        }
        else
        {
            tokens.push_back(input);
        }
    }
    return tokens;
}

long long charstoll(const char *instr)
{
  long long retval;

  retval = 0;
  for (; *instr; instr++) {
    retval = 10*retval + (*instr - '0');
  }
  return retval;
}

std::string &ltrim(std::string &s, const char &c)
{
    size_t pos = s.find_first_not_of(c);
    s = s.substr(pos == string::npos ? s.length() : pos, s.length());
    return s;
}

std::string_view ltrim(const std::string_view s, const char &c)
{
    size_t pos = s.find_first_not_of(c);
    return s.substr(pos == std::string::npos ? s.size() : pos, s.length());
}

std::string &rtrim(std::string &s, const char &c)
{
    size_t pos = s.find_last_of(c);
    size_t last = pos == string::npos ? s.length() : pos;
    if (last + 1 < s.length())
    {
        if (s.at(last + 1) != c)
        {
            last = s.length();
        }
    }

    s = s.substr(0, last);
    return s;
}

string removeTrailingSeparators(string &path)
{
    return rtrim(rtrim(path,'/'),'\\');
}

vector<string> getlistOfWords(const char *ptr, bool escapeBackSlashInCompletion, bool ignoreTrailingSpaces)
{
    vector<string> words;

    const char* wptr = "";

    // split line into words with quoting and escaping
    for (;; )
    {
        // skip leading blank space
        while (*(const signed char*)ptr > 0 && *ptr <= ' ' && (ignoreTrailingSpaces || *(ptr+1)))
        {
            ptr++;
        }

        if (!*ptr)
        {
            break;
        }

        // quoted arg / regular arg
        if (*ptr == '"')
        {
            ptr++;
            wptr = ptr;
            words.push_back(string());

            for (;; )
            {
                if (( *ptr == '"' ) || ( *ptr == '\\' ) || !*ptr)
                {
                    words[words.size() - 1].append(wptr, ptr - wptr);

                    if (!*ptr || ( *ptr++ == '"' ))
                    {
                        break;
                    }

                    wptr = ptr - 1;
                }
                else
                {
                    ptr++;
                }
            }
        }
        else if (*ptr == '\'') // quoted arg / regular arg
        {
            ptr++;
            wptr = ptr;
            words.push_back(string());

            for (;; )
            {
                if (( *ptr == '\'' ) || ( *ptr == '\\' ) || !*ptr)
                {
                    words[words.size() - 1].append(wptr, ptr - wptr);

                    if (!*ptr || ( *ptr++ == '\'' ))
                    {
                        break;
                    }

                    wptr = ptr - 1;
                }
                else
                {
                    ptr++;
                }
            }
        }
        else
        {
            while (*ptr == ' ') ptr++;// only possible if ptr+1 is the end

            wptr = ptr;

            const char *prev = ptr;
            //while ((unsigned char)*ptr > ' ')
            while ((*ptr != '\0') && !(*ptr ==' ' && *prev !='\\'))
            {
                if (*ptr == '"' && *(ptr+1) != '\0') // if quote is found, look for the ending quote
                {
                    do
                    {
                        ++ptr;
                    } while (*ptr != '"' && *(ptr+1) != '\0');
                }
                prev = ptr;
                ptr++;
            }
            words.emplace_back(wptr, ptr - wptr);
        }
    }

    if (escapeBackSlashInCompletion && words.size()> 1 && words[0] == "completion")
    {
        for (int i = 1; i < (int)words.size(); i++)
        {
            replaceAll(words[i],"\\","\\\\");
        }
    }

    return words;
}

bool stringcontained(const char * s, vector<string> list)
{
    for (int i = 0; i < (int)list.size(); i++)
    {
        if (list[i] == s)
        {
            return true;
        }
    }

    return false;
}

char * dupstr(char* s)
{
    char *r;

    r = (char*)malloc(sizeof( char ) * ( strlen(s) + 1 ));
    strcpy(r, s);
    return( r );
}

bool replace(std::string& str, const std::string& from, const std::string& to)
{
    size_t start_pos = str.find(from);
    if (start_pos == std::string::npos)
    {
        return false;
    }
    str.replace(start_pos, from.length(), to);
    return true;
}

void replaceAll(std::string& str, const std::string& from, const std::string& to)
{
    if (from.empty())
    {
        return;
    }
    size_t start_pos = 0;
    while (( start_pos = str.find(from, start_pos)) != std::string::npos)
    {
        str.replace(start_pos, from.length(), to);
        start_pos += to.length();
    }
}

int toInteger(string what, int failValue)
{
    if (what.empty())
    {
        return failValue;
    }
    if (!isdigit(what[0]) && !( what[0] != '-' ) && ( what[0] != '+' ))
    {
        return failValue;
    }

    char * p;
    long l = strtol(what.c_str(), &p, 10);

    if (*p != 0)
    {
        return failValue;
    }

    if (( l < INT_MIN ) || ( l > INT_MAX ))
    {
        return failValue;
    }
    return (int)l;
}

string joinStrings(const vector<string>& vec, const char* delim, bool quoted)
{
    stringstream res;
    if (!quoted)
    {
        std::copy(vec.begin(), vec.end(), ostream_iterator<string>(res, delim));
    }
    else
    {
        for(vector<string>::const_iterator i = vec.begin(); i != vec.end(); ++i)
        {
            res << "\"" << *i << "\"" << delim;
        }
    }
    if (vec.size()>1)
    {
        string toret = res.str();
        return toret.substr(0,toret.size()-strlen(delim));
    }
    return res.str();
}

unsigned int getstringutf8size(const string &str) {
    int c,i,ix,q;
    for (q=0, i=0, ix=int(str.length()); i < ix; i++, q++)
    {
        c = (unsigned char) str[i];

        if (c>=0 && c<=127) i+=0;
        else if ((c & 0xE0) == 0xC0) i+=1;
#ifdef _WIN32
        else if ((c & 0xF0) == 0xE0) i+=2;
#else
        else if ((c & 0xF0) == 0xE0)
        {
            if ((i+2)>ix || c != 0xE2 || (strncmp(&str.c_str()[i],"\u21f5",3)
                    && strncmp(&str.c_str()[i],"\u21d3",3) && strncmp(&str.c_str()[i],"\u21d1",3) ) )
            { //known 1 character gliphs
                q++;
            }
            i+=2;
        } //these gliphs may occupy 2 characters! Problem: not always. Let's assume the worse
#endif
        else if ((c & 0xF8) == 0xF0) i+=3;
        else return 0;//invalid utf8
    }
    return q;
}

string getFixLengthString(const string &origin, unsigned int size, const char delim, bool alignedright)
{
    string toret;
    size_t printableSize = getstringutf8size(origin);
    size_t bytesSize = origin.size();
    if (printableSize <= size){
        if (alignedright)
        {
            toret.insert(0,size-printableSize,delim);
            toret.insert(size-bytesSize,origin,0,bytesSize);

        }
        else
        {
            toret.insert(0,origin,0,bytesSize);
            toret.insert(bytesSize,size-printableSize,delim);
        }
    }
    else
    {
        toret.insert(0,origin,0,(size+1)/2-2);
        if (size > 3) toret.insert((size+1)/2-2,3,'.');
        if (size > 1) toret.insert((size+1)/2+1,origin,bytesSize-(size)/2+1,(size)/2-1); //TODO: This could break characters if multibyte!  //alternative: separate in multibyte strings and print one by one?
    }

    return toret;
}

string getRightAlignedString(const string origin, unsigned int minsize)
{
    ostringstream os;
    os << std::setw(minsize) << origin;
    return os.str();
}

bool startsWith(const std::string_view str, const std::string_view prefix)
{
    return str.rfind(prefix, 0) == 0;
}

string toLower(const std::string& str)
{
    std::string lower = str;
    for (char& c : lower)
    {
        c = std::tolower(c);
    }
    return lower;
}

template <typename Stream_T>
void printCenteredLine(Stream_T &os, string msj, unsigned int width, bool encapsulated)
{
    unsigned int msjsize = getstringutf8size(msj);
    bool overflowed = false;
    if (msjsize>width)
    {
        overflowed = true;
        width = unsigned(msjsize);
    }
    if (encapsulated && !overflowed)
        os << "|";
    for (unsigned int i = 0; i < (width-msjsize)/2; i++)
        os << " ";
    os << msj;
    for (unsigned int i = 0; i < (width-msjsize)/2 + (width-msjsize)%2 ; i++)
        os << " ";
    if (encapsulated && !overflowed)
        os << "|";
    os << endl;
}

// Instantiate those that can be used:
template void printCenteredLine<OUTSTREAMTYPE>(OUTSTREAMTYPE &os, string msj, unsigned int width, bool encapsulated);
template void printCenteredLine<std::ostringstream>(std::ostringstream &os, string msj, unsigned int width, bool encapsulated);

void printCenteredContents(OUTSTREAMTYPE &os, string msj, unsigned int width, bool encapsulated)
{
     string headfoot = " ";
     headfoot.append(width, '-');
     //unsigned int msjsize = getstringutf8size(msj);

     bool printfooter = false;

     if (msj.size())
     {
         string header;
         if (msj.at(0) == '<')
         {
             size_t possenditle = msj.find(">");
             if (width >= 2 && possenditle < (width -2))
             {
                 header.append(" ");
                 header.append((width - possenditle ) / 2, '-');
                 header.append(msj.substr(0,possenditle+1));
                 header.append(width - getstringutf8size(header) + 1, '-');
                 msj = msj.substr(possenditle + 1);
             }
         }
         if (header.size() || encapsulated)
         {
             os << (header.size()?header:headfoot) << endl;
             printfooter = true;
         }
     }

     size_t possepnewline = msj.find("\n");
     size_t possep = msj.find(" ");

     if (possepnewline != string::npos && possepnewline < width)
     {
         possep = possepnewline;
     }
     size_t possepprev = possep;


     while (msj.size())
     {

         if (possepnewline != string::npos && possepnewline <= width)
         {
             possep = possepnewline;
             possepprev = possep;
         }
         else
         {
             while (possep < width && possep != string::npos)
             {
                 possepprev = possep;
                 possep = msj.find_first_of(" ", possep+1);
             }
         }

         if (possepprev == string::npos || (possep == string::npos && msj.size() <= width))
         {
             printCenteredLine(os, msj, width, encapsulated);
             break;
         }
         else
         {
             printCenteredLine(os, msj.substr(0,possepprev), width, encapsulated);
             if (possepprev < (msj.size() - 1))
             {
                 msj = msj.substr(possepprev + 1);
                 possepnewline = msj.find("\n");
                 possep = msj.find(" ");
                 possepprev = possep;
             }
             else
             {
                 break;
             }
         }
     }
     if (printfooter)
     {
         os << headfoot << endl;
     }
}

void printCenteredLine(string msj, unsigned int width, bool encapsulated)
{
    OUTSTRINGSTREAM os;
    printCenteredLine(os, msj, width, encapsulated);
#ifdef _WIN32
    WindowsUtf8StdoutGuard utf8Guard;
#endif
    COUT << os.str();
}

void printCenteredContents(string msj, unsigned int width, bool encapsulated)
{
    OUTSTRINGSTREAM os;
    printCenteredContents(os, msj, width, encapsulated);
#ifdef _WIN32
    WindowsUtf8StdoutGuard utf8Guard;
#else
    StdoutMutexGuard stdoutGuard;
#endif

    COUT << os.str();
}

void printCenteredContentsCerr(string msj, unsigned int width, bool encapsulated)
{
    OUTSTRINGSTREAM os;
    printCenteredContents(os, msj, width, encapsulated);
#ifdef _WIN32
    WindowsUtf8StdoutGuard utf8Guard;
#else
    StdoutMutexGuard stdoutGuard;
#endif
    CERR << os.str();
}

void printPercentageLineCerr(const char *title, long long completed, long long total, float percentDowloaded, bool cleanLineAfter)
{
    int cols = getNumberOfCols(80);

    string outputString;
    outputString.resize(cols + 1);
    for (int i = 0; i < cols; i++)
    {
        outputString[i] = '.';
    }

    outputString[cols] = '\0';
    char *ptr = (char *)outputString.c_str();
    sprintf(ptr, "%s%s", title, " ||");
    ptr += strlen(title);
    ptr += strlen(" ||");
    *ptr = '.'; //replace \0 char

    char aux[41];

    if (total < 1048576)
    {
        sprintf(aux,"||(%lld/%lld KB: %6.2f %%) ", completed / 1024, total / 1024, percentDowloaded);
    }
    else
    {
        sprintf(aux,"||(%lld/%lld MB: %6.2f %%) ", completed / 1024 / 1024, total / 1024 / 1024, percentDowloaded);
    }


    sprintf((char *)outputString.c_str() + cols - strlen(aux), "%s",                         aux);
    for (int i = 0; i < ( cols - (strlen(title) + strlen(" ||")) - strlen(aux)) * 1.0 * min(100.0f,percentDowloaded) / 100.0; i++)
    {
        *ptr++ = '#';
    }

#ifdef _WIN32
    WindowsUtf8StdoutGuard utf8Guard;
#else
    StdoutMutexGuard stdoutGuard;
#endif

     // TODO: should this be CERR ? (`\r`) may not behave as wanted
    if (cleanLineAfter)
    {
        cerr << outputString << '\r' << flush;
    }
    else
    {
        cerr << outputString << endl;
    }
}

int getFlag(const map<string, int> *flags, const char * optname)
{
    auto i = flags->find(optname);

    if (i != flags->end())
        return i->second;

    return 0;
}

string getOption(const map<string, string> *cloptions, const char * optname, string defaultValue)
{
    auto i = cloptions->find(optname);

    if (i != cloptions->end())
        return i->second;

    return defaultValue;
}

std::optional<string> getOptionAsOptional(const map<string, string>& cloptions, const char * optname)
{
    if (cloptions.find(optname) == cloptions.end())
    {
        return std::nullopt;
    }
    return cloptions.at(optname);
}

int getintOption(const map<string, string> *cloptions, const char * optname, int defaultValue)
{
    auto i = cloptions->find(optname);

    auto result = defaultValue;

    if (i != cloptions->end())
        istringstream(i->second) >> result;

    return result;
}

std::optional<int> getIntOptional(const std::map<std::string, std::string>& cloptions, const char* optName)
{
    auto it = cloptions.find(optName);
    if (it == cloptions.end())
    {
        return std::nullopt;
    }

    try
    {
        return std::stoi(it->second);
    }
    catch (...)
    {
        return std::nullopt;
    }
}

void discardOptionsAndFlags(vector<string> *ws)
{
    for (std::vector<string>::iterator it = ws->begin(); it != ws->end(); )
    {
        /* std::cout << *it; ... */
        string w = ( string ) * it;
        if (w.length() && ( w.at(0) == '-' )) //begins with "-"
        {
            it = ws->erase(it);
        }
        else //not an option/flag
        {
            ++it;
        }
    }
}

string sizeProgressToText(long long partialSize, long long totalSize, bool equalizeUnitsLength, bool humanreadable)
{
    ostringstream os;
    os.precision(2);
    if (humanreadable)
    {
        string unit;
        unit = ( equalizeUnitsLength ? " B" : "B" );
        double reducedPartSize = (double)totalSize;
        double reducedSize = (double)totalSize;

        if ( totalSize > 1099511627776LL *2 )
        {
            reducedPartSize = totalSize / (double) 1099511627776ull;
            reducedSize = totalSize / (double) 1099511627776ull;
            unit = "TB";
        }
        else if ( totalSize > 1073741824LL *2 )
        {
            reducedPartSize = totalSize / (double) 1073741824L;
            reducedSize = totalSize / (double) 1073741824L;
            unit = "GB";
        }
        else if (totalSize > 1048576 * 2)
        {
            reducedPartSize = totalSize / (double) 1048576;
            reducedSize = totalSize / (double) 1048576;
            unit = "MB";
        }
        else if (totalSize > 1024 * 2)
        {
            reducedPartSize = totalSize / (double) 1024;
            reducedSize = totalSize / (double) 1024;
            unit = "KB";
        }
        os << fixed << reducedPartSize << "/" << reducedSize;
        os << " " << unit;
    }
    else
    {
        os << partialSize << "/" << totalSize;
    }

    return os.str();
}

string sizeToText(long long totalSize, bool equalizeUnitsLength, bool humanreadable)
{
    ostringstream os;
    os.precision(2);
    if (humanreadable)
    {
        string unit;
        unit = ( equalizeUnitsLength ? " B" : "B" );
        double reducedSize = (double)totalSize;

        if ( totalSize > 1099511627776LL *2 )
        {
            reducedSize = totalSize / (double) 1099511627776ull;
            unit = "TB";
        }
        else if ( totalSize > 1073741824LL *2 )
        {
            reducedSize = totalSize / (double) 1073741824L;
            unit = "GB";
        }
        else if (totalSize > 1048576 * 2)
        {
            reducedSize = totalSize / (double) 1048576;
            unit = "MB";
        }
        else if (totalSize > 1024 * 2)
        {
            reducedSize = totalSize / (double) 1024;
            unit = "KB";
        }
        os << fixed << reducedSize;
        os << " " << (reducedSize == 0.0 ? " " : "") << unit;
    }
    else
    {
        os << totalSize;
    }

    return os.str();
}

int64_t textToSize(const char *text)
{
    int64_t sizeinbytes = 0;

    char * ptr = (char *)text;
    char * last = (char *)text;
    while (*ptr != '\0')
    {
        if (( *ptr < '0' ) || ( *ptr > '9' ) || ( *ptr == '.' ) )
        {
            switch (*ptr)
            {
                case 'b': //Bytes
                case 'B':
                    *ptr = '\0';
                    sizeinbytes += int64_t(atof(last));
                    break;

                case 'k': //KiloBytes
                case 'K':
                    *ptr = '\0';
                    sizeinbytes += int64_t(1024.0 * atof(last));
                    break;

                case 'm': //MegaBytes
                case 'M':
                    *ptr = '\0';
                    sizeinbytes += int64_t(1048576.0 * atof(last));
                    break;

                case 'g': //GigaBytes
                case 'G':
                    *ptr = '\0';
                    sizeinbytes += int64_t(1073741824.0 * atof(last));
                    break;

                case 't': //TeraBytes
                case 'T':
                    *ptr = '\0';
                    sizeinbytes += int64_t(1125899906842624.0 * atof(last));
                    break;

                default:
                {
                    return -1;
                }
            }
            last = ptr + 1;
        }
        char *prev = ptr;
        ptr++;
        if (*ptr == '\0' && ( ( *prev == '.' ) || ( ( *prev >= '0' ) && ( *prev <= '9' ) ) ) ) //reach the end with a number or dot
        {
            return -1;
        }
    }
    return sizeinbytes;

}

string percentageToText(float percentage)
{
    ostringstream os;
    os.precision(2);
    if (percentage != percentage) //NaN
    {
        os << "----%";
    }
    else
    {
        os << fixed << percentage*100.0 << "%";
    }

    return os.str();
}

unsigned int getNumberOfCols(unsigned int defaultwidth)
{
#ifdef _WIN32
    CONSOLE_SCREEN_BUFFER_INFO csbi;
    int columns = defaultwidth;

    if (GetConsoleScreenBufferInfo(GetStdHandle(STD_OUTPUT_HANDLE), &csbi))
    {
        columns = csbi.srWindow.Right - csbi.srWindow.Left - 1;
    }

    return columns;
#else
    struct winsize size;
    if ( ioctl(STDOUT_FILENO,TIOCGWINSZ,&size) != -1
         || (ioctl(STDIN_FILENO,TIOCGWINSZ,&size) != -1))
    {
        if (size.ws_col > 2)
        {
            return size.ws_col - 2;
        }
    }
    return defaultwidth;
#endif
}

void sleepSeconds(int seconds)
{
#ifdef _WIN32
    Sleep(1000*seconds);
#else
    sleep(seconds);
#endif
}

void sleepMilliSeconds(long milliseconds)
{
#ifdef _WIN32
    Sleep(milliseconds);
#else
    usleep(milliseconds *1000);
#endif
}

bool isValidEmail(string email)
{
    return !( (email.find("@") == string::npos)
                    || (email.find_last_of(".") == string::npos)
                    || (email.find("@") > email.find_last_of(".")));
}

#ifdef __linux__
std::string getCurrentExecPath()
{
    std::string path = ".";
    pid_t pid = getpid();
    char buf[20] = {0};
    sprintf(buf,"%d",pid);
    std::string _link = "/proc/";
    _link.append( buf );
    _link.append( "/exe");
    char proc[PATH_MAX];
    int ch = readlink(_link.c_str(),proc,PATH_MAX);
    if (ch != -1) {
        proc[ch] = 0;
        path = proc;
        std::string::size_type t = path.find_last_of("/");
        path = path.substr(0,t);
    }

    return path;
}
#endif

string &ltrimProperty(string &s, const char &c)
{
    size_t pos = s.find_first_not_of(c);
    s = s.substr(pos == string::npos ? s.length() : pos, s.length());
    return s;
}

string &rtrimProperty(string &s, const char &c)
{
    size_t pos = s.find_last_not_of(c);
    if (pos != string::npos)
    {
        pos++;
    }
    s = s.substr(0, pos);
    return s;
}

string &trimProperty(string &what)
{
    rtrimProperty(what,' ');
    ltrimProperty(what,' ');
    if (what.size() > 1)
    {
        if (what[0] == '\'' || what[0] == '"')
        {
            rtrimProperty(what, what[0]);
            ltrimProperty(what, what[0]);
        }
    }
    return what;
}

string getPropertyFromFile(const fs::path &configFilePath, const char *propertyName)
{
    ifstream infile(configFilePath);
    string line;

    while (getline(infile, line))
    {
        if (line.length() > 0 && line[0] != '#')
        {
            if (!strlen(propertyName)) //if empty return first line
            {
                return trimProperty(line);
            }
            string key, value;
            size_t pos = line.find("=");
            if (pos != string::npos && ((pos + 1) < line.size()))
            {
                key = line.substr(0, pos);
                rtrimProperty(key, ' ');

                if (!strcmp(key.c_str(), propertyName))
                {
                    value = line.substr(pos + 1);
                    return trimProperty(value);
                }
            }
        }
    }

    return string();
}

void ColumnDisplayer::endregistry()
{
    values.push_back(std::move(currentRegistry));
    currentlength = 0;
}

void ColumnDisplayer::setPrefix(const std::string &prefix)
{
    mPrefix = prefix;
}

void ColumnDisplayer::addHeader(const string &name, bool fixed, int minWidth)
{
    fields[name] = Field(name, fixed, minWidth);
}

void ColumnDisplayer::addValue(const string &name, const string &value, bool replace)
{
    int len = getstringutf8size(value);
    if (!replace)
    {
        if (currentRegistry.size() && currentRegistry.find(name) != currentRegistry.end())
        {
            endregistry();
        }
    }

    currentRegistry[name] = value;
    currentlength += len;
    if (fields.find(name) == fields.end())
    {
        addHeader(name, true);
    }
    if (find (mFieldnames.begin(), mFieldnames.end(), name) == mFieldnames.end())
    {
        mFieldnames.push_back(name);
    }

    fields[name].updateMaxValue(len);
}

ColumnDisplayer::ColumnDisplayer(std::map<std::string, int> *clflags, std::map<std::string, std::string> *cloptions)
    : mClflags(clflags), mCloptions(cloptions), mUnfixedColsMinSize(getintOption(cloptions,"path-display-size", 0))
{

}

OUTSTRING ColumnDisplayer::str(bool printHeader)
{
    OUTSTRINGSTREAM oss;
    print(oss, printHeader);
    return oss.str();
}

void ColumnDisplayer::printHeaders(OUTSTREAMTYPE &os)
{
    print(os, getintOption(mCloptions, "client-width", getNumberOfCols(75)), true, true);
}

void ColumnDisplayer::print(OUTSTREAMTYPE &os, bool printHeader)
{
    print(os, getintOption(mCloptions, "client-width", getNumberOfCols(75)), printHeader);
}

void ColumnDisplayer::print(OUTSTREAMTYPE &os, int fullWidth, bool printHeader, bool onlyHeaders)
{
    if (currentRegistry.size())
    {
        endregistry();
    }

    auto outputcols = getOption(mCloptions,"output-cols", "");

    decltype (mFieldnames) fieldnames;


    if (!outputcols.empty())
    {
        auto listofCols = split(outputcols, ",");
        for (auto el : listofCols)
        {
            auto it = find (mFieldnames.begin(), mFieldnames.end(), el);
            if (it != mFieldnames.end())
            {
                fieldnames.push_back(el);
            }
        }
    }
    else
    {
        fieldnames = mFieldnames;
    }

    auto colseparator = getOption(mCloptions,"col-separator", "");
    if (!colseparator.empty()) //col separator separated values
    {
        if (printHeader)
        {
            bool first = true;
            os << mPrefix;
            for (auto el : fieldnames)
            {
                Field &f = fields[el];
                if (!first)
                {
                    os << colseparator;
                }
                first = false;
                os << f.name;
            }
            os << std::endl;
        }

        if (!onlyHeaders)
        {
            for (auto &registry : values)
            {
                bool firstvalue = true;
                os << mPrefix;
                for (auto &el : fieldnames)
                {
                    Field &f = fields[el];
                    if (!firstvalue)
                    {
                        os << colseparator;
                    }
                    firstvalue = false;

                    if (registry.find(f.name) != registry.end())
                    {
                        os << registry[f.name];
                    }

                }
                os << std::endl;
            }
        }

        return;
    }


    int unfixedfieldscount = 0;
    int unfixedFieldsMaxLengthSum = 0;

    int leftWidth = fullWidth;
    vector<Field *> unfixedfields;
    for (auto &el : fields)
    {
        Field &f = el.second;
        if (f.fixedSize)
        {
            if (f.fixedWidth)
            {
                f.dispWidth = f.fixedWidth;
            }
            else
            {
                f.dispWidth = max((int)getstringutf8size(f.name),f.maxValueLength);
            }
            leftWidth-=(f.dispWidth + 1);
        }
        else
        {
            unfixedfieldscount++;
            unfixedfields.push_back(&f);
            unfixedFieldsMaxLengthSum+=f.maxValueLength;
        }
    }

    auto unfixedFieldsMaxLengthsLeft = unfixedFieldsMaxLengthSum;
    for (auto &f: unfixedfields)
    {
        unfixedFieldsMaxLengthsLeft -= f->maxValueLength;

        f->dispWidth = max(
                    (int)getstringutf8size(f->name), // min limit: header size
                    min( f->maxValueLength // max limit: its longest value
                         , max(mUnfixedColsMinSize, // min limit 2: the min limit for unfixed columns
                               max((leftWidth - unfixedfieldscount + 1)/(unfixedfieldscount), (leftWidth - unfixedfieldscount + 1 - unfixedFieldsMaxLengthsLeft)) //either an equitative share between all unfixedfields left, or all the space the other left me considering their maxLegnths
                               )
                        )
                    );
        leftWidth-=(f->dispWidth + 1);
        unfixedfieldscount--;
    }

    if (printHeader)
    {
        bool first = true;
        os << mPrefix;
        for (auto el : fieldnames)
        {
            Field &f = fields[el];
            if (!first)
            {
                os << " ";
            }
            first = false;
            os << getFixLengthString(f.name, f.dispWidth);
        }
        os << std::endl;
    }

    if (!onlyHeaders)
    {
        for (auto &registry : values)
        {
            bool firstvalue = true;
            os << mPrefix;
            for (auto &el : fieldnames)
            {
                Field &f = fields[el];
                if (!firstvalue)
                {
                    os << " ";
                }
                firstvalue = false;

                if (registry.find(f.name) != registry.end())
                {
                    os << getFixLengthString(registry[f.name], f.dispWidth);
                }
                else
                {
                    os << getFixLengthString("", f.dispWidth);
                }

            }
            os << std::endl;
        }
    }
}

void ColumnDisplayer::clear()
{
    *this = ColumnDisplayer(mClflags, mCloptions);
}

Field::Field()
{

}

Field::Field(string name, bool fixed, int minWidth) :name(name), fixedSize(fixed), fixedWidth(minWidth)
{
    if (fixed)
    {
        this->dispWidth = minWidth;
    }

}

void Field::updateMaxValue(int newcandidate)
{
    if (newcandidate > this->maxValueLength)
    {
        this->maxValueLength = newcandidate;
    }
}

std::unique_ptr<PlatformDirectories> PlatformDirectories::getPlatformSpecificDirectories()
{
#ifdef _WIN32
    return std::make_unique<WindowsDirectories>();
#elif defined(__APPLE__)
    return std::make_unique<MacOSDirectories>();
#else
    return std::make_unique<PosixDirectories>();
#endif
}

#ifdef _WIN32
fs::path WindowsDirectories::configDirPath()
{
    wchar_t szPath[MAX_PATH];

    if (GetModuleFileNameW(NULL, szPath, MAX_PATH) == 0)
    {
        return {};
    }

    fs::path folder = fs::path(szPath).parent_path() / ".megaCmd";

    auto suffix = _wgetenv(L"MEGACMD_WORKING_FOLDER_SUFFIX");
    if (suffix != nullptr)
    {
        folder += "_";
        folder += suffix;
    }

    folder = nonMaxPathLimitedPath(folder); // prepend //?/
    return folder;
}

std::wstring getNamedPipeName()
{
    std::wstring name = L"\\\\.\\pipe\\megacmdpipe_";
    wchar_t username[UNLEN + 1];
    DWORD username_len = UNLEN + 1;
    wchar_t *suffix;

    GetUserNameW(username, &username_len);
    name += username;

    suffix = _wgetenv(L"MEGACMD_PIPE_SUFFIX");
    if (suffix != nullptr)
    {
        name += L"_";
        name += suffix;
    }

    return name;
}
#else // !defined(_WIN32)
std::string PosixDirectories::homeDirPath()
{
    const char *homedir = getenv("HOME");
    if (homedir != nullptr)
    {
        return homedir;
    }

    struct passwd pwd = {};
    struct passwd *pwdresult = nullptr;
    long int bufsize = sysconf(_SC_GETPW_R_SIZE_MAX);
    bufsize = bufsize == -1 ? 1024 : bufsize;
    auto pwdbuf = std::unique_ptr<char[]>(new char[bufsize]);
    if (getpwuid_r(getuid(), &pwd, pwdbuf.get(), bufsize, &pwdresult))
    {
        std::cerr << "Warn: Could not get HOME folder from getpwuid_r. errno = " << errno << std::endl;
        return std::string();
    }
    return std::string(pwd.pw_dir);
}

fs::path PosixDirectories::configDirPath()
{
    std::string home = homeDirPath();
    if (home.empty())
    {
        return noHomeFallbackFolder();
    }

    struct stat path_stat = {};
    bool exists = !stat(home.c_str(), &path_stat) && S_ISDIR(path_stat.st_mode);

    return exists ? home.append("/.megaCmd") : noHomeFallbackFolder();
}

string PosixDirectories::noHomeFallbackFolder()
{
    return std::string("/tmp/megacmd-").append(std::to_string(getuid()));
}

#ifdef __APPLE__
fs::path MacOSDirectories::runtimeDirPath()
{
    std::string home = homeDirPath();
    if (home.empty())
    {
        // fallback to Posix:
        return PosixDirectories::runtimeDirPath();
    }

    auto cachesPath = std::string(home).append("/Library/Caches");
    struct stat path_stat = {};
    bool exists = !stat(cachesPath.c_str(), &path_stat) && S_ISDIR(path_stat.st_mode);

    return exists ? cachesPath.append("/megacmd.mac") : noHomeFallbackFolder();
}
#endif // !defined(__APPLE__)

std::string getOrCreateSocketPath(bool createDirectory)
{
    auto dirs = PlatformDirectories::getPlatformSpecificDirectories();
    auto socketFolder = dirs->runtimeDirPath();
    if (socketFolder.empty())
    {
        std::cerr << "FATAL: Could not get runtime folder for socket path" << std::endl;
        throw std::runtime_error("Could not get runtime folder for socket path");
    }

    const char *sockname_c = getenv("MEGACMD_SOCKET_NAME");
    std::string sockname = sockname_c != nullptr ? std::string(sockname_c) : "megacmd.socket";

    static auto MAX_SOCKET_PATH = sizeof(sockaddr_un::sun_path) / sizeof(decltype(sockaddr_un::sun_path[0]));

    if ((socketFolder.string().size() + 1 + sockname.size()) >= (MAX_SOCKET_PATH - 1))
    {
        if (createDirectory)
        {
            std::cerr << "WARN: socket path in runtime dir would exceed max size. Falling back to /tmp" << std::endl;
        }
        socketFolder = PosixDirectories::noHomeFallbackFolder();
    }

    struct stat path_stat = {};
    if (createDirectory)
    {
        bool exists = !stat(socketFolder.c_str(), &path_stat) && S_ISDIR(path_stat.st_mode);
        if (!exists && createDirectory)
        {
            mode_t mode = umask(0);
            bool failed = mkdir(socketFolder.c_str(), 0700) != 0;
            if (failed)
            {
                std::cerr << "Failed to create folder for unix socket: " << socketFolder << ": " << std::strerror(errno) << std::endl;
            }
            umask(mode);

            if (failed)
            {
                return std::string();
            }
        }
    }

    return (socketFolder / sockname).string();
}
#endif // ifdef(_WIN32) else
} //end namespace
