i have fcm

docker/README.md

@@ -102,6 +102,7 @@ You can specify the following environment variables when issuing `docker run` co
 | `FCM_VAPID_KEY` | string |  | Also called 'Web Client certificate' in the FCM console. Required by the web client to receive push notifications. |
 | `MEDIA_HANDLER` | string | `fs` | Handler of large files, either `fs` or `s3` |
 | `MYSQL_DSN` | string | `'root@tcp(mysql)/tinode'` | MySQL [DSN](https://github.com/go-sql-driver/mysql#dsn-data-source-name). |
+| `PLUGIN_PYTHON_CHAT_BOT_ENABLED` | bool | `false` | Enable calling into the plugin provided by Python chatbot | 
 | `RESET_DB` | bool | `false` | Drop and recreate the database. |
 | `SMTP_HOST_URL` | string | `'http://localhost:6060/'` | URL of the host where the webapp is running (email verification). |
 | `SMTP_PASSWORD` | string |  | Password to use for authentication with the SMTP server (email verification). |

server/hub.go

@@ -607,8 +607,6 @@ func topicInit(sreg *sessionJoin, h *Hub) {
 				}
 			}
 
-			// t.clearId is not currently used for p2p topics
-
 			// Publics is already swapped
 			userData.public = sub1.GetPublic()
 			userData.topicName = userID2.UserId()

server/push/fcm/push_fcm.go

@@ -6,6 +6,7 @@ import (
 	"errors"
 	"log"
 	"strconv"
+	"time"
 
 	fbase "firebase.google.com/go"
 	fcm "firebase.google.com/go/messaging"
@@ -111,7 +112,7 @@ func payloadToData(pl *push.Payload) (map[string]string, error) {
 	// Must use "xfrom" because "from" is a reserved word.
 	// Google did not bother to document it anywhere.
 	data["xfrom"] = pl.From
-	data["ts"] = pl.Timestamp.String()
+	data["ts"] = pl.Timestamp.Format(time.RFC3339Nano)
 	data["seq"] = strconv.Itoa(pl.SeqId)
 	data["mime"] = pl.ContentType
 	data["content"], err = drafty.ToPlainText(pl.Content)
@@ -173,13 +174,17 @@ func sendNotifications(rcpt *push.Receipt, config *configType) {
 							Color: config.IconColor,
 						},
 					}
-				} else {
-					// No need to handle webpush separately.
-					msg.Notification = &fcm.Notification{
-						Title: "New message",
-						Body:  data["content"],
-					}
 				}
+
+				// Firebase messaging is buggy and poorly documented. If
+				// msg.Notification is defined, then firebase will ignore
+				// whatever handler is set in setBackgroundMessageHandler.
+				// See dicussion of this madness here:
+				// https://github.com/firebase/quickstart-js/issues/71
+				// msg.Notification = &fcm.Notification{
+				//	 Title: "New message",
+				//	 Body:  data["content"],
+				// }
 				_, err := handler.client.Send(ctx, &msg)
 				if err != nil {
 					if fcm.IsMessageRateExceeded(err) ||