atlas/tools/redditcrawl.py

"""
Auth setup
1. Head to https://www.reddit.com/prefs/apps
2. Click "create another app"
3. Give it a name and description
4. Select "script"
5. Redirect to http://localhost:8080
6. Create file "credentials" with the format below
┌─────────────────────────────────────────────────────┐
│ [ID]        <-  Under "personal use script"         │
│ [Secret]                                            │
│ [Username]  <-  Must be a mod, don't do this if you │
│ [Password]  <-  don't know what you are doing.      │
└─────────────────────────────────────────────────────┘
7. Run Script

Running Script
1. Input the next ID to use
2. Manually resolve errors in manual_atlas.json
3   a. Use merge_out.py, or...
    b.  a. Copy temp_atlas.json entries into web/_js/atlas.js (mind the edits!)
        b. Copy read-ids-temp.txt IDs into data/read-ids.txt
5. Create a pull request
"""

import praw
import json
import time
import re
import traceback
from formatter import format_all
from migrate_atlas_format import migrate_atlas_format

OUT_FILE = open('temp_atlas.json', 'w', encoding='utf-8')
READ_IDS_FILE = open('read-ids-temp.txt', 'w')
FAIL_FILE = open('manual_atlas.txt', 'w', encoding='utf-8')

OUT_FILE_LINES = ['[\n', ']\n']

with open('credentials', 'r') as file:
	credentials = file.readlines()
	client_id = credentials[0].strip()
	client_secret = credentials[1].strip()
	username = credentials[2].strip() if len(credentials) > 3 else ""
	password = credentials[3].strip() if len(credentials) > 3 else ""

reddit = praw.Reddit(
	client_id=client_id, 
	client_secret=client_secret,
	username=username,
	password=password,
	user_agent='atlas_bot'
)

has_write_access = not reddit.read_only
if not has_write_access:
	print("Warning: No write access. Post flairs will not be updated.")
	time.sleep(5)

existing_ids = []

with open('../data/read-ids.txt', 'r') as edit_ids_file:
	for id in [x.strip() for x in edit_ids_file.readlines()]:
		existing_ids.append(id)

# with open('../web/atlas.json', 'r') as atlas_file:
# 	atlas_raw: list = json.loads(atlas_file)
# 	atlas = {}
# 	atlas_ids = []
# 	for index in atlas_raw:
# 		entry = atlas_raw[index]
# 		id = entry['id']
# 		del entry['id']
# 		atlas[id] = entry
# 		atlas_ids.append(id)

def set_flair(submission, flair):
	if has_write_access and submission.link_flair_text != flair:
		flair_choices = submission.flair.choices()
		flair = next(x for x in flair_choices if x["flair_text_editable"] and flair == x["flair_text"])
		submission.flair.select(flair["flair_template_id"])

total_all_flairs = 0
duplicate_count = 0
failcount = 0
successcount = 0
totalcount = 0

for submission in reddit.subreddit('placeAtlas2').new(limit=2000):
	total_all_flairs += 1

	if (submission.id in existing_ids):
		set_flair(submission, "Processed Entry")
		print("Found first duplicate!")
		duplicate_count += 1
		if (duplicate_count > 0):
			break
		else:
			continue
	
	if submission.link_flair_text == "New Entry" or submission.link_flair_text == "Edit Entry":

		try:

			text = submission.selftext
			rawtext = text

			text = text.replace('\u200c', '')
			text = re.compile(r"(\{.+\})", re.DOTALL).search(text).group(0)
			# Test if it needs to escape the escape character. Usually happens on fancy mode.
			try: json.loads(text)
			except json.JSONDecodeError: text = re.sub(r"\\(.)", r"\1", text)

			submission_json = json.loads(text)

			if submission_json:

				if submission.link_flair_text == "Edit Entry":

					assert submission_json["id"] != 0, "Edit invalid because ID is tampered, it must not be 0!"

					submission_json_dummy = {"id": submission_json["id"], "edit": submission.id}
					submission_json["contributors"] = []

					try:
						if not submission.author.name in submission_json:
							submission_json["contributors"].append(submission.author.name)
					except AttributeError:
						pass

				else:

					assert submission_json["id"] == 0, "Edit invalid because ID is tampered, it must be 0!"
					
					submission_json_dummy = {"id": submission.id}
					submission_json["contributors"] = []

					try:
						if not submission.author.name in submission_json:
							submission_json["contributors"].append(submission.author.name)
					except AttributeError:
						pass

				for key in submission_json:
					if not key in submission_json_dummy:
						submission_json_dummy[key] = submission_json[key];
				(submission_json, validation_status) = format_all(submission_json_dummy, True)
				
				assert validation_status < 3, \
					"Submission invalid after validation. This may be caused by not enough points on the path."

				submission_json = migrate_atlas_format(submission_json)
				
				OUT_FILE_LINES[len(OUT_FILE_LINES) - 2].replace('\n', ',\n')
				OUT_FILE_LINES.insert(len(OUT_FILE_LINES) - 1, json.dumps(submission_json, ensure_ascii=False) + '\n')
				READ_IDS_FILE.write(submission.id + '\n')
				successcount += 1
				set_flair(submission, "Processed Entry")

		except Exception as e:
			FAIL_FILE.write(
				"\n\n" + "="*40 + "\n\nSubmission ID: " +
				submission.id + "\n\n" +
				traceback.format_exc() + "\n\n" +
				"==== RAW ====" + "\n\n" +
				rawtext + "\n\n"
				"==== CLEAN ====" + "\n\n" +
				text + "\n\n"
			)
			failcount += 1
			set_flair(submission, "Rejected Entry")

		print("Wrote " + submission.id + ", submitted " + str(round(time.time()-submission.created_utc)) + " seconds ago")
		totalcount += 1

OUT_FILE.writelines(OUT_FILE_LINES)

print(f"\n\nTotal all flairs: {total_all_flairs}\nSuccess: {successcount}/{totalcount}\nFail: {failcount}/{totalcount}\nPlease check manual_atlas.txt for failed entries to manually resolve.")