IOT PIVOT IRRIGATION

public class MainActivity extends AppCompatActivity {


    TextView powerText, directionText;
    Button refresh;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        PNConfiguration pnConfiguration = new PNConfiguration();
        pnConfiguration.setSubscribeKey("mykey");
        pnConfiguration.setPublishKey("mykey");
        pnConfiguration.setUuid("MobilePhone");

        final PubNub pubnub = new PubNub(pnConfiguration);

        powerText = (TextView) findViewById(R.id.power);
        directionText = (TextView) findViewById(R.id.direction);
        refresh = (Button) findViewById(R.id.refreshBtn);
        refresh.setOnClickListener(new View.OnClickListener() {

               @Override
               public void onClick(View v) {
                   pubnub.publish()
                           .message(Arrays.asList("PUB"))
                           .channel("IoTPivot")
                           .shouldStore(true)
                           .usePOST(true)
                           .async(new PNCallback<PNPublishResult>() {
                               @Override
                               public void onResponse(PNPublishResult result, PNStatus status) {
                                   if (status.isError()) {
                                       // something bad happened.
                                       System.out.println("error happened while publishing: " + status.toString());
                                   } else {
                                       System.out.println("publish worked! timetoken: " + result.getTimetoken());
                                   }
                               }
                           });


               }
           }
        );



        pubnub.addListener(new SubscribeCallback() {
            @Override
            public void status(PubNub pubnub, PNStatus status) {


                if (status.getCategory() == PNStatusCategory.PNUnexpectedDisconnectCategory) {
                    // This event happens when radio / connectivity is lost
                }

                else if (status.getCategory() == PNStatusCategory.PNConnectedCategory) {

                    // Connect event. You can do stuff like publish, and know you'll get it.
                    // Or just use the connected event to confirm you are subscribed for
                    // UI / internal notifications, etc

                    if (status.getCategory() == PNStatusCategory.PNConnectedCategory){
                        pubnub.publish().channel("IoTPivot").message("hello!!").async(new PNCallback<PNPublishResult>() {
                            @Override
                            public void onResponse(PNPublishResult result, PNStatus status) {
                                // Check whether request successfully completed or not.
                                if (!status.isError()) {

                                    // Message successfully published to specified channel.
                                }
                                // Request processing failed.
                                else {

                                    // Handle message publish error. Check 'category' property to find out possible issue
                                    // because of which request did fail.
                                    //
                                    // Request can be resent using: [status retry];
                                }
                            }
                        });
                    }
                }
                else if (status.getCategory() == PNStatusCategory.PNReconnectedCategory) {

                    // Happens as part of our regular operation. This event happens when
                    // radio / connectivity is lost, then regained.
                }
                else if (status.getCategory() == PNStatusCategory.PNDecryptionErrorCategory) {

                    // Handle messsage decryption error. Probably client configured to
                    // encrypt messages and on live data feed it received plain text.
                }
            }

            @Override
            public void message(PubNub pubnub, PNMessageResult message) {
                // Handle new message stored in message.message
                if (message.getChannel() != null) {
                    // Message has been received on channel group stored in
                    // message.getChannel()
                }
                else {
                    // Message has been received on channel stored in
                    // message.getSubscription()
                }

            /*
                log the following items with your favorite logger
                    - message.getMessage()
                    - message.getSubscription()
                    - message.getTimetoken()
            */
                
                JsonElement result = message.getMessage();
                if (result.isJsonObject()) {
                    JsonObject r = result.getAsJsonObject();
                    String m = r.get("string").toString();
                    System.out.println(m);
                    // Message Format

                    if(m.contains("PWRON")) {
                        System.out.println("IoT Pivot is ON");
                        runOnUiThread(new Runnable() {
                            @Override
                            public void run() {

                                //stuff that updates ui
                                setPowerText("ON");
                            }
                        });
                    }
                    else if (m.contains("PWROFF")) {
                        System.out.println("IoT Pivot is OFF");
                        runOnUiThread(new Runnable() {
                            @Override
                            public void run() {

                                //stuff that updates ui
                                setPowerText("OFF");
                                setDirectionText("OFF");
                            }
                        });
                    }
                    if(m.contains("DIRFWD")) {
                        System.out.println("IoT Pivot is FWD");
                        runOnUiThread(new Runnable() {
                            @Override
                            public void run() {

                                //stuff that updates ui
                                setDirectionText("FORWARD");
                            }
                        });
                    }
                    else if (m.contains("DIRRVRS")) {
                        System.out.println("IoT Pivot is RVRS");
                        runOnUiThread(new Runnable() {
                            @Override
                            public void run() {

                                //stuff that updates ui
                                setDirectionText("REVERSE");
                            }
                        });

                    }
                }
                else {
                    if(message.toString().contains("PWRON")) {
                        System.out.println("IoT Pivot is ON");
                        runOnUiThread(new Runnable() {
                            @Override
                            public void run() {

                                //stuff that updates ui
                                setPowerText("ON");
                            }
                        });
                    }
                    else if (message.toString().contains("PWROFF")) {
                        System.out.println("IoT Pivot is OFF");
                        runOnUiThread(new Runnable() {
                            @Override
                            public void run() {

                                //stuff that updates ui
                                setPowerText("OFF");
                            }
                        });
                    }
                    if(message.toString().contains("DIRFWD")) {
                        System.out.println("IoT Pivot is FWD");
                        runOnUiThread(new Runnable() {
                            @Override
                            public void run() {

                                //stuff that updates ui
                                setDirectionText("FORWARD");
                            }
                        });
                    }
                    else if (message.toString().contains("DIRRVRS")) {
                        System.out.println("IoT Pivot is RVRS");
                        runOnUiThread(new Runnable() {
                            @Override
                            public void run() {

                                //stuff that updates ui
                                setDirectionText("REVERSE");
                            }
                        });
                    }

                }

            }

            @Override
            public void presence(PubNub pubnub, PNPresenceEventResult presence) {

            }
        });

        pubnub.subscribe().channels(Arrays.asList("IoTPivot")).execute();
    }
    public void setPowerText(String powerText) {
        this.powerText.setText(powerText);
    }

    public void setDirectionText(String directionText) {
        this.directionText.setText(directionText);
    }


}