Lomanic/bibliogram
1
0
Fork 0
mirror of https://git.sr.ht/~cadence/bibliogram synced 2024-11-22 08:07:30 +00:00
Code Issues Releases Wiki Activity

Make import script tell you what's happening

Browse Source
This commit is contained in:
Cadence Ember 2020-07-07 22:01:24 +12:00
parent 0c0a3cf7a8
commit 1b5342428a
No known key found for this signature in database
GPG Key ID: 128B99B1B74A6412
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
scripts/import_users.js
View File

@ -11,7 +11,15 @@ const {request} = require("../src/lib/utils/request")
} }
if (target.match(/^https?:\/\//)) { if (target.match(/^https?:\/\//)) {
var usersString = await request(target).text() console.log("Seems to be a URL, requesting now. This could take a few minutes. Be patient.")
const ref = await request(target)
const res = await ref.response()
const lengthContainer = res.headers.get("content-length")
if (lengthContainer) {
const length = Number(Array.isArray(lengthContainer) ? lengthContainer[0] : lengthContainer)
console.log(`${Math.floor(length/1000)} kB will be downloaded`)
}
var usersString = await ref.text()
} else { } else {
var usersString = await fs.readFile(target, {encoding: "utf8"}) var usersString = await fs.readFile(target, {encoding: "utf8"})
} }
@ -19,10 +27,12 @@ const {request} = require("../src/lib/utils/request")
/** @type {{username: string, user_id: string, created: number, updated: number, updated_version: number, biography: string, post_count: number, following_count: number, followed_by_count: number, external_url: string, full_name: string, is_private: number, is_verified: number, profile_pic_url: string}[]} */ /** @type {{username: string, user_id: string, created: number, updated: number, updated_version: number, biography: string, post_count: number, following_count: number, followed_by_count: number, external_url: string, full_name: string, is_private: number, is_verified: number, profile_pic_url: string}[]} */
const incomingUsers = JSON.parse(usersString) const incomingUsers = JSON.parse(usersString)
process.stdout.write("Noting existing users... ")
const existing = new Map() const existing = new Map()
for (const row of db.prepare("SELECT user_id, updated, updated_version FROM Users").iterate()) { for (const row of db.prepare("SELECT user_id, updated, updated_version FROM Users").iterate()) {
existing.set(row.user_id, row) existing.set(row.user_id, row)
} }
process.stdout.write("done.\n")
const base = const base =
"INTO Users (username, user_id, created, updated, updated_version, biography, post_count, following_count, followed_by_count, external_url, full_name, is_private, is_verified, profile_pic_url) VALUES " "INTO Users (username, user_id, created, updated, updated_version, biography, post_count, following_count, followed_by_count, external_url, full_name, is_private, is_verified, profile_pic_url) VALUES "
@ -34,6 +44,7 @@ const {request} = require("../src/lib/utils/request")
let overwrittenCount = 0 let overwrittenCount = 0
let skippedCount = 0 let skippedCount = 0
process.stdout.write("Importing into database... ")
db.transaction(() => { db.transaction(() => {
for (const user of incomingUsers) { for (const user of incomingUsers) {
if (existing.has(user.user_id)) { if (existing.has(user.user_id)) {
@ -50,6 +61,7 @@ const {request} = require("../src/lib/utils/request")
} }
} }
})() })()
process.stdout.write("done.\n")
console.log(`Imported ${incomingUsers.length} entries (${newCount} new, ${overwrittenCount} overwritten, ${skippedCount} skipped)`) console.log(`Imported ${incomingUsers.length} entries (${newCount} new, ${overwrittenCount} overwritten, ${skippedCount} skipped)`)
})() })()