integrate JWTKit with Vapor about jwt HOT 9 CLOSED

import Foundation
import Vapor
import JWT

final class JWTMiddleware: Middleware, Service {
    func respond(to request: Request, chainingTo next: Responder) throws -> Future<Response> {
        guard let authorization = request.http.headers["Authorization"].first,
            let bearer = authorization.split(separator: " ").first,
            let token = authorization.split(separator: " ").last, bearer == "Bearer"
            else { throw Abort(.unauthorized, reason: "No Authorization Header") }
        
        let jwt: JWTService = try request.make()
        let payload = try JWT<JWTAuthPayload>(from: String(token), verifiedUsing: jwt.signer).payload
        guard let userId = UUID(uuidString: payload.userId) else { throw Abort(.unauthorized, reason: "Invalid User") }
        return request.newConnection(to: .psql)
            .flatMap(to: User?.self) { con in
                return try User.find(userId, on: con)
            }.flatMap(to: Response.self) {
                if let u = $0 {
                    try request.authenticate(u)
                }
                _ = try request.requireAuthenticated(User.self)
                return try next.respond(to: request)
        }
    }
}

final class JWTService: Service {
    
    var signer: JWTSigner
    
    init(secret: String) throws {
        self.signer = JWTSigner.hs512(key: Data(secret.utf8))
    }
    
    func signUser<T: CanteenModel>(_ user: T, type: JWTAuthPayload.UserType) throws -> String {
        let expiration = ExpirationClaim(value: Date(timeIntervalSinceNow:(60 * 60 * 1))) // 60 minutes x 1 hour
        var jwt = JWT(payload:
            JWTAuthPayload(
                exp: expiration,
                userId: user.id?.uuidString ?? ""
            )
        )
        let data = try self.signer.sign(&jwt)
        return String(data: data, encoding: .utf8) ?? ""
    }
}

struct JWTAuthPayload: JWTPayload {
    enum CodingKeys: String, CodingKey {
        case exp
        case userId = "user_id"
    }
    
    var exp: ExpirationClaim
    var userId: String
    
    func verify() throws {
        try self.exp.verify()
    }
}