Console chat utility that demonstrates PubNub integration with Golang.
- Leverages the PubNub Network for chat with Publish and Subscribe.
- Uses GoCUI for a simple console user interface.
- Username and channel are configurable.
Download the appropriate pre-compiled executable from here: https://github.com/chandler767/Go-Chat/releases
Build your own chat app with PubNub and Golang.
- Install the latest version of Go and setup your $GOPATH.
- Use
go getin your terminal to download the GoCUI package and the PubNub messaging package:
go get github.com/jroimartin/gocui
go get github.com/pubnub/go/messaging- Create a new directory for your project and create a file named
main.go. - The
main.gowill contain the code for the layout of our chat application using GoCUI. GoCUI is a minimalist Go package aimed at creating Console User Interfaces. In this example we create two views (input and ouput) for our chat app, call a manager function that updates our views when the window size changes, and bind the enter key to the text input to submit messages.
package main
import (
"bufio"
"fmt"
"log"
"os"
"strings"
"github.com/jroimartin/gocui"
)
func drawchat(channel string, username string) {
// Create a new GUI.
g, err := gocui.NewGui(gocui.OutputNormal)
if err != nil {
panic(err)
return
}
defer g.Close()
g.Cursor = true
// Update the views when terminal changes size.
g.SetManagerFunc(func(g *gocui.Gui) error {
termwidth, termheight := g.Size()
_, err := g.SetView("output", 0, 0, termwidth-1, termheight-4)
if err != nil {
return err
}
_, err = g.SetView("input", 0, termheight-3, termwidth-1, termheight-1)
if err != nil {
return err
}
return nil
})
// Terminal width and height.
termwidth, termheight := g.Size()
// Output.
ov, err := g.SetView("output", 0, 0, termwidth-1, termheight-4)
if err != nil && err != gocui.ErrUnknownView {
log.Println("Failed to create output view:", err)
return
}
ov.Title = " Messages - <" + channel + "> "
ov.FgColor = gocui.ColorRed
ov.Autoscroll = true
ov.Wrap = true
// Send a welcome message.
_, err = fmt.Fprintln(ov, "<Go-Chat>: Welcome to Go-Chat powered by PubNub!")
if err != nil {
log.Println("Failed to print into output view:", err)
}
_, err = fmt.Fprintln(ov, "<Go-Chat>: Press Ctrl-C to quit.")
if err != nil {
log.Println("Failed to print into output view:", err)
}
// Input.
iv, err := g.SetView("input", 0, termheight-3, termwidth-1, termheight-1)
if err != nil && err != gocui.ErrUnknownView {
log.Println("Failed to create input view:", err)
return
}
iv.Title = " New Message - <" + username + "> "
iv.FgColor = gocui.ColorWhite
iv.Editable = true
err = iv.SetCursor(0, 0)
if err != nil {
log.Println("Failed to set cursor:", err)
return
}
// Bind Ctrl-C so the user can quit.
err = g.SetKeybinding("", gocui.KeyCtrlC, gocui.ModNone, func(g *gocui.Gui, v *gocui.View) error {
return gocui.ErrQuit
})
if err != nil {
log.Println("Could not set key binding:", err)
return
}
// Bind enter key to input to send new messages.
err = g.SetKeybinding("input", gocui.KeyEnter, gocui.ModNone, func(g *gocui.Gui, iv *gocui.View) error {
// Read buffer from the beginning.
iv.Rewind()
// Get output view and print.
ov, err := g.View("output")
if err != nil {
log.Println("Cannot get output view:", err)
return err
}
_, err = fmt.Fprintf(ov, "<%s>: %s", username, iv.Buffer())
if err != nil {
log.Println("Cannot print to output view:", err)
}
// Reset input.
iv.Clear()
// Reset cursor.
err = iv.SetCursor(0, 0)
if err != nil {
log.Println("Failed to set cursor:", err)
}
return err
})
if err != nil {
log.Println("Cannot bind the enter key:", err)
}
// Set the focus to input.
_, err = g.SetCurrentView("input")
if err != nil {
log.Println("Cannot set focus to input view:", err)
}
// Start the main loop.
err = g.MainLoop()
log.Println("Main loop has finished:", err)
}
func main() {
// Get channel and username.
reader := bufio.NewReader(os.Stdin)
fmt.Print("Enter Channel Name: ")
channel, err := reader.ReadString('\n')
if err != nil {
log.Println("Could not set channel:", err)
}
fmt.Print("Enter Desired Username: ")
username, err := reader.ReadString('\n')
if err != nil {
log.Println("Could not set username:", err)
}
// Create the GUI.
drawchat(strings.TrimSuffix(channel, "\n"), strings.TrimSuffix(username, "\n"))
}- Run the application:
go run main.go. You should be able to enter a channel name, username, and send messages to yourself.
- Now we need to integrate PubNub to send messages to other users and receive messages.
- You need PubNub API Keys. This allows the chat communication over a data stream network. You can fill in the YOUR_PUBLISH_API_KEY and YOUR_SUBSCRIBE_API_KEY placeholder strings with your API keys that you get on the PubNub website.
- Import the PubNub messaging package and the encoding/json package.
"github.com/pubnub/go/messaging"
"encoding/json"
- Initialize PubNub at the beginning of the function that creates our chat GUI.
// Initialize PubNub
pubnub := messaging.NewPubnub("YOUR_PUBLISH_API_KEY", "YOUR_SUBSCRIBE_API_KEY", "", "", false, "", nil)
- Subscribe (listen on) a channel. This is async. We have to refresh the output view when a new message is received. Add this inside the drawchat function before where the main loop is started.
// Subscribe (listen on) a channel.
successChannel := make(chan []byte)
go pubnub.Subscribe(channel, "", successChannel, false, make(chan []byte))
go func() {
for {
select {
case response := <-successChannel:
var msg []interface{}
err := json.Unmarshal(response, &msg)
if err != nil {
log.Println(err)
return
}
ov, err := g.View("output")
if err != nil {
log.Println("Cannot get output view:", err)
return
}
switch m := msg[0].(type) {
case []interface{}:
// Get output view and print.
_, err = fmt.Fprintf(ov, "%s", m[0])
if err != nil {
log.Println("Cannot print to output view:", err)
}
}
// Refresh view
g.Update(func(g *gocui.Gui) error {
return nil
})
}
}
}()- Change your enter key binding function to send messages to PubNub instead of displaying them in the output. The messages will display in the output if they are succesfully sent to PubNub and received by pubnub.Subscribe() function.
// Bind enter key to input to send new messages.
err = g.SetKeybinding("input", gocui.KeyEnter, gocui.ModNone, func(g *gocui.Gui, iv *gocui.View) error {
// Read buffer from the beginning.
iv.Rewind()
// Send message if text was entered.
if len(iv.Buffer()) >= 2 {
go pubnub.Publish(
channel,
"<"+username+">: "+iv.Buffer(),
make(chan []byte),
make(chan []byte),
)
// Reset input.
iv.Clear()
// Reset cursor.
err = iv.SetCursor(0, 0)
if err != nil {
log.Println("Failed to set cursor:", err)
}
return err
}
return nil
})
if err != nil {
log.Println("Cannot bind the enter key:", err)
}- For reference you can print the PubNub version info at the start of our main() function.
// Print version info.
fmt.Println("PubNub SDK for go;", messaging.VersionInfo())- Try it out
go run main.go.
