Function getSenderDeviceForSpecUser

clientapi/routing/group_master_notice.go:112–160

getSenderDeviceForSpecUser It returns an userapi.Device, which is used for building the event

(
	ctx context.Context,
	userId string,
	userAPI userapi.ClientUserAPI,
	cfg *config.ClientAPI,
)

// getSenderDeviceForSpecUser
// It returns an userapi.Device, which is used for building the event
func getSenderDeviceForSpecUser(
	ctx context.Context,
	userId string,
	userAPI userapi.ClientUserAPI,
	cfg *config.ClientAPI,
) (*userapi.Device, error) {
	// Check if we got existing devices
	deviceRes := &userapi.QueryDevicesResponse{}
	err := userAPI.QueryDevices(ctx, &userapi.QueryDevicesRequest{
		UserID: userId,
	}, deviceRes)
	if err != nil {
		return nil, err
	}

	if len(deviceRes.Devices) > 0 {
		return &deviceRes.Devices[0], nil
	}
	local, domain, err := gomatrixserverlib.SplitID('@', userId)
	if err != nil {
		return nil, err
	}
	if domain != cfg.Matrix.ServerName {
		return nil, errors.New("wrong servername")
	}
	// create an AccessToken
	token, err := tokens.GenerateLoginToken(tokens.TokenOptions{
		ServerPrivateKey: cfg.Matrix.PrivateKey.Seed(),
		ServerName:       string(cfg.Matrix.ServerName),
		UserID:           userId,
	})
	if err != nil {
		return nil, err
	}

	// create a new device, if we didn't find any
	var devRes userapi.PerformDeviceCreationResponse
	err = userAPI.PerformDeviceCreation(ctx, &userapi.PerformDeviceCreationRequest{
		Localpart:          local,
		DeviceDisplayName:  &local,
		AccessToken:        token,
		NoDeviceListUpdate: true,
	}, &devRes)

	if err != nil {
		return nil, err
	}
	return devRes.Device, nil
}