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

Add zblock_feed_info_update

Browse Source
This commit is contained in:
Mina Brown
2024-11-23 15:33:10 -05:00
parent 44b1f80b9e
commit ca6d37a1cf
3 changed files with 29 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
feed_info.c
View File

@ -95,3 +95,27 @@ zblock_feed_info_err zblock_feed_info_insert(PGconn *conn, zblock_feed_info *fee
PQclear(insert_res);
return result;
}
// 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) {
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), "%ld", feed->channel_id);
const char *const update_params[] = {feed->last_pubDate, feed->url, channel_id_str};
// save the updated pubDate to disk once that's implemented
PGresult *update_res = PQexecParams(conn,
"UPDATE feeds SET last_pubDate = $1 WHERE url = $2 AND channel_id = $3",
3, NULL, update_params, NULL, NULL, 0
);
zblock_feed_info_err result = ZBLOCK_FEED_INFO_OK;
if (PQresultStatus(update_res) != PGRES_COMMAND_OK) {
log_error("Failed to update feed: %s", PQresultErrorMessage(update_res));
result = ZBLOCK_FEED_INFO_DBERROR;
}
PQclear(update_res);
return result;
}

3
feed_info.h
View File

@ -42,4 +42,7 @@ zblock_feed_info_err zblock_feed_info_exists(PGconn *conn, const char *url, u64s
// Insert new feed into the database
zblock_feed_info_err zblock_feed_info_insert(PGconn *conn, zblock_feed_info *feed);
// 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);
#endif

17
main.c
View File

@ -155,21 +155,8 @@ static void timer_retrieve_feeds(struct discord *client, struct discord_timer *t
}
if (update_pubDate) {
char *current_pubDate = mrss_feed->item->pubDate;
char channel_id_str[21]; // hold a 64-bit int in decimal form
snprintf(channel_id_str, sizeof(channel_id_str), "%ld", feed_buffer->info.channel_id);
const char *const update_params[] = {current_pubDate, feed_buffer->info.url, channel_id_str};
// save the updated pubDate to disk once that's implemented
PGresult *update_res = PQexecParams(database_conn,
"UPDATE feeds SET last_pubDate = $1 WHERE url = $2 AND channel_id = $3",
3, NULL, update_params, NULL, NULL, 0
);
if (PQresultStatus(update_res) != PGRES_COMMAND_OK) {
log_error("Failed to update pubDate: %s", PQresultErrorMessage(update_res)); // cry
}
PQclear(update_res);
feed_buffer->info.url = mrss_feed->item->pubDate;
zblock_feed_info_update(database_conn, &feed_buffer->info);
}
// done with our feed!