groupme-lib/examples/real_time_updates/main.go

package main

import (
	"context"
	"fmt"
	"log"

	"gitea.watsonlabs.net/watsonb8/groupme-lib"
)

// This is not a real token. Please find yours by logging
// into the GroupMe development website: https://dev.groupme.com/

var authorizationToken = "ASD"
var authorizationToken2 = "ASDF"

// A short program that subscribes to 2 groups and 2 direct chats
// and prints out all recognized events in those
func main() {
	//create push subscription and start listening
	p := groupme.NewPushSubscription(context.Background())
	err := p.Connect(context.TODO())
	if err != nil {
		return
	}

	// Create a new client with your auth token
	client := groupme.NewClient()
	User, _ := client.MyUser(context.Background(), authorizationToken)
	User2, _ := client.MyUser(context.Background(), authorizationToken2)

	//handles (in this case prints) all messages
	p.AddFullHandler(Handler{User: User}, authorizationToken)
	p.AddHandler(Handler{User: User2}, authorizationToken2)

	//Subscribe to get messages and events for the specific user
	p.SubscribeToUser(context.Background(), User.ID, authorizationToken)
	p.SubscribeToUser(context.Background(), User2.ID, authorizationToken2)
	if err != nil {
		log.Fatal(err)
	}

	// Get the groups your user is part of
	groups, err := client.IndexGroups(
		context.Background(),
		&groupme.GroupsQuery{
			Page:    0,
			PerPage: 2,
			Omit:    "memberships",
		}, authorizationToken)

	groups2, err := client.IndexGroups(
		context.Background(),
		&groupme.GroupsQuery{
			Page:    0,
			PerPage: 2,
			Omit:    "memberships",
		}, authorizationToken2)

	if err != nil {
		fmt.Println(err)
		return
	}
	//Subscribe to those groups
	for _, j := range groups {
		err = p.SubscribeToGroup(context.TODO(), j.ID, authorizationToken)
		if err != nil {
			log.Fatal(err)
		}
	}

	for _, j := range groups2 {
		err = p.SubscribeToGroup(context.TODO(), j.ID, authorizationToken2)
		if err != nil {
			log.Fatal(err)
		}
	}

	//get chats your user is part of
	chats, err := client.IndexChats(context.Background(),
		&groupme.IndexChatsQuery{
			Page:    0,
			PerPage: 2,
		}, authorizationToken)
	chats2, err := client.IndexChats(context.Background(),
		&groupme.IndexChatsQuery{
			Page:    0,
			PerPage: 2,
		}, authorizationToken2)
	//subscribe to all those chats
	for _, j := range chats {
		go func() {
			err := p.SubscribeToDM(context.TODO(), j.LastMessage.ConversationID, authorizationToken)
			if err != nil {
				log.Fatal(err)
			}
		}()

	}

	for _, j := range chats2 {
		go func() {
			err := p.SubscribeToDM(context.TODO(), j.LastMessage.ConversationID, authorizationToken2)
			if err != nil {
				log.Fatal(err)
			}
		}()

	}

	//blocking
	<-make(chan (struct{}))
}

// Following example handlers print out all data
type Handler struct {
	User *groupme.User
}

func (h Handler) HandleError(e error) {
	fmt.Println(e)
}

func (h Handler) HandleTextMessage(msg groupme.Message) {
	fmt.Println(msg.Text, msg.Name, msg.Attachments)
}

func (h Handler) HandleJoin(group groupme.ID) {
	fmt.Println("User joined group with id", group.String())
}

func (h Handler) HandleLike(msg groupme.Message) {
	fmt.Println(msg.ID, "liked by", msg.FavoritedBy)
}

func (h Handler) HandlerMembership(i groupme.ID) {
	fmt.Println("Membership event on", i.String())
}

func (h Handler) HandleGroupTopic(group groupme.ID, newTopic string) {
	fmt.Println(group.String(), "has new topic of", newTopic)
}
func (h Handler) HandleGroupName(group groupme.ID, newName string) {
	fmt.Println(group.String(), "has new name of", newName)
}
func (h Handler) HandleGroupAvatar(group groupme.ID, newAvatar string) {
	fmt.Println(group.String(), "has new avatar url of", newAvatar)
}

func (h Handler) HandleLikeIcon(group groupme.ID, PackID, PackIndex int, Type string) {
	//Not sure how to use without groupme icon packs
	if len(Type) == 0 {
		fmt.Println("Default like icon set")
		return
	}
	fmt.Println(group.String(), "has new like icon of", PackID, PackIndex, Type)
}

func (h Handler) HandleNewNickname(group groupme.ID, user groupme.ID, newName string) {
	fmt.Printf("In group %s, user %s has new nickname %s\n", group.String(), user.String(), newName)
}
func (h Handler) HandleNewAvatarInGroup(group groupme.ID, user groupme.ID, avatarURL string) {
	if avatarURL == "" {
		//get default avatar
		avatarURL = h.User.ImageURL
	}
	fmt.Printf("In group %s, user %s has new avatar with url %s\n", group.String(), user.String(), avatarURL)
}

func (h Handler) HandleMembers(group groupme.ID, members []groupme.Member, added bool) {
	action := "removed"
	if added {
		action = "added"
	}

	fmt.Printf("In group %s, users %v %s\n", group.String(), members, action)
}