mirror of
https://github.com/abhinavxd/libredesk.git
synced 2025-11-02 21:13:47 +00:00
494bc15b0a
Before this feature the only way to create a conversation was by adding inbox and sending an email. Agents first search contacts by email, see a dropdown select an existing contact or fill a new email for new contact. The backend creates contact if it does not exist, creates a conversation, sends a reply to the conversation. Optinally assigns conversation to a user / team. fix: Replies to emails create a new conversation instead of attaching to the previous one. Was not happening in gmail, as gmail was sending the references headers in all replies and I missed this completely. So when libredesk searches a conversation by references headers it worked! Instead the right way is to generate the outgoing email message id and saving it in DB. This commit fixes that. There could be more backup strategies like putting reference number in the subject but that can be explored later. chore: new role `conversatons:write` that enables the create conversations feature for an agent. chore: migrations for v0.4.0.
75 lines
2.2 KiB
Go
75 lines
2.2 KiB
Go
// Package search provides search functionality.
|
|
package search
|
|
|
|
import (
|
|
"embed"
|
|
|
|
"github.com/abhinavxd/libredesk/internal/dbutil"
|
|
"github.com/abhinavxd/libredesk/internal/envelope"
|
|
models "github.com/abhinavxd/libredesk/internal/search/models"
|
|
"github.com/jmoiron/sqlx"
|
|
"github.com/zerodha/logf"
|
|
)
|
|
|
|
var (
|
|
//go:embed queries.sql
|
|
efs embed.FS
|
|
)
|
|
|
|
// Manager is the search manager
|
|
type Manager struct {
|
|
q queries
|
|
lo *logf.Logger
|
|
}
|
|
|
|
// Opts contains the options for creating a new search manager
|
|
type Opts struct {
|
|
DB *sqlx.DB
|
|
Lo *logf.Logger
|
|
}
|
|
|
|
// queries contains all the prepared queries
|
|
type queries struct {
|
|
SearchConversations *sqlx.Stmt `query:"search-conversations"`
|
|
SearchMessages *sqlx.Stmt `query:"search-messages"`
|
|
SearchContacts *sqlx.Stmt `query:"search-contacts"`
|
|
}
|
|
|
|
// New creates a new search manager
|
|
func New(opts Opts) (*Manager, error) {
|
|
var q queries
|
|
if err := dbutil.ScanSQLFile("queries.sql", &q, opts.DB, efs); err != nil {
|
|
return nil, err
|
|
}
|
|
return &Manager{q: q, lo: opts.Lo}, nil
|
|
}
|
|
|
|
// Conversations searches conversations based on the query
|
|
func (s *Manager) Conversations(query string) ([]models.Conversation, error) {
|
|
var results = make([]models.Conversation, 0)
|
|
if err := s.q.SearchConversations.Select(&results, query); err != nil {
|
|
s.lo.Error("error searching conversations", "error", err)
|
|
return nil, envelope.NewError(envelope.GeneralError, "Error searching conversations", nil)
|
|
}
|
|
return results, nil
|
|
}
|
|
|
|
// Messages searches messages based on the query
|
|
func (s *Manager) Messages(query string) ([]models.Message, error) {
|
|
var results = make([]models.Message, 0)
|
|
if err := s.q.SearchMessages.Select(&results, query); err != nil {
|
|
s.lo.Error("error searching messages", "error", err)
|
|
return nil, envelope.NewError(envelope.GeneralError, "Error searching messages", nil)
|
|
}
|
|
return results, nil
|
|
}
|
|
|
|
// Contacts searches contacts based on the query
|
|
func (s *Manager) Contacts(query string) ([]models.Contact, error) {
|
|
var results = make([]models.Contact, 0)
|
|
if err := s.q.SearchContacts.Select(&results, query); err != nil {
|
|
s.lo.Error("error searching contacts", "error", err)
|
|
return nil, envelope.NewError(envelope.GeneralError, "Error searching contacts", nil)
|
|
}
|
|
return results, nil
|
|
} |