events.go

package main

import (
	"fmt"

	"github.com/katzenpost/catshadow"
	"github.com/katzenpost/client"
)

func eventLoop(events <-chan interface{}, conversationModel *ConversationModel, contactListModel *ContactListModel) {
	for {
		ev, ok := <-events
		if !ok {
			return
		}

		handleEvent(ev, conversationModel, contactListModel)
	}
}

func handleEvent(ev interface{}, conversationModel *ConversationModel, contactListModel *ContactListModel) {
	switch event := ev.(type) {
	case *client.ConnectionStatusEvent:
		status := "Connecting..."
		if event.IsConnected {
			status = "Connected"
		}
		if event.Err != nil {
			status = "Disconnected"
			accountBridge.SetError(event.Err.Error())
		}

		accountBridge.SetStatus(status)

	case *catshadow.KeyExchangeCompletedEvent:
		fmt.Println(event.Nickname, event.Err)

		if event.Err != nil {
			accountBridge.SetError(event.Err.Error())
			return
		}
		contactListModel.updateContactStatus(event.Nickname, true)

	case *catshadow.MessageSentEvent:
		conversationModel.updateMessageStatus(string(event.MessageID[:]), StatusSent)

	case *catshadow.MessageNotSentEvent:
		// XXX: conversationModel.updateMessageStatus(string(event.MessageID[:]), StatusNotSent)
		return

	case *catshadow.MessageDeliveredEvent:
		conversationModel.updateMessageStatus(string(event.MessageID[:]), StatusDelivered)

	case *catshadow.MessageReceivedEvent:
		switch config.Notification {
		case "Full":
			notify("catchat", "New message received from "+event.Nickname)
		case "Anonymized":
			notify("catchat", "New message received")
		}

		if accountBridge.Recipient() != event.Nickname {
			return
		}

		var m = NewMessage(nil)
		m.Nickname = event.Nickname
		m.Avatar = "" // FIXME: add avatar
		m.Message = string(event.Message)
		m.Timestamp = event.Timestamp
		conversationModel.AppendMessage(m)

	default:
		// This case indicates a programming BUG!
		panic(fmt.Sprintf("%s is an unknown event received, aborting", event))
	}
}