Quick and dirty example for FCM XMPP server which uses channels for comunications

golang-fcm-xmpp-server.go

package main

import (
	"github.com/titan-x/gcm/ccs"
	"log"
	"time"
	"encoding/json"
)

func sendMe(sendM chan string) {
	for {
		select {
		case <-time.After(time.Duration(2e9)):
			sendM <- "test 11"
		}
	}
}

func read(c *ccs.Conn, rec chan string) {
	for {
		m, _ := c.Receive()

		go func(m *ccs.InMsg, rec chan string) {
			dd, _ := json.Marshal(m)
			rec <- string(dd)
		}(m,rec)
	}
}

func main() {
	// fcm-xmpp.googleapis.com:5235 for prod
	c, err := ccs.Connect("fcm-xmpp.googleapis.com:5236", "APP_ID", "APP_KEY", false)
	if err != nil {
		return
	}

	send := make(chan string)
	rec := make(chan string)

	go sendMe(send)
	go read(c,rec)

	for {
		select {
		case el := <-send:
			log.Println(el)
			_, err = c.Send(&ccs.OutMsg{To: "device_registration_id", Data: map[string]string{"test_message": el}})
		case msg := <- rec:
			log.Println(msg)
		}
	}
}