stuffs
This commit is contained in:
parent
94a69518b1
commit
bd8c149945
GPG key ID:
0FF5B8826803F895
9 changed files with 240 additions and 117 deletions
|
|
@ -1,5 +1,6 @@
|
|||
#include <chrono>
|
||||
#include <curl/curl.h>
|
||||
#include <filesystem>
|
||||
#include <fmt/core.h>
|
||||
#include <rfl/json.hpp>
|
||||
#include <rfl/json/load.hpp>
|
||||
|
|
@ -8,87 +9,111 @@
|
|||
|
||||
using rfl::Error;
|
||||
using rfl::Result;
|
||||
namespace fs = std::filesystem;
|
||||
|
||||
// Function to read cache from file
|
||||
fn ReadCacheFromFile() -> Result<WeatherOutput> {
|
||||
#ifdef __WIN32__
|
||||
const char* tempPath = getenv("TEMP");
|
||||
const string path = string(tempPath) + "\\weather_cache.json";
|
||||
std::ifstream ifs(path);
|
||||
#else
|
||||
std::ifstream ifs("/tmp/weather_cache.json");
|
||||
#endif
|
||||
namespace {
|
||||
// Common function to get cache path
|
||||
fn GetCachePath() -> Result<fs::path> {
|
||||
std::error_code errc;
|
||||
fs::path cachePath = fs::temp_directory_path(errc);
|
||||
|
||||
if (!ifs.is_open())
|
||||
return Error("Cache file not found.");
|
||||
if (errc)
|
||||
return Error("Failed to get temp directory: " + errc.message());
|
||||
|
||||
fmt::println("Reading from cache file...");
|
||||
|
||||
std::stringstream buf;
|
||||
|
||||
buf << ifs.rdbuf();
|
||||
|
||||
Result<WeatherOutput> val = rfl::json::read<WeatherOutput>(buf.str());
|
||||
|
||||
fmt::println("Successfully read from cache file.");
|
||||
|
||||
return val;
|
||||
}
|
||||
|
||||
// Function to write cache to file
|
||||
fn WriteCacheToFile(const WeatherOutput& data) -> Result<u8> {
|
||||
fmt::println("Writing to cache file...");
|
||||
|
||||
#ifdef __WIN32__
|
||||
const char* tempPath = getenv("TEMP");
|
||||
const string path = string(tempPath) + "\\weather_cache.json";
|
||||
std::ofstream ofs(path);
|
||||
#else
|
||||
std::ofstream ofs("/tmp/weather_cache.json");
|
||||
#endif
|
||||
|
||||
if (!ofs.is_open())
|
||||
return Error("Failed to open cache file for writing.");
|
||||
|
||||
ofs << rfl::json::write(data);
|
||||
|
||||
fmt::println("Successfully wrote to cache file.");
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
fn WriteCallback(void* contents, const usize size, const usize nmemb, string* str) -> usize {
|
||||
const usize totalSize = size * nmemb;
|
||||
str->append(static_cast<char*>(contents), totalSize);
|
||||
return totalSize;
|
||||
}
|
||||
|
||||
// Function to make API request
|
||||
fn MakeApiRequest(const string& url) -> Result<WeatherOutput> {
|
||||
fmt::println("Making API request to URL: {}", url);
|
||||
|
||||
CURL* curl = curl_easy_init();
|
||||
string responseBuffer;
|
||||
|
||||
if (curl) {
|
||||
curl_easy_setopt(curl, CURLOPT_URL, url.c_str());
|
||||
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, WriteCallback);
|
||||
curl_easy_setopt(curl, CURLOPT_WRITEDATA, &responseBuffer);
|
||||
const CURLcode res = curl_easy_perform(curl);
|
||||
curl_easy_cleanup(curl);
|
||||
|
||||
if (res != CURLE_OK)
|
||||
return Error(fmt::format("Failed to perform cURL request: {}", curl_easy_strerror(res)));
|
||||
|
||||
fmt::println("Received response from API. Response size: {}", responseBuffer.size());
|
||||
fmt::println("Response: {}", responseBuffer);
|
||||
|
||||
WeatherOutput output = rfl::json::read<WeatherOutput>(responseBuffer).value();
|
||||
|
||||
return output; // Return an empty result for now
|
||||
cachePath /= "weather_cache.json";
|
||||
return cachePath;
|
||||
}
|
||||
|
||||
return Error("Failed to initialize cURL.");
|
||||
// Function to read cache from file
|
||||
fn ReadCacheFromFile() -> Result<WeatherOutput> {
|
||||
Result<fs::path> cachePath = GetCachePath();
|
||||
if (!cachePath)
|
||||
return Error(cachePath.error()->what());
|
||||
|
||||
std::ifstream ifs(*cachePath, std::ios::binary);
|
||||
if (!ifs.is_open())
|
||||
return Error("Cache file not found: " + cachePath.value().string());
|
||||
|
||||
DEBUG_LOG("Reading from cache file...");
|
||||
|
||||
std::string content((std::istreambuf_iterator<char>(ifs)), std::istreambuf_iterator<char>());
|
||||
|
||||
Result<WeatherOutput> result = rfl::json::read<WeatherOutput>(content);
|
||||
|
||||
DEBUG_LOG("Successfully read from cache file.");
|
||||
return result;
|
||||
}
|
||||
|
||||
// Function to write cache to file
|
||||
fn WriteCacheToFile(const WeatherOutput& data) -> Result<u8> {
|
||||
Result<fs::path> cachePath = GetCachePath();
|
||||
if (!cachePath)
|
||||
return Error(cachePath.error()->what());
|
||||
|
||||
DEBUG_LOG("Writing to cache file...");
|
||||
|
||||
// Write to temporary file first
|
||||
fs::path tempPath = *cachePath;
|
||||
tempPath += ".tmp";
|
||||
|
||||
{
|
||||
std::ofstream ofs(tempPath, std::ios::binary | std::ios::trunc);
|
||||
if (!ofs.is_open())
|
||||
return Error("Failed to open temp file: " + tempPath.string());
|
||||
|
||||
auto json = rfl::json::write(data);
|
||||
ofs << json;
|
||||
|
||||
if (!ofs)
|
||||
return Error("Failed to write to temp file");
|
||||
} // File stream closes here
|
||||
|
||||
// Atomic replace
|
||||
std::error_code errc;
|
||||
fs::rename(tempPath, *cachePath, errc);
|
||||
|
||||
if (errc) {
|
||||
fs::remove(tempPath, errc);
|
||||
return Error("Failed to replace cache file: " + errc.message());
|
||||
}
|
||||
|
||||
DEBUG_LOG("Successfully wrote to cache file.");
|
||||
return 0;
|
||||
}
|
||||
|
||||
fn WriteCallback(void* contents, const usize size, const usize nmemb, string* str) -> usize {
|
||||
const usize totalSize = size * nmemb;
|
||||
str->append(static_cast<char*>(contents), totalSize);
|
||||
return totalSize;
|
||||
}
|
||||
|
||||
// Function to make API request
|
||||
fn MakeApiRequest(const string& url) -> Result<WeatherOutput> {
|
||||
DEBUG_LOG("Making API request to URL: {}", url);
|
||||
|
||||
CURL* curl = curl_easy_init();
|
||||
string responseBuffer;
|
||||
|
||||
if (curl) {
|
||||
curl_easy_setopt(curl, CURLOPT_URL, url.c_str());
|
||||
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, WriteCallback);
|
||||
curl_easy_setopt(curl, CURLOPT_WRITEDATA, &responseBuffer);
|
||||
const CURLcode res = curl_easy_perform(curl);
|
||||
curl_easy_cleanup(curl);
|
||||
|
||||
if (res != CURLE_OK)
|
||||
return Error(fmt::format("Failed to perform cURL request: {}", curl_easy_strerror(res)));
|
||||
|
||||
DEBUG_LOG("Received response from API. Response size: {}", responseBuffer.size());
|
||||
DEBUG_LOG("Response: {}", responseBuffer);
|
||||
|
||||
WeatherOutput output = rfl::json::read<WeatherOutput>(responseBuffer).value();
|
||||
|
||||
return output; // Return an empty result for now
|
||||
}
|
||||
|
||||
return Error("Failed to initialize cURL.");
|
||||
}
|
||||
}
|
||||
|
||||
// Core function to get weather information
|
||||
|
|
@ -100,14 +125,14 @@ fn Weather::getWeatherInfo() const -> WeatherOutput {
|
|||
WeatherOutput dataVal = *data;
|
||||
|
||||
if (system_clock::now() - system_clock::time_point(seconds(dataVal.dt)) < minutes(10)) {
|
||||
fmt::println("Cache is valid. Returning cached data.");
|
||||
DEBUG_LOG("Cache is valid. Returning cached data.");
|
||||
|
||||
return dataVal;
|
||||
}
|
||||
|
||||
fmt::println("Cache is expired.");
|
||||
DEBUG_LOG("Cache is expired.");
|
||||
} else {
|
||||
fmt::println("No valid cache found.");
|
||||
DEBUG_LOG("No valid cache found.");
|
||||
}
|
||||
|
||||
WeatherOutput result;
|
||||
|
|
@ -117,7 +142,7 @@ fn Weather::getWeatherInfo() const -> WeatherOutput {
|
|||
|
||||
const char* loc = curl_easy_escape(nullptr, city.c_str(), static_cast<int>(city.length()));
|
||||
|
||||
fmt::println("City: {}", loc);
|
||||
DEBUG_LOG("City: {}", loc);
|
||||
|
||||
const string apiUrl = fmt::format(
|
||||
"https://api.openweathermap.org/data/2.5/"
|
||||
|
|
@ -131,7 +156,7 @@ fn Weather::getWeatherInfo() const -> WeatherOutput {
|
|||
} else {
|
||||
const auto [lat, lon] = get<Coords>(location);
|
||||
|
||||
fmt::println("Coordinates: lat = {:.3f}, lon = {:.3f}", lat, lon);
|
||||
DEBUG_LOG("Coordinates: lat = {:.3f}, lon = {:.3f}", lat, lon);
|
||||
|
||||
const string apiUrl = fmt::format(
|
||||
"https://api.openweathermap.org/data/2.5/"
|
||||
|
|
@ -148,7 +173,7 @@ fn Weather::getWeatherInfo() const -> WeatherOutput {
|
|||
// Update the cache with the new data
|
||||
WriteCacheToFile(result);
|
||||
|
||||
fmt::println("Returning new data.");
|
||||
DEBUG_LOG("Returning new data.");
|
||||
|
||||
return result;
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue