Function AlertCmd

pkg/apiserver/papi_cmd.go:90–186

(ctx context.Context, message *Message, p *Papi, sync bool)

}

func AlertCmd(ctx context.Context, message *Message, p *Papi, sync bool) error {
	switch message.Header.OperationCmd {
	case "add":
		data, err := json.Marshal(message.Data)
		if err != nil {
			return err
		}

		alert := &models.Alert{}

		if err := json.Unmarshal(data, alert); err != nil {
			return fmt.Errorf("message for '%s' contains bad alert format: %w", message.Header.OperationType, err)
		}

		log.Infof("Received order %s from PAPI (%d decisions)", alert.UUID, len(alert.Decisions))
		decisionsToKeep := make([]*models.Decision, 0)
		for _, decision := range alert.Decisions {
			if decision.Value == nil {
				continue
			}
			isAllowlisted, reason, err := p.DBClient.IsAllowlisted(ctx, *decision.Value)
			if err != nil {
				log.Errorf("Failed to check if decision '%s' is allowlisted: %s", *decision.Value, err)
				// keep the decision in case of error during allowlist check
				decisionsToKeep = append(decisionsToKeep, decision)
				continue
			}
			if isAllowlisted {
				log.Infof("Decision '%s' is allowlisted, removing it (%s)", *decision.Value, reason)
				continue
			}
			decisionsToKeep = append(decisionsToKeep, decision)
		}
		alert.Decisions = decisionsToKeep

		if len(alert.Decisions) == 0 {
			log.Infof("All decisions are allowlisted for alert %s, skipping alert creation", alert.UUID)
			return nil
		}

		/*Fix the alert with missing mandatory items*/
		if alert.StartAt == nil || *alert.StartAt == "" {
			log.Warnf("Alert %d has no StartAt, setting it to now", alert.ID)
			alert.StartAt = new(time.Now().UTC().Format(time.RFC3339))
		}

		if alert.StopAt == nil || *alert.StopAt == "" {
			log.Warnf("Alert %d has no StopAt, setting it to now", alert.ID)
			alert.StopAt = new(time.Now().UTC().Format(time.RFC3339))
		}

		alert.EventsCount = new(int32(0))
		alert.Capacity = new(int32(0))
		alert.Leakspeed = new("")
		alert.Simulated = new(false)
		alert.ScenarioHash = new("")
		alert.ScenarioVersion = new("")
		alert.Message = new("")