require "pubnub"
 
--
-- GET YOUR PUBNUB KEYS HERE:
-- http://www.pubnub.com/account#api-keys
--
multiplayer = pubnub.new({
    publish_key   = "demo",             -- YOUR PUBLISH KEY
    subscribe_key = "demo",             -- YOUR SUBSCRIBE KEY
    secret_key    = nil,                -- YOUR SECRET KEY
    ssl           = nil,                -- ENABLE SSL?
    origin        = "pubsub.pubnub.com" -- PUBNUB CLOUD ORIGIN
})

--
-- PUBNUB SUBSCRIBE CHANNEL (RECEIVE MESSAGES)
--
multiplayer:subscribe({
    channel  = "lua-corona-demo-channel",
    callback = function(message)
        -- MESSAGE RECEIVED!!!
        print(message)
    end,
    errorback = function()
        print("Network Connection Lost")
    end
})

--
-- PUBNUB PUBLISH MESSAGE (SEND A MESSAGE)
--
multiplayer:publish({
    channel  = "lua-corona-demo-channel",
    message  = { "1234", 2, 3, 4 },
    callback = function(info)
 
        -- WAS MESSAGE DELIVERED?
        if info[1] then
            print("MESSAGE DELIVERED SUCCESSFULLY!")
        else
            print("MESSAGE FAILED BECAUSE -> " .. info[2])
        end
 
    end
})

--
-- PUBNUB UN-SUBSCRIBE CHANNEL (STOP RECEIVING MESSAGES)
--
multiplayer:unsubscribe({
    channel = "lua-corona-demo-channel"
})

--
-- PUBNUB LOAD MESSAGE HISTORY
--
multiplayer:history({
    channel  = "lua-corona-demo-channel",
    limit    = 10,
    callback = function(messages)
        if not messages then
            return print("ERROR LOADING HISTORY")
        end
 
        -- NO HISTORY?
        if not (#messages > 0) then
            return print("NO HISTORY YET")
        end
 
        -- LOOP THROUGH MESSAGE HISTORY
        for i, message in ipairs(messages) do
            print(Json.Encode(message))
        end
    end
})

--
-- PUBNUB SERVER TIME
--
multiplayer:time({
    callback = function(time)
        -- PRINT TIME
        print("PUBNUB SERVER TIME: " .. time)
    end
})

--
-- HOSTING PLAYER LISTENS FOR CHALLENGER 1v1
--
multiplayer:subscribe({
    channel  = "checkers-game-room-" .. game_room_id,
    callback = function(message)
 
        -- NEW CHALLENGER?
        if message.action and message.action == "request_game_play" then
            -- ACCEPT CHALLENGER and BEGIN GAMEPLAY
        end
 
    end,
    errorback = function()
        print("Network Connection Lost")
    end
})

--
-- REQUEST GAME PLAY IN GAME ROOM X
--
multiplayer:publish({
    channel = "checkers-game-room-" .. game_room_id,
    message = { action = "request_game_play" }
})

--
-- GAME LOBBY ROOM
--
players_in_lobby = {}
 
 
multiplayer:subscribe({
    channel  = "game-lobby-room",
    callback = function(message)
 
        -- REQUEST FOR PLAYERS IN GAME LOBBY ROOM?
        if message.action == "ping" then
            -- EVERYONE ANNOUNCES PRESENCE
            -- THIS GIVES EVERYONE IN THE LOBBY A FULL LIST OF PLAYERS
            multiplayer:publish({
                channel = "game-lobby-room",
                message = { 
                    action = "pong", -- REPLY TO "ping" REQUEST
                    player = {
                        id   = 12345,
                        name = "JohnyPlayer"
                    }
                }
            })
 
        -- RECEIVE PLAYERS IN GAME LOBBY ROOM
        elseif message.action == "pong" then
            -- UPDATE PLAYERS TABLE IN GAME LOBBY 
            players_in_lobby[message.player.id] = message.player
        end
 
    end,
    errorback = function()
        print("Network Connection Lost")
    end
})

--
-- REQUEST ALL PLAYER'S DETAILS IN GAME LOBBY ROOM
--
multiplayer:publish({
    channel = "game-lobby-room",
    message = { action = "ping" }
})

--
-- GENERATING A UNIQUE ID FOR A PLAYER
--
my_player_details = {
    id   = nil,
    name = "Johny Player"
}
 
multiplayer:time({
    callback = function(time)
        -- GIVE PLAYER A UNIQUE ID
        my_player_details.id = time .. '-' .. math.random( 1, 999999 )
    end
})

require "pubnub"
 
multiplayer = pubnub.new({
    publish_key   = "demo",
    subscribe_key = "demo",
    secret_key    = nil,
    ssl           = nil,
    origin        = "pubsub.pubnub.com"
})
 
-- 
-- Player ID (Generated Later)
-- 
my_player_id   = nil
my_player_name = "John Smith"
 
--
-- Generate Player ID
--
multiplayer:time({
    callback = function(time)
        my_player_id.id = time .. '-' .. math.random( 1, 999999 )
    end
})
 
-- 
-- Players Per Channel
-- 
players_per_game_room = {
    game_room_1234 = {},
    game_room_5678 = {}
}
 
game_room_1234 = "game_room_1234"
 
 
-- 
-- Join Game Room 1234
-- 
multiplayer:subscribe({
    channel  = game_room_1234,
    callback = function(message)
 
        -- 
        -- Ping? then Pong!
        -- This sends a message from all players, to all players.
        -- This lets you know who and how many players are on a channel.
        -- 
        if message.action == "ping" then
            multiplayer:publish({
                channel = game_room_1234,
                message = {
                    action  = "pong",
                    id      = my_player_id,
                    name    = my_player_name
                }
            })
 
        -- 
        -- Collect Live Players who are in this Game Room.
        -- 
        elseif message.action == "pong" then
            players_per_game_room[game_room_1234][message.id] = message
 
        -- 
        -- Some Other Game Event
        -- 
        elseif message.action == "something-else" then
            
        end
    end
})
 
 
-- 
-- Request Info About Connected Players
-- 
multiplayer:publish({
    channel = game_room_1234,
    message = { action = "ping" }
})
 
-- 
-- Print info on Game Room 1234
-- 
function wait_for_info_from_players()
    --
    -- Print Number of Players
    --
    print("Number of Players in channel: " .. game_room_1234)
    print(#players_per_game_room[game_room_1234])
 
    --
    -- Print Info about Each Player
    --
    for id, player in pairs(players_per_game_room[game_room_1234]) do
        print("Player: " .. id "'s Name is " .. player.name)
    end
end
 
-- 
-- Wait at 1 to 3 seconds for player response
-- before we assume we've received messages from everyone.
-- 
timer.performWithDelay( 2000, wait_for_info_from_players )