Chapter 16 sources

Author: tib

Chapter 16/MyProjectClient/iOS/Assets/MyProject.entitlements

@@ -2,6 +2,8 @@
 <!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
 <plist version="1.0">
 <dict>
+	<key>aps-environment</key>
+	<string>development</string>
 	<key>com.apple.developer.applesignin</key>
 	<array>
 		<string>Default</string>

Chapter 16/MyProjectClient/iOS/Sources/AppDelegate.swift

@@ -10,13 +10,16 @@ import UIKit
 
 @UIApplicationMain
 class AppDelegate: UIResponder {
-    
+    var accountView: AccountView?
 }
 
 extension AppDelegate: UIApplicationDelegate {
 
     func application(_ application: UIApplication,
                      didFinishLaunchingWithOptions launchOptions: [UIApplication.LaunchOptionsKey: Any]?) -> Bool {
+        
+        application.registerForRemoteNotifications()
+   
         return true
     }
 
@@ -26,5 +29,20 @@ extension AppDelegate: UIApplicationDelegate {
         return .init(name: "Default Configuration",
                      sessionRole: connectingSceneSession.role)
     }
+    
+    func application(_ application: UIApplication, didRegisterForRemoteNotificationsWithDeviceToken deviceToken: Data) {
+        let token = deviceToken.map { String(format: "%02.2hhx", $0) }.joined()
+        print(token)
+        UserDefaults.standard.set(token, forKey: "device-token")
+        UserDefaults.standard.synchronize()
+        self.accountView = App.shared.modules.account() as? AccountView
+        self.accountView?.presenter?.registerUserDevice() { [unowned self] in
+            self.accountView = nil
+        }
+    }
+    
+    func application(_ application: UIApplication, didFailToRegisterForRemoteNotificationsWithError error: Error) {
+        print(error)
+    }
 }
 

Chapter 16/MyProjectClient/iOS/Sources/Modules/Account/AccountInteractor.swift

@@ -21,4 +21,10 @@ extension AccountInteractor: AccountInteractorPresenterInterface {
         .mapError { $0 as Error }
         .eraseToAnyPublisher()
     }
+    
+    func register(deviceToken: String, bearerToken: String) -> AnyPublisher<Void, Error> {
+        self.services.api.register(deviceToken: deviceToken, bearerToken: bearerToken)
+        .mapError { $0 as Error }
+        .eraseToAnyPublisher()
+    }
 }

Chapter 16/MyProjectClient/iOS/Sources/Modules/Account/AccountModule.swift

@@ -29,12 +29,14 @@ protocol AccountPresenterViewInterface: PresenterViewInterface {
     func close()
     func signIn(token: String)
     func logout()
+    func registerUserDevice(_ block: @escaping (() -> Void))
 }
 
 // MARK: - interactor
 
 protocol AccountInteractorPresenterInterface: InteractorPresenterInterface {
     func signIn(token: String) -> AnyPublisher<String, Error>
+    func register(deviceToken: String, bearerToken: String) -> AnyPublisher<Void, Error>
 }
 
 // MARK: - view

Chapter 16/MyProjectClient/iOS/Sources/Modules/Account/AccountPresenter.swift

@@ -64,4 +64,24 @@ extension AccountPresenter: AccountPresenterViewInterface {
         UserDefaults.standard.synchronize()
         self.view.displayLogin()
     }
+    
+    func registerUserDevice(_ block: @escaping (() -> Void)) {
+        guard
+            let bearerToken = UserDefaults.standard.string(forKey: "user-token"),
+            let deviceToken = UserDefaults.standard.string(forKey: "device-token")
+        else {
+            return
+        }
+        self.operations["device"] = self.interactor.register(deviceToken: deviceToken, bearerToken: bearerToken)
+        .sink(receiveCompletion: { [weak self] completion in
+            switch completion {
+            case .finished:
+                print("Device registered.")
+            case .failure(let error):
+                print(error)
+            }
+            self?.operations.removeValue(forKey: "device")
+            block()
+        }) { _ in }
+    }
 }

Chapter 16/MyProjectClient/iOS/Sources/Modules/Account/AccountView.swift

