package models import ( "errors" "fmt" "time" "github.com/jinzhu/gorm" ) //Campaign is a struct representing a created campaign type Campaign struct { Id int64 `json:"id"` UserId int64 `json:"-"` Name string `json:"name" sql:"not null"` CreatedDate time.Time `json:"created_date"` CompletedDate time.Time `json:"completed_date"` TemplateId int64 `json:"-"` Template Template `json:"template"` PageId int64 `json:"-"` Page Page `json:"page"` Status string `json:"status"` Results []Result `json:"results,omitempty"` Groups []Group `json:"groups,omitempty"` Events []Event `json:"timeline,omitemtpy"` SMTP SMTP `json:"smtp"` URL string `json:"url"` } // ErrCampaignNameNotSpecified indicates there was no template given by the user var ErrCampaignNameNotSpecified = errors.New("Campaign name not specified") // ErrGroupNotSpecified indicates there was no template given by the user var ErrGroupNotSpecified = errors.New("No groups specified") // ErrTemplateNotSpecified indicates there was no template given by the user var ErrTemplateNotSpecified = errors.New("No email template specified") // ErrPageNotSpecified indicates a landing page was not provided for the campaign var ErrPageNotSpecified = errors.New("No landing page specified") // ErrTemplateNotFound indicates the template specified does not exist in the database var ErrTemplateNotFound = errors.New("Template not found") // ErrGroupnNotFound indicates a group specified by the user does not exist in the database var ErrGroupNotFound = errors.New("Group not found") // ErrPageNotFound indicates a page specified by the user does not exist in the database var ErrPageNotFound = errors.New("Page not found") // Validate checks to make sure there are no invalid fields in a submitted campaign func (c *Campaign) Validate() error { switch { case c.Name == "": return ErrCampaignNameNotSpecified case len(c.Groups) == 0: return ErrGroupNotSpecified case c.Template.Name == "": return ErrTemplateNotSpecified case c.Page.Name == "": return ErrPageNotSpecified } return nil } // SendTestEmailRequest is the structure of a request // to send a test email to test an SMTP connection type SendTestEmailRequest struct { Template Template `json:"template"` Page Page `json:"page"` SMTP SMTP `json:"smtp"` URL string `json:"url"` Tracker string `json:"tracker"` TrackingURL string `json:"tracking_url"` Target } // Validate ensures the SendTestEmailRequest structure // is valid. func (s *SendTestEmailRequest) Validate() error { switch { case s.Template.Name == "": return ErrTemplateNotSpecified case s.Email == "": return ErrEmailNotSpecified } return nil } // UpdateStatus changes the campaign status appropriately func (c *Campaign) UpdateStatus(s string) error { // This could be made simpler, but I think there's a bug in gorm return db.Table("campaigns").Where("id=?", c.Id).Update("status", s).Error } // AddEvent creates a new campaign event in the database func (c *Campaign) AddEvent(e Event) error { e.CampaignId = c.Id e.Time = time.Now() return db.Debug().Save(&e).Error } // Event contains the fields for an event // that occurs during the campaign type Event struct { Id int64 `json:"-"` CampaignId int64 `json:"-"` Email string `json:"email"` Time time.Time `json:"time"` Message string `json:"message"` Details string `json:"details"` } // GetCampaigns returns the campaigns owned by the given user. func GetCampaigns(uid int64) ([]Campaign, error) { cs := []Campaign{} err := db.Model(&User{Id: uid}).Related(&cs).Error if err != nil { fmt.Println(err) } for i, _ := range cs { err := db.Model(&cs[i]).Related(&cs[i].Results).Error if err != nil { Logger.Println(err) } err = db.Model(&cs[i]).Related(&cs[i].Events).Error if err != nil { Logger.Println(err) } err = db.Table("templates").Where("id=?", cs[i].TemplateId).Find(&cs[i].Template).Error if err != nil { Logger.Println(err) } err = db.Table("pages").Where("id=?", cs[i].PageId).Find(&cs[i].Page).Error if err != nil { Logger.Println(err) } } return cs, err } // GetCampaign returns the campaign, if it exists, specified by the given id and user_id. func GetCampaign(id int64, uid int64) (Campaign, error) { c := Campaign{} err := db.Where("id = ?", id).Where("user_id = ?", uid).Find(&c).Error if err != nil { Logger.Printf("%s: campaign not found\n", err) return c, err } err = db.Model(&c).Related(&c.Results).Error if err != nil { Logger.Printf("%s: results not found for campaign\n", err) return c, err } err = db.Model(&c).Related(&c.Events).Error if err != nil { Logger.Printf("%s: events not found for campaign\n", err) return c, err } err = db.Table("templates").Where("id=?", c.TemplateId).Find(&c.Template).Error if err != nil { Logger.Printf("%s: template not found for campaign\n", err) return c, err } err = db.Table("pages").Where("id=?", c.PageId).Find(&c.Page).Error if err != nil { Logger.Printf("%s: page not found for campaign\n", err) } return c, err } // PostCampaign inserts a campaign and all associated records into the database. func PostCampaign(c *Campaign, uid int64) error { if err := c.Validate(); err != nil { return err } // Fill in the details c.UserId = uid c.CreatedDate = time.Now() c.CompletedDate = time.Time{} c.Status = CAMPAIGN_QUEUED // Check to make sure all the groups already exist for i, g := range c.Groups { c.Groups[i], err = GetGroupByName(g.Name, uid) if err == gorm.RecordNotFound { Logger.Printf("Error - Group %s does not exist", g.Name) return ErrGroupNotFound } else if err != nil { Logger.Println(err) return err } } // Check to make sure the template exists t, err := GetTemplateByName(c.Template.Name, uid) if err == gorm.RecordNotFound { Logger.Printf("Error - Template %s does not exist", t.Name) return ErrTemplateNotFound } else if err != nil { Logger.Println(err) return err } c.Template = t c.TemplateId = t.Id // Check to make sure the page exists p, err := GetPageByName(c.Page.Name, uid) if err == gorm.RecordNotFound { Logger.Printf("Error - Page %s does not exist", p.Name) return ErrPageNotFound } else if err != nil { Logger.Println(err) return err } c.Page = p c.PageId = p.Id // Insert into the DB err = db.Save(c).Error if err != nil { Logger.Println(err) return err } err = c.AddEvent(Event{Message: "Campaign Created"}) if err != nil { Logger.Println(err) } // Insert all the results for _, g := range c.Groups { // Insert a result for each target in the group for _, t := range g.Targets { r := Result{Email: t.Email, Status: STATUS_UNKNOWN, CampaignId: c.Id, UserId: c.UserId, FirstName: t.FirstName, LastName: t.LastName} r.GenerateId() err = db.Save(&r).Error if err != nil { Logger.Printf("Error adding result record for target %s\n", t.Email) Logger.Println(err) } c.Results = append(c.Results, r) } } return nil } //DeleteCampaign deletes the specified campaign func DeleteCampaign(id int64) error { Logger.Printf("Deleting campaign %d\n", id) // Delete all the campaign results err := db.Where("campaign_id=?", id).Delete(&Result{}).Error if err != nil { Logger.Println(err) return err } err = db.Where("campaign_id=?", id).Delete(&Event{}).Error if err != nil { Logger.Println(err) return err } // Delete the campaign err = db.Delete(&Campaign{Id: id}).Error if err != nil { Logger.Panicln(err) return err } return err }