jobs

Documentation

Index

• Variables
• type MailEvent
• type TokenExtendEvent

Variables

var MailerJob = scheduler.NewJob("mailer_job", func(_ context.Context, ev MailEvent) error {
	m := gomail.NewMessage()
	c := config.Config()
	if c.MailFrom == "" {
		c.MailFrom = c.SMTPUsername
	}
	m.SetHeader("From", c.MailFrom)
	m.SetHeader("To", ev.To)
	m.SetHeader("Subject", ev.Subject)
	m.SetBody("text/html; charset=utf-8", ev.ContentHTML)

	username := c.SMTPUsername
	if username == "" {
		username = c.MailFrom
	}
	d := gomail.NewDialer(c.SMTPHost, c.SMTPPort, username, c.SMTPPassword)
	if !c.SMTPSecure {
		d.TLSConfig = &tls.Config{InsecureSkipVerify: true}
	}
	return d.DialAndSend(m)
})

var TokenDeleteJob = scheduler.NewJob("token_delete_job", func(ctx context.Context, token string) error {
	taskId, err := db.InternallyDeleteToken(ctx, token)
	if err != nil {
		return err
	}
	_, err = db.DeleteTasks(ctx, taskId)
	return err
})

var TokenExtendJob = scheduler.NewJob("token_extend_job", func(ctx context.Context, e TokenExtendEvent) error {
	taskId, err := db.InternallyGetTokenJobID(ctx, e.Token)
	if err != nil {
		return err
	}
	_, err = db.ExtendTask(ctx, taskId, e.In)
	return err
})

var TokensDestructionJob = scheduler.NewJob("tokens_destruction_job", func(ctx context.Context, userId uint64) error {
	tokens, err := db.InternallyDeleteAllUserIDTokens(ctx, userId)
	if err != nil {
		return err
	}
	_, err = db.DeleteTasks(ctx, tokens...)
	return err
})

Types

type MailEvent

type MailEvent struct {
	To, Subject, ContentHTML string
}

type TokenExtendEvent

type TokenExtendEvent struct {
	Token string
	In    time.Duration
}