starbitdev/zblock
1
0
Fork 0
mirror of https://github.com/WCBROW01/zblock.git synced 2025-12-11 20:18:07 -05:00
Code Issues Packages Projects Releases Wiki Activity

[feed_info.c] Send numeric parameters in binary format

Browse Source
This commit is contained in:
Mina Brown
2024-11-24 20:46:43 -05:00
parent b2f76bf2a3
commit 0e01785913
1 changed files with 27 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
feed_info.c
View File

@ -47,11 +47,14 @@ time_t pubDate_to_time_t(char *s) {
zblock_feed_info_err zblock_feed_info_exists(PGconn *conn, const char *url, u64snowflake channel_id, int *exists) { zblock_feed_info_err zblock_feed_info_exists(PGconn *conn, const char *url, u64snowflake channel_id, int *exists) {
if (!conn || !exists) return ZBLOCK_FEED_INFO_INVALID_ARGS; if (!conn || !exists) return ZBLOCK_FEED_INFO_INVALID_ARGS;
char channel_id_str[21]; // hold a 64-bit int in decimal form uint64_t channel_id_be = htobe64(channel_id);
snprintf(channel_id_str, sizeof(channel_id_str), "%" PRId64, channel_id); const char *const params[] = {url, (char *) channel_id_be};
const int param_lengths[] = {0, sizeof(channel_id_be)};
const char *const params[] = {url, channel_id_str}; const int param_formats[] = {0, 1};
PGresult *res = PQexecParams(conn, "SELECT COUNT(1) FROM feeds WHERE url = $1 AND channel_id = $2", 2, NULL, params, NULL, NULL, 1); PGresult *res = PQexecParams(conn,
"SELECT COUNT(1) FROM feeds WHERE url = $1 AND channel_id = $2::bigint",
2, NULL, params, param_lengths, param_formats, 1
);
if (PQresultStatus(res) != PGRES_TUPLES_OK) { if (PQresultStatus(res) != PGRES_TUPLES_OK) {
log_error(PQresultErrorMessage(res)); log_error(PQresultErrorMessage(res));
PQclear(res); PQclear(res);
@ -78,15 +81,14 @@ zblock_feed_info_err zblock_feed_info_insert(PGconn *conn, zblock_feed_info *fee
} }
} }
// I don't want to deal with the extra fuss that is sending these in binary format uint64_t channel_id_be = htobe64(feed->channel_id);
char channel_id_str[21]; uint64_t guild_id_be = htobe64(feed->guild_id);
snprintf(channel_id_str, sizeof(channel_id_str), "%" PRId64, feed->channel_id); const char *const insert_params[] = {feed->url, feed->last_pubDate, (char *) channel_id_be, feed->title, (char *) guild_id_be};
char guild_id_str[21]; const int param_lengths[] = {0, 0, sizeof(channel_id_be), 0, sizeof(guild_id_be)};
snprintf(guild_id_str, sizeof(guild_id_str), "%" PRId64, feed->guild_id); const int param_formats[] = {0, 0, 1, 0, 1};
const char *const insert_params[] = {feed->url, feed->last_pubDate, channel_id_str, feed->title, guild_id_str};
PGresult *insert_res = PQexecParams(conn, PGresult *insert_res = PQexecParams(conn,
"INSERT INTO feeds (url, last_pubDate, channel_id, title, guild_id) VALUES ($1, $2, $3, $4, $5)", "INSERT INTO feeds (url, last_pubDate, channel_id, title, guild_id) VALUES ($1, $2, $3::bigint, $4, $5::bigint)",
5, NULL, insert_params, NULL, NULL, 0 5, NULL, insert_params, param_lengths, param_formats, 1
); );
zblock_feed_info_err result = ZBLOCK_FEED_INFO_OK; zblock_feed_info_err result = ZBLOCK_FEED_INFO_OK;
@ -114,13 +116,13 @@ zblock_feed_info_err zblock_feed_info_delete(PGconn *conn, const char *url, u64s
} }
} }
// I don't want to deal with the extra fuss that is sending these in binary format uint64_t channel_id_be = htobe64(channel_id);
char channel_id_str[21]; const char *const params[] = {url, (char *) channel_id_be};
snprintf(channel_id_str, sizeof(channel_id_str), "%" PRId64, channel_id); const int param_lengths[] = {0, sizeof(channel_id_be)};
const char *const params[] = {url, channel_id_str}; const int param_formats[] = {0, 1};
PGresult *res = PQexecParams(conn, PGresult *res = PQexecParams(conn,
"DELETE FROM feeds WHERE url = $1 AND channel_id = $2", "DELETE FROM feeds WHERE url = $1 AND channel_id = $2::bigint",
2, NULL, params, NULL, NULL, 0 2, NULL, params, param_lengths, param_formats, 1
); );
zblock_feed_info_err result = ZBLOCK_FEED_INFO_OK; zblock_feed_info_err result = ZBLOCK_FEED_INFO_OK;
@ -136,15 +138,14 @@ zblock_feed_info_err zblock_feed_info_delete(PGconn *conn, const char *url, u64s
// updates the last_pubDate field of a given feed in the database // updates the last_pubDate field of a given feed in the database
zblock_feed_info_err zblock_feed_info_update(PGconn *conn, zblock_feed_info_minimal *feed) { zblock_feed_info_err zblock_feed_info_update(PGconn *conn, zblock_feed_info_minimal *feed) {
if (!conn || !feed) return ZBLOCK_FEED_INFO_INVALID_ARGS; if (!conn || !feed) return ZBLOCK_FEED_INFO_INVALID_ARGS;
char channel_id_str[21]; // hold a 64-bit int in decimal form
snprintf(channel_id_str, sizeof(channel_id_str), "%" PRId64, feed->channel_id);
const char *const update_params[] = {feed->last_pubDate, feed->url, channel_id_str}; uint64_t channel_id_be = htobe64(feed->channel_id);
// save the updated pubDate to disk once that's implemented const char *const update_params[] = {feed->last_pubDate, feed->url, (char *) channel_id_be};
const int param_lengths[] = {0, 0, sizeof(channel_id_be)};
const int param_formats[] = {0, 0, 1};
PGresult *update_res = PQexecParams(conn, PGresult *update_res = PQexecParams(conn,
"UPDATE feeds SET last_pubDate = $1 WHERE url = $2 AND channel_id = $3", "UPDATE feeds SET last_pubDate = $1 WHERE url = $2 AND channel_id = $3::bigint",
3, NULL, update_params, NULL, NULL, 0 3, NULL, update_params, param_lengths, param_formats, 1
); );
zblock_feed_info_err result = ZBLOCK_FEED_INFO_OK; zblock_feed_info_err result = ZBLOCK_FEED_INFO_OK;