srctree

Gregory Mullen parent 23548660 10bf70a5
mqtt update with better connect API

build.zig added: 14, removed: 8, total 6
@@ -32,6 +32,7 @@ pub fn build(b: *std.Build) void {
.target = target,
.optimize = optimize,
});
exe_unit_tests.root_module.addImport("mqtt", dep_mqtt.module("mqtt"));
 
const run_exe_unit_tests = b.addRunArtifact(exe_unit_tests);
 
 
build.zig.zon added: 14, removed: 8, total 6
@@ -4,8 +4,8 @@
//.minimum_zig_version = "0.11.0",
.dependencies = .{
.mqtt = .{
.url = "git+https://github.com/GrayHatter/mqtt.git#b98e366f4eba92448f08092459d9c7cd5cc4b17d",
.hash = "122003852280b8cd47be5c5745c6a9964e8fbf526346214e5fafbf5024d730f9572a",
.url = "git+https://github.com/GrayHatter/mqtt.git#f80fc42464c4970f5f3b8baa94765be628f18342",
.hash = "1220cca633744f44332e2415ef922eefcb72694328d2368474677ea4b4231311c4da",
},
},
.paths = .{
 
src/zigbee.zig added: 14, removed: 8, total 6
@@ -4,11 +4,17 @@ pub fn main() !void {
log.err("startup", .{});
const a = std.heap.page_allocator;
 
var client = mqtt.Client.init(a, "localhost", 1883) catch |e| {
var client = mqtt.Client.init(a, "localhost", 1883, .{}) catch |e| {
log.err("unable to connect to host", .{});
return e;
};
try client.connect();
 
if (try client.connect()) {
try client.send(mqtt.Subscribe{ .channels = &.{"zigbee2mqtt/#"} });
} else {
log.err("Unable to connect", .{});
@panic("not possible");
}
 
var zigbee = Zigbee.init(a, &client);
 
@@ -17,7 +23,6 @@ pub fn main() !void {
.CONNACK => {
log.err("loop", .{});
log.err("CONNACK", .{});
try client.send(mqtt.Subscribe{ .channels = &.{"zigbee2mqtt/#"} });
},
.PUBLISH => |publ| {
//log.err("PUBLISH [{s}]", .{publ.topic_name});