|
| 1 | +from memory import UnsafePointer |
| 2 | +from utils import StaticTuple |
| 3 | + |
| 4 | +from libc import ( |
| 5 | + AF_INET, |
| 6 | + AI_PASSIVE, |
| 7 | + SOCK_STREAM, |
| 8 | + SHUT_RDWR, |
| 9 | + addrinfo, |
| 10 | + c_char, |
| 11 | + connect, |
| 12 | + getaddrinfo, |
| 13 | + htons, |
| 14 | + in_addr, |
| 15 | + sizeof, |
| 16 | + sockaddr, |
| 17 | + sockaddr_in, |
| 18 | + socket, |
| 19 | + shutdown, |
| 20 | +) |
| 21 | + |
| 22 | + |
| 23 | +fn get_ip_address(host: String) raises -> in_addr: |
| 24 | + var host_ptr = host.unsafe_cstr_ptr() |
| 25 | + var my_addrinfo = addrinfo() |
| 26 | + var servinfo = UnsafePointer[addrinfo]().alloc(1) |
| 27 | + servinfo.init_pointee_move(my_addrinfo) |
| 28 | + |
| 29 | + var hints = addrinfo() |
| 30 | + hints.ai_family = AF_INET |
| 31 | + hints.ai_socktype = SOCK_STREAM |
| 32 | + hints.ai_flags = AI_PASSIVE |
| 33 | + |
| 34 | + var error = getaddrinfo( |
| 35 | + host_ptr, |
| 36 | + UnsafePointer[c_char](), |
| 37 | + UnsafePointer.address_of(hints), |
| 38 | + UnsafePointer.address_of(servinfo), |
| 39 | + ) |
| 40 | + if error != 0: |
| 41 | + raise Error("getaddrinfo failed: {}".format(error)) |
| 42 | + |
| 43 | + var addrinfo = servinfo[] |
| 44 | + var ai_addr = addrinfo.ai_addr |
| 45 | + |
| 46 | + return ai_addr.bitcast[sockaddr_in]()[].sin_addr |
| 47 | + |
| 48 | + |
| 49 | +fn main() raises: |
| 50 | + var ip: in_addr |
| 51 | + var host = "localhost" |
| 52 | + var port = 8080 |
| 53 | + print("Connecting to ", host, " on port ", port) |
| 54 | + |
| 55 | + ip = get_ip_address(host) |
| 56 | + |
| 57 | + # Convert ip address to network byte order. |
| 58 | + var addr: sockaddr_in = sockaddr_in( |
| 59 | + AF_INET, htons(port), ip, StaticTuple[c_char, 8](0, 0, 0, 0, 0, 0, 0, 0) |
| 60 | + ) |
| 61 | + var addr_ptr = UnsafePointer[sockaddr_in].address_of(addr).bitcast[sockaddr]() |
| 62 | + var sock = socket(AF_INET, SOCK_STREAM, 0) |
| 63 | + |
| 64 | + if connect(sock, addr_ptr, sizeof[sockaddr_in]()) == -1: |
| 65 | + print("Failed to connect to server") |
| 66 | + else: |
| 67 | + print("Connected to server") |
| 68 | + |
| 69 | + _ = shutdown(sock, SHUT_RDWR) |
0 commit comments