Eli Ribble
44c4f17f32
The goal of this rework is to make it so I can pass around platform.User instead of a pair of models.Organization and models.User. This is useful for reason I kind of forget now, but it started with working on notifications and ballooned massively from there into refactoring a number of things that were bugging me. This also includes a tiny amount of work on server-side events (SSE). * background stuff lives inside the platform now, which I need for having it push updates through SSE * userfile now lives in the platform, under file, so other platform functions can safely use it * oauth is broken into pieces and inside platform because other stuff was calling it already, but badly. * notifications go into the platform as well
84 lines
1.8 KiB
Go
84 lines
1.8 KiB
Go
package background
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"sync"
|
|
|
|
//commsemail "github.com/Gleipnir-Technology/nidus-sync/comms/email"
|
|
//"github.com/Gleipnir-Technology/nidus-sync/config"
|
|
"github.com/Gleipnir-Technology/nidus-sync/platform/email"
|
|
"github.com/Gleipnir-Technology/nidus-sync/platform/text"
|
|
"github.com/rs/zerolog/log"
|
|
)
|
|
|
|
var waitGroup sync.WaitGroup
|
|
|
|
func Start(ctx context.Context) {
|
|
newOAuthTokenChannel = make(chan struct{}, 10)
|
|
|
|
channelJobAudio = make(chan jobAudio, 100) // Buffered channel to prevent blocking
|
|
channelJobCSV = make(chan jobCSV, 100) // Buffered channel to prevent blocking
|
|
channelJobEmail = make(chan email.Job, 100) // Buffered channel to prevent blocking
|
|
channelJobText = make(chan text.Job, 100) // Buffered channel to prevent blocking
|
|
|
|
/*
|
|
waitGroup.Add(1)
|
|
go func() {
|
|
defer waitGroup.Done()
|
|
commsemail.StartWebsocket(ctx, config.ForwardEmailAPIToken)
|
|
}()
|
|
*/
|
|
|
|
waitGroup.Add(1)
|
|
go func() {
|
|
defer waitGroup.Done()
|
|
refreshFieldseekerData(ctx, newOAuthTokenChannel)
|
|
}()
|
|
|
|
waitGroup.Add(1)
|
|
go func() {
|
|
defer waitGroup.Done()
|
|
startWorkerAudio(ctx, channelJobAudio)
|
|
}()
|
|
|
|
waitGroup.Add(1)
|
|
go func() {
|
|
defer waitGroup.Done()
|
|
startWorkerCSV(ctx, channelJobCSV)
|
|
}()
|
|
|
|
waitGroup.Add(1)
|
|
go func() {
|
|
defer waitGroup.Done()
|
|
startWorkerEmail(ctx, channelJobEmail)
|
|
}()
|
|
|
|
waitGroup.Add(1)
|
|
go func() {
|
|
defer waitGroup.Done()
|
|
startWorkerText(ctx, channelJobText)
|
|
}()
|
|
|
|
err := addWaitingJobs(ctx)
|
|
if err != nil {
|
|
log.Error().Err(err).Msg("Failed to add waiting background jobs")
|
|
}
|
|
}
|
|
|
|
func WaitForExit() {
|
|
|
|
waitGroup.Wait()
|
|
}
|
|
|
|
func addWaitingJobs(ctx context.Context) error {
|
|
err := addWaitingJobsCommit(ctx)
|
|
if err != nil {
|
|
return fmt.Errorf("commit: %w", err)
|
|
}
|
|
err = addWaitingJobsImport(ctx)
|
|
if err != nil {
|
|
return fmt.Errorf("commit: %w", err)
|
|
}
|
|
return nil
|
|
}
|