diff options
author | Navan Chauhan <navanchauhan@gmail.com> | 2023-12-12 13:07:40 -0700 |
---|---|---|
committer | Navan Chauhan <navanchauhan@gmail.com> | 2023-12-12 13:07:40 -0700 |
commit | 315e2510d577b7303f4b8204a4555aad26bc41a3 (patch) | |
tree | ec16e87bda839f71424d489d1e8dda96c69d504c /Sources/server.swift | |
parent | df466eba1bd4c9728fdb66e1a5fcf0e89203cf39 (diff) |
move files
Diffstat (limited to 'Sources/server.swift')
-rw-r--r-- | Sources/server.swift | 94 |
1 files changed, 0 insertions, 94 deletions
diff --git a/Sources/server.swift b/Sources/server.swift deleted file mode 100644 index c8cf97b..0000000 --- a/Sources/server.swift +++ /dev/null @@ -1,94 +0,0 @@ -// The Swift Programming Language -// https://docs.swift.org/swift-book - -import ArgumentParser -import Foundation -import Logging -import NIO - -@main -struct swiftGopher: ParsableCommand { - @Option(name: [.short, .long], help: "Hostname used for generating selectors") - var gopherHostName: String = "localhost" - @Option(name: [.short, .long]) - var host: String = "0.0.0.0" - @Option(name: [.short, .long]) - var port: Int = 8080 - @Option(name: [.customShort("d"), .long], help: "Data directory to map") - var gopherDataDir: String = "./example-gopherdata" - @Flag(help: "Disable full-text search feature") - var disableSearch: Bool = false - @Flag(help: "Disable reading gophermap files to override automatic generation") - var disableGophermap: Bool = false - - public mutating func run() throws { - let eventLoopGroup = MultiThreadedEventLoopGroup( - numberOfThreads: System.coreCount - ) - - defer { - try! eventLoopGroup.syncShutdownGracefully() - } - - let localGopherDataDir = gopherDataDir - let localGopherHostName = gopherHostName - let localPort = port - let localEnableSearch = !disableSearch - let localDisableGophermap = disableGophermap - - let logger = Logger(label: "com.navanchauhan.gopher.server") - - let serverBootstrap = ServerBootstrap( - group: eventLoopGroup - ) - .serverChannelOption( - ChannelOptions.backlog, - value: 256 - ) - .serverChannelOption( - ChannelOptions.socketOption( - .so_reuseaddr - ), - value: 1 - ) - .childChannelInitializer { channel in - channel.pipeline.addHandlers([ - BackPressureHandler(), - GopherHandler( - logger: logger, - gopherdata_dir: localGopherDataDir, - gopherdata_host: localGopherHostName, - gopherdata_port: localPort, - enableSearch: localEnableSearch, - disableGophermap: localDisableGophermap - ), - ]) - } - .childChannelOption( - ChannelOptions.socketOption( - .so_reuseaddr - ), - value: 1 - ) - .childChannelOption( - ChannelOptions.maxMessagesPerRead, - value: 16 - ) - .childChannelOption( - ChannelOptions.recvAllocator, - value: AdaptiveRecvByteBufferAllocator() - ) - - let defaultHost = host - let defaultPort = port - - let channel = try serverBootstrap.bind( - host: defaultHost, - port: defaultPort - ).wait() - - logger.info("Server started and listening on \(channel.localAddress!)") - try channel.closeFuture.wait() - logger.info("Server closed") - } -} |