Blaming USB-Meter/USB Meter/Model/Measurements.swift at 7758c50ad7f5a18c5619c7b796e5373784fbc3f7 · bogdan/USB-Meter

USB-Meter / USB Meter / Model / Measurements.swift

Newer ■ ■ ■ ■ ■ ■ ■ ■ ■ ■ Older

bogdan Improve chart controls and fix tab bar and portrait layout issues

185 lines | 5.528kb

Initial commit Bogdan Timofte authored 2 weeks ago	1	//
	2	// Measurements.swift
	3	// USB Meter
	4	//
	5	// Created by Bogdan Timofte on 07/05/2020.
	6	// Copyright © 2020 Bogdan Timofte. All rights reserved.
	7	//
	8
	9	import Foundation
	10	import CoreGraphics
	11
	12	class Measurements : ObservableObject {
	13
	14	class Measurement : ObservableObject {
	15	struct Point : Identifiable , Hashable {
Improve chart controls and f... Bogdan Timofte authored a week ago	16	enum Kind: Hashable {
	17	case sample
	18	case discontinuity
	19	}
	20
Initial commit Bogdan Timofte authored 2 weeks ago	21	var id : Int
	22	var timestamp: Date
	23	var value: Double
Improve chart controls and f... Bogdan Timofte authored a week ago	24	var kind: Kind = .sample
	25
	26	var isSample: Bool {
	27	kind == .sample
	28	}
	29
	30	var isDiscontinuity: Bool {
	31	kind == .discontinuity
	32	}
	33
Initial commit Bogdan Timofte authored 2 weeks ago	34	func point() -> CGPoint {
	35	return CGPoint(x: timestamp.timeIntervalSince1970, y: value)
	36	}
	37	}
	38
	39	var points: [Point] = []
	40	var context = ChartContext()
	41
Improve chart controls and f... Bogdan Timofte authored a week ago	42	var samplePoints: [Point] {
	43	points.filter { $0.isSample }
	44	}
	45
	46	private func rebuildContext() {
	47	context.reset()
	48	for point in points where point.isSample {
	49	context.include(point: point.point())
	50	}
	51	}
	52
	53	private func appendPoint(timestamp: Date, value: Double, kind: Point.Kind) {
	54	let newPoint = Measurement.Point(id: points.count, timestamp: timestamp, value: value, kind: kind)
	55	points.append(newPoint)
	56	if newPoint.isSample {
	57	context.include(point: newPoint.point())
	58	}
	59	self.objectWillChange.send()
	60	}
	61
Initial commit Bogdan Timofte authored 2 weeks ago	62	func removeValue(index: Int) {
	63	points.remove(at: index)
Improve chart controls and f... Bogdan Timofte authored a week ago	64	for index in points.indices {
	65	points[index].id = index
Initial commit Bogdan Timofte authored 2 weeks ago	66	}
Improve chart controls and f... Bogdan Timofte authored a week ago	67	rebuildContext()
Initial commit Bogdan Timofte authored 2 weeks ago	68	self.objectWillChange.send()
	69	}
	70
	71	func addPoint(timestamp: Date, value: Double) {
Improve chart controls and f... Bogdan Timofte authored a week ago	72	appendPoint(timestamp: timestamp, value: value, kind: .sample)
	73	}
	74
	75	func addDiscontinuity(timestamp: Date) {
	76	guard !points.isEmpty else { return }
	77	guard points.last?.isDiscontinuity == false else { return }
	78	appendPoint(timestamp: timestamp, value: points.last?.value ?? 0, kind: .discontinuity)
Initial commit Bogdan Timofte authored 2 weeks ago	79	}
	80
Improve chart controls and f... Bogdan Timofte authored a week ago	81	func resetSeries() {
Initial commit Bogdan Timofte authored 2 weeks ago	82	points.removeAll()
	83	context.reset()
	84	self.objectWillChange.send()
	85	}
Implement charge record work... Bogdan Timofte authored 2 weeks ago	86
	87	func trim(before cutoff: Date) {
	88	points = points
	89	.filter { $0.timestamp >= cutoff }
	90	.enumerated()
	91	.map { index, point in
Improve chart controls and f... Bogdan Timofte authored a week ago	92	Measurement.Point(id: index, timestamp: point.timestamp, value: point.value, kind: point.kind)
Implement charge record work... Bogdan Timofte authored 2 weeks ago	93	}
Improve chart controls and f... Bogdan Timofte authored a week ago	94	rebuildContext()
Implement charge record work... Bogdan Timofte authored 2 weeks ago	95	self.objectWillChange.send()
	96	}
Initial commit Bogdan Timofte authored 2 weeks ago	97	}
	98
	99	@Published var power = Measurement()
	100	@Published var voltage = Measurement()
	101	@Published var current = Measurement()
	102
Improve chart controls and f... Bogdan Timofte authored a week ago	103	private var pendingBucketSecond: Int?
	104	private var pendingBucketTimestamp: Date?
Initial commit Bogdan Timofte authored 2 weeks ago	105
	106	private var itemsInSum: Double = 0
	107	private var powerSum: Double = 0
	108	private var voltageSum: Double = 0
	109	private var currentSum: Double = 0
Implement charge record work... Bogdan Timofte authored 2 weeks ago	110
Improve chart controls and f... Bogdan Timofte authored a week ago	111	private func resetPendingAggregation() {
	112	pendingBucketSecond = nil
	113	pendingBucketTimestamp = nil
Implement charge record work... Bogdan Timofte authored 2 weeks ago	114	itemsInSum = 0
	115	powerSum = 0
	116	voltageSum = 0
	117	currentSum = 0
Improve chart controls and f... Bogdan Timofte authored a week ago	118	}
	119
	120	private func flushPendingValues() {
	121	guard let pendingBucketTimestamp, itemsInSum > 0 else { return }
	122	self.power.addPoint(timestamp: pendingBucketTimestamp, value: powerSum / itemsInSum)
	123	self.voltage.addPoint(timestamp: pendingBucketTimestamp, value: voltageSum / itemsInSum)
	124	self.current.addPoint(timestamp: pendingBucketTimestamp, value: currentSum / itemsInSum)
	125	resetPendingAggregation()
Implement charge record work... Bogdan Timofte authored 2 weeks ago	126	self.objectWillChange.send()
	127	}
Improve chart controls and f... Bogdan Timofte authored a week ago	128
	129	func resetSeries() {
	130	power.resetSeries()
	131	voltage.resetSeries()
	132	current.resetSeries()
	133	resetPendingAggregation()
	134	self.objectWillChange.send()
	135	}
	136
	137	func reset() {
	138	resetSeries()
	139	}
Initial commit Bogdan Timofte authored 2 weeks ago	140
	141	func remove(at idx: Int) {
	142	power.removeValue(index: idx)
	143	voltage.removeValue(index: idx)
	144	current.removeValue(index: idx)
	145	self.objectWillChange.send()
	146	}
	147
Implement charge record work... Bogdan Timofte authored 2 weeks ago	148	func trim(before cutoff: Date) {
Improve chart controls and f... Bogdan Timofte authored a week ago	149	flushPendingValues()
Implement charge record work... Bogdan Timofte authored 2 weeks ago	150	power.trim(before: cutoff)
	151	voltage.trim(before: cutoff)
	152	current.trim(before: cutoff)
	153	self.objectWillChange.send()
	154	}
	155
Initial commit Bogdan Timofte authored 2 weeks ago	156	func addValues(timestamp: Date, power: Double, voltage: Double, current: Double) {
	157	let valuesTimestamp = timestamp.timeIntervalSinceReferenceDate.intValue
Improve chart controls and f... Bogdan Timofte authored a week ago	158
	159	if pendingBucketSecond == valuesTimestamp {
	160	pendingBucketTimestamp = timestamp
Initial commit Bogdan Timofte authored 2 weeks ago	161	itemsInSum += 1
Implement charge record work... Bogdan Timofte authored 2 weeks ago	162	powerSum += power
Initial commit Bogdan Timofte authored 2 weeks ago	163	voltageSum += voltage
	164	currentSum += current
Improve chart controls and f... Bogdan Timofte authored a week ago	165	return
Initial commit Bogdan Timofte authored 2 weeks ago	166	}
Improve chart controls and f... Bogdan Timofte authored a week ago	167
	168	flushPendingValues()
	169
	170	pendingBucketSecond = valuesTimestamp
	171	pendingBucketTimestamp = timestamp
	172	itemsInSum = 1
	173	powerSum = power
	174	voltageSum = voltage
	175	currentSum = current
	176	}
	177
	178	func markDiscontinuity(at timestamp: Date) {
	179	flushPendingValues()
	180	power.addDiscontinuity(timestamp: timestamp)
	181	voltage.addDiscontinuity(timestamp: timestamp)
	182	current.addDiscontinuity(timestamp: timestamp)
	183	self.objectWillChange.send()
Initial commit Bogdan Timofte authored 2 weeks ago	184	}
	185	}