Mechanical Stat-Clock for Planetside 2

#include <ArduinoWebsockets.h>  //Library for handling websocket connection and subscription.
#include "ESP8266WiFi.h"  //library for handling netowrking.
#include <ArduinoJson.h>  //library for reading and manipulating JSON documents

const char* ssid = "YOUR WIFI SSID";
const char* password = "YOUR WIFI PASSWORD";
const char* wss_server_host = "wss://push.planetside2.com/streaming?environment=ps2&service-id=s:YOURAPIKEY"; //Replace with your API key
const uint16_t wss_server_port = 8080;

using namespace websockets;

WebsocketsClient client;
bool newKill = false; //Variable for storing the condition of a new kill occuring
bool newDeath = false; //Variable for storing the condition of a new death occuring

int killPin = 13; //D1 The pin connected to the kill impulse counter
int deathPin = 12; //D2 The pin connected to the death impulse counter

int jogForward = 0; //Pin connected to the jog Forward button
int delayPin = 2; //Pin connected to the delay button
int selectPin = 14;  //Pin for selecting which counter to alter.

int killDelayCount = 0; //Variable for storing how many kills to not count.
int deathDelayCount = 0; //Variable for storing how many kills to not count.

//Event Outputs
//Whenever a respective event occurs the tip or ring or both on the TRS jack will output a 50ms pulse.
int killOut = 9;  //Variable for assigning the kill out event to the tip of the TRS jack.
int DeathOut = 10;  //Variable for assigning the death out event to the ring og the TRS jack.


void setup() {
  Serial.begin(115200); //Open a serial port for debuggin'
  delay(500);
  WiFi.begin(ssid, password);   //connect to wifi using ssid and password defined in the global constants section
  while (WiFi.status() != WL_CONNECTED) {   //While waiting for a connection print dots. this will loop forever unless connected.
    Serial.print(".");
    delay(1000);
  }
  pinMode(selectPin, INPUT_PULLUP);
  pinMode(jogForward, INPUT_PULLUP);
  pinMode(delayPin, INPUT_PULLUP);

  pinMode(killPin, OUTPUT);
  pinMode(deathPin, OUTPUT);
  pinMode(killOut, OUTPUT);
  pinMode(DeathOut, OUTPUT);
  
  digitalWrite(killPin, HIGH);
  digitalWrite(deathPin, HIGH);
  digitalWrite(killOut, HIGH);
  digitalWrite(DeathOut, HIGH);

  Serial.println();
  Serial.println("Connected to WiFi!");
  Serial.println("Connecting to Websocket.");

  //Attempt to connected to the Rogue Planet Census Websocket
  bool connected = client.connect(wss_server_host); //this line attempts connection and stores the status in a boolean
  if (connected) {
    Serial.println("Successfully connected to Census!");
    //Here we will subscribe to the events and characters we want to track, 
    //Make sure to replace the long number with your character ID
    client.send("{\"service\":\"event\",\"action\":\"subscribe\",\"characters\":[\"5429221350718803697\"],\"eventNames\":[\"Death\"]}");
    /*this is a very messy string but here is the basics.
    all interior quotes are escaped with a \
    service event action subscribe tells the server we want to subscribe to information
    characters defines which planetside account we want information to pertain to.
    the long number is my player id number which you can find by going to the planetside players website and looking in the url
    event names defines the event we want to subscrbe to.
  */
  }
  else {
    Serial.println("Failed to connect to census websocket.");
  }

  //Create a json document with ArduinoJSON and a variable to store objects.
  DynamicJsonDocument doc(1024); //1024 is what i calculated will store the longest messages from the server
  JsonObject obj = doc.as<JsonObject>();

  //Run this callback whenever a message is recieved.
  client.onMessage([&](WebsocketsMessage message) {
    Serial.print("Message Recieved: ");Serial.println(message.data());
    DynamicJsonDocument doc(1024);
    deserializeJson(doc, message.data());
    JsonObject obj = doc.as<JsonObject>();
    //now that we have a somewhat easy to use json file we can start parsing it for the information we want.
    String eventType = obj[String("type")]; //This creates a string variable called event type that looks in the json document for the object called type.
    String eventName = obj["payload"][String("event_name")]; //These strings follow the same pattern.
    String attackerId = obj["payload"][String("attacker_character_id")];
    String victamId = obj["payload"][String("character_id")];
    /*These two strings are very important to the function of our tracker
    the census websocket does not count kills and deaths for a player seperately, only death events which are interactions
    so to distinguish between the two we will look at the player IDs to see who killed who
    we will also need a carve out for suicides.
    */
    Serial.print("Event Type: ");Serial.println(eventType);
    Serial.print("Event Name: ");Serial.println(eventName);
    Serial.print("Attacker ID:  ");Serial.println(attackerId);
    Serial.print("Victam ID:  ");Serial.println(victamId);
    Serial.print("Kill Delays:  ");Serial.println(killDelayCount);
     Serial.print("Death Delays:  ");Serial.println(deathDelayCount);
    //Now that we have all our information in easy to sue strings we will start processing the information..
    //This statement counts a kill, it checks to make sure I was not the victim and sends a 50ms impulse to the counter.
    
//This statement tracks a kill.
if (eventName == "Death" && victamId != "5429221350718803697" && killDelayCount != 0) {
  digitalWrite(killPin, LOW);
      delay(100);
      digitalWrite(killPin, HIGH);
      delay(50);
  digitalWrite(killOut, LOW);
      delay(50);
      digitalWrite(killOut, HIGH);
      delay(50);
}
//This statement tracks a death but not a suicide.
if (eventName == "Death" && victamId == "5429221350718803697" && attackerId != "5429221350718803697" && deathDelayCount != 0) {
  digitalWrite(deathPin, LOW);
  delay(100);
  digitalWrite(deathPin, HIGH);
  delay(50);
  digitalWrite(DeathOut, LOW);
      delay(50);
      digitalWrite(DeathOut, HIGH);
      delay(50);
}
  });


}

void loop() {
  if (client.available()) { //this statements checks if there is information from the websocket and gets it
    client.poll();
  }
  //this code manages the buttons for incrementing and delaying kills or deaths because we cannot always trust our device to be powered on, or census to work right.
  if(digitalRead(selectPin) == HIGH) { //Select Released
    if (digitalRead(jogForward) == LOW) {
      digitalWrite(deathPin, LOW);
      delay(100);
      digitalWrite(deathPin, HIGH);
      delay(50);
    }

    if (digitalRead(delayPin) == LOW) {
      deathDelayCount ++;
    }

  }

  if(digitalRead(selectPin) == HIGH) { //Select Pressed
    if (digitalRead(jogForward) == LOW) {
      digitalWrite(killPin, LOW);
      delay(100);
      digitalWrite(killPin, HIGH);
      delay(50);
    }

    if (digitalRead(delayPin) == LOW) {
      killDelayCount ++;
    }
  }


}