main.cpp

/*
Copyright (c) 2022 Snowplow Analytics Ltd. All rights reserved.

This program is licensed to you under the Apache License Version 2.0,
and you may not use this file except in compliance with the Apache License Version 2.0.
You may obtain a copy of the Apache License Version 2.0 at http://www.apache.org/licenses/LICENSE-2.0.

Unless required by applicable law or agreed to in writing,
software distributed under the Apache License Version 2.0 is distributed on an
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the Apache License Version 2.0 for the specific language governing permissions and limitations there under.
*/

#include <fstream>
#include <string>

#include "../src/storage.hpp"
#include "../src/utils.hpp"
#include "run.hpp"

using snowplow::SelfDescribingJson;
using snowplow::SNOWPLOW_TRACKER_VERSION_LABEL;
using snowplow::Utils;
using std::cout;
using std::endl;
using std::ofstream;
using std::string;

int main(int argc, char **argv) {
  // run and measure performance
  string db_name = "performance.db";
  double mocked_emitter_and_mocked_session = run_mocked_emitter_and_mocked_session(db_name);
  double mocked_emitter_and_real_session = run_mocked_emitter_and_real_session(db_name);
  double mute_emitter_and_mocked_session = run_mute_emitter_and_mocked_session(db_name);
  double mute_emitter_and_real_session = run_mute_emitter_and_real_session(db_name);

  // print results
  cout << endl
       << "RESULTS (" << NUM_OPERATIONS << " operations x " << NUM_THREADS << " threads)" << endl
       << endl;
  cout << "Mocked emitter and mocked session: " << mocked_emitter_and_mocked_session << " seconds" << endl;
  cout << "Mocked emitter and real session: " << mocked_emitter_and_real_session << " seconds" << endl;
  cout << "Mute emitter and mocked session: " << mute_emitter_and_mocked_session << " seconds" << endl;
  cout << "Mute emitter and real session: " << mute_emitter_and_real_session << " seconds" << endl;

  // store results in logs as JSON
  json results;
  results["num_operations"] = NUM_OPERATIONS;
  results["num_threads"] = NUM_THREADS;
  results["mocked_emitter_and_mocked_session"] = mocked_emitter_and_mocked_session;
  results["mocked_emitter_and_real_session"] = mocked_emitter_and_real_session;
  results["mute_emitter_and_mocked_session"] = mute_emitter_and_mocked_session;
  results["mute_emitter_and_real_session"] = mute_emitter_and_real_session;

  SelfDescribingJson desktop_context = Utils::get_desktop_context();
  json desktop_context_json = desktop_context.get();
  json output;
  output["desktop_context"] = desktop_context_json;
  output["results"] = results;
  output["timestamp"] = Utils::get_unix_epoch_ms();
  output["tracker_version"] = SNOWPLOW_TRACKER_VERSION_LABEL;

  ofstream outfile;
  outfile.open("performance/logs.txt", std::ios_base::app);
  outfile << output.dump() << endl;
  outfile.close();

  return 0;
}