Method phoneMonitor

api/pkg/services/heartbeat_service.go:214–245

(ctx context.Context, params *HeartbeatMonitorStoreParams)

}

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

	monitor, err := service.monitorRepository.Load(ctx, params.UserID, params.Owner)
	if stacktrace.GetCode(err) == repositories.ErrCodeNotFound {
		monitor = &entities.HeartbeatMonitor{
			ID:          uuid.New(),
			PhoneID:     params.PhoneID,
			UserID:      params.UserID,
			Owner:       params.Owner,
			PhoneOnline: true,
			CreatedAt:   time.Now().UTC(),
			UpdatedAt:   time.Now().UTC(),
		}

		if err = service.monitorRepository.Store(ctx, monitor); err != nil {
			msg := fmt.Sprintf("cannot save heartbeat monitor for owner [%s] and user [%s]", monitor.Owner, monitor.UserID)
			return nil, false, service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
		}

		ctxLogger.Info(fmt.Sprintf("heartbeat monitor saved with id [%s] for owner [%s] and user [%s]", monitor.ID, monitor.Owner, monitor.UserID))
		return monitor, true, nil
	}

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

	return monitor, monitor.RequiresCheck(), nil
}

// DeleteMonitor an entities.HeartbeatMonitor
func (service *HeartbeatService) DeleteMonitor(ctx context.Context, userID entities.UserID, owner string) error {