Skip to content

Commit 8fc335d

Browse files
committed
fix packaging errors
1 parent c816ab2 commit 8fc335d

File tree

10 files changed

+45
-47
lines changed

10 files changed

+45
-47
lines changed

external/libc.mojo

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ alias FD_STDERR: c_int = 2
1111
alias SUCCESS = 0
1212
alias GRND_NONBLOCK: UInt8 = 1
1313

14-
alias char_pointer = AnyPointer[c_char]
14+
alias char_pointer = UnsafePointer[c_char]
1515

1616
# Adapted from https://github.com/crisadamo/mojo-Libc . Huge thanks to Cristian!
1717
# C types

lightbug.🔥

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,14 @@
11
from lightbug_http import *
2+
from sys import is_defined
23

34
fn main() raises:
4-
var server = SysServer()
5-
var handler = Welcome()
6-
server.listen_and_serve("0.0.0.0:8080", handler)
5+
if is_defined["TEST"]():
6+
try:
7+
run_tests()
8+
print("Test suite passed")
9+
except e:
10+
print("Test suite failed: " + e.__str__())
11+
else:
12+
var server = SysServer()
13+
var handler = Welcome()
14+
server.listen_and_serve("0.0.0.0:8080", handler)

lightbug_http/__init__.mojo

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
from lightbug_http.http import HTTPRequest, HTTPResponse, OK
22
from lightbug_http.service import HTTPService, Welcome
33
from lightbug_http.sys.server import SysServer
4-
4+
from lightbug_http.tests.run import run_tests
55

66
trait DefaultConstructible:
77
fn __init__(inout self) raises:

lightbug_http/http.mojo

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,6 @@
11
from time import now
22
from external.morrow import Morrow
3-
43
from external.gojo.strings import StringBuilder
5-
6-
# from external.gojo.builtins import Bytes
7-
# import external.gojo.io
84
from lightbug_http.uri import URI
95
from lightbug_http.io.bytes import Bytes
106
from lightbug_http.header import RequestHeader, ResponseHeader

lightbug_http/python/__init__.mojo

Lines changed: 15 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -6,16 +6,24 @@ struct Modules:
66
var builtins: PythonObject
77
var socket: PythonObject
88

9-
fn __init__(inout self) raises -> None:
9+
fn __init__(inout self) -> None:
1010
self.builtins = self.__load_builtins()
1111
self.socket = self.__load_socket()
1212

1313
@staticmethod
14-
fn __load_socket() raises -> PythonObject:
15-
var socket = Python.import_module("socket")
16-
return socket
14+
fn __load_socket() -> PythonObject:
15+
try:
16+
var socket = Python.import_module("socket")
17+
return socket
18+
except e:
19+
print("Failed to import socket module")
20+
return None
1721

1822
@staticmethod
19-
fn __load_builtins() raises -> PythonObject:
20-
var builtins = Python.import_module("builtins")
21-
return builtins
23+
fn __load_builtins() -> PythonObject:
24+
try:
25+
var builtins = Python.import_module("builtins")
26+
return builtins
27+
except e:
28+
print("Failed to import builtins module")
29+
return None

lightbug_http/python/net.mojo

Lines changed: 8 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ struct PythonTCPListener:
4242
self.socket = socket
4343

4444
@always_inline
45-
fn accept[T: Connection](self) raises -> T:
45+
fn accept(self) raises -> PythonConnection:
4646
var conn_addr = self.socket.accept()
4747
return PythonConnection(self.__pymodules, conn_addr)
4848

@@ -55,16 +55,16 @@ struct PythonTCPListener:
5555
return self.__addr
5656

5757

58-
struct PythonListenConfig(ListenConfig):
58+
struct PythonListenConfig:
5959
var __pymodules: Modules
6060
var __keep_alive: Duration
6161

62-
fn __init__(inout self) raises:
63-
self.__keep_alive = Duration(default_tcp_keep_alive)
62+
fn __init__(inout self):
63+
self.__keep_alive = default_tcp_keep_alive
6464
self.__pymodules = Modules()
6565

66-
fn __init__(inout self, keep_alive: Duration) raises:
67-
self.__keep_alive = Duration(keep_alive)
66+
fn __init__(inout self, keep_alive: Duration):
67+
self.__keep_alive = keep_alive
6868
self.__pymodules = Modules()
6969

