Repository navigation
Expand file tree
/
Copy pathConnectionManager.swift
More file actions
79 lines (62 loc) · 2.03 KB
/
Copy pathConnectionManager.swift
File metadata and controls
79 lines (62 loc) · 2.03 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
//
// ConnectionManager.swift
// CardsAgainst
//
// Created by JP Simard on 11/2/14.
// Copyright (c) 2014 JP Simard. All rights reserved.
//
import Foundation
import PeerKit
import MultipeerConnectivity
protocol MPCSerializable {
var mpcSerialized: Data { get }
init(mpcSerialized: Data)
}
enum Event: String {
case startGame, answer, cancelAnswer, vote, nextCard, endGame
}
struct ConnectionManager {
// MARK: Properties
fileprivate static var peers: [MCPeerID] {
return PeerKit.session?.connectedPeers as [MCPeerID]? ?? []
}
static var otherPlayers: [Player] {
return peers.map { Player(peer: $0) }
}
static var allPlayers: [Player] { return [Player.getMe()] + otherPlayers }
// MARK: Start
static func start() {
PeerKit.transceive(serviceType: "cards-against")
}
// MARK: Event Handling
static func onConnect(_ run: PeerBlock?) {
PeerKit.onConnect = run
}
static func onDisconnect(_ run: PeerBlock?) {
PeerKit.onDisconnect = run
}
static func onEvent(_ event: Event, run: ObjectBlock?) {
if let run = run {
PeerKit.eventBlocks[event.rawValue] = run
} else {
PeerKit.eventBlocks.removeValue(forKey: event.rawValue)
}
}
// MARK: Sending
static func sendEvent(_ event: Event, object: [String: MPCSerializable]? = nil,
toPeers peers: [MCPeerID]? = PeerKit.session?.connectedPeers) {
var anyObject: [String: Data]?
if let object = object {
anyObject = [String: Data]()
for (key, value) in object {
anyObject![key] = value.mpcSerialized
}
}
PeerKit.sendEvent(event.rawValue, object: anyObject as AnyObject, toPeers: peers)
}
static func sendEventForEach(_ event: Event, objectBlock: () -> ([String: MPCSerializable])) {
for peer in ConnectionManager.peers {
ConnectionManager.sendEvent(event, object: objectBlock(), toPeers: [peer])
}
}
}