# -*-perl-*-

use strict;
use Test::More 'no_plan';
use lib "$ENV{LJHOME}/cgi-bin";
require 'ljlib.pl';
require 'ljprotocol.pl';

use LJ::Event;
use LJ::Test qw(memcache_stress temp_user);
use FindBin qw($Bin);

if ($LJ::DISABLED{esn}) {
    plan skip_all => "ESN is disabled: set $LJ::DISABLED{esn}=0 to run this test.";
    exit 0;
}

test_esn_flow(sub {
    my ($u1, $u2, $path) = @_;
    my $subsc = $u1->subscribe(
                                event   => "JournalNewEntry",
                                method  => "Email",
                                journal => $u2,
                                );
    ok($subsc, "got subscription");

    my $got_email = 0;
    local $LJ::_T_EMAIL_NOTIFICATION = sub {
        my $email = shift;
        $got_email = $email;
    };

    my $entry = $u2->t_post_fake_entry;
    ok($entry, "made a post");

    LJ::Event->process_fired_events;

    ok($got_email, "got the email on path $path");

    # remove subscription
    ok($subsc->delete, "Removed subscription");
});

sub test_esn_flow {
    my $cv = shift;
    my $u1 = temp_user();
    my $u2 = temp_user();
    foreach my $path ('1-4', '1-2-4', '1-2-3-4') {
        if ($path eq '1-2-4') {
            local $LJ::_T_ESN_FORCE_P1_P2 = 1;
            $cv->($u1, $u2, $path);
        } elsif ($path eq '1-2-3-4') {
            local $LJ::_T_ESN_FORCE_P1_P2 = 1;
            local $LJ::_T_ESN_FORCE_P2_P3 = 1;
            $cv->($u1, $u2, $path);
        } else {
            $cv->($u1, $u2, $path);
        }
    }
}

1;