logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-06-30 22:39:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix format

Browse Source
This commit is contained in:
Arnaud 2026-05-12 10:25:02 +04:00
parent 0ce3139a82
commit adf1b79930
No known key found for this signature in database
GPG Key ID: A6C7C781817146FA
3 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
storage/rest/api.nim
View File

@ -646,7 +646,8 @@ proc initDebugApi(
RestApiResponse.error(Http400, "Missing filtering value", headers = headers)
let behavior = FilteringBehavior.fromString(filtering).valueOr:
return RestApiResponse.error(Http400, "Invalid filtering value", headers = headers)
return
RestApiResponse.error(Http400, "Invalid filtering value", headers = headers)
natSimulation.setFiltering(behavior)
return RestApiResponse.response("", headers = headers)

5
storage/storage.nim
View File

@ -253,8 +253,9 @@ proc new*(
var natRouter: Option[NatRouter]
let switch =
if config.natSimulation.isSome:
let filtering = FilteringBehavior.fromString(config.natSimulation.get)
.valueOr(AddressAndPortDependent)
let filtering = FilteringBehavior.fromString(config.natSimulation.get).valueOr(
AddressAndPortDependent
)
let router = NatRouter.new(filtering)
natRouter = some(router)
switchBuilder

16
storage/utils/natsimulation.nim
View File

@ -21,12 +21,18 @@ type NatTransport* = ref object of Transport
tcp: TcpTransport
router: NatRouter
proc fromString*(T: type FilteringBehavior, s: string): Result[FilteringBehavior, string] =
proc fromString*(
T: type FilteringBehavior, s: string
): Result[FilteringBehavior, string] =
case s
of "endpoint-independent": ok(EndpointIndependent)
of "address-dependent": ok(AddressDependent)
of "address-and-port-dependent": ok(AddressAndPortDependent)
else: err("Unknown filtering behavior: " & s)
of "endpoint-independent":
ok(EndpointIndependent)
of "address-dependent":
ok(AddressDependent)
of "address-and-port-dependent":
ok(AddressAndPortDependent)
else:
err("Unknown filtering behavior: " & s)
proc new*(T: type NatRouter, filtering: FilteringBehavior): T =
T(filtering: filtering)