Make chat persistent across reboot
All checks were successful
Deploy with Docker Compose / deploy (push) Successful in 3m25s
All checks were successful
Deploy with Docker Compose / deploy (push) Successful in 3m25s
This commit is contained in:
@@ -38,6 +38,7 @@ func main() {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
|
services.InitWebSocket(db)
|
||||||
|
|
||||||
// SPOTIFY
|
// SPOTIFY
|
||||||
spotifyAuthState := os.Getenv("SPOTIFY_AUTH_STATE")
|
spotifyAuthState := os.Getenv("SPOTIFY_AUTH_STATE")
|
||||||
|
|||||||
@@ -30,8 +30,7 @@ type Post struct {
|
|||||||
type Message struct {
|
type Message struct {
|
||||||
ID uint `gorm:"primarykey" json:"id"`
|
ID uint `gorm:"primarykey" json:"id"`
|
||||||
Content string `json:"text"`
|
Content string `json:"text"`
|
||||||
AuthorID uint `json:"-"`
|
AuthorID uint `json:"authorId"`
|
||||||
Author *User `gorm:"foreignKey:AuthorID" json:"author"`
|
|
||||||
CreatedAt time.Time `json:"createdAt"`
|
CreatedAt time.Time `json:"createdAt"`
|
||||||
DeletedAt gorm.DeletedAt `gorm:"index" json:"deletedAt"`
|
DeletedAt gorm.DeletedAt `gorm:"index" json:"deletedAt"`
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -37,6 +37,7 @@ func migrateDatabase(db *gorm.DB) error {
|
|||||||
&models.Activity{},
|
&models.Activity{},
|
||||||
&models.Favorite{},
|
&models.Favorite{},
|
||||||
&models.Rowing{},
|
&models.Rowing{},
|
||||||
|
&models.Message{},
|
||||||
)
|
)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -3,49 +3,15 @@ package services
|
|||||||
import (
|
import (
|
||||||
"net/http"
|
"net/http"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
|
||||||
|
|
||||||
"adam-french.co.uk/backend/models"
|
"adam-french.co.uk/backend/models"
|
||||||
|
"gorm.io/gorm"
|
||||||
|
|
||||||
"github.com/gorilla/websocket"
|
"github.com/gorilla/websocket"
|
||||||
)
|
)
|
||||||
|
|
||||||
const maxMessages = 50
|
const maxMessages = 50
|
||||||
|
|
||||||
type MessageRing struct {
|
|
||||||
buf []models.Message
|
|
||||||
next int // index to write next
|
|
||||||
full bool // have we wrapped at least once
|
|
||||||
}
|
|
||||||
|
|
||||||
func NewMessageRing(size int) *MessageRing {
|
|
||||||
return &MessageRing{
|
|
||||||
buf: make([]models.Message, size),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *MessageRing) Add(m models.Message) {
|
|
||||||
r.buf[r.next] = m
|
|
||||||
r.next = (r.next + 1) % len(r.buf)
|
|
||||||
if r.next == 0 {
|
|
||||||
r.full = true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Messages returns messages in chronological order (oldest -> newest).
|
|
||||||
func (r *MessageRing) Messages() []models.Message {
|
|
||||||
if !r.full {
|
|
||||||
// buffer not wrapped yet; only use [0:next)
|
|
||||||
return r.buf[:r.next]
|
|
||||||
}
|
|
||||||
|
|
||||||
// wrapped: start at next, then to end, then from 0 to next
|
|
||||||
out := make([]models.Message, len(r.buf))
|
|
||||||
copy(out, r.buf[r.next:])
|
|
||||||
copy(out[len(r.buf)-r.next:], r.buf[:r.next])
|
|
||||||
return out
|
|
||||||
}
|
|
||||||
|
|
||||||
var Upgrader = websocket.Upgrader{
|
var Upgrader = websocket.Upgrader{
|
||||||
ReadBufferSize: 1024,
|
ReadBufferSize: 1024,
|
||||||
WriteBufferSize: 1024,
|
WriteBufferSize: 1024,
|
||||||
@@ -56,26 +22,32 @@ var Upgrader = websocket.Upgrader{
|
|||||||
|
|
||||||
var (
|
var (
|
||||||
clients = make(map[*websocket.Conn]bool)
|
clients = make(map[*websocket.Conn]bool)
|
||||||
messages = NewMessageRing(maxMessages)
|
|
||||||
mu sync.Mutex
|
mu sync.Mutex
|
||||||
|
wsDB *gorm.DB
|
||||||
|
nextAuthorID uint
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func InitWebSocket(database *gorm.DB) {
|
||||||
|
wsDB = database
|
||||||
|
}
|
||||||
|
|
||||||
func HandleWebSocket(conn *websocket.Conn) {
|
func HandleWebSocket(conn *websocket.Conn) {
|
||||||
defer conn.Close()
|
defer conn.Close()
|
||||||
|
|
||||||
mu.Lock()
|
mu.Lock()
|
||||||
clients[conn] = true
|
clients[conn] = true
|
||||||
|
nextAuthorID++
|
||||||
|
authorID := nextAuthorID
|
||||||
|
|
||||||
history := messages.Messages()
|
var history []models.Message
|
||||||
|
wsDB.Order("created_at ASC").Limit(maxMessages).Find(&history)
|
||||||
|
|
||||||
// Send existing message history to new client
|
|
||||||
for _, msg := range history {
|
for _, msg := range history {
|
||||||
if err := conn.WriteJSON(msg); err != nil {
|
if err := conn.WriteJSON(msg); err != nil {
|
||||||
mu.Unlock()
|
mu.Unlock()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
mu.Unlock()
|
mu.Unlock()
|
||||||
|
|
||||||
for {
|
for {
|
||||||
@@ -84,11 +56,13 @@ func HandleWebSocket(conn *websocket.Conn) {
|
|||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
incoming.CreatedAt = time.Now()
|
incoming.AuthorID = authorID
|
||||||
|
|
||||||
// Store and broadcast
|
|
||||||
mu.Lock()
|
mu.Lock()
|
||||||
messages.Add(incoming)
|
wsDB.Create(&incoming)
|
||||||
|
wsDB.Where("id NOT IN (?)",
|
||||||
|
wsDB.Model(&models.Message{}).Select("id").Order("created_at DESC").Limit(maxMessages),
|
||||||
|
).Delete(&models.Message{})
|
||||||
|
|
||||||
for client := range clients {
|
for client := range clients {
|
||||||
if err := client.WriteJSON(incoming); err != nil {
|
if err := client.WriteJSON(incoming); err != nil {
|
||||||
@@ -99,7 +73,6 @@ func HandleWebSocket(conn *websocket.Conn) {
|
|||||||
mu.Unlock()
|
mu.Unlock()
|
||||||
}
|
}
|
||||||
|
|
||||||
// Cleanup on disconnect
|
|
||||||
mu.Lock()
|
mu.Lock()
|
||||||
delete(clients, conn)
|
delete(clients, conn)
|
||||||
mu.Unlock()
|
mu.Unlock()
|
||||||
|
|||||||
Reference in New Issue
Block a user