BP-Base

FizzEvent = EventSet("Fizz", e => e.data.number % 3 == 2);
BuzzEvent = EventSet("Buzz", e => e.data.number % 5 == 4);

on(FizzEvent.and(EventSets.not(BuzzEvent)), function (e) {
    request(Event("Fizz", { number: e.data.number + 1 }));
})
on(BuzzEvent.and(EventSets.not(FizzEvent)), function (e) {
    request(Event("Buzz", { number: e.data.number + 1 }));
})
on(FizzEvent.and(BuzzEvent), function (e) {
    request(Event("FizzBuzz", { number: e.data.number + 1 }));
})
on(EventSets.not(FizzEvent.or(BuzzEvent)), function (e) {
    bthread("AnnounceHandler", function () {  (1)
        request(Event("Announce", { number: e.data.number + 1 }));
    });
})

bthread('Start', function () {
    request(Event("Announce", { number: 0 }));
    waitFor(any({ number: 30 }));
    block(any("Announce"));
});

bthread('Request 10 countries', function () {
    for (let i = 0; i < 10; i++) {
        requestOne(
            Event("United States", { Language: "English", Continent: "North America" }),
            Event("France", { Language: "French", Continent: "Europe" }),
            Event("Japan", { Language: "Japanese", Continent: "Asia" }),
            Event("Brazil", { Language: "Portuguese", Continent: "South America" }),
            Event("Australia", { Language: "English", Continent: "Australia" }),
            Event("South Africa", { Language: "English", Continent: "Africa" }),
            Event("Russia", { Language: "Russian", Continent: "Europe" }),
            Event("China", { Language: "Chinese", Continent: "Asia" }),
            Event("India", { Language: "Hindi", Continent: "Asia" }),
            Event("Germany", { Language: "German", Continent: "Europe" }),
            Event("Italy", { Language: "Italian", Continent: "Europe" }),
            Event("Spain", { Language: "Spanish", Continent: "Europe" }),
            Event("Mexico", { Language: "Spanish", Continent: "North America" }),
            Event("Canada", { Language: "English", Continent: "North America" }),
            Event("Argentina", { Language: "Spanish", Continent: "South America" }),
        );
    }
});


bthread('Wait for English', function () {
    while (true) {
        waitFor(any({ Language: "English" }));
        bp.log.info("Its an English speaking country!");
    }
});

bthread('Wait for two words name', function () {
    while (true) {
        waitFor(any(/.* .*/));
        bp.log.info("Its a two words name country!");
    }
});

bthread('Wait for Europe', function () {
    while (true) {
        waitFor(any({ Continent: "Europe" }));
        bp.log.info("Its a European country!");
    }
});

bthread('Wait for Canda or Japan', function () {
    while (true) {
        waitFor([any("Canada"), any("Japan")]);
        bp.log.info("Its either Canada or Japan!");
    }
});

bthread('Request 10 countries', function () {
    for (let i = 0; i < 10; i++) {
        select("Country").from(["United States", "France", "Japan", "Brazil", "Russia", "China", "India"]);
    }
});

bthread('Greet in English', function () {
    while (true) {
        waitFor(selectEvent("Country", "United States"));
        sync({ request: Event("Greet", { greeting: "Hello" }), block: select("Country").any() });
    }
});

bthread('Greet in French', function () {
    while (true) {
        waitFor(selectEvent("Country", "France"));
        sync({ request: Event("Greet", { greeting: "Bonjour" }), block: select("Country").any() });
    }
});

bthread('Greet in Japanese', function () {
    while (true) {
        waitFor(selectEvent("Country", "Japan"));
        sync({ request: Event("Greet", { greeting: "こんにちは" }), block: select("Country").any() });
    }
});

bthread('Greet in Portuguese', function () {
    while (true) {
        waitFor(selectEvent("Country", "Brazil"));
        sync({ request: Event("Greet", { greeting: "Olá" }), block: select("Country").any() });
    }
});

bthread('Greet in Russian', function () {
    while (true) {
        waitFor(selectEvent("Country", "Russia"));
        sync({ request: Event("Greet", { greeting: "Привет" }), block: select("Country").any() });
    }
});

bthread('Greet in Chinese', function () {
    while (true) {
        waitFor(selectEvent("Country", "China"));
        sync({ request: Event("Greet", { greeting: "你好" }), block: select("Country").any() });
    }
});

bthread('Greet in Hindi', function () {
    while (true) {
        waitFor(selectEvent("Country", "India"));
        sync({ request: Event("Greet", { greeting: "नमस्ते" }), block: select("Country").any() });
    }
});

bthread('Get environment variable', function () {
    const user = getEnv("USER");
    bp.log.info("The user is: " + user);
});

function foo() {
    if (isInBThread()) {
        bp.log.info("I am in a bthread");
    } else {
        bp.log.info("I am not in a bthread");
    }
}

foo();

bthread('Is in bthread demo', function () {
    foo();
});

function foo(e) {
    if (!isEvent(e)) e = Event(e);
    request(e);
}

bthread('Using foo in two ways', function () {
    foo(Event("x"));
    foo("x");
});

function foo(e) {
    if (!isEventSet(e) && !isEvent(e)) e = any(e);
    waitFor(e);
}

bthread('Using foo in three ways', function () {
    foo(Event("x"));
    foo("x");
    foo(any("x"));
    bp.log.info("All done!");
});

bthread('Using foo in three ways', function () {
    request(Event("x"));
    request(Event("x"));
    request(Event("x"));
});