add topic messaging

app/src/main/java/in/antaragni/ant/GCMClientManager.java

@@ -11,6 +11,7 @@
 
 import com.google.android.gms.common.ConnectionResult;
 import com.google.android.gms.common.GooglePlayServicesUtil;
+import com.google.android.gms.gcm.GcmPubSub;
 import com.google.android.gms.gcm.GoogleCloudMessaging;
 import com.google.android.gms.iid.InstanceID;
 
@@ -47,7 +48,6 @@ public GCMClientManager(Activity activity, String projectNumber) {
   public void registerIfNeeded(final RegistrationCompletedHandler handler) {
     if (checkPlayServices()) {
       regid = getRegistrationId(getContext());
-
       if (regid.isEmpty()) {
         registerInBackground(handler);
       } else { // got id from cache
@@ -77,6 +77,11 @@ protected String doInBackground(Void... params) {
           regid = instanceID.getToken(projectNumber, GoogleCloudMessaging.INSTANCE_ID_SCOPE, null);
           Log.i(TAG, regid);
 
+          if (regid != null)
+          {
+            GcmPubSub pubSub = GcmPubSub.getInstance(getContext());
+            pubSub.subscribe(regid, "/topics/antaragni", null);
+          }
           // Persist the regID - no need to register again.
           storeRegistrationId(getContext(), regid);
 
@@ -106,7 +111,7 @@ protected void onPostExecute(String regId) {
    * @return registration ID, or empty string if there is no existing
    *         registration ID.
    */
-  private String getRegistrationId(Context context) {
+  public String getRegistrationId(Context context) {
     final SharedPreferences prefs = getGCMPreferences(context);
     String registrationId = prefs.getString(PROPERTY_REG_ID, "");
     if (registrationId.isEmpty()) {

app/src/main/java/in/antaragni/ant/GcmMessageHandler.java

@@ -6,15 +6,37 @@
 import android.content.Context;
 import android.os.Bundle;
 import android.support.v4.app.NotificationCompat;
+import in.antaragni.ant.datahandler.DatabaseAccess;
 
 public class GcmMessageHandler extends GcmListenerService {
   public static final int MESSAGE_NOTIFICATION_ID = 435345;
+  private DatabaseAccess databaseAccess;
+
+
+
+
 
   @Override
   public void onMessageReceived(String from, Bundle data) {
-    String message = data.getString("message");
-
-    createNotification(message, from);
+    String title = data.getString("title");
+    String time = data.getString("time");
+    String venue = data.getString("venue");
+    String event_name = data.getString("eventname");
+    String message = "" ;
+    message = message.concat(event_name);
+    databaseAccess = DatabaseAccess.getInstance(this);
+    databaseAccess.open();
+
+    if (!time.isEmpty())  {
+      databaseAccess.updateinfo(event_name, Integer.parseInt(time));
+      message = message.concat( " " + time);
+    }
+    if (!venue.isEmpty()) {
+      databaseAccess.updateinfo(event_name, venue);
+      message = message.concat( " " + venue);
+    }
+    createNotification(title, message);
+    databaseAccess.close();
   }
 
   // Creates notification based on title and body received
@@ -28,5 +50,6 @@ private void createNotification(String title, String body) {
     mNotificationManager.notify(MESSAGE_NOTIFICATION_ID, mBuilder.build());
   }
 
+
 }
 

app/src/main/java/in/antaragni/ant/MainActivity.java

@@ -6,10 +6,8 @@
 import android.support.v4.app.Fragment;
 import android.support.v7.app.AppCompatActivity;
 import android.support.v7.widget.Toolbar;
-import android.util.Log;
 import android.view.View;
 import android.widget.AdapterView;
-import android.widget.Toast;
 
 import com.mikepenz.iconics.typeface.FontAwesome;
 import com.mikepenz.materialdrawer.Drawer;
@@ -19,6 +17,7 @@
 import com.mikepenz.materialdrawer.model.interfaces.Nameable;
 import com.mikepenz.materialdrawer.util.KeyboardUtil;
 
+
 import in.antaragni.ant.fragments.ContactFragment;
 import in.antaragni.ant.fragments.EventFragment;
 import in.antaragni.ant.fragments.FoodFragment;
@@ -42,7 +41,6 @@ public class MainActivity extends AppCompatActivity
   private GCMClientManager pushClientManager;
   String PROJECT_NUMBER = "138444406408";
 
-
   @Override
   protected void onCreate(Bundle savedInstanceState)
   {
@@ -152,17 +150,20 @@ public void onDrawerSlide(View drawerView, float slideOffset)
     gcmregister();
   }
 
+
+
+
+
   public void gcmregister()
   {
     pushClientManager = new GCMClientManager(this, PROJECT_NUMBER);
     pushClientManager.registerIfNeeded(new GCMClientManager.RegistrationCompletedHandler()
     {
+
       @Override
       public void onSuccess(String registrationId, boolean isNewRegistration)
       {
-        Toast.makeText(MainActivity.this, registrationId,
-          Toast.LENGTH_SHORT).show();
-        Log.wtf("gcm token", registrationId);
+
         // SEND async device registration to your back-end server
         // linking user with device registration id
         // POST https://my-back-end.com/devices/register?user_id=123&device_id=abc
@@ -200,6 +201,9 @@ public void onBackPressed()
     if (result != null && result.isDrawerOpen())
     {
       result.closeDrawer();
+    }
+    else
+    {
       super.onBackPressed();
     }
   }

app/src/main/java/in/antaragni/ant/datahandler/DatabaseAccess.java

@@ -5,6 +5,7 @@
 import android.database.Cursor;
 import android.database.sqlite.SQLiteDatabase;
 import android.database.sqlite.SQLiteOpenHelper;
+import android.util.Log;
 
 import com.google.android.gms.maps.model.LatLng;
 
@@ -141,4 +142,18 @@ public List<Food> getFood()
     cursor.close();
     return list;
   }
+
+  public void updateinfo(String event_name,int time)
+  {
+    String query = "UPDATE eventdetails SET start_time=" + time + " WHERE name='" + event_name + "';";
+    database.execSQL(query);
+  }
+
+  public void updateinfo(String event_name,String venue)
+  {
+    String query = "UPDATE eventdetails SET venue='" + venue + "' WHERE name='" + event_name + "';";
+    database.execSQL(query);
+  }
+
+
 }