Method Data

modules/smtp/handler.go:102–148

(r io.Reader)

}

func (s *session) Data(r io.Reader) error {
	raw, err := io.ReadAll(r)
	if err != nil {
		return err
	}

	parsed, attachments, err := parseEmail(raw, s.to)
	if err != nil {
		slog.Error("smtp: failed to parse email", "err", err)
		return nil
	}

	// Generate event UUID for attachment storage.
	eventUUID := event.GenerateUUID()

	// Store attachments.
	if s.backend.attachments != nil && len(attachments) > 0 {
		for _, att := range attachments {
			path := eventUUID + "/" + att.Filename
			if err := s.backend.attachments.Store(path, att.content); err != nil {
				slog.Error("smtp: failed to store attachment", "err", err)
				continue
			}
			attUUID := event.GenerateUUID()
			if s.backend.db != nil {
				s.backend.db.Exec(
					`INSERT INTO smtp_attachments (uuid, event_uuid, name, path, size, mime, content_id) VALUES (?, ?, ?, ?, ?, ?, ?)`,
					attUUID, eventUUID, att.Filename, path, len(att.content), att.Type, att.ContentID,
				)
			}
		}
	}

	payload, _ := json.Marshal(parsed)

	inc := &event.Incoming{
		UUID:    eventUUID,
		Type:    "smtp",
		Payload: json.RawMessage(payload),
		Project: s.project,
	}

	if err := s.backend.eventService.HandleIncoming(context.Background(), inc); err != nil {
		slog.Error("smtp: failed to store event", "err", err)
	}
	return nil
}

func (s *session) Reset()        { s.from = ""; s.to = nil; s.project = "" }
func (s *session) Logout() error { return nil }