//AppDelegate.swift

import PubNub

// 需要 delegate PNObjectEventListener

// ...省略

let configuration = PNConfiguration(publishKey: "demo", subscribeKey: "sub-c-52a9ab50-291b-11e5-baaa-0619f8945a4f")
       self.client = PubNub.clientWithConfiguration(configuration)
       self.client.addListener(self)
       self.client.subscribeToChannels(["lightning_ticker_BTC_JPY"], withPresence: false)

// 添加实现delegate的fucntion

func client(_ client: PubNub, didReceiveMessage message: PNMessageResult) {

        let bicoinInfo = message.data.message as! NSDictionary

        // bitcoinInfo是一个词典类型，保存了诸如`best_ask`, `best_bid`, `ltp` 之类的情报。
        // bitcoinInfo["ltp"] => 299900
        // 我们需要把这个东西传给apple watch。
    }

// 导入
import WatchConnectivity

// 初始化
if WCSession.isSupported() {
    self.session.delegate = self
    self.session.activate()
}

// 实现delegate
func session(_ session: WCSession, didReceiveMessage message: [String : Any], replyHandler: @escaping ([String : Any]) -> Void) {
       // 将当前的tick保存在lastestTick中。
       // 获取 lastTick
       self.session.transferUserInfo(["tick": lastestTick])
   }

func session(_ session: WCSession, activationDidCompleteWith activationState: WCSessionActivationState, error: Error?) {
   }

// 同样需要导入WatchConnectivity

import WatchConnectivity

// 初始化

func applicationDidFinishLaunching() {
       if WCSession.isSupported() {
           self.session.delegate = self
           self.session.activate()
       }
       // Perform any final initialization of your application.
   }

// 实现delegate

func session(_ session: WCSession, activationDidCompleteWith activationState: WCSessionActivationState, error: Error?) {
   }
   func session(_ session: WCSession, didReceiveMessage message: [String : Any], replyHandler: @escaping ([String : Any]) -> Void) {

   }
func session(_ session: WCSession, didReceiveUserInfo userInfo: [String : Any] = [:]) {
        let lastTick = userInfo["tick"] as! NSDictionary
        // 更新持有的tick数据
        TickData.setTick(tick: lastTick)
        let complicationServer = CLKComplicationServer.sharedInstance()
        guard let activeComplications = complicationServer.activeComplications else {
            return
        }

        for complication in activeComplications {
            complicationServer.reloadTimeline(for: complication)
        }

    }

// MARK: - Placeholder Templates

   func getLocalizableSampleTemplate(for complication: CLKComplication, withHandler handler: @escaping (CLKComplicationTemplate?) -> Void) {
       // This method will be called once per supported complication, and the results will be cached
       let template = CLKComplicationTemplateModularLargeStandardBody()
       let image = UIImage(named: "bitcoin")

       template.headerImageProvider =
           CLKImageProvider(onePieceImage: image!)

       template.headerTextProvider =
           CLKSimpleTextProvider(text: "BTC/JPY")
       template.body1TextProvider =
           CLKSimpleTextProvider(text: "0")

       handler(template)
   }

// MARK: - Timeline Population

   func getCurrentTimelineEntry(for complication: CLKComplication, withHandler handler: @escaping (CLKComplicationTimelineEntry?) -> Void) {

       // Call the handler with the current timeline entry
       let lastTick = TickData.getTick()
       let ltp = String(describing: lastTick["ltp"] as! Int)
       let template = CLKComplicationTemplateModularLargeStandardBody()
       let image = UIImage(named: "bitcoin")

       template.headerImageProvider =
           CLKImageProvider(onePieceImage: image!)

       template.headerTextProvider =
           CLKSimpleTextProvider(text: "BTC/JPY")
       template.body1TextProvider =
           CLKSimpleTextProvider(text: ltp)

       let entry = CLKComplicationTimelineEntry.init(date: Date(), complicationTemplate: template)

       handler(entry)

   }