client = PubNub({
    subscribeKey: "demo",
    publishKey: "demo",
    uuid: "roku-client",
}, messagePort)

client.<api-function>({<parameters>}, <callback>, <context>)

publishCallback = function(status as Object, context as Object)
end function

' Prepare shared message port.
' Message port should be used for both application / user events handling and PubNub client
' 'run-loop'
messagePort = createObject("roMessagePort")

' Create and configure PubNub client instance.
client = PubNub({
    subscribeKey: "demo-36",
    publishKey: "demo-36",
    uuid: "roku-client",
}, messagePort)

while true
    message = wait(250, messagePort)
    pubnubCanHandle = client.handleMessage(message)
    if type(message) = "roUrlEvent" AND pubnubCanHandle = false then
        ' Application request handling code. If client's 'handleMessage' function return
        ' 'false' - it mean what client doesn't recognize request and probably it has been sent
        ' by application and should be handled by it.
    end if

    if message = "roSGScreenEvent" AND message.isScreenClosed() = true then
        client.destroy()
        exit while
    end if

    ' Handle any other user interactions.
end while

client.destroy()

objectEventListener = {
    status: function(client as Object, status as Object)
        ?"Status change:", status
        ' Check example application for possible state variations.
        if status.error = true AND status.operation = PNOperationType().PNSubscribeOperation then
            if status.automaticallyRetry = true then
                ' It is possible to cancel automatic retry
                ' if required using client's function:
                client.cancelSubscriptionRetry()
            end if
        end if
    end function
    presence: function(client as Object, presence as Object)
        ?"Received '"+presence.data.presenceEvent+"' presence event with details:", presence.data.presence
    end function
    message: function(client as Object, message as Object)
        ?"Received message on '"+message.data.channel+"': ",message.data.message
    end function
}

client.addListener(objectEventListener)

' Unregister specific listener.
client.removeListener(objectEventListener)

' Unregister all listeners.  
client.removeAllListeners()

client.subscribe({
    channels: ["pubnub-channel", "roku-channel"]
    channelGroups: ["pubnub-group", "brightscript-group"]
    withPresence: false
    "state": {"pubnub-channel": {"welcome": "online"}}
})

client.unsubscribeAll()

client.unsubscribe({
    channels: ["pubnub-channel", "roku-channel"]
    channelGroups: ["brightscript-group"]
})

channels = client.channels()
channelGroups = client.channelGroups()

if client.presenceEnabledForChannel("roku-channel") = false then
    client.subscribe({channels: ["roku-channel-pnpres"]})
end if

publishCallback = function(status as Object)
    if status.error = false then
        ' Handle successful message publish.
    else
        ' Handle message publish error.
        ?"Message publish did fail with error details:",status.errorData
    end if
end function

client.publish({
    channel: "roku-channel"
    message: {hello: "world"}
}, publishCallback)

historyCallback = function(result = invalid as Dynamic, status = invalid as Dynamic)
    if result <> invalid then
        ' Handle successful history fetch.
        ?"Messages between "+box(result.data.start).toStr()+" .. "+box(result.data["end"]).toStr()+": "+PNObject(result.data.messages).toString()
    else
        ' Handle messages history request error.
        ?"Messages history fetch did fail with error details:",status.errorData
    end if
end function
client.history({channel: "hello-channel"}, historyCallback)

channelsAddCallback = function(status as Object)
    if status.error = false then
        ' Handle successful channels addition from group.
    else
        ' Handle channels addition error.
        ?"Channels addition did fail with error details:",status.errorData
    end if
end function

client.addChannels({
    channels: ["brightscript", "roku"]
    group: "roku-developers-community"
}, channelsAddCallback)

channelsRemoveCallback = function(status as Object)
    if status.error = false then
        ' Handle successful channels removal from group.
    else
        ' Handle channels removal error.
        ?"Channels remove did fail with error details:",status.errorData
    end if
end function

client.removeChannels({
    channels: ["brightscript"]
    group: "roku-developers-community"
}, channelsRemoveCallback)

groupRemoveCallback = function(status as Object)
    if status.error = false then
        ' Handle successful channel group removal.
    else
        ' Handle channel group removal error.
        ?"Channel group remove did fail with error details:",status.errorData
    end if
end function

client.deleteGroup({group: "roku-developers-community"}, groupRemoveCallback)

channelsAuditCallback = function(result = invalid as Dynamic, status = invalid as Dynamic)
    if result <> invalid then
        ' Handle successful group's channels fetch.
        ?"Channels:",result.data.channels
    else
        ' Handle group's channels request error.
        ?"Group's channels fetch did fail with error details:",status.errorData
    end if
end function

client.listChannels({group: "roku-developers-community"}, channelsAuditCallback)

hereNowCallback = function(result = invalid as Dynamic, status = invalid as Dynamic)
    if result <> invalid then
        ' Handle users' presence information fetch.
        ?"Occupancy:",result.data.occupancy
        ?"Participants: "+PNObject(result.data.uuids).toString()
    else
        ' Handle users' presence information request error.
        ?"Users' presence information fetch did fail with error details:",status.errorData
    end if
end function

client.hereNow({channel: "roku-channel"}, hereNowCallback)

whereNowCallback = function(result = invalid as Dynamic, status = invalid as Dynamic)
    if result <> invalid then
        ' Handle user channels presence fetch.
        ?"Channels:",result.data.channels
    else
        ' Handle user channels presence request error.
        ?"User channels fetch did fail with error details:",status.errorData
    end if
end function

client.whereNow({uuid: client.configuration().uuid}, whereNowCallback)

setStateCallback = function(status as Object)
    if status.error = false then
        ' Handle successful client's state change.
    else
        ' Handle client's state change error.
        ?"Did fail to change client's state with error details:",status.errorData
    end if
end function

client.setState({
    channel: "roku-channel"
    uuid: client.configuration().uuid
    "state":{welcome:{"to":"Roku channel"}}
}, setStateCallback)

getStateCallback = function(result = invalid as Dynamic, status = invalid as Dynamic)
    if result <> invalid then
        ' Handle client's state for user fetch.
        ?"User state:",result.data.state
    else
        ' Handle client's state for user request error.
        ?"User state fetch did fail with error details:",status.errorData
    end if
end function

client.getState({
    channel: "roku-channel"
    uuid: client.configuration().uuid
}, getStateCallback)

timeCallback = function(result = invalid as Dynamic, status = invalid as Dynamic)
    if result <> invalid then
        ' Handle time fetch.
        ?"Timetoken",result.data.timetoken
    else
        ' Handle time request error.
        ?"User state fetch did fail with error details:",status.errorData
    end if
end function

client.time(timeCallback)