-- More information about this indicator can be found at:
-- http://fxcodebase.com/code/viewtopic.php?f=17&t=19572
-- Id: 6679

--+------------------------------------------------------------------+
--|                               Copyright © 2018, Gehtsoft USA LLC |
--|                                            http://fxcodebase.com |
--+------------------------------------------------------------------+
--|                                      Developed by : Mario Jemic  |
--|                                          mario.jemic@gmail.com   |
--+------------------------------------------------------------------+
--|                                 Support our efforts by donating  |
--|                                   Paypal: https://goo.gl/9Rj74e  |
--|                    Patreon : https://www.patreon.com/mariojemic  |
--|                    BitCoin : 15VCJTLaz12Amr7adHSBtL9v8XomURo9RF  |
--|               BitCoin Cash : 1BEtS465S3Su438Kc58h2sqvVvHK9Mijtg  |
--|           Ethereum : 0x8C110cD61538fb6d7A2B47858F0c0AaBd663068D  |
--|                   LiteCoin : LLU8PSY2vsq7B9kRELLZQcKf5nJQrdeqwD  |
--+------------------------------------------------------------------+

function Init()
    indicator:name("Horizontal line tool");
    indicator:description("");
    indicator:requiredSource(core.Tick);
    indicator:type(core.Indicator);

    indicator.parameters:addGroup("Style");
    indicator.parameters:addInteger("Size", "Label Size", "", 10, 1, 100);
    indicator.parameters:addColor("color", "Line Color", "", core.rgb(255, 0, 0));
    indicator.parameters:addColor("selected", "Selected Line Color", "", core.rgb(0, 0, 255));
    indicator.parameters:addColor("undefined", "Undefined Line Color", "", core.rgb(0, 0, 0));
    indicator.parameters:addInteger("width", "Line Width", "", 1, 1, 5);
    indicator.parameters:addInteger("style", "Line Style", "", core.LINE_SOLID);
    indicator.parameters:setFlag("style", core.FLAG_LINE_STYLE);

    indicator.parameters:addGroup("Alerts");
    indicator.parameters:addBoolean("PlaySound", "Play Sound", "", false);
    indicator.parameters:addFile("SoundFile", "Sound File", "", "");
    indicator.parameters:setFlag("SoundFile", core.FLAG_SOUND);
    indicator.parameters:addBoolean("RecurrentSound", "Recurrent Sound", "", false);

    indicator.parameters:addGroup("Email");
    indicator.parameters:addBoolean("SendEmail", "Send Email", "", false);
    indicator.parameters:addString("Email", "Email", "", "");
    indicator.parameters:setFlag("Email", core.FLAG_EMAIL);
end

-- Indicator instance initialization routine
-- Processes indicator parameters and creates output streams
-- TODO: Refine the first period calculation for each of the output streams.
-- TODO: Calculate all constants, create instances all subsequent indicators and load all required libraries
-- Parameters block

local first;
local source = nil;
local db;
local Size;
local pattern = "([^;]*);([^;]*)";
local Index = {};
local Count;
local Line = {};
local name;
local font;
local Last;
local Email;
local SendEmail;
local PlaySound, RecurrentSound, SoundFile  ;
local Alert;
local Out = {};
local Crossover = {};
local Crossunder = {};
local Plus = {};
local Minus = {};
-- Routine
function Prepare(nameOnly)
    source = instance.source;
    first = source:first();
    Size = instance.parameters.Size;

    SendEmail = instance.parameters.SendEmail;
    if SendEmail then
        Email = instance.parameters.Email;
    else
        Email = nil;
    end
    assert(not(SendEmail) or (SendEmail and Email ~= ""), "E-mail address must be specified");

    PlaySound = instance.parameters.PlaySound;
    if PlaySound then
        SoundFile = instance.parameters.SoundFile;
    else
        SoundFile = nil;
    end
    assert(not(PlaySound) or (PlaySound and SoundFile ~= ""), "Sound file must be chosen");
    RecurrentSound = instance.parameters.RecurrentSound;

    name = profile:id() .. "(" .. source:name() .. ")";
    instance:name(name);
    if nameOnly then
        return;
    end

    require("storagedb");
    db = storagedb.get_db(source:name());

    font = core.host:execute("createFont", "Arial", Size, true, false);

    core.host:execute("addCommand", 10, "New", "");
    core.host:execute("addCommand", 11, "Next", "");
    core.host:execute("addCommand", 12, "Previous", "");
    core.host:execute("addCommand", 13, "Delete", "");
    core.host:execute("addCommand", 14, "Reset", "");
    core.host:execute("addCommand", 15, "Select", "");
end

-- Indicator calculation routine
-- TODO: Add your code for calculation output values
function Update(period, mode)
    if period < source:size() - 1 then
        return;
    end
    core.host:execute("removeAll")
    local Count = db:get("Count", 0);
    local Cursor = tonumber(db:get("Cursor", 0));
    if Count ~= 0 then
        for i = 1, Count, 1 do
            local LevelOne = tonumber(db:get(tostring("LevelOne" .. i), 0));
            local color;
            if LevelOne == 0 then
                color = instance.parameters.undefined;
            elseif i == Cursor then
                color = instance.parameters.selected;
            else
                color = instance.parameters.color;
            end

            if Last ~= source:serial(period) then
                Last = source:serial(period);
                local j;
                for j = 1, Count, 1 do
                    Crossunder[j] = nil;
                    Crossover[j] = nil;
                end
            end

            local Text = tostring(i);
            core.host:execute("drawLabel1", i, -i * 20, core.CR_RIGHT, 50, core.CR_TOP, core.H_Left, core.V_Center, font, color, Text);
            if LevelOne ~= 0 then
               -- local First = core.findDate(source, DateOne, true)
                core.host:execute("drawLine", 100 + i, source:date(source:first()), LevelOne, source:date(source:size() - 1), LevelOne, color);
                if source[period] > LevelOne and source[period - 1] < LevelOne then
                    Crossunder[i] = nil;
                    if Crossover[i] ~= source:date(period) then
                        Crossover[i] = source:date(period);
                        SoundAlert();
                        EmailAlert("Cross Over");
                    end
                elseif source[period] < LevelOne and source[period - 1] > LevelOne then
                    Crossover[i] = nil;
                    if Crossunder[i] ~= source:date(period) then
                        Crossunder[i] = source:date(period);
                        SoundAlert();
                        EmailAlert("Cross Under");
                    end
                end
            end
        end
    end
end

function Parse(message)
    local level, date;
    level, date = string.match(message, pattern, 0);

    if level == nil or date == nil then
        return nil, nil;
    end

    return tonumber(date), tonumber(level);
end

function ReleaseInstance()
    core.host:execute("deleteFont", font);
end

function AsyncOperationFinished(cookie, success, message)
    local Date
    local Level
    Date, Level = Parse(message);
    if cookie == 10 then
        local Count = tonumber(db:get("Count", 0));
        local Count = tonumber(db:get("Count", 0));
        db:put("Count", tostring(Count + 1));
        db:put("Cursor", tostring(Count + 1));
    elseif cookie == 13 then
        local Cursor = tonumber(db:get("Cursor", 0));
        Delete(Cursor);
    elseif cookie == 11 then
        local Cursor = tonumber(db:get("Cursor", 0));
        local Count = tonumber(db:get("Count", 0));
        Cursor = Cursor + 1;
        if Cursor > Count then
            Cursor = Count;
        end
        db:put("Cursor", tostring(Cursor));
    elseif cookie == 12 then
        local Cursor = tonumber(db:get("Cursor", 0));
        Cursor = Cursor - 1;
        if Cursor < 1 then
            Cursor = 1;
        end
        db:put("Cursor", tostring(Cursor));
    elseif cookie == 14 then
        local Count = tonumber(db:get("Count", 0));
        local Cursor = tonumber(db:get("Cursor", 0));

        local i;
        for i = 1, Count, 1 do
            Delete(i);
        end
        db:put("Count", tostring(0));
        db:put("Cursor", tostring(0));

        Cursor = Cursor - 1

    elseif cookie == 15 then
        local Cursor = tonumber(db:get("Cursor", 0));
        db:put(tostring("LevelOne" .. Cursor), tostring(Level));
    end

    if cookie == 10 or cookie == 13 or cookie == 11 or cookie == 12 or cookie == 14 or cookie == 15 or cookie == 16 then
        instance:updateFrom(source:size() - 1);
        return core.ASYNC_REDRAW;
    end
end

function Delete(Cursor)
    db:put(tostring("LevelOne" .. Cursor), tostring(0));
end

function SoundAlert()
    terminal:alertSound(SoundFile, RecurrentSound);
end

function EmailAlert(Subject)
    if not SendEmail then
        return
    end
    local date = source:date(NOW);
    local DATA = core.dateToTable(date);
    local LABEL = DATA.month .. ", " .. DATA.day .. ", " .. DATA.hour .. ", " .. DATA.min .. ", " .. DATA.sec;
    terminal:alertEmail(Email, Subject, profile:id() .. "(" .. source:instrument() .. ")" .. source[NOW] .. ", " .. Subject .. ", " .. LABEL);
end