@@ -8,6 +8,7 @@
 import Foundation
 import UIKit
 import AuthenticationServices
+import UserNotifications
 
 final class AccountView: UIViewController, ViewInterface {
 
@@ -50,6 +51,7 @@ final class AccountView: UIViewController, ViewInterface {
         self.view.backgroundColor = .systemBackground
 
         self.navigationItem.rightBarButtonItem = .init(barButtonSystemItem: .close, target: self, action: #selector(self.close))
+        self.navigationItem.leftBarButtonItem = .init(barButtonSystemItem: .fastForward, target: self, action: #selector(self.notif))
 
         self.logoutButton.setTitle("Logout", for: .normal)
         self.logoutButton.addTarget(self, action: #selector(self.logout), for: .touchUpInside)
@@ -65,6 +67,13 @@ final class AccountView: UIViewController, ViewInterface {
     @objc func logout() {
         self.presenter.logout()
     }
+    
+    @objc func notif() {
+        let notif = UNUserNotificationCenter.current()
+        notif.requestAuthorization(options: [.badge, .sound, .alert]) { granted, error in
+            // check if granted or error happened
+        }
+    }
 
     @objc func siwa() {
         let provider = ASAuthorizationAppleIDProvider()

Chapter 16/MyProjectClient/iOS/Sources/Modules/Root/RootView.swift

@@ -133,12 +133,12 @@ extension RootView: UITableViewDataSource {
         cell.coverView.image = defaultImage
 
         self.operations["cell-\(indexPath.row)"]?.cancel()
-        self.operations["cell-\(indexPath.row)"] = URLSession.shared
-            .downloadTaskPublisher(for: item.imageUrl)
-            .map { UIImage(contentsOfFile: $0.url.path) ?? defaultImage  }
-            .replaceError(with: defaultImage)
-            .receive(on: DispatchQueue.main)
-            .assign(to: \.image, on: cell.coverView)
+//        self.operations["cell-\(indexPath.row)"] = URLSession.shared
+//            .downloadTaskPublisher(for: item.imageUrl)
+//            .map { UIImage(contentsOfFile: $0.url.path) ?? defaultImage  }
+//            .replaceError(with: defaultImage)
+//            .receive(on: DispatchQueue.main)
+//            .assign(to: \.image, on: cell.coverView)
 
         return cell
     }

Chapter 16/MyProjectClient/iOS/Sources/Services/Api/ApiServiceInterface.swift

@@ -28,4 +28,5 @@ protocol ApiServiceInterface: ServiceInterface {
 
     func getBlogPosts() -> AnyPublisher<Page<BlogPostListObject>, HTTP.Error>
     func siwa(token: String) -> AnyPublisher<UserToken, HTTP.Error>
+    func register(deviceToken: String, bearerToken: String) -> AnyPublisher<Void, HTTP.Error>
 }

Chapter 16/MyProjectClient/iOS/Sources/Services/Api/MyProject/MyProjectApiService.swift

@@ -58,8 +58,9 @@ final class MyProjectApiService: ApiServiceInterface {
         let url = URL(string: self.baseUrl + "/user/sign-in-with-apple")!
         var request = URLRequest(url: url)
         request.httpMethod = HTTP.Method.post.rawValue.uppercased()
+        request.addValue("application/json", forHTTPHeaderField: "Content-Type")
         request.httpBody = try! JSONEncoder().encode(Body(idToken: token))
-        
+
         return URLSession.shared.dataTaskPublisher(for: request)
         .tryMap { data, response in
             guard let httpResponse = response as? HTTPURLResponse else {
@@ -79,4 +80,36 @@ final class MyProjectApiService: ApiServiceInterface {
         }
         .eraseToAnyPublisher()
     }
+    
+    func register(deviceToken: String, bearerToken: String) -> AnyPublisher<Void, HTTP.Error> {
+        struct Body: Codable {
+            let token: String
+        }
+
+        let url = URL(string: self.baseUrl + "/user/devices")!
+        var request = URLRequest(url: url)
+        request.httpMethod = HTTP.Method.post.rawValue.uppercased()
+        request.addValue("Bearer \(bearerToken)", forHTTPHeaderField: "Authorization")
+        request.addValue("application/json", forHTTPHeaderField: "Content-Type")
+        request.httpBody = try! JSONEncoder().encode(Body(token: deviceToken))
+
+        return URLSession.shared.dataTaskPublisher(for: request)
+        .tryMap { data, response in
+            guard let httpResponse = response as? HTTPURLResponse else {
+                throw HTTP.Error.invalidResponse
+            }
+            guard httpResponse.statusCode == 200 else {
+                throw HTTP.Error.statusCode(httpResponse.statusCode)
+            }
+            return ()
+        }
+        .mapError { error -> HTTP.Error in
+            if let httpError = error as? HTTP.Error {
+                return httpError
+            }
+            return HTTP.Error.unknown(error)
+        }
+        .eraseToAnyPublisher()
+    }
+
 }

Chapter 16/MyProjectClient/iOS/Sources/Services/ServiceBuilder.swift

@@ -11,6 +11,6 @@ import Foundation
 final class ServiceBuilder: ServiceBuilderInterface {
 
     lazy var api: ApiServiceInterface = {
-        MyProjectApiService(baseUrl: "http://localhost:8080/api")
+        MyProjectApiService(baseUrl: "http://192.168.0.129:3000/api")
     }()
 }

Chapter 16/myProject/.env.development

@@ -6,9 +6,13 @@ FS_NAME=vaportestbucket
 FS_REGION=us-west-1
 AWS_KEY=my-key
 AWS_SECRET=my-secret
-SIWA_ID=com.example.myproject.service
-SIWA_APP_ID=com.example.myproject.ios
+SIWA_ID=com.example.service
+SIWA_APP_ID=com.example.ios.app
 SIWA_REDIRECT_URL=https://localhost/redirect
 SIWA_TEAM_ID=team-id
 SIWA_JWK_ID=jwk-id
 SIWA_KEY=base-64-encoded-key
+APNS_KEY_ID=key-id
+APNS_TEAM_ID=team-id
+APNS_TOPIC=ios-bundle-identifier
+APNS_KEY=base-64-encoded-key

Chapter 16/myProject/Sources/App/Extensions/Environment+App.swift

@@ -11,12 +11,16 @@ extension Environment {
 
     static let awsKey = Self.get("AWS_KEY")!
     static let awsSecret = Self.get("AWS_SECRET")!
-    
+
     static let siwaId = Self.get("SIWA_ID")!
-    //...
     static let siwaAppId = Self.get("SIWA_APP_ID")!
     static let siwaRedirectUrl = Self.get("SIWA_REDIRECT_URL")!
     static let siwaTeamId = Self.get("SIWA_TEAM_ID")!
     static let siwaJWKId = Self.get("SIWA_JWK_ID")!
     static let siwaKey = Self.get("SIWA_KEY")!.base64Decoded()!
+    //...
+    static let apnsKeyId = Self.get("APNS_KEY_ID")!
+    static let apnsTeamId = Self.get("APNS_TEAM_ID")!
+    static let apnsTopic = Self.get("APNS_TOPIC")!
+    static let apnsKey = Self.get("APNS_KEY")!.base64Decoded()!
 }

Chapter 16/myProject/Sources/App/Modules/Admin/Views/Home.leaf

@@ -6,7 +6,8 @@
         <section class="wrapper">
             <p>#(message)</p>
             <a href="/admin/blog/posts">Blog posts</a> &middot;
-            <a href="/admin/blog/categories">Blog categories</a>
+            <a href="/admin/blog/categories">Blog categories</a> &middot;
+            <a href="/admin/user/push">Push notification</a>
         </section>
     #endexport
 #endextend

Chapter 16/myProject/Sources/App/Modules/User/Controllers/UserAdminController.swift

@@ -0,0 +1,65 @@
+import Vapor
+import Fluent
+import ViewKit
+
+struct UserAdminController {
+    
+    func renderPushView(_ req: Request,
+                title: String? = nil,
+                message: String? = nil,
+                userId: String? = nil,
+                status: String? = nil) -> EventLoopFuture<View> {
+        struct Context: Encodable {
+            let title: String?
+            var message: String?
+            var userId: String?
+            var status: String?
+            var users: [FormFieldOption]
+        }
+
+        return UserModel.query(on: req.db).all()
+            .mapEach { FormFieldOption(key: $0.id!.uuidString, label: $0.email) }
+            .flatMap {
+                let context = Context(title: title,
+                                      message: message,
+                                      userId: userId,
+                                      status: status,
+                                      users: $0)
+                return req.view.render("User/Frontend/Push", context)
+        }
+    }
+
+    func pushView(req: Request) throws -> EventLoopFuture<View> {
+        self.renderPushView(req)
+    }
+    
+    func push(req: Request) throws -> EventLoopFuture<View> {
+        struct Input: Decodable {
+            let title: String
+            let message: String
+            let userId: String
+        }
+        let input = try req.content.decode(Input.self)
+        guard !input.title.isEmpty || !input.message.isEmpty else {
+            return self.renderPushView(req, status: "Missing required field!")
+        }
+        guard let userId = UUID(uuidString: input.userId) else {
+            throw Abort(.badRequest)
+        }
+        return UserModel
+            .query(on: req.db)
+            .filter(\.$id == userId)
+            .with(\.$devices)
+            .first()
+            .unwrap(or: Abort(.notFound))
+            .flatMap { user -> EventLoopFuture<Void> in
+                let futures: [EventLoopFuture<Void>] = user.devices.map {
+                    return req.apns.send(.init(title: input.title, subtitle: input.message), to: $0.token)
+                }
+                return EventLoopFuture.andAllComplete(futures, on: req.eventLoop)
+            }
+            .flatMap {
+                self.renderPushView(req, status: "Notification sent!")
+            }
+    }
+}

Chapter 16/myProject/Sources/App/Modules/User/Controllers/UserApiController.swift

@@ -24,4 +24,17 @@ struct UserApiController {
             UserTokenModel.create(on: req.db, for: user.id!).map { $0.getContent }
         }
     }
+    
+    func registerDevice(req: Request) throws -> EventLoopFuture<HTTPStatus> {
+        guard let user = req.auth.get(UserModel.self) else {
+            throw Abort(.unauthorized)
+        }
+        struct Input: Decodable {
+            let token: String
+        }
+        let input = try req.content.decode(Input.self)
+        return UserDeviceModel(token: input.token, userId: user.id!)
+            .create(on: req.db)
+            .transform(to: HTTPStatus.ok)
+    }
 }

Chapter 16/myProject/Sources/App/Modules/User/Migrations/UserMigration_v1_3_0.swift

@@ -0,0 +1,21 @@
+import Fluent
+
+struct UserMigration_v1_3_0: Migration {
+
+    func prepare(on db: Database) -> EventLoopFuture<Void> {
+        db.schema(UserDeviceModel.schema)
+            .id()
+            .field(UserDeviceModel.FieldKeys.token, .string, .required)
+            .field(UserDeviceModel.FieldKeys.userId, .uuid)
+            .foreignKey(UserDeviceModel.FieldKeys.userId,
+                        references: UserModel.schema, .id,
+                        onDelete: .cascade,
+                        onUpdate: .cascade)
+            .unique(on: UserDeviceModel.FieldKeys.token)
+            .create()
+    }
+
+    func revert(on db: Database) -> EventLoopFuture<Void> {
+        db.schema(UserDeviceModel.schema).delete()
+    }
+}

Chapter 16/myProject/Sources/App/Modules/User/Models/UserDeviceModel.swift

@@ -0,0 +1,31 @@
+import Vapor
+import Fluent
+import ViperKit
+
+final class UserDeviceModel: ViperModel {
+    typealias Module = UserModule
+
+    static let name = "devices"
+
+    struct FieldKeys {
+        static var token: FieldKey { "token" }
+        static var userId: FieldKey { "user_id" }
+    }
+
+    // MARK: - fields
+
+    @ID() var id: UUID?
+    @Field(key: FieldKeys.token) var token: String
+    @Parent(key: FieldKeys.userId) var user: UserModel
+
+    init() { }
+
+    init(id: UserDeviceModel.IDValue? = nil,
+         token: String,
+         userId: UUID)
+    {
+        self.id = id
+        self.token = token
+        self.$user.id = userId
+    }
+}