Replace firstRun/getLog with backfillUserLogs/syncUserLogs
This commit is contained in:
Keith Solomon
+31
-76
@@ -52,102 +52,57 @@ function getDatabaseConnection() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Pulls and stores all vault transaction logs for a user from the Torn API.
|
* Pulls and stores the full vault transaction log history for a user.
|
||||||
*
|
*
|
||||||
* This function retrieves all transaction logs related to vault deposits and
|
* Pages through the v2 Torn API using `_metadata.links.next` until the
|
||||||
* withdrawals for a specified user. It continues fetching logs until no more
|
* API reports no further pages. Intended for first-run use when the
|
||||||
* entries are available, and stores each entry in the database. Each log entry
|
* local database is empty. Idempotent: re-running on a partially
|
||||||
* is uniquely identified by its ID and includes details such as timestamp,
|
* populated database inserts only new entries (ON CONFLICT DO NOTHING).
|
||||||
* description, and amount. The function requires the user's API key to
|
|
||||||
* authenticate requests to the Torn API.
|
|
||||||
*
|
*
|
||||||
* @param string $user The user whose transaction logs are to be retrieved and stored.
|
* @param string $user The user whose logs should be fetched.
|
||||||
*
|
|
||||||
* @throws ApiKeyMissingException If the user does not have an API key configured.
|
|
||||||
* @throws CurlErrorException If there is an error during the API call.
|
|
||||||
* @throws Exception If there is an error decoding the JSON response or if the response is invalid.
|
|
||||||
*
|
*
|
||||||
* @return void
|
* @return void
|
||||||
*/
|
*/
|
||||||
function firstRun($user) {
|
function backfillUserLogs($user) {
|
||||||
$apiKey = USER_KEYS[$user];
|
$url = 'https://api.torn.com/v2/user?selections=log&log=5850,5851';
|
||||||
$pdo = getDatabaseConnection();
|
$pdo = getDatabaseConnection();
|
||||||
$to = time();
|
|
||||||
|
|
||||||
do {
|
do {
|
||||||
$url = "https://api.torn.com/v2/user?selections=log&log=5850,5851&to=$to";
|
$next = fetchAndStoreLogPage($pdo, $user, $url);
|
||||||
$ch = curl_init($url);
|
$url = $next;
|
||||||
|
} while ($next !== null);
|
||||||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
||||||
curl_setopt(
|
|
||||||
$ch, CURLOPT_HTTPHEADER, [
|
|
||||||
'accept: application/json',
|
|
||||||
"Authorization: ApiKey $apiKey"
|
|
||||||
]
|
|
||||||
);
|
|
||||||
|
|
||||||
$response = curl_exec($ch);
|
|
||||||
|
|
||||||
curl_close($ch);
|
|
||||||
|
|
||||||
$data = json_decode($response, true);
|
|
||||||
|
|
||||||
if (empty($data['log'])) {
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
foreach ($data['log'] as $key => $entry) {
|
|
||||||
$description = $entry['title'];
|
|
||||||
$timestamp = $entry['timestamp'];
|
|
||||||
$amount = isset($entry['data']['deposited']) ? $entry['data']['deposited'] : -$entry['data']['withdrawn'];
|
|
||||||
|
|
||||||
$stmt = $pdo->prepare('INSERT INTO vault (ID, user, timestamp, description, amount) VALUES (:id, :user, :timestamp, :description, :amount)');
|
|
||||||
|
|
||||||
$stmt->bindValue(':id', $key);
|
|
||||||
$stmt->bindValue(':user', $user);
|
|
||||||
$stmt->bindValue(':timestamp', $timestamp);
|
|
||||||
$stmt->bindValue(':description', $description);
|
|
||||||
$stmt->bindValue(':amount', $amount);
|
|
||||||
|
|
||||||
$stmt->execute();
|
|
||||||
}
|
|
||||||
|
|
||||||
$to = end($data['log'])['timestamp'];
|
|
||||||
} while (true);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Retrieves the user's log entries from the Torn API
|
* Synchronizes recent vault transactions for a user.
|
||||||
*
|
*
|
||||||
* @param string $user The user to retrieve the log for
|
* On a non-empty database, fetches only entries newer than the user's
|
||||||
* @param boolean $debug Whether to output debug information (default: false)
|
* most recent row. Falls back to full backfill when the database is
|
||||||
|
* empty.
|
||||||
*
|
*
|
||||||
* @throws Exception If the user does not have an API key configured,
|
* @param string $user The user whose logs should be synced.
|
||||||
* if the API call fails, or if the log data is invalid
|
|
||||||
*
|
*
|
||||||
* @return void
|
* @return void
|
||||||
*/
|
*/
|
||||||
function getLog($user, $debug = false) {
|
function syncUserLogs($user) {
|
||||||
|
if (dbNew()) {
|
||||||
|
backfillUserLogs($user);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
$pdo = getDatabaseConnection();
|
$pdo = getDatabaseConnection();
|
||||||
|
|
||||||
ensureUserHasApiKey($user);
|
$stmt = $pdo->prepare('SELECT MAX(timestamp) AS max_ts FROM vault WHERE user = :user');
|
||||||
|
$stmt->bindValue(':user', $user);
|
||||||
|
$stmt->execute();
|
||||||
|
$lastTs = (int)$stmt->fetch(PDO::FETCH_ASSOC)['max_ts'];
|
||||||
|
|
||||||
$stmt = $pdo->query("SELECT MAX(timestamp) AS max_timestamp FROM vault WHERE user = '$user'");
|
$url = "https://api.torn.com/v2/user?selections=log&log=5850,5851&from=" . ($lastTs + 1);
|
||||||
$row = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
||||||
|
|
||||||
$from = $row['max_timestamp'];
|
do {
|
||||||
$to = time();
|
$next = fetchAndStoreLogPage($pdo, $user, $url);
|
||||||
|
$url = $next;
|
||||||
$apiKey = USER_KEYS[$user];
|
} while ($next !== null);
|
||||||
$apiEndpoint = "https://api.torn.com/user/?selections=log&log=5850,5851&to=$to&from=$from&key=$apiKey";
|
|
||||||
|
|
||||||
$responseData = executeApiCall($apiEndpoint);
|
|
||||||
validateApiResponse($responseData);
|
|
||||||
|
|
||||||
$checkStmt = prepareCheckStatement($pdo);
|
|
||||||
$insertStmt = prepareInsertStatement($pdo);
|
|
||||||
|
|
||||||
processLogEntries($responseData['log'], $user, $checkStmt, $insertStmt, $debug);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
Reference in New Issue
Block a user