From 89d14d0e1c6f70ee2039dd1683d10781e1d39807 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=C3=81d=C3=A1m=20Kov=C3=A1cs?= <kovacsadam07@outlook.hu>
Date: Sat, 29 Mar 2025 17:55:25 +0100
Subject: [PATCH] feat: succesfull http request

---
 src/main.zig | 114 +++++++++++++++++++++++++++++++++++++++------------
 1 file changed, 88 insertions(+), 26 deletions(-)

diff --git a/src/main.zig b/src/main.zig
index 943018a..3c120f8 100644
--- a/src/main.zig
+++ b/src/main.zig
@@ -5,6 +5,14 @@ pub const p = @cImport({
     // PICO W specific header
     @cInclude("pico/cyw43_arch.h");
 });
+
+const c = @cImport({
+    @cInclude("pico/cyw43_arch.h");
+    @cInclude("lwip/init.h");
+    @cInclude("lwip/tcp.h");
+    @cInclude("lwip/dns.h");
+});
+
 const std = @import("std");
 const BUTTON_PIN = 15;
 const GPIO_IN = false;
@@ -27,6 +35,7 @@ export fn main() c_int {
     p.cyw43_arch_gpio_put(p.CYW43_WL_GPIO_LED_PIN, true);
     p.sleep_ms(200);
     p.cyw43_arch_gpio_put(p.CYW43_WL_GPIO_LED_PIN, false);
+    p.sleep_ms(200);
 
     p.gpio_init(BUTTON_PIN);
     p.gpio_set_dir(BUTTON_PIN, GPIO_IN);
@@ -39,7 +48,13 @@ export fn main() c_int {
     // }
     // _ = p.printf("Hello world\n");
 
-    httpRequest();
+    // httpRequest();
+    main2();
+
+    p.cyw43_arch_gpio_put(p.CYW43_WL_GPIO_LED_PIN, true);
+    p.sleep_ms(200);
+    p.cyw43_arch_gpio_put(p.CYW43_WL_GPIO_LED_PIN, false);
+    p.sleep_ms(200);
 
     while (true) {
         while (p.gpio_get(BUTTON_PIN)) {
@@ -50,30 +65,77 @@ export fn main() c_int {
     }
 }
 
-fn httpRequest() !void {
+fn httpRequest() void {
     // Create a general purpose allocator
-    var gpa = std.heap.GeneralPurposeAllocator(.{}){};
-    defer _ = gpa.deinit();
-
-    // Create a HTTP client
-    var client = std.http.Client{ .allocator = gpa.allocator() };
-    defer client.deinit();
-
-    // Allocate a buffer for server headers
-    var buf: [4096]u8 = undefined;
-
-    // Start the HTTP request
-    const uri = try std.Uri.parse("https://www.google.com?q=zig");
-    var req = try client.open(.GET, uri, .{ .server_header_buffer = &buf });
-    defer req.deinit();
-
-    // Send the HTTP request headers
-    try req.send();
-    // Finish the body of a request
-    try req.finish();
-
-    // Waits for a response from the server and parses any headers that are sent
-    try req.wait();
-
-    std.debug.print("status={d}\n", .{req.response.status});
+    // var gpa = std.heap.GeneralPurposeAllocator(.{}){};
+    // defer _ = gpa.deinit();
+    //
+    // // Create a HTTP client
+    // var client = std.http.Client{ .allocator = gpa.allocator() };
+    // defer client.deinit();
+    //
+    // // Allocate a buffer for server headers
+    // var buf: [4096]u8 = undefined;
+    //
+    // // Start the HTTP request
+    // const uri = try std.Uri.parse("https://www.google.com?q=zig");
+    // var req = try client.open(.GET, uri, .{ .server_header_buffer = &buf });
+    // defer req.deinit();
+    //
+    // // Send the HTTP request headers
+    // try req.send();
+    // // Finish the body of a request
+    // try req.finish();
+    //
+    // // Waits for a response from the server and parses any headers that are sent
+    // try req.wait();
+    //
+    // std.debug.print("status={d}\n", .{req.response.status});
+}
+
+
+fn tcp_recv_callback(_: ?*anyopaque, pcb: ?*c.tcp_pcb, p1: ?*c.pbuf, _: c.err_t) callconv(.C) c.err_t {
+    if (p1 == null) {
+        _ = c.tcp_close(pcb);
+        return c.ERR_OK;
+    }
+    defer { _ = c.pbuf_free(p1); }
+    // std.debug.print("Received data: {s}\n", .{@ptrCast([*]const u8, p1.?.payload)});
+    return c.ERR_OK;
+}
+
+fn send_http_request(pcb: ?*c.tcp_pcb) void {
+    const request = "POST /todo-channel-name HTTP/1.1\r\nHost: ntfy.sh\r\nTitle: Csengo\r\nContent-Length: 6\r\n\r\nCsengo";
+    _ = c.tcp_write(pcb, request, request.len, c.TCP_WRITE_FLAG_COPY);
+    _ = c.tcp_output(pcb);
+
+    p.cyw43_arch_gpio_put(p.CYW43_WL_GPIO_LED_PIN, true);
+    p.sleep_ms(1000);
+    p.cyw43_arch_gpio_put(p.CYW43_WL_GPIO_LED_PIN, false);
+    p.sleep_ms(1000);
+}
+
+fn tcp_connected_callback(_: ?*anyopaque, pcb: ?*c.tcp_pcb, err: c.err_t) callconv(.C) c.err_t {
+    if (err != c.ERR_OK) {
+        return err;
+    }
+    // std.debug.print("Connected to server\n", .{});
+    _ = c.tcp_recv(pcb, tcp_recv_callback);
+    send_http_request(pcb);
+    return c.ERR_OK;
+}
+
+
+
+fn dns_callback(_: [*c]const u8, ipaddr: [*c]const c.struct_ip4_addr, _: ?*anyopaque) callconv(.C) void {
+    if (ipaddr) |addr| {
+        const pcb = c.tcp_new();
+        if (pcb == null) {
+            return;
+        }
+        _ = c.tcp_connect(pcb, addr, 80, tcp_connected_callback);
+    } }
+
+pub fn main2() void {
+    _ = c.dns_gethostbyname("ntfy.sh", null, dns_callback, null);
 }