7070
fn listen(inout self, network: String, address: String) raises -> PythonTCPListener:
@@ -132,14 +132,11 @@ struct PythonConnection(Connection):
132132
return TCPAddr(self.raddr[0].__str__(), self.raddr[1].__int__())
133133

134134

135-
struct PythonNet(Net):
135+
struct PythonNet:
136136
var __lc: PythonListenConfig
137137

138138
fn __init__(inout self):
139-
try:
140-
self.__lc = PythonListenConfig(default_tcp_keep_alive)
141-
except e:
142-
print("Could not initialize PythonListenConfig: " + e.__str__())
139+
self.__lc = PythonListenConfig(default_tcp_keep_alive)
143140

144141
fn __init__(inout self, keep_alive: Duration) raises:
145142
self.__lc = PythonListenConfig(keep_alive)

lightbug_http/python/server.mojo

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ struct PythonServer:
6767
self.ln = ln
6868

6969
while True:
70-
var conn = self.ln.accept[PythonConnection]()
70+
var conn = self.ln.accept()
7171
var buf = Bytes()
7272
var read_len = conn.read(buf)
7373
var first_line_and_headers = next_line(buf)

lightbug_http/sys/net.mojo

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -232,7 +232,7 @@ struct SysConnection(Connection):
232232
return self.raddr
233233

234234

235-
struct SysNet(Net):
235+
struct SysNet:
236236
var __lc: SysListenConfig
237237

238238
fn __init__(inout self) raises:
@@ -409,7 +409,7 @@ fn create_connection(sock: c_int, host: String, port: UInt16) raises -> SysConne
409409
print("Connected to server at " + host + ":" + port.__str__())
410410

411411
var laddr = TCPAddr()
412-
var raddr = TCPAddr(host, port.to_int())
412+
var raddr = TCPAddr(host, int(port))
413413
var conn = SysConnection(sock, laddr, raddr)
414414

415415
return conn

lightbug_http/tests/run.mojo

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -17,11 +17,3 @@ fn run_client_tests() raises:
1717
# test_mojo_client_lightbug_external_req(mojo_client)
1818
test_mojo_client_lightbug(mojo_client)
1919
test_python_client_lightbug(py_client)
20-
21-
22-
fn main():
23-
try:
24-
run_tests()
25-
print("Test suite passed")
26-
except e:
27-
print("Test suite failed: " + e.__str__())

lightbug_http/tests/utils.mojo

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -113,10 +113,7 @@ struct FakeServer(ServerTrait):
113113
fn __init__(
114114
inout self, addr: String, service: HTTPService, error_handler: ErrorHandler
115115
):
116-
try:
117-
self.__listener = FakeListener()
118-
except e:
119-
print(e)
116+
self.__listener = FakeListener()
120117
self.__handler = FakeResponder()
121118

122119
fn get_concurrency(self) -> Int:
@@ -128,7 +125,7 @@ struct FakeServer(ServerTrait):
128125
fn serve(inout self) -> None:
129126
while not self.__listener.closed:
130127
try:
131-
_ = self.__listener.accept[FakeConnection]()
128+
_ = self.__listener.accept()
132129
except e:
133130
print(e)
134131

@@ -175,23 +172,23 @@ struct FakeListener:
175172
var request: Bytes
176173
var closed: Bool
177174

178-
fn __init__(inout self) raises:
175+
fn __init__(inout self):
179176
self.request_count = 0
180177
self.request = Bytes()
181178
self.closed = False
182179

183-
fn __init__(inout self, addr: TCPAddr) raises:
180+
fn __init__(inout self, addr: TCPAddr):
184181
self.request_count = 0
185182
self.request = Bytes()
186183
self.closed = False
187184

188-
fn __init__(inout self, request_count: Int, request: Bytes) -> None:
185+
fn __init__(inout self, request_count: Int, request: Bytes):
189186
self.request_count = request_count
190187
self.request = request
191188
self.closed = False
192189

193190
@always_inline
194-
fn accept[T: Connection](self) raises -> T:
191+
fn accept(self) raises -> FakeConnection:
195192
return FakeConnection()
196193

197194
fn close(self) raises:

0 commit comments

Comments
 (0)