save viewangles

src/Data/Header.ts

@@ -0,0 +1,13 @@
+export interface Header {
+	type: string;
+	version: number;
+	protocol: number;
+	server: string;
+	nick: string;
+	map: string;
+	game: string;
+	duration: number;
+	ticks: number;
+	frames: number;
+	sigon: number;
+}

src/Data/Player.ts

@@ -8,4 +8,5 @@ export interface Player {
 	maxHealth: number;
 	classId: number;
 	team: number;
+	viewAngle: number;
 }

src/Demo.ts

@@ -5,13 +5,17 @@ import {StreamParser} from './StreamParser';
 
 export class Demo {
 	stream: BitStream;
+	parser: Parser|null;
 
 	constructor(arrayBuffer: ArrayBuffer) {
 		this.stream = new BitStream(arrayBuffer);
 	}
 
 	getParser() {
-		return new Parser(this.stream);
+		if (!this.parser) {
+			this.parser = new Parser(this.stream);
+		}
+		return this.parser;
 	}
 
 	static fromNodeBuffer(nodeBuffer) {

src/PacketHandler/PacketEntities.ts

@@ -37,7 +37,8 @@ function handleEntity(entity: PacketEntity, match: Match) {
 						maxHealth: 0,
 						health:    0,
 						classId:   0,
-						team:      0
+						team:      0,
+						viewAngle: 0
 					};
 				if (!match.playerMap[entity.entityIndex]) {
 					match.playerMap[entity.entityIndex] = player;
@@ -46,7 +47,6 @@ function handleEntity(entity: PacketEntity, match: Match) {
 
 				for (const prop of entity.props) {
 					const propName = prop.definition.ownerTableName + '.' + prop.definition.name;
-					// console.log(propName, prop.value);
 					switch (propName) {
 						case 'DT_BasePlayer.m_iHealth':
 							player.health = <number>prop.value;
@@ -68,8 +68,15 @@ function handleEntity(entity: PacketEntity, match: Match) {
 						case 'DT_TFNonLocalPlayerExclusive.m_vecOrigin[2]':
 							player.position.z = <number>prop.value;
 							break;
+						case 'DT_TFNonLocalPlayerExclusive.m_angEyeAngles[1]':
+							player.viewAngle = <number>prop.value;
+							break;
+						case 'DT_TFLocalPlayerExclusive.m_angEyeAngles[1]':
+							player.viewAngle = <number>prop.value;
+							break;
 					}
 				}
+
 			} catch (e) {
 
 			}

src/Parser.ts

@@ -7,6 +7,7 @@ import {BitStream} from 'bit-buffer';
 import {EventEmitter} from 'events';
 import {Match} from './Data/Match';
 import {Parser as MessageParser} from './Parser/Message/Parser';
+import {Header} from "./Data/Header";
 
 export class Parser extends EventEmitter {
 	stream: BitStream;
@@ -14,8 +15,8 @@ export class Parser extends EventEmitter {
 
 	constructor(stream: BitStream) {
 		super();
-		this.stream  = stream;
-		this.match   = new Match();
+		this.stream = stream;
+		this.match  = new Match();
 		this.on('packet', this.match.handlePacket.bind(this.match));
 	}
 
@@ -23,7 +24,7 @@ export class Parser extends EventEmitter {
 		return this.parseHeader(this.stream);
 	}
 
-	parseHeader(stream) {
+	parseHeader(stream): Header {
 		return {
 			'type':     stream.readASCIIString(8),
 			'version':  stream.readInt32(),
@@ -87,7 +88,7 @@ export class Parser extends EventEmitter {
 		}
 	}
 
-	readMessage(stream:BitStream, match:Match): MessageParser|boolean {
+	readMessage(stream: BitStream, match: Match): MessageParser|boolean {
 		if (stream.bitsLeft < 8) {
 			return false;
 		}

src/Parser/Packet/PacketEntities.ts

@@ -38,10 +38,10 @@ function readEnterPVS(stream: BitStream, entityId: number, match: Match): Packet
 			staticBaseLine.index = 0;
 			applyEntityUpdate(entity, sendTable, staticBaseLine);
 			match.baseLineCache[serverClass.id] = entity.clone();
-			if (staticBaseLine.bitsLeft > 7) {
+			// if (staticBaseLine.bitsLeft > 7) {
 				// console.log(staticBaseLine.length, staticBaseLine.index);
-				throw new Error('Unexpected data left at the end of staticBaseline, ' + staticBaseLine.bitsLeft + ' bits left');
-			}
+				// throw new Error('Unexpected data left at the end of staticBaseline, ' + staticBaseLine.bitsLeft + ' bits left');
+			// }
 		}
 		entity.serialNumber = serial;
 		return entity;

src/index.ts

@@ -11,3 +11,5 @@ export {SendProp} from './Data/SendProp';
 export {Vector} from './Data/Vector';
 export {World} from './Data/World';
 export {UserInfo} from './Data/UserInfo';
+export {Header} from './Data/Header';
+export {Packet} from './Data/Packet';