Method HandleJoin

pkg/joinserver/joinserver.go:235–658

HandleJoin handles the given join-request.

(ctx context.Context, req *ttnpb.JoinRequest, authorizer Authorizer)

// HandleJoin handles the given join-request.
func (js *JoinServer) HandleJoin(ctx context.Context, req *ttnpb.JoinRequest, authorizer Authorizer) (res *ttnpb.JoinResponse, err error) {
	if err := authorizer.RequireAuthorized(ctx); err != nil {
		return nil, err
	}

	logger := log.FromContext(ctx)
	defer func() {
		if err != nil {
			registerRejectJoin(ctx, req, err)
		}
	}()

	supported := false
	for _, ver := range supportedMACVersions {
		if req.SelectedMacVersion == ver {
			supported = true
			break
		}
	}
	if !supported {
		return nil, errUnsupportedMACVersion.WithAttributes("version", req.SelectedMacVersion)
	}

	req.Payload = &ttnpb.Message{}
	if err = lorawan.UnmarshalMessage(req.RawPayload, req.Payload); err != nil {
		return nil, errDecodePayload.WithCause(err)
	}

	if req.Payload.MHdr.Major != ttnpb.Major_LORAWAN_R1 {
		return nil, errUnsupportedLoRaWANMajorVersion.WithAttributes("major", req.Payload.MHdr.Major)
	}
	if req.Payload.MHdr.MType != ttnpb.MType_JOIN_REQUEST {
		return nil, errWrongPayloadType.WithAttributes("type", req.Payload.MHdr.MType)
	}

	pld := req.Payload.GetJoinRequestPayload()
	if pld == nil {
		return nil, errNoJoinRequest.New()
	}
	devEUI := types.MustEUI64(pld.DevEui).OrZero()
	if devEUI.IsZero() {
		return nil, errNoDevEUI.New()
	}
	joinEUI := types.MustEUI64(pld.JoinEui).OrZero()
	logger = logger.WithFields(log.Fields(
		"join_eui", joinEUI,
		"dev_eui", devEUI,
	))

	var match bool
	for _, p := range js.euiPrefixes {
		if p.Matches(joinEUI) {
			match = true
			break
		}
	}
	if !match {
		return nil, errUnknownJoinEUI.New()