Method StoreMonitor

api/pkg/services/heartbeat_service.go:182–212

StoreMonitor a new entities.HeartbeatMonitor

(ctx context.Context, params *HeartbeatMonitorStoreParams)

// StoreMonitor a new entities.HeartbeatMonitor
func (service *HeartbeatService) StoreMonitor(ctx context.Context, params *HeartbeatMonitorStoreParams) (*entities.HeartbeatMonitor, error) {
	ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger)
	defer span.End()

	monitor, scheduleCheck, err := service.phoneMonitor(ctx, params)
	if err != nil {
		msg := fmt.Sprintf("cannot create monitor for with userID [%s] and owner [%s]", params.UserID, params.Owner)
		return nil, service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
	}

	if !scheduleCheck {
		ctxLogger.Info(fmt.Sprintf("heartbeat monitor [%s] for owner [%s] does not need scheduling because it was updated at [%s]", monitor.ID, monitor.Owner, monitor.UpdatedAt))
		return monitor, nil
	}

	ctxLogger.Info(fmt.Sprintf("scheduling heartbeat monitor [%s] for owner [%s] and user [%s]", monitor.ID, monitor.Owner, monitor.UserID))

	monitorParams := &HeartbeatMonitorParams{
		Owner:     monitor.Owner,
		PhoneID:   monitor.PhoneID,
		UserID:    monitor.UserID,
		MonitorID: monitor.ID,
		Source:    params.Source,
	}
	if err = service.scheduleHeartbeatCheck(ctx, time.Now().UTC(), monitorParams); err != nil {
		msg := fmt.Sprintf("cannot schedule healthcheck for monitor [%s] with owner [%s] and userID [%s]", monitor.ID, params.Owner, params.UserID)
		return nil, service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
	}

	return monitor, nil
}

func (service *HeartbeatService) phoneMonitor(ctx context.Context, params *HeartbeatMonitorStoreParams) (*entities.HeartbeatMonitor, bool, error) {
	ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger)