sylveos

nrf-client.zig (1400B)

---

 const std = @import("std");
 const shared = @import("shared");
 const pi = @import("pi");
 
 const nrf = pi.devices.nrf;
 const clock = pi.devices.clock;
 const uart = pi.devices.mini_uart;
 
 fn wait_for_ans(client_dev: *nrf.Device) !u8 {
     var buffer: [4]u8 = undefined;
 
     while (true) {
         const bytes_collected = client_dev.receive(&buffer) catch |err| {
             if (err == nrf.Error.NotReady) continue;
             return err;
         };
         if (bytes_collected == 4) break;
         if (bytes_collected > 0) {
             uart.print("read: {d}\n", .{bytes_collected});
         }
 
         clock.delay_ms(1);
     }
 
     return buffer[3];
 }
 
 // Server:
 // CS - 8
 // CE - 6
 //
 // Client:
 // CS - 7
 // CE - 5
 pub fn main() !void {
     uart.print("creating client\n", .{});
 
     const client_addr = 0xE5E5E5E5E5;
 
     var client_dev: nrf.Device = try .init(.{
         .spi_config = .{
             .chip_select = .@"1",
             .pins = .Lower,
         },
         .ce_pin = 5,
         .int_pin = 22,
         .payload_size = 4,
     });
     uart.print("initialized client\n", .{});
 
     try client_dev.set_rx_addr(0, client_addr);
     client_dev.connect();
 
     while (true) {
         const b = try wait_for_ans(&client_dev);
 
         uart.print("got byte: {c}\n", .{b});
 
         clock.delay_ms(10);
 
         if (b == '\r') break;
     }
 
     uart.print("done!\n", .{});
     uart.flush();
 }