drivers/examples/sx128x/lora_rx/main.go at 9b03124979c92baaf8790f1c5c2398309795ff8b · jwetzell/drivers · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
package main

import (
	"errors"
	"machine"
	"runtime"
	"time"

	"tinygo.org/x/drivers/sx128x"
)

var (
	// pin mapping specific to the lilygo t3s3, change as needed for your board
	sdoPin   = machine.GPIO6
	sdiPin   = machine.GPIO3
	sckPin   = machine.GPIO5
	nssPin   = machine.GPIO7
	busyPin  = machine.GPIO36
	resetPin = machine.GPIO8
	dio1Pin  = machine.GPIO9
)

func setupPins() {
	nssPin.Configure(machine.PinConfig{Mode: machine.PinOutput})
	nssPin.Set(true)

	resetPin.Configure(machine.PinConfig{Mode: machine.PinOutput})
	resetPin.Set(true)

	busyPin.Configure(machine.PinConfig{Mode: machine.PinInput})
	dio1Pin.Configure(machine.PinConfig{Mode: machine.PinInput})
}

func main() {
	setupPins()

	spi := machine.SPI0
	spi.Configure(machine.SPIConfig{
		Mode:      0,
		Frequency: 8 * 1e6,
		SDO:       sdoPin,
		SDI:       sdiPin,
		SCK:       sckPin,
	})

	radio := sx128x.New(
		spi,
		nssPin,
		resetPin,
		busyPin,
	)

	radio.WaitWhileBusy(time.Second)
	SetupLora(radio)

	for {
		data, err := Rx(radio)
		if err != nil {
			println("failed to receive:", err)
		} else {
			println("received:", string(data))
		}
	}
}

func SetupLora(radio *sx128x.Device) {
	radio.SetStandby(sx128x.STANDBY_RC)
	radio.SetPacketType(sx128x.PACKET_TYPE_LORA)
	radio.SetRegulatorMode(sx128x.REGULATOR_DC_DC)

	radio.SetRfFrequency(2400000000) // 2.4Ghz
	radio.SetModulationParamsLoRa(sx128x.LORA_SF_9, sx128x.LORA_BW_1600, sx128x.LORA_CR_4_7)

	// section 14.4.1 shows required register setting for setting up LoRa operations. These depend on the chosen spreading factor.
	radio.WriteRegister(0x925, []byte{0x32})
	radio.WriteRegister(0x93C, []byte{0x01})

	radio.SetTxParams(13, sx128x.RADIO_RAMP_02_US)
	radio.SetPacketParamsLoRa(12, sx128x.LORA_HEADER_EXPLICIT, 0xFF, sx128x.LORA_CRC_DISABLE, sx128x.LORA_IQ_STD)
	radio.WriteRegister(sx128x.REG_LORA_SYNC_WORD_MSB, []byte{0x14, 0x24}) // full sync word is 0x1424

}

func Rx(radio *sx128x.Device) ([]byte, error) {
	radio.SetStandby(sx128x.STANDBY_RC)
	radio.SetDioIrqParams(sx128x.IRQ_RX_DONE_MASK|sx128x.IRQ_RX_TX_TIMEOUT_MASK, sx128x.IRQ_RX_DONE_MASK|sx128x.IRQ_RX_TX_TIMEOUT_MASK, 0x00, 0x00)
	radio.SetBufferBaseAddress(0, 0)
	radio.ClearIrqStatus(sx128x.IRQ_ALL_MASK)
	radio.SetRx(sx128x.PERIOD_BASE_4_MS, 250) // 4ms * 250 = 1s
	// busy wait for IRQ indication
	for dio1Pin.Get() == false {
		runtime.Gosched()
	}
	irqStatus, _ := radio.GetIrqStatus()
	if irqStatus&sx128x.IRQ_RX_DONE_MASK != 0 {
		payloadLength, bufferOffset, err := radio.GetRxBufferStatus()
		if err != nil {
			return nil, err
		}
		data, err := radio.ReadBuffer(bufferOffset, payloadLength)
		return data, nil
	} else if irqStatus&sx128x.IRQ_RX_TX_TIMEOUT_MASK != 0 {
		return nil, errors.New("rx timeout")
	}
	return nil, errors.New("unexpected IRQ status")
}