Add toolkit for fcm/apns push testing.

Author: cloudwebrtc

README.md

@@ -16,3 +16,7 @@
     "has_video": false,
 }
 ```
+
+## push test tool
+
+Please refer to the [Tool](/tools/) to test callkeep offline push.

tools/README.md

@@ -0,0 +1,17 @@
+# CallKeep test tool
+
+This tool is used to demonstrate the basic push process for verifying callkeep. The tool is written in golang.
+
+## For iOS APNS
+
+please refer to `https://developer.apple.com/account/resources/certificates/add`.
+Choose `VoIP Services Certificate` to create a push certificate, download voip_services.cer and install it to the keychain tool, and export its private key rename it to `callkeep-apns.p12`
+
+`go run cmd/main.go -i +8618612345678 -p apns -d $ios_device_token`
+
+## For Android FCM
+
+please refer to `https://console.firebase.google.com/project/[your project]/settings/serviceaccounts/adminsdk`
+Select the `go` sdk format under your fcm project to download serviceAccountKey.json and rename it to `callkee-fcm.json`
+
+`go run cmd/main.go -i +8618612345678 -p fcm -d $android_fcm_token`

tools/cmd/main.go

@@ -0,0 +1,63 @@
+package main
+
+import (
+	"encoding/json"
+	"flag"
+	"fmt"
+
+	"github.com/flutter-webrtc/callkeep/tools/pkg/fcm"
+	"github.com/flutter-webrtc/callkeep/tools/pkg/pushkit"
+	log "github.com/pion/ion-log"
+)
+
+func pushCallKeep(provider string, token string, payload map[string]string) error {
+	log.Infof("CallKeep Push Request")
+
+	log.Infof("provider=%v", provider)
+	log.Infof("token=%v", token)
+
+	data, _ := json.MarshalIndent(payload, "", " ")
+	log.Infof("payload=\n%v", string(data))
+
+	switch provider {
+	case "apns":
+		pushkit.APNSPush("./callkeep-apns.p12", token, payload)
+		return nil
+	case "fcm":
+		fcm.FCMPush("./callkeep-fcm.json", token, payload)
+		return nil
+	}
+	return fmt.Errorf("%v provider not found", provider)
+}
+
+func main() {
+	log.Init("info")
+	h := false
+	flag.BoolVar(&h, "h", false, "help")
+	provider := ""
+	flag.StringVar(&provider, "p", "fcm", "push provider type fcm | apns.")
+	token := ""
+	flag.StringVar(&token, "d", "", "device token.")
+	cid := ""
+	flag.StringVar(&cid, "i", "", "caller id.")
+	flag.Parse()
+
+	if h || len(token) == 0 || len(cid) == 0 {
+		flag.Usage()
+		return
+	}
+
+	log.Infof("try push")
+
+	payload := map[string]string{
+		"caller_id":      cid,
+		"caller_name":    "push test",
+		"caller_id_type": "number",
+		"has_video":      "false",
+	}
+
+	err := pushCallKeep(provider, token, payload)
+	if err != nil {
+		log.Errorf("push failed %v", err)
+	}
+}

tools/go.mod

@@ -0,0 +1,13 @@
+module github.com/flutter-webrtc/callkeep/tools
+
+go 1.16
+
+require (
+	cloud.google.com/go/firestore v1.5.0 // indirect
+	firebase.google.com/go v3.13.0+incompatible
+	github.com/dgrijalva/jwt-go v3.2.0+incompatible // indirect
+	github.com/pion/ion-log v1.2.0
+	github.com/sideshow/apns2 v0.20.0
+	golang.org/x/crypto v0.0.0-20210513164829-c07d793c2f9a // indirect
+	google.golang.org/api v0.48.0
+)

tools/go.sum

@@ -0,0 +1,36 @@
+package fcm
+
+import (
+	"context"
+
+	firebase "firebase.google.com/go"
+	"firebase.google.com/go/messaging"
+	log "github.com/pion/ion-log"
+	"google.golang.org/api/option"
+)
+
+func FCMPush(fcmCert string, token string, payload map[string]string) (string, error) {
+	opt := option.WithCredentialsFile(fcmCert)
+	app, err := firebase.NewApp(context.Background(), nil, opt)
+
+	// Obtain a messaging.Client from the App.
+	ctx := context.Background()
+	client, err := app.Messaging(ctx)
+
+	// See documentation on defining a message payload.
+	message := &messaging.Message{
+		Data:  payload,
+		Token: token,
+	}
+
+	// Send a message to the device corresponding to the provided
+	// registration token.
+	response, err := client.Send(ctx, message)
+	if err != nil {
+		log.Errorf("FCMPush: err %v", err)
+		return "", err
+	}
+	// Response is a message ID string.
+	log.Infof("Successfully sent message: %v", response)
+	return response, err
+}

tools/pkg/fcm/fcm.go

@@ -0,0 +1,35 @@
+package pushkit
+
+import (
+	"encoding/json"
+
+	log "github.com/pion/ion-log"
+	"github.com/sideshow/apns2"
+	"github.com/sideshow/apns2/certificate"
+)
+
+func APNSPush(p12 string, token string, payload map[string]string) {
+
+	cert, err := certificate.FromP12File(p12, "")
+	if err != nil {
+		log.Errorf("Cert Error: %v", err)
+	}
+
+	data, _ := json.Marshal(payload)
+	notification := &apns2.Notification{}
+	notification.DeviceToken = token
+	notification.PushType = "voip"      // voip | alert
+	notification.Payload = []byte(data) // See Payload section below
+
+	// If you want to test push notifications for builds running directly from XCode (Development), use
+	client := apns2.NewClient(cert).Development()
+	// For apps published to the app store or installed as an ad-hoc distribution use Production()
+	//client := apns2.NewClient(cert).Production()
+	res, err := client.Push(notification)
+
+	if err != nil {
+		log.Errorf("Error: %v", err)
+	}
+
+	log.Infof("Push response: %v %v %v\n", res.StatusCode, res.ApnsID, res.Reason)
+}