func.py 93 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426
  1. # Init
  2. import os
  3. import sys
  4. import platform
  5. import smtplib
  6. import shutil
  7. import json
  8. import datetime
  9. import ipaddress
  10. import subprocess
  11. import email.mime.text
  12. import email.utils
  13. import email.header
  14. from .func_tool import *
  15. # Init-Version
  16. with open('version.json', encoding = 'utf8') as file_data:
  17. version_list = json_loads(file_data.read())
  18. print('Version : ' + version_list['r_ver'])
  19. print('DB set version : ' + version_list['c_ver'])
  20. print('Skin set version : ' + version_list['s_ver'])
  21. # Init-PIP_Install
  22. data_up_date = 1
  23. if os.path.exists(os.path.join('data', 'version.json')):
  24. with open(os.path.join('data', 'version.json'), encoding = 'utf8') as file_data:
  25. data_load_ver = file_data.read()
  26. if data_load_ver == version_list['r_ver']:
  27. data_up_date = 0
  28. if data_up_date == 1:
  29. with open(os.path.join('data', 'version.json'), 'w', encoding = 'utf8') as f:
  30. f.write(version_list['r_ver'])
  31. if platform.system() in ('Linux', 'Darwin', 'Windows'):
  32. python_ver = ''
  33. python_ver = str(sys.version_info.major) + '.' + str(sys.version_info.minor)
  34. run_list = [
  35. sys.executable,
  36. 'python' + python_ver,
  37. 'python3',
  38. 'python',
  39. 'py -' + python_ver
  40. ]
  41. for exe_name in run_list:
  42. try:
  43. subprocess.check_call([exe_name, "-m", "pip", "install", "--upgrade", "--user", "-r", "requirements-optional.txt"])
  44. except:
  45. pass
  46. try:
  47. subprocess.check_call([exe_name, "-m", "pip", "install", "--upgrade", "--user", "-r", "requirements.txt"])
  48. subprocess.Popen([exe_name] + sys.argv)
  49. os._exit(0)
  50. except:
  51. pass
  52. else:
  53. print('Error : automatic installation is not supported.')
  54. print('Help : try "python3 -m pip install -r requirements.txt"')
  55. else:
  56. print('Error : automatic installation is not supported.')
  57. print('Help : try "python3 -m pip install -r requirements.txt"')
  58. else:
  59. print('PIP check pass')
  60. # Init-Load
  61. from .func_render import class_do_render
  62. from diff_match_patch import diff_match_patch
  63. import werkzeug.routing
  64. import werkzeug.debug
  65. import flask
  66. import asyncio
  67. import aiohttp
  68. import requests
  69. from PIL import Image
  70. try:
  71. import mysqlclient as pymysql
  72. except:
  73. import pymysql
  74. if sys.version_info < (3, 6):
  75. import sha3
  76. # Func
  77. # Func-main
  78. original_render_template = flask.render_template
  79. def custom_render_template(template_name_or_list, **context):
  80. context['data'] = '<div class="opennamu_main">' + context['data'] + '</div>'
  81. return original_render_template(template_name_or_list, **context)
  82. flask.render_template = custom_render_template
  83. global_lang_data = {}
  84. global_some_set = {}
  85. def do_db_set(db_set):
  86. for for_a in db_set:
  87. global_func_some_set_do('db_' + for_a, db_set[for_a])
  88. global_some_set_do('db_' + for_a, db_set[for_a])
  89. class flask_data_or_variable:
  90. def __init__(self, flask_data, var_dict):
  91. if var_dict == {}:
  92. self.data = flask_data
  93. self.selected_flask = True
  94. else:
  95. self.data = var_dict
  96. self.selected_flask = False
  97. def get(self, dict_name, replace_data):
  98. if self.selected_flask == True:
  99. return self.data.get(dict_name, replace_data)
  100. else:
  101. if dict_name in self.data:
  102. return self.data[dict_name]
  103. else:
  104. return replace_data
  105. def global_some_set_do(set_name, data = None):
  106. global global_some_set
  107. if data != None:
  108. global_some_set[set_name] = data
  109. if set_name in global_some_set:
  110. return global_some_set[set_name]
  111. else:
  112. return None
  113. async def python_to_golang(func_name, other_set = {}):
  114. other_set = {
  115. "url" : func_name,
  116. "data" : json_dumps(other_set)
  117. }
  118. if flask.has_request_context():
  119. other_set["session"] = json_dumps(dict(flask.session))
  120. if "Cookie" in flask.request.headers:
  121. other_set["cookie"] = flask.request.headers["Cookie"]
  122. else:
  123. other_set["cookie"] = ""
  124. other_set["ip"] = ip_check()
  125. else:
  126. other_set["session"] = "{}"
  127. other_set["cookie"] = ""
  128. other_set["ip"] = "127.0.0.1"
  129. port_data = global_some_set_do("setup_golang_port")
  130. async with aiohttp.ClientSession() as session:
  131. while 1:
  132. async with session.post('http://localhost:' + port_data + '/', data = json_dumps(other_set)) as res:
  133. data = await res.json()
  134. if "response" in data and data["response"] == "error":
  135. raise Exception(f"API returned error: {data}")
  136. else:
  137. return data
  138. async def opennamu_make_list(left = '', right = '', bottom = '', class_name = ''):
  139. data_html = f'<span class="{class_name}">'
  140. data_html += '<div class="opennamu_recent_change">'
  141. data_html += left
  142. data_html += '<div style="float: right;">'
  143. data_html += right
  144. data_html += '</div>'
  145. data_html += '<div style="clear: both;"></div>'
  146. if bottom != '':
  147. data_html += '<hr>'
  148. data_html += bottom
  149. data_html += '</div>'
  150. data_html += '<hr class="main_hr">'
  151. data_html += '</span>'
  152. return data_html
  153. # Func-init
  154. def get_init_set_list(need = 'all'):
  155. init_set_list = {
  156. 'host' : {
  157. 'display' : 'Host',
  158. 'require' : 'conv',
  159. 'default' : '0.0.0.0'
  160. }, 'port' : {
  161. 'display' : 'Port',
  162. 'require' : 'conv',
  163. 'default' : '3000'
  164. }, 'golang_port' : {
  165. 'display' : 'Golang port',
  166. 'require' : 'conv',
  167. 'default' : '3001'
  168. }, 'language' : {
  169. 'display' : 'Language',
  170. 'require' : 'select',
  171. 'default' : 'ko-KR',
  172. 'list' : ['ko-KR', 'en-US']
  173. }, 'markup' : {
  174. 'display' : 'Markup',
  175. 'require' : 'select',
  176. 'default' : 'namumark',
  177. 'list' : ['namumark', 'namumark_beta', 'macromark', 'markdown', 'custom', 'raw']
  178. }, 'encode' : {
  179. 'display' : 'Encryption method',
  180. 'require' : 'select',
  181. 'default' : 'sha3',
  182. 'list' : ['sha3', 'sha3-salt', 'sha3-512', 'sha3-512-salt']
  183. }
  184. }
  185. if need == 'all':
  186. return init_set_list
  187. else:
  188. return init_set_list[need]
  189. class get_db_connect:
  190. def __init__(self, db_type = '', init_mode = False):
  191. self.db_set = {}
  192. self.init_mode = init_mode
  193. for for_a in ("db_type", "db_name"):
  194. self.db_set[for_a] = global_some_set_do(for_a)
  195. if db_type != '':
  196. self.db_set['db_type'] = db_type
  197. if self.db_set['db_type'] == 'mysql':
  198. for for_a in ("db_mysql_host", "db_mysql_user", "db_mysql_pw", "db_mysql_port"):
  199. self.db_set[for_a] = global_some_set_do(for_a)
  200. def __enter__(self):
  201. if self.db_set['db_type'] == 'sqlite':
  202. self.conn = sqlite3.connect(
  203. self.db_set['db_name'] + '.db',
  204. check_same_thread = False,
  205. isolation_level = None
  206. )
  207. else:
  208. # try connect
  209. print('Wait for DB connection...')
  210. self.conn = None
  211. try_cnt = 1
  212. while (self.conn == None and not (self.conn.open() if self.conn != None else False)) and try_cnt <= 5:
  213. try:
  214. if self.init_mode:
  215. self.conn = pymysql.connect(
  216. host = self.db_set['db_mysql_host'],
  217. user = self.db_set['db_mysql_user'],
  218. password = self.db_set['db_mysql_pw'],
  219. charset = 'utf8mb4',
  220. port = int(self.db_set['db_mysql_port']),
  221. autocommit = True
  222. )
  223. else:
  224. self.conn = pymysql.connect(
  225. host = self.db_set['db_mysql_host'],
  226. user = self.db_set['db_mysql_user'],
  227. password = self.db_set['db_mysql_pw'],
  228. charset = 'utf8mb4',
  229. port = int(self.db_set['db_mysql_port']),
  230. autocommit = True,
  231. db = self.db_set['db_name']
  232. )
  233. except pymysql.err.OperationalError as err:
  234. if try_cnt + 1 > 5:
  235. raise err
  236. else:
  237. time.sleep(0.5)
  238. continue
  239. finally:
  240. try_cnt += 1
  241. if self.conn == None:
  242. raise Exception("Unable to connect database")
  243. return self.conn
  244. def __exit__(self, exc_type, exc_value, traceback):
  245. self.conn.commit()
  246. self.conn.close()
  247. # class get_whoosh_connect:
  248. class class_check_json:
  249. def do_check_set_json(self):
  250. if os.getenv('NAMU_DB') or os.getenv('NAMU_DB_TYPE'):
  251. set_data = {}
  252. set_data['db'] = os.getenv('NAMU_DB') if os.getenv('NAMU_DB') else 'data'
  253. set_data['db_type'] = os.getenv('NAMU_DB_TYPE') if os.getenv('NAMU_DB_TYPE') else 'sqlite'
  254. else:
  255. if os.path.exists(os.path.join('data', 'set.json')):
  256. db_set_list = ['db', 'db_type']
  257. with open(os.path.join('data', 'set.json'), encoding = 'utf8') as file_data:
  258. set_data = json_loads(file_data.read())
  259. for i in db_set_list:
  260. if not i in set_data:
  261. os.remove(os.path.join('data', 'set.json'))
  262. break
  263. if not os.path.exists(os.path.join('data', 'set.json')):
  264. set_data = {}
  265. normal_db_type = ['sqlite', 'mysql']
  266. print('DB type (' + normal_db_type[0] + ') [' + ', '.join(normal_db_type) + '] : ', end = '')
  267. data_get = str(input())
  268. if data_get == '' or not data_get in normal_db_type:
  269. set_data['db_type'] = 'sqlite'
  270. else:
  271. set_data['db_type'] = data_get
  272. all_src = []
  273. if set_data['db_type'] == 'sqlite':
  274. for i_data in os.listdir("."):
  275. f_src = re.search(r"(.+)\.db$", i_data)
  276. if f_src:
  277. all_src += [f_src.group(1)]
  278. print('DB name (data) [' + ', '.join(all_src) + '] : ', end = '')
  279. data_get = str(input())
  280. if data_get == '':
  281. set_data['db'] = 'data'
  282. else:
  283. set_data['db'] = data_get
  284. with open(os.path.join('data', 'set.json'), 'w', encoding = 'utf8') as f:
  285. f.write(json_dumps(set_data))
  286. print('DB name : ' + set_data['db'])
  287. print('DB type : ' + set_data['db_type'])
  288. data_db_set = {}
  289. data_db_set['name'] = set_data['db']
  290. data_db_set['type'] = set_data['db_type']
  291. return data_db_set
  292. def do_check_mysql_json(self, data_db_set):
  293. def do_check_mysql_env():
  294. env_keys = ['NAMU_DB_HOST', 'NAMU_DB_PORT', 'NAMU_DB_USER', 'NAMU_DB_PASSWORD']
  295. vaild = False
  296. for key in env_keys:
  297. if os.getenv(key):
  298. vaild = True
  299. break
  300. return vaild
  301. if do_check_mysql_env():
  302. # ['user', 'password', 'host', 'port']
  303. set_data_mysql = {}
  304. set_data_mysql['host'] = os.getenv('NAMU_DB_HOST') if os.getenv('NAMU_DB_HOST') else 'localhost'
  305. set_data_mysql['port'] = os.getenv('NAMU_DB_PORT') if os.getenv('NAMU_DB_PORT') else 3306
  306. if not os.getenv('NAMU_DB_USER'):
  307. raise Exception('Error : NAMU_DB_USER env not set')
  308. else:
  309. set_data_mysql['user'] = os.getenv('NAMU_DB_USER')
  310. if not os.getenv('NAMU_DB_PASSWORD'):
  311. raise Exception('Error : NAMU_DB_PASSWORD env not set')
  312. else:
  313. set_data_mysql['password'] = os.getenv('NAMU_DB_PASSWORD')
  314. elif os.path.exists(os.path.join('data', 'mysql.json')):
  315. db_set_list = ['user', 'password', 'host', 'port']
  316. with open(os.path.join('data', 'mysql.json'), encoding = 'utf8') as file_data:
  317. set_data = json_loads(file_data.read())
  318. for i in db_set_list:
  319. if not i in set_data:
  320. os.remove(os.path.join('data', 'mysql.json'))
  321. break
  322. set_data_mysql = set_data
  323. elif not os.path.exists(os.path.join('data', 'mysql.json')):
  324. set_data_mysql = {}
  325. print('DB user ID : ', end = '')
  326. set_data_mysql['user'] = str(input())
  327. print('DB password : ', end = '')
  328. set_data_mysql['password'] = str(input())
  329. print('DB host (localhost) : ', end = '')
  330. set_data_mysql['host'] = str(input())
  331. if set_data_mysql['host'] == '':
  332. set_data_mysql['host'] = 'localhost'
  333. print('DB port (3306) : ', end = '')
  334. set_data_mysql['port'] = str(input())
  335. if set_data_mysql['port'] == '':
  336. set_data_mysql['port'] = '3306'
  337. with open(os.path.join('data', 'mysql.json'), 'w', encoding = 'utf8') as f:
  338. f.write(json_dumps(set_data_mysql))
  339. data_db_set['mysql_user'] = set_data_mysql['user']
  340. data_db_set['mysql_pw'] = set_data_mysql['password']
  341. if 'host' in set_data_mysql:
  342. data_db_set['mysql_host'] = set_data_mysql['host']
  343. else:
  344. data_db_set['mysql_host'] = 'localhost'
  345. if 'port' in set_data_mysql:
  346. data_db_set['mysql_port'] = set_data_mysql['port']
  347. else:
  348. data_db_set['mysql_port'] = '3306'
  349. return data_db_set
  350. def __init__(self):
  351. self.data_db_set = {}
  352. def __new__(cls):
  353. instance = super().__new__(cls)
  354. cls.data_db_set = instance.do_check_set_json()
  355. if cls.data_db_set['type'] == 'mysql':
  356. cls.data_db_set = instance.do_check_mysql_json(cls.data_db_set)
  357. return cls.data_db_set
  358. def get_db_table_list():
  359. # DB table
  360. # Init-Create_DB
  361. # --이거 개편한다더니 도대체 언제?--
  362. create_data = {}
  363. # 폐지 예정 (data_set으로 통합)
  364. create_data['data_set'] = ['doc_name', 'doc_rev', 'set_name', 'set_data']
  365. create_data['data'] = ['title', 'data', 'type']
  366. create_data['history'] = ['id', 'title', 'data', 'date', 'ip', 'send', 'leng', 'hide', 'type']
  367. create_data['rc'] = ['id', 'title', 'date', 'type']
  368. create_data['acl'] = ['title', 'data', 'type']
  369. # 개편 예정 (data_link로 변경)
  370. create_data['back'] = ['title', 'link', 'type', 'data']
  371. # 폐지 예정 (topic_set으로 통합) [가장 시급]
  372. create_data['topic_set'] = ['thread_code', 'set_name', 'set_id', 'set_data']
  373. create_data['rd'] = ['title', 'sub', 'code', 'date', 'band', 'stop', 'agree', 'acl']
  374. create_data['topic'] = ['id', 'data', 'date', 'ip', 'block', 'top', 'code']
  375. # 폐지 예정 (user_set으로 통합)
  376. create_data['rb'] = ['block', 'end', 'today', 'blocker', 'why', 'band', 'login', 'ongoing']
  377. # 개편 예정 (wiki_set과 wiki_filter과 wiki_vote으로 변경)
  378. create_data['other'] = ['name', 'data', 'coverage']
  379. create_data['html_filter'] = ['html', 'kind', 'plus', 'plus_t']
  380. create_data['vote'] = ['name', 'id', 'subject', 'data', 'user', 'type', 'acl']
  381. # 개편 예정 (auth와 auth_log로 변경)
  382. create_data['alist'] = ['name', 'acl']
  383. create_data['re_admin'] = ['who', 'what', 'time']
  384. # 개편 예정 (user_notice와 user_agent로 변경)
  385. create_data['ua_d'] = ['name', 'ip', 'ua', 'today', 'sub']
  386. create_data['user_set'] = ['name', 'id', 'data']
  387. create_data['user_notice'] = ['id', 'name', 'data', 'date', 'readme']
  388. create_data['bbs_set'] = ['set_name', 'set_code', 'set_id', 'set_data']
  389. create_data['bbs_data'] = ['set_name', 'set_code', 'set_id', 'set_data']
  390. return create_data
  391. async def update(conn, ver_num, set_data):
  392. curs = conn.cursor()
  393. # 업데이트 하위 호환 유지 함수
  394. if ver_num < 3160027:
  395. print('Add init set')
  396. set_init(conn)
  397. if ver_num < 3170002:
  398. curs.execute(db_change("select html from html_filter where kind = 'extension'"))
  399. if not curs.fetchall():
  400. for i in ['jpg', 'jpeg', 'png', 'gif', 'webp', 'svg']:
  401. curs.execute(db_change("insert into html_filter (html, kind) values (?, 'extension')"), [i])
  402. if ver_num < 3170400:
  403. curs.execute(db_change("select title, sub, code from topic where id = '1'"))
  404. for i in curs.fetchall():
  405. curs.execute(db_change("update topic set code = ? where title = ? and sub = ?"), [i[2], i[0], i[1]])
  406. curs.execute(db_change("update rd set code = ? where title = ? and sub = ?"), [i[2], i[0], i[1]])
  407. if ver_num < 3171800:
  408. curs.execute(db_change("select data from other where name = 'recaptcha'"))
  409. change_rec = curs.fetchall()
  410. if change_rec and change_rec[0][0] != '':
  411. new_rec = re.search(r'data-sitekey="([^"]+)"', change_rec[0][0])
  412. if new_rec:
  413. curs.execute(db_change("update other set data = ? where name = 'recaptcha'"), [new_rec.group(1)])
  414. else:
  415. curs.execute(db_change("update other set data = '' where name = 'recaptcha'"))
  416. curs.execute(db_change("update other set data = '' where name = 'sec_re'"))
  417. if ver_num < 3172800 and set_data['type'] == 'mysql':
  418. get_data_mysql = json_loads(open('data/mysql.json', encoding = 'utf8').read())
  419. with open('data/mysql.json', 'w') as f:
  420. f.write('{ "user" : "' + get_data_mysql['user'] + '", "password" : "' + get_data_mysql['password'] + '", "host" : "localhost" }')
  421. if ver_num < 3183603:
  422. curs.execute(db_change("select block from ban where band = 'O'"))
  423. for i in curs.fetchall():
  424. curs.execute(db_change("update ban set block = ?, band = 'regex' where block = ? and band = 'O'"), ['^' + i[0].replace('.', '\\.'), i[0]])
  425. curs.execute(db_change("select block from rb where band = 'O'"))
  426. for i in curs.fetchall():
  427. curs.execute(db_change("update rb set block = ?, band = 'regex' where block = ? and band = 'O'"), ['^' + i[0].replace('.', '\\.'), i[0]])
  428. if ver_num < 3190201:
  429. today_time = get_time()
  430. curs.execute(db_change("select block, end, why, band, login from ban"))
  431. for i in curs.fetchall():
  432. curs.execute(db_change("insert into rb (block, end, today, why, band, login, ongoing) values (?, ?, ?, ?, ?, ?, ?)"), [i[0], i[1], today_time, i[2], i[3], i[4], '1'])
  433. if ver_num < 3191301:
  434. curs.execute(db_change('select id, title, date from history where not title like "user:%" order by date desc limit 50'))
  435. data_list = curs.fetchall()
  436. for get_data in data_list:
  437. curs.execute(db_change("insert into rc (id, title, date, type) values (?, ?, ?, 'normal')"), [get_data[0], get_data[1], get_data[2]])
  438. if ver_num < 3202400:
  439. curs.execute(db_change("select data from other where name = 'update'"))
  440. get_data = curs.fetchall()
  441. if get_data and get_data[0][0] == 'master':
  442. curs.execute(db_change("update other set data = 'beta' where name = 'update'"), [])
  443. if ver_num < 3202600:
  444. curs.execute(db_change("select name, regex, sub from filter"))
  445. for i in curs.fetchall():
  446. curs.execute(db_change("insert into html_filter (html, kind, plus, plus_t) values (?, 'regex_filter', ?, ?)"), [i[0], i[1], i[2]])
  447. curs.execute(db_change("select title, link, icon from inter"))
  448. for i in curs.fetchall():
  449. curs.execute(db_change("insert into html_filter (html, kind, plus, plus_t) values (?, 'inter_wiki', ?, ?)"), [i[0], i[1], i[2]])
  450. if ver_num < 3203400:
  451. curs.execute(db_change("select user, css from custom"))
  452. for i in curs.fetchall():
  453. curs.execute(db_change("insert into user_set (name, id, data) values ('custom_css', ?, ?)"), [re.sub(r' \(head\)$', '', i[0]), i[1]])
  454. if ver_num < 3205500:
  455. curs.execute(db_change("select title, decu, dis, view, why from acl"))
  456. for i in curs.fetchall():
  457. curs.execute(db_change("insert into acl (title, data, type) values (?, ?, ?)"), [i[0], i[1], 'decu'])
  458. curs.execute(db_change("insert into acl (title, data, type) values (?, ?, ?)"), [i[0], i[2], 'dis'])
  459. curs.execute(db_change("insert into acl (title, data, type) values (?, ?, ?)"), [i[0], i[3], 'view'])
  460. curs.execute(db_change("insert into acl (title, data, type) values (?, ?, ?)"), [i[0], i[4], 'why'])
  461. if ver_num < 3300101:
  462. # 캐시 초기화
  463. curs.execute(db_change('delete from cache_data'))
  464. if ver_num < 3300301:
  465. # regex_filter 오류 해결
  466. curs.execute(db_change('delete from html_filter where kind = "regex_filter" and html is null'))
  467. if ver_num < 3302302:
  468. # user이랑 user_set 테이블의 통합
  469. curs.execute(db_change('select id, pw, acl, date, encode from user'))
  470. for i in curs.fetchall():
  471. curs.execute(db_change("insert into user_set (name, id, data) values (?, ?, ?)"), ['pw', i[0], i[1]])
  472. curs.execute(db_change("insert into user_set (name, id, data) values (?, ?, ?)"), ['acl', i[0], i[2]])
  473. curs.execute(db_change("insert into user_set (name, id, data) values (?, ?, ?)"), ['date', i[0], i[3]])
  474. curs.execute(db_change("insert into user_set (name, id, data) values (?, ?, ?)"), ['encode', i[0], i[4]])
  475. if ver_num < 3400101:
  476. # user_set이랑 user_application 테이블의 통합
  477. curs.execute(db_change('select id, pw, date, encode, question, answer, ip, ua, email from user_application'))
  478. for i in curs.fetchall():
  479. sql_data = {}
  480. sql_data['id'] = i[0]
  481. sql_data['pw'] = i[1]
  482. sql_data['date'] = i[2]
  483. sql_data['encode'] = i[3]
  484. sql_data['question'] = i[4]
  485. sql_data['answer'] = i[5]
  486. sql_data['ip'] = i[6]
  487. sql_data['ua'] = i[7]
  488. sql_data['email'] = i[8]
  489. curs.execute(db_change("insert into user_set (name, id, data) values (?, ?, ?)"), ['application', i[0], json_dumps(sql_data)])
  490. if ver_num < 3500105:
  491. curs.execute(db_change('delete from acl where title like "file:%" and data = "admin" and type like "decu%"'))
  492. if ver_num < 3500106:
  493. curs.execute(db_change("select data from other where name = 'domain'"))
  494. db_data = curs.fetchall()
  495. if db_data and db_data[0][0] != '':
  496. db_data = db_data[0][0]
  497. db_data = re.match(r'[^/]+\/\/([^/]+)', db_data)
  498. if db_data:
  499. db_data = db_data.group(1)
  500. curs.execute(db_change("update other set data = ? where name = 'domain'"), [db_data])
  501. else:
  502. curs.execute(db_change("update other set data = '' where name = 'domain'"))
  503. if ver_num < 3500107:
  504. db_table_list = get_db_table_list()
  505. for for_a in db_table_list:
  506. for for_b in db_table_list[for_a]:
  507. curs.execute(db_change("update " + for_a + " set " + for_b + " = '' where " + for_b + " is null"))
  508. if ver_num < 3500113:
  509. db_table_list = get_db_table_list()
  510. for for_a in db_table_list:
  511. for for_b in db_table_list[for_a]:
  512. curs.execute(db_change("update " + for_a + " set " + for_b + " = '' where " + for_b + " is null"))
  513. if ver_num < 3500114:
  514. curs.execute(db_change('delete from alarm'))
  515. if ver_num < 3500354:
  516. curs.execute(db_change("select data from other where name = 'robot'"))
  517. db_data = curs.fetchall()
  518. if db_data:
  519. robot_default = '' + \
  520. 'User-agent: *\n' + \
  521. 'Disallow: /\n' + \
  522. 'Allow: /$\n' + \
  523. 'Allow: /image/\n' + \
  524. 'Allow: /views/\n' + \
  525. 'Allow: /w/' + \
  526. ''
  527. if db_data[0][0] == robot_default:
  528. curs.execute(db_change("insert into other (name, data, coverage) values ('robot_default', 'on', '')"))
  529. if ver_num < 3500355:
  530. # other coverage 오류 해결
  531. curs.execute(db_change("update other set coverage = '' where coverage is null"))
  532. if ver_num < 3500358:
  533. curs.execute(db_change("drop index history_index"))
  534. curs.execute(db_change("create index history_index on history (title, ip)"))
  535. if ver_num < 3500360:
  536. # 마지막 편집 따로 기록하도록
  537. # create_data['data_set'] = ['doc_name', 'doc_rev', 'set_name', 'set_data']
  538. print("Update 3500360...")
  539. curs.execute(db_change('delete from data_set where set_name = "last_edit"'))
  540. curs.execute(db_change("select title from data"))
  541. db_data = curs.fetchall()
  542. for for_a in db_data:
  543. curs.execute(db_change("select date from history where title = ? order by date desc limit 1"), [for_a[0]])
  544. db_data_2 = curs.fetchall()
  545. if db_data_2:
  546. curs.execute(db_change("insert into data_set (doc_name, doc_rev, set_name, set_data) values (?, '', 'last_edit', ?)"), [for_a[0], db_data_2[0][0]])
  547. curs.execute(db_change('delete from acl where title like "file:%" and data = "admin" and type like "decu%"'))
  548. print("Update 3500360 complete")
  549. if ver_num < 3500361:
  550. # curs.execute(db_change('select id from user_set where name = "email" and data = ?'), [user_email])
  551. curs.execute(db_change('select id from user_set where name = "email"'))
  552. for db_data in curs.fetchall():
  553. if ip_or_user(db_data[0]) == 1:
  554. curs.execute(db_change('delete from user_set where id = ? and name = "email"'), [db_data[0]])
  555. # create_data['history'] = ['id', 'title', 'data', 'date', 'ip', 'send', 'leng', 'hide', 'type']
  556. # create_data['rc'] = ['id', 'title', 'date', 'type']
  557. if ver_num == 3500362:
  558. curs.execute(db_change("drop index history_index"))
  559. curs.execute(db_change("create index history_index on history (title, ip)"))
  560. if ver_num < 3500365:
  561. curs.execute(db_change("update back set data = '' where data is null"))
  562. if ver_num < 3500371:
  563. curs.execute(db_change("delete from user_notice"))
  564. user_alarm_count = {}
  565. curs.execute(db_change("select name, data, date from alarm"))
  566. for db_data in curs.fetchall():
  567. if db_data[0] in user_alarm_count:
  568. user_alarm_count[db_data[0]] += 1
  569. else:
  570. user_alarm_count[db_data[0]] = 1
  571. curs.execute(db_change('insert into user_notice (id, name, data, date, readme) values (?, ?, ?, ?, "")'), [str(user_alarm_count[db_data[0]]), db_data[0], db_data[1], db_data[2]])
  572. if ver_num < 3500372:
  573. # ID 글자 확인 호환용
  574. curs.execute(db_change('insert into html_filter (html, kind, plus, plus_t) values (?, ?, ?, ?)'), [r'(?:[^A-Za-zㄱ-힣0-9])', 'name', '', ''])
  575. if ver_num < 3500373:
  576. select_data = {}
  577. curs.execute(db_change("select name, id, data from user_set where name = 'application'"))
  578. for db_data in curs.fetchall():
  579. select_data[db_data[1]] = db_data
  580. curs.execute(db_change("delete from user_set where name = 'application'"))
  581. for db_data in select_data:
  582. curs.execute(db_change("insert into user_set (id, name, data) values (?, ?, ?)"), [select_data[db_data][1], select_data[db_data][0], select_data[db_data][2]])
  583. if ver_num < 3500374:
  584. # ban 오류 해결
  585. curs.execute(db_change("update rb set ongoing = '' where ongoing is null"))
  586. curs.execute(db_change("update rb set login = '' where login is null"))
  587. if ver_num < 3500375:
  588. curs.execute(db_change("select title, type, user from scan"))
  589. for for_a in curs.fetchall():
  590. type_data = 'watchlist' if for_a[1] == '' else 'star_doc'
  591. curs.execute(db_change("insert into user_set (id, name, data) values (?, ?, ?)"), [for_a[2], type_data, for_a[0]])
  592. if ver_num < 3500376:
  593. curs.execute(db_change("select doc_name, doc_rev from data_set where set_name = 'edit_request_data'"))
  594. for for_a in curs.fetchall():
  595. curs.execute(db_change("select id from history where title = ? order by id + 0 desc limit 1"), [for_a[0]])
  596. get_data = curs.fetchall()
  597. if get_data and (int(get_data[0][0]) + 1) == int(for_a[1]):
  598. curs.execute(db_change("insert into data_set (doc_name, doc_rev, set_name, set_data) values (?, ?, 'edit_request_doing', '1')"), [for_a[0], for_a[1]])
  599. if ver_num < 3500377 and set_data['type'] == 'sqlite':
  600. conn.execute('pragma journal_mode = delete')
  601. if ver_num < 3500378:
  602. curs.execute(db_change("select title from data where title like 'category:%' or title like 'user:%' or title like 'file:%'"))
  603. for for_a in curs.fetchall():
  604. mode = ''
  605. if re.search('^user:', for_a[0]):
  606. mode = 'user'
  607. elif re.search('^file:', for_a[0]):
  608. mode = 'file'
  609. elif re.search('^category:', for_a[0]):
  610. mode = 'category'
  611. curs.execute(db_change('delete from data_set where doc_name = ? and set_name = "doc_type"'), [for_a[0]])
  612. curs.execute(db_change("insert into data_set (doc_name, doc_rev, set_name, set_data) values (?, '', 'doc_type', ?)"), [for_a[0], mode])
  613. if ver_num < 3500379:
  614. curs.execute(db_change("select distinct doc_name from data_set where doc_rev = 'not_exist' or doc_rev = ''"))
  615. for for_a in curs.fetchall():
  616. data_set_exist = ''
  617. curs.execute(db_change("select title from data where title = ?"), [for_a[0]])
  618. if not curs.fetchall():
  619. data_set_exist = 'not_exist'
  620. curs.execute(db_change("update data_set set doc_rev = ? where doc_name = ? and (doc_rev = '' or doc_rev = 'not_exist')"), [data_set_exist, for_a[0]])
  621. if ver_num < 20240513:
  622. curs.execute(db_change("update user_set set data = '☑️' where name = 'user_title' and data = '✅'"))
  623. if ver_num < 20240732:
  624. curs.execute(db_change("select distinct name from alist where acl = 'owner'"))
  625. for for_a in curs.fetchall():
  626. curs.execute(db_change("select distinct id from user_set where name = 'acl' and data = ?"), [for_a[0]])
  627. for for_b in curs.fetchall():
  628. lang_name = get_lang_name(conn, tool = 'inter')
  629. if lang_name == 'ko-KR':
  630. await add_alarm(for_b[0], 'tool:system', '메인 ACL이 권한으로 개편되면서 기존 설정 값이 날라갔으니 권한으로 재설정 해주세요.')
  631. else:
  632. await add_alarm(for_b[0], 'tool:system', 'As the main ACL has been reorganized into the auth, the existing setting values have been lost, so please reset it to the auth.')
  633. print('Update completed')
  634. def set_init_always(conn, ver_num, run_mode):
  635. curs = conn.cursor()
  636. # 버전 기입
  637. curs.execute(db_change('delete from other where name = "ver"'))
  638. curs.execute(db_change('insert into other (name, data, coverage) values ("ver", ?, "")'), [ver_num])
  639. # 기본 권한 그룹 설정
  640. curs.execute(db_change('delete from alist where name = "owner"'))
  641. curs.execute(db_change('insert into alist (name, acl) values ("owner", "owner")'))
  642. curs.execute(db_change("select name from alist where name = 'user' limit 1"))
  643. if not curs.fetchall():
  644. curs.execute(db_change('insert into alist (name, acl) values ("user", "user")'))
  645. curs.execute(db_change("select name from alist where name = 'ip' limit 1"))
  646. if not curs.fetchall():
  647. curs.execute(db_change('insert into alist (name, acl) values ("ip", "ip")'))
  648. curs.execute(db_change("select name from alist where name = 'ban' limit 1"))
  649. if not curs.fetchall():
  650. curs.execute(db_change('insert into alist (name, acl) values ("ban", "view")'))
  651. # 문서 댓글용 게시판 생성
  652. bbs_num = '0'
  653. bbs_name = 'document_comment'
  654. bbs_type = 'comment'
  655. curs.execute(db_change("insert into bbs_set (set_name, set_code, set_id, set_data) values ('bbs_name', '', ?, ?)"), [bbs_num, bbs_name])
  656. curs.execute(db_change("insert into bbs_set (set_name, set_code, set_id, set_data) values ('bbs_type', '', ?, ?)"), [bbs_num, bbs_type])
  657. # 이미지 폴더 없으면 생성
  658. if not os.path.exists(load_image_url(conn)):
  659. os.makedirs(load_image_url(conn))
  660. # 비밀키 없으면 생성
  661. curs.execute(db_change('select data from other where name = "key"'))
  662. if not curs.fetchall():
  663. curs.execute(db_change('insert into other (name, data, coverage) values ("key", ?, "")'), [load_random_key()])
  664. # 솔트키 없으면 생성
  665. curs.execute(db_change('select data from other where name = "salt_key"'))
  666. if not curs.fetchall():
  667. curs.execute(db_change('insert into other (name, data, coverage) values ("salt_key", ?, "")'), [load_random_key(4)])
  668. # 문서 전체 갯수 없으면 생성
  669. curs.execute(db_change('select data from other where name = "count_all_title"'))
  670. if not curs.fetchall():
  671. curs.execute(db_change('insert into other (name, data, coverage) values ("count_all_title", "0", "")'))
  672. # 위키 접근 비밀번호 있으면 temp DB로 넘겨줌
  673. curs.execute(db_change('select data from other where name = "wiki_access_password_need"'))
  674. db_data = curs.fetchall()
  675. if db_data and db_data[0][0] != '':
  676. curs.execute(db_change('select data from other where name = "wiki_access_password"'))
  677. db_data = curs.fetchall()
  678. if db_data:
  679. global_some_set_do("wiki_access_password", db_data[0][0])
  680. curs.execute(db_change('select data from other where name = "load_ip_select"'))
  681. db_data = curs.fetchall()
  682. if db_data and db_data[0][0] != '':
  683. global_func_some_set_do("load_ip_select", db_data[0][0])
  684. # OS마다 실행 파일 설정
  685. exe_type = linux_exe_chmod()
  686. if platform.system() == 'Linux' or platform.system() == 'Darwin':
  687. os.system('chmod +x ./route_go/bin/' + exe_type)
  688. def linux_exe_chmod():
  689. exe_type = ''
  690. if platform.system() == 'Linux':
  691. if platform.machine() in ["AMD64", "x86_64"]:
  692. exe_type = 'main.amd64.bin'
  693. else:
  694. exe_type = 'main.arm64.bin'
  695. elif platform.system() == 'Darwin':
  696. exe_type = 'main.mac.arm64.bin'
  697. else:
  698. if platform.machine() in ["AMD64", "x86_64"]:
  699. exe_type = 'main.amd64.exe'
  700. else:
  701. exe_type = 'main.arm64.exe'
  702. return exe_type
  703. def set_init(conn):
  704. curs = conn.cursor()
  705. # 초기값 설정 함수
  706. curs.execute(db_change("select html from html_filter where kind = 'email'"))
  707. if not curs.fetchall():
  708. for i in ['naver.com', 'gmail.com', 'daum.net', 'kakao.com']:
  709. curs.execute(db_change("insert into html_filter (html, kind, plus, plus_t) values (?, 'email', '', '')"), [i])
  710. curs.execute(db_change("select html from html_filter where kind = 'extension'"))
  711. if not curs.fetchall():
  712. for i in ['jpg', 'jpeg', 'png', 'gif', 'webp']:
  713. curs.execute(db_change("insert into html_filter (html, kind, plus, plus_t) values (?, 'extension', '', '')"), [i])
  714. curs.execute(db_change('select data from other where name = "smtp_server" or name = "smtp_port" or name = "smtp_security"'))
  715. if not curs.fetchall():
  716. for i in [['smtp_server', 'smtp.gmail.com'], ['smtp_port', '587'], ['smtp_security', 'starttls']]:
  717. curs.execute(db_change("insert into other (name, data, coverage) values (?, ?, '')"), [i[0], i[1]])
  718. curs.execute(db_change('insert into html_filter (html, kind, plus, plus_t) values (?, ?, ?, ?)'), [r'(?:[^A-Za-zㄱ-힣0-9])', 'name', '', ''])
  719. # Func-simple
  720. ## Func-simple-without_DB
  721. def get_default_admin_group():
  722. return ['owner', 'user', 'ip', 'ban']
  723. def get_default_robots_txt(conn):
  724. data = '' + \
  725. 'User-agent: *\n' + \
  726. 'Disallow: /\n' + \
  727. 'Allow: /$\n' + \
  728. 'Allow: /w/\n' + \
  729. 'Allow: /bbs/w/\n' + \
  730. 'Allow: /sitemap.xml$\n' + \
  731. 'Allow: /sitemap_*.xml$' + \
  732. ''
  733. if os.path.exists('sitemap.xml'):
  734. data += '' + \
  735. '\n' + \
  736. 'Sitemap: ' + load_domain(conn, 'full') + '/sitemap.xml' + \
  737. ''
  738. return data
  739. def load_random_key(long = 128):
  740. return ''.join(random.choice("0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ") for _ in range(long))
  741. def http_warning(conn):
  742. return '''
  743. <div id="opennamu_http_warning_text"></div>
  744. <span style="display: none;" id="opennamu_http_warning_text_lang">''' + get_lang(conn, 'http_warning') + '''</span>
  745. '''
  746. def get_next_page_bottom(conn, link, num, page, end = 50):
  747. list_data = ''
  748. if num == 1:
  749. if len(page) == end:
  750. list_data += '' + \
  751. '<hr class="main_hr">' + \
  752. '<a href="' + link.format(str(num + 1)) + '">(' + get_lang(conn, 'next') + ')</a>' + \
  753. ''
  754. elif len(page) != end:
  755. list_data += '' + \
  756. '<hr class="main_hr">' + \
  757. '<a href="' + link.format(str(num - 1)) + '">(' + get_lang(conn, 'previous') + ')</a>' + \
  758. ''
  759. else:
  760. list_data += '' + \
  761. '<hr class="main_hr">' + \
  762. '<a href="' + link.format(str(num - 1)) + '">(' + get_lang(conn, 'previous') + ')</a> ' + \
  763. '<a href="' + link.format(str(num + 1)) + '">(' + get_lang(conn, 'next') + ')</a>' + \
  764. ''
  765. return list_data
  766. def leng_check(A, B):
  767. # B -> new
  768. # A -> old
  769. return '0' if A == B else (('-' + str(A - B)) if A > B else ('+' + str(B - A)))
  770. def number_check(data, f = 0):
  771. try:
  772. float(data) if f == 1 else int(data)
  773. return data
  774. except:
  775. return '1'
  776. def redirect(conn, data = '/'):
  777. return flask.redirect(load_domain(conn, 'full') + data)
  778. # Golang 의존
  779. async def get_acl_list(type_data = 'normal'):
  780. if type_data == 'user':
  781. type_data = 'user_document'
  782. other_set = {}
  783. other_set['type'] = type_data
  784. data = await python_to_golang('api_list_acl', other_set)
  785. return data["data"]
  786. ## Func-simple-with_DB
  787. async def get_user_title_list(conn, ip = ''):
  788. curs = conn.cursor()
  789. ip = ip_check() if ip == '' else ip
  790. # default
  791. user_title = {
  792. '' : get_lang(conn, 'default'),
  793. '🌳' : '🌳 newbie',
  794. }
  795. curs.execute(db_change('select name from user_set where id = ? and name = ?'), [ip, 'get_🥚'])
  796. if curs.fetchall():
  797. user_title['🥚'] = '🥚 easter_egg'
  798. curs.execute(db_change('select data from user_set where name = ? and id = ?'), ['challenge_first_contribute', ip])
  799. if curs.fetchall():
  800. user_title['🔰'] = '🔰 first_contribute'
  801. curs.execute(db_change('select data from user_set where name = ? and id = ?'), ['challenge_tenth_contribute', ip])
  802. if curs.fetchall():
  803. user_title['📝'] = '📝 tenth_contribute'
  804. curs.execute(db_change('select data from user_set where name = ? and id = ?'), ['challenge_hundredth_contribute', ip])
  805. if curs.fetchall():
  806. user_title['🖊️'] = '🖊️ hundredth_contribute'
  807. curs.execute(db_change('select data from user_set where name = ? and id = ?'), ['challenge_thousandth_contribute', ip])
  808. if curs.fetchall():
  809. user_title['🏅'] = '🏅 thousandth_contribute'
  810. curs.execute(db_change('select data from user_set where name = ? and id = ?'), ['challenge_first_discussion', ip])
  811. if curs.fetchall():
  812. user_title['💬'] = '💬 first_discussion'
  813. curs.execute(db_change('select data from user_set where name = ? and id = ?'), ['challenge_tenth_discussion', ip])
  814. if curs.fetchall():
  815. user_title['💡'] = '💡 tenth_discussion'
  816. curs.execute(db_change('select data from user_set where name = ? and id = ?'), ['challenge_hundredth_discussion', ip])
  817. if curs.fetchall():
  818. user_title['📢'] = '📢 hundredth_discussion'
  819. curs.execute(db_change('select data from user_set where name = ? and id = ?'), ['challenge_thousandth_discussion', ip])
  820. if curs.fetchall():
  821. user_title['📜'] = '📜 thousandth_discussion'
  822. curs.execute(db_change('select data from user_set where name = ? and id = ?'), ['challenge_admin', ip])
  823. if curs.fetchall():
  824. user_title['☑️'] = '☑️ before_admin'
  825. if await acl_check(tool = 'all_admin_auth') != 1:
  826. user_title['✅'] = '✅ admin'
  827. return user_title
  828. def load_image_url(conn):
  829. curs = conn.cursor()
  830. curs.execute(db_change('select data from other where name = "image_where"'))
  831. image_where = curs.fetchall()
  832. image_where = image_where[0][0] if image_where else os.path.join('data', 'images')
  833. return image_where
  834. def load_domain(conn, data_type = 'normal'):
  835. curs = conn.cursor()
  836. domain = ''
  837. try:
  838. sys_host = flask.request.host
  839. except:
  840. sys_host = ''
  841. if data_type == 'full':
  842. curs.execute(db_change("select data from other where name = 'http_select'"))
  843. db_data = curs.fetchall()
  844. domain += db_data[0][0] if db_data and db_data[0][0] != '' else 'http'
  845. domain += '://'
  846. curs.execute(db_change("select data from other where name = 'domain'"))
  847. db_data = curs.fetchall()
  848. domain += db_data[0][0] if db_data and db_data[0][0] != '' else sys_host
  849. else:
  850. curs.execute(db_change("select data from other where name = 'domain'"))
  851. db_data = curs.fetchall()
  852. domain += db_data[0][0] if db_data and db_data[0][0] != '' else sys_host
  853. return domain
  854. def get_tool_js_safe(data):
  855. data = data.replace('\n', '\\\\n')
  856. data = data.replace('\\', '\\\\')
  857. data = data.replace("'", "\\'")
  858. data = data.replace('"', '\\"')
  859. return data
  860. def edit_button(conn):
  861. curs = conn.cursor()
  862. insert_list = []
  863. curs.execute(db_change("select html, plus from html_filter where kind = 'edit_top'"))
  864. db_data = curs.fetchall()
  865. for get_data in db_data:
  866. insert_list += [[get_data[1], get_data[0]]]
  867. data = ''
  868. for insert_data in insert_list:
  869. data += '<a href="javascript:do_insert_data(\'' + get_tool_js_safe(insert_data[0]) + '\');">(' + html.escape(insert_data[1]) + ')</a> '
  870. data += (' ' if data != '' else '') + '<a href="/filter/edit_top">(' + get_lang(conn, 'add') + ')</a>'
  871. data += '<hr class="main_hr">'
  872. return data
  873. def ip_warning(conn):
  874. curs = conn.cursor()
  875. if ip_or_user() != 0:
  876. curs.execute(db_change('select data from other where name = "no_login_warning"'))
  877. data = curs.fetchall()
  878. if data and data[0][0] != '':
  879. text_data = '' + \
  880. '<span>' + data[0][0] + '</span>' + \
  881. '<hr class="main_hr">' + \
  882. ''
  883. else:
  884. text_data = '' + \
  885. '<span>' + get_lang(conn, 'no_login_warning') + '</span>' + \
  886. '<hr class="main_hr">' + \
  887. ''
  888. else:
  889. text_data = ''
  890. return text_data
  891. # Func-login
  892. def pw_encode(conn, data, db_data_encode = ''):
  893. curs = conn.cursor()
  894. if db_data_encode == '':
  895. curs.execute(db_change('select data from other where name = "encode"'))
  896. db_data = curs.fetchall()
  897. db_data_encode = db_data[0][0] if db_data else 'sha3'
  898. if db_data_encode == 'sha256':
  899. return hashlib.sha256(bytes(data, 'utf-8')).hexdigest()
  900. elif db_data_encode == 'sha3':
  901. return hashlib.sha3_256(bytes(data, 'utf-8')).hexdigest()
  902. elif db_data_encode == 'sha3-512':
  903. return hashlib.sha3_512(bytes(data, 'utf-8')).hexdigest()
  904. else:
  905. curs.execute(db_change('select data from other where name = "salt_key"'))
  906. db_data = curs.fetchall()
  907. db_data_salt = db_data[0][0] if db_data else ''
  908. if db_data_encode == 'sha3-salt':
  909. return hashlib.sha3_256(bytes(data + db_data_salt, 'utf-8')).hexdigest()
  910. else:
  911. return hashlib.sha3_512(bytes(data + db_data_salt, 'utf-8')).hexdigest()
  912. def pw_check(conn, data, data2, type_d = 'no', id_d = ''):
  913. curs = conn.cursor()
  914. curs.execute(db_change('select data from other where name = "encode"'))
  915. db_data = curs.fetchall()
  916. load_set_data = db_data[0][0] if db_data and db_data[0][0] != '' else 'sha3'
  917. set_data = load_set_data
  918. if type_d != 'no':
  919. set_data = 'sha3' if type_d == '' else type_d
  920. re_data = 1 if pw_encode(conn, data, set_data) == data2 else 0
  921. if load_set_data != set_data and re_data == 1 and id_d != '':
  922. curs.execute(db_change("update user_set set data = ? where id = ? and name = 'pw'"), [pw_encode(conn, data), id_d])
  923. curs.execute(db_change("update user_set set data = ? where id = ? and name = 'encode'"), [load_set_data, id_d])
  924. return re_data
  925. # Func-skin
  926. def easy_minify(conn, data, tool = None):
  927. return data
  928. def get_lang_name(conn, tool = ''):
  929. curs = conn.cursor()
  930. if tool != 'inter':
  931. ip = ip_check()
  932. if ip_or_user(ip) == 0:
  933. curs.execute(db_change('select data from user_set where name = "lang" and id = ?'), [ip])
  934. rep_data = curs.fetchall()
  935. elif 'lang' in flask.session:
  936. rep_data = [[flask.session['lang']]]
  937. else:
  938. curs.execute(db_change("select data from other where name = 'language'"))
  939. rep_data = curs.fetchall()
  940. else:
  941. curs.execute(db_change("select data from other where name = 'language'"))
  942. rep_data = curs.fetchall()
  943. if not rep_data or rep_data[0][0] in ('', 'default'):
  944. curs.execute(db_change("select data from other where name = 'language'"))
  945. rep_data = curs.fetchall()
  946. if rep_data:
  947. lang_name = rep_data[0][0]
  948. else:
  949. lang_name = 'en-US'
  950. return lang_name
  951. def get_lang(conn, data, safe = 0):
  952. lang_name = get_lang_name(conn)
  953. if (lang_name + '_' + data) in global_lang_data:
  954. if safe == 1:
  955. return global_lang_data[lang_name + '_' + data]
  956. else:
  957. return html.escape(global_lang_data[lang_name + '_' + data])
  958. else:
  959. lang_list = os.listdir('lang')
  960. if (lang_name + '.json') in lang_list:
  961. lang = json_loads(open(os.path.join('lang', lang_name + '.json'), encoding = 'utf8').read())
  962. for title in lang:
  963. global_lang_data[lang_name + '_' + title] = lang[title]
  964. else:
  965. lang = {}
  966. if data in lang:
  967. if safe == 1:
  968. return lang[data]
  969. else:
  970. return html.escape(lang[data])
  971. print(data + ' (' + lang_name + ')')
  972. return html.escape(data + ' (' + lang_name + ')')
  973. # 하위 호환용
  974. def load_lang(data, safe = 0):
  975. with get_db_connect() as conn:
  976. return get_lang(conn, data, safe)
  977. def skin_check(conn, set_n = 0):
  978. curs = conn.cursor()
  979. # 개편 필요?
  980. skin_list = load_skin(conn, 'ringo', 1)
  981. skin = skin_list[0]
  982. ip = ip_check()
  983. user_need_skin = ''
  984. if ip_or_user(ip) == 0:
  985. curs.execute(db_change('select data from user_set where name = "skin" and id = ?'), [ip])
  986. skin_exist = curs.fetchall()
  987. if skin_exist:
  988. user_need_skin = skin_exist[0][0]
  989. else:
  990. if 'skin' in flask.session:
  991. user_need_skin = flask.session['skin']
  992. user_need_skin = '' if user_need_skin == 'default' else user_need_skin
  993. if user_need_skin == '':
  994. curs.execute(db_change('select data from other where name = "skin"'))
  995. skin_exist = curs.fetchall()
  996. if skin_exist:
  997. user_need_skin = skin_exist[0][0]
  998. if user_need_skin != '' and user_need_skin in skin_list:
  999. skin = user_need_skin
  1000. if set_n == 0:
  1001. return './views/' + skin + '/index.html'
  1002. else:
  1003. return skin
  1004. def cache_v():
  1005. return '.cache_v288'
  1006. def wiki_css(data):
  1007. # without_DB
  1008. data += ['' for _ in range(0, 4 - len(data))]
  1009. data_css = ''
  1010. data_css_dark = ''
  1011. data_css_ver = cache_v()
  1012. db_data = global_some_set_do("main_css")
  1013. if db_data:
  1014. data_css = db_data
  1015. else:
  1016. data_css += '<meta http-equiv="Cache-Control" content="max-age=31536000">'
  1017. # External JS
  1018. data_css += '<script defer src="https://cdn.jsdelivr.net/npm/katex@0.16.11/dist/katex.min.js" integrity="sha384-7zkQWkzuo3B5mTepMUcHkMB5jZaolc2xDwL6VFqjFALcbeS9Ggm/Yr2r3Dy4lfFg" crossorigin="anonymous"></script>'
  1019. data_css += '<script defer src="https://cdnjs.cloudflare.com/ajax/libs/highlight.js/11.8.0/highlight.min.js" integrity="sha512-rdhY3cbXURo13l/WU9VlaRyaIYeJ/KBakckXIvJNAQde8DgpOmE+eZf7ha4vdqVjTtwQt69bD2wH2LXob/LB7Q==" crossorigin="anonymous" referrerpolicy="no-referrer"></script>'
  1020. data_css += '<script defer src="https://cdnjs.cloudflare.com/ajax/libs/highlight.js/11.8.0/languages/x86asm.min.js" integrity="sha512-HeAchnWb+wLjUb2njWKqEXNTDlcd1QcyOVxb+Mc9X0bWY0U5yNHiY5hTRUt/0twG8NEZn60P3jttqBvla/i2gA==" crossorigin="anonymous" referrerpolicy="no-referrer"></script>'
  1021. data_css += '<script defer src="https://cdnjs.cloudflare.com/ajax/libs/monaco-editor/0.48.0/min/vs/loader.min.js" integrity="sha512-ZG31AN9z/CQD1YDDAK4RUAvogwbJHv6bHrumrnMLzdCrVu4HeAqrUX7Jsal/cbUwXGfaMUNmQU04tQ8XXl5Znw==" crossorigin="anonymous" referrerpolicy="no-referrer"></script>'
  1022. data_css += '<script defer src="https://cdnjs.cloudflare.com/ajax/libs/highlightjs-line-numbers.js/2.8.0/highlightjs-line-numbers.min.js"></script>'
  1023. # Func JS
  1024. data_css += '<script defer src="/views/main_css/js/func/func.js' + data_css_ver + '"></script>'
  1025. data_css += '<script defer src="/views/main_css/js/func/insert_version.js' + data_css_ver + '"></script>'
  1026. data_css += '<script defer src="/views/main_css/js/func/insert_user_info.js' + data_css_ver + '"></script>'
  1027. data_css += '<script defer src="/views/main_css/js/func/insert_version_skin.js' + data_css_ver + '"></script>'
  1028. data_css += '<script defer src="/views/main_css/js/func/insert_http_warning_text.js' + data_css_ver + '"></script>'
  1029. data_css += '<script defer src="/views/main_css/js/func/ie_end_of_life.js' + data_css_ver + '"></script>'
  1030. data_css += '<script defer src="/views/main_css/js/func/shortcut.js' + data_css_ver + '"></script>'
  1031. data_css += '<script defer src="/views/main_css/js/func/editor.js' + data_css_ver + '"></script>'
  1032. data_css += '<script defer src="/views/main_css/js/func/render.js' + data_css_ver + '"></script>'
  1033. # Main CSS
  1034. data_css += '<link rel="stylesheet" href="/views/main_css/css/main.css' + data_css_ver + '">'
  1035. # External CSS
  1036. data_css += '<link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/katex@0.16.11/dist/katex.min.css" integrity="sha384-nB0miv6/jRmo5UMMR1wu3Gz6NLsoTkbqJghGIsx//Rlm+ZU03BU6SQNC66uf4l5+" crossorigin="anonymous">'
  1037. data_css += '<link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/highlight.js/11.8.0/styles/default.min.css" integrity="sha512-hasIneQUHlh06VNBe7f6ZcHmeRTLIaQWFd43YriJ0UND19bvYRauxthDg8E4eVNPm9bRUhr5JGeqH7FRFXQu5g==" crossorigin="anonymous" referrerpolicy="no-referrer" />'
  1038. data_css += '<link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/monaco-editor/0.41.0/min/vs/editor/editor.main.min.css" integrity="sha512-MFDhxgOYIqLdcYTXw7en/n5BshKoduTitYmX8TkQ+iJOGjrWusRi8+KmfZOrgaDrCjZSotH2d1U1e/Z1KT6nWw==" crossorigin="anonymous" referrerpolicy="no-referrer" />'
  1039. global_some_set_do("main_css", data_css)
  1040. # Darkmode
  1041. db_data = global_some_set_do("dark_main_css")
  1042. if db_data:
  1043. data_css_dark = db_data
  1044. else:
  1045. # Main CSS
  1046. data_css_dark += '<link rel="stylesheet" href="/views/main_css/css/sub/dark.css' + data_css_ver + '">'
  1047. # External CSS
  1048. data_css_dark += '<link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/highlight.js/11.8.0/styles/dark.min.css" integrity="sha512-bfLTSZK4qMP/TWeS1XJAR/VDX0Uhe84nN5YmpKk5x8lMkV0D+LwbuxaJMYTPIV13FzEv4CUOhHoc+xZBDgG9QA==" crossorigin="anonymous" referrerpolicy="no-referrer" />'
  1049. global_some_set_do("dark_main_css", data_css_dark)
  1050. data = data[0:2] + ['', data_css] + data[2:3] + [data_css_dark] + data[3:]
  1051. return data
  1052. def cut_100(data):
  1053. return ''
  1054. async def wiki_set():
  1055. other_set = {}
  1056. data = await python_to_golang('api_func_wiki_set', other_set)
  1057. return data["data"]
  1058. async def wiki_custom(conn):
  1059. curs = conn.cursor()
  1060. ip = ip_check()
  1061. skin_name = '_' + skin_check(conn, 1)
  1062. if ip_or_user(ip) == 0:
  1063. user_icon = 1
  1064. user_name = ip
  1065. if 'head' in flask.session:
  1066. user_head = flask.session['head']
  1067. else:
  1068. curs.execute(db_change("select data from user_set where id = ? and name = 'custom_css'"), [ip])
  1069. db_data = curs.fetchall()
  1070. user_head = db_data[0][0] if db_data else ''
  1071. flask.session['head'] = db_data[0][0] if db_data else ''
  1072. if 'head' + skin_name in flask.session:
  1073. user_head += flask.session['head' + skin_name]
  1074. else:
  1075. curs.execute(db_change("select data from user_set where id = ? and name = ?"), [ip, 'custom_css' + skin_name])
  1076. db_data = curs.fetchall()
  1077. user_head += db_data[0][0] if db_data else ''
  1078. flask.session['head' + skin_name] = db_data[0][0] if db_data else ''
  1079. curs.execute(db_change('select data from user_set where name = "email" and id = ?'), [ip])
  1080. email = curs.fetchall()
  1081. email = email[0][0] if email else ''
  1082. if await acl_check(tool = 'all_admin_auth') != 1:
  1083. user_admin = '1'
  1084. curs.execute(db_change("select data from user_set where id = ? and name = 'acl'"), [ip])
  1085. curs.execute(db_change('select acl from alist where name = ?'), [curs.fetchall()[0][0]])
  1086. user_acl = curs.fetchall()
  1087. user_acl_list = [for_a[0] for for_a in user_acl]
  1088. user_acl_list = user_acl_list if user_acl_list != [] else '0'
  1089. else:
  1090. user_admin = '0'
  1091. user_acl_list = '0'
  1092. curs.execute(db_change("select count(*) from user_notice where name = ? and readme = ''"), [ip])
  1093. count = curs.fetchall()
  1094. user_notice = str(count[0][0]) if count else '0'
  1095. else:
  1096. user_icon = 0
  1097. user_name = get_lang(conn, 'user')
  1098. email = ''
  1099. user_admin = '0'
  1100. user_acl_list = '0'
  1101. user_notice = '0'
  1102. user_head = flask.session['head'] if 'head' in flask.session else ''
  1103. user_head += flask.session['head' + skin_name] if 'head' + skin_name in flask.session else ''
  1104. curs.execute(db_change("select title from rd where title = ? and stop = '' limit 1"), ['user:' + ip])
  1105. user_topic = '1' if curs.fetchall() else '0'
  1106. split_path = flask.request.path.split('/')
  1107. split_path = split_path[1:] if len(split_path) > 1 else 0
  1108. return [
  1109. '',
  1110. '',
  1111. user_icon,
  1112. user_head,
  1113. email,
  1114. user_name,
  1115. user_admin,
  1116. str((await ban_check())[0]),
  1117. user_notice,
  1118. user_acl_list,
  1119. ip,
  1120. user_topic,
  1121. split_path,
  1122. await level_check(ip)
  1123. ]
  1124. def load_skin(conn, data = '', set_n = 0, default = 0):
  1125. # without_DB
  1126. # data -> 가장 앞에 있을 스킨 이름
  1127. # set_n == 0 -> 스트링으로 반환
  1128. # set_n == 1 -> 리스트로 반환
  1129. # default == 0 -> 디폴트 미포함
  1130. # default == 1 -> 디폴트 포함
  1131. skin_return_data = []
  1132. skin_return_data_str = ''
  1133. skin_list_get = os.listdir('views')
  1134. if default == 1:
  1135. skin_list_get = ['default'] + skin_list_get
  1136. for skin_data in skin_list_get:
  1137. if skin_data != 'default':
  1138. see_data = skin_data
  1139. else:
  1140. see_data = get_lang(conn, 'default')
  1141. if skin_data != 'main_css':
  1142. if set_n == 0:
  1143. if skin_data == data:
  1144. skin_return_data_str = '' + \
  1145. '<option value="' + skin_data + '">' + \
  1146. see_data + \
  1147. '</option>' + \
  1148. '' + skin_return_data_str
  1149. else:
  1150. skin_return_data_str += '' + \
  1151. '<option value="' + skin_data + '">' + \
  1152. see_data + \
  1153. '</option>' + \
  1154. ''
  1155. else:
  1156. if skin_data == data:
  1157. skin_return_data = [skin_data] + skin_return_data
  1158. else:
  1159. skin_return_data += [skin_data]
  1160. if set_n == 0:
  1161. return skin_return_data_str
  1162. else:
  1163. return skin_return_data
  1164. # Func-markup
  1165. def render_set(conn, doc_name = '', doc_data = '', data_type = 'view', markup = '', parameter = {}):
  1166. curs = conn.cursor()
  1167. # data_type in ['view', 'from', 'thread', 'api_view', 'api_thread', 'api_include', 'backlink']
  1168. # data_type을 list 형식으로 개편 필요할 듯
  1169. return_type = True
  1170. if data_type in ['api_from', 'api_view', 'api_thread', 'api_include']:
  1171. return_type = False
  1172. if data_type == '':
  1173. data_type = 'view'
  1174. elif data_type == 'api_view':
  1175. data_type = 'view'
  1176. elif data_type == 'api_from':
  1177. data_type = 'from'
  1178. elif data_type == 'api_thread':
  1179. data_type = 'thread'
  1180. elif data_type == 'api_include':
  1181. data_type = 'include'
  1182. doc_data = '' if doc_data == None else doc_data
  1183. ip = ip_check()
  1184. render_lang_data = {
  1185. 'toc' : get_lang(conn, 'toc'),
  1186. 'category' : get_lang(conn, 'category')
  1187. }
  1188. curs.execute(db_change('select data from other where name = "category_text"'))
  1189. db_data = curs.fetchall()
  1190. if db_data and db_data[0][0] != '':
  1191. render_lang_data['category'] = db_data[0][0]
  1192. get_class_render = class_do_render(
  1193. conn,
  1194. render_lang_data,
  1195. markup,
  1196. parameter,
  1197. render_set
  1198. ).do_render(
  1199. doc_name,
  1200. doc_data,
  1201. data_type
  1202. )
  1203. if data_type == 'backlink':
  1204. return ''
  1205. get_class_render[0] = '<div class="opennamu_render_complete">' + get_class_render[0] + '</div>'
  1206. font_size_set_data = get_main_skin_set(conn, flask.session, 'main_css_font_size', ip)
  1207. if font_size_set_data != 'default':
  1208. font_size_set_data = number_check(font_size_set_data)
  1209. get_class_render[0] = '' + \
  1210. '''<style>
  1211. .opennamu_render_complete {
  1212. font-size: ''' + font_size_set_data + '''px !important;
  1213. }
  1214. </style>''' + \
  1215. '' + get_class_render[0]
  1216. curs.execute(db_change("select data from other where name = 'namumark_compatible'"))
  1217. db_data = curs.fetchall()
  1218. if db_data and db_data[0][0] != '':
  1219. get_class_render[0] = '' + \
  1220. '''<style>
  1221. .opennamu_render_complete {
  1222. font-size: 15px !important;
  1223. line-height: 1.5;
  1224. }
  1225. .opennamu_render_complete td {
  1226. padding: 5px 10px !important;
  1227. word-break: break-all;
  1228. }
  1229. .opennamu_render_complete summary {
  1230. list-style: none !important;
  1231. font-weight: bold !important;
  1232. }
  1233. .opennamu_render_complete .opennamu_folding {
  1234. margin-bottom: 5px;
  1235. }
  1236. .opennamu_render_complete .opennamu_footnote {
  1237. padding-bottom: 30px;
  1238. }
  1239. .opennamu_render_complete iframe {
  1240. display: block;
  1241. }
  1242. </style>''' + \
  1243. '' + get_class_render[0]
  1244. table_set_data = get_main_skin_set(conn, flask.session, 'main_css_table_scroll', ip)
  1245. if table_set_data == 'on':
  1246. get_class_render[0] = '<style>.table_safe { overflow-x: scroll; white-space: nowrap; }</style>' + get_class_render[0]
  1247. joke_set_data = get_main_skin_set(conn, flask.session, 'main_css_view_joke', ip)
  1248. if joke_set_data == 'off':
  1249. get_class_render[0] = '<style>.opennamu_joke { display: none; }</style>' + get_class_render[0]
  1250. math_set_data = get_main_skin_set(conn, flask.session, 'main_css_math_scroll', ip)
  1251. if math_set_data == 'on':
  1252. get_class_render[0] = '<style>.katex .base { overflow-x: scroll; }</style>' + get_class_render[0]
  1253. transparent_set_data = get_main_skin_set(conn, flask.session, 'main_css_table_transparent', ip)
  1254. if transparent_set_data == 'on':
  1255. get_class_render[0] = '' + \
  1256. '''<style>
  1257. .table_safe td {
  1258. background: transparent !important;
  1259. color: inherit !important;
  1260. }
  1261. </style>''' + \
  1262. '' + get_class_render[0]
  1263. if not return_type:
  1264. return [get_class_render[0], get_class_render[1]]
  1265. else:
  1266. return get_class_render[0] + '<script>window.addEventListener("DOMContentLoaded", function() {' + get_class_render[1] + '});</script>'
  1267. def render_simple_set(conn, data):
  1268. # without_DB
  1269. toc_data = ''
  1270. toc_regex = r'<h([1-6])>([^<>]+)<\/h[1-6]>'
  1271. toc_search_data = re.findall(toc_regex, data)
  1272. heading_stack = [0, 0, 0, 0, 0, 0]
  1273. if toc_search_data:
  1274. toc_data += '''
  1275. <div class="opennamu_TOC" id="toc">
  1276. <span class="opennamu_TOC_title">''' + get_lang(conn, 'toc') + '''</span>
  1277. <br>
  1278. '''
  1279. for toc_search_in in toc_search_data:
  1280. heading_level = int(toc_search_in[0])
  1281. heading_level_str = str(heading_level)
  1282. heading_stack[heading_level - 1] += 1
  1283. for for_a in range(heading_level, 6):
  1284. heading_stack[for_a] = 0
  1285. heading_stack_str = ''.join([str(for_a) + '.' if for_a != 0 else '' for for_a in heading_stack])
  1286. heading_stack_str = re.sub(r'\.$', '', heading_stack_str)
  1287. toc_data += '''
  1288. <br>
  1289. <span class="opennamu_TOC_list">
  1290. ''' + ('<span style="margin-left: 10px;"></span>' * (heading_stack_str.count('.'))) + '''
  1291. <a href="#s-''' + heading_stack_str + '''">''' + heading_stack_str + '''.</a>
  1292. ''' + toc_search_in[1] + '''
  1293. </span>
  1294. '''
  1295. data = re.sub(toc_regex, '<h' + toc_search_in[0] + ' id="s-' + heading_stack_str + '"><a href="#toc">' + heading_stack_str + '.</a> ' + toc_search_in[1] + '</h' + toc_search_in[0] + '>', data, 1)
  1296. if toc_data != '':
  1297. toc_data += '</div>'
  1298. footnote_data = ''
  1299. footnote_regex = r'<sup>((?:(?!<sup>|<\/sup>).)+)<\/sup>'
  1300. footnote_search_data = re.findall(footnote_regex, data)
  1301. footnote_count = 1
  1302. if footnote_search_data:
  1303. footnote_data += '<div class="opennamu_footnote">'
  1304. for footnote_search in footnote_search_data:
  1305. footnote_count_str = str(footnote_count)
  1306. if footnote_count != 1:
  1307. footnote_data += '<br>'
  1308. footnote_data += '<a id="fn-' + footnote_count_str + '" href="#rfn-' + footnote_count_str + '">(' + footnote_count_str + ')</a> ' + footnote_search
  1309. data = re.sub(footnote_regex, '<sup id="rfn-' + footnote_count_str + '"><a href="#fn-' + footnote_count_str + '">(' + footnote_count_str + ')</a></sup>', data, 1)
  1310. footnote_count += 1
  1311. if footnote_data != '':
  1312. footnote_data += '</div>'
  1313. data = toc_data + data + footnote_data
  1314. return data
  1315. # Func-request
  1316. async def send_email(conn, who, title, data):
  1317. curs = conn.cursor()
  1318. curs.execute(db_change('' + \
  1319. 'select name, data from other ' + \
  1320. 'where name = "smtp_email" or name = "smtp_pass" or name = "smtp_server" or name = "smtp_port" or name = "smtp_security"' + \
  1321. ''))
  1322. rep_data = curs.fetchall()
  1323. smtp_email = ''
  1324. smtp_pass = ''
  1325. smtp_server = ''
  1326. smtp_security = ''
  1327. smtp_port = ''
  1328. smtp = ''
  1329. for i in rep_data:
  1330. if i[0] == 'smtp_email':
  1331. smtp_email = i[1]
  1332. elif i[0] == 'smtp_pass':
  1333. smtp_pass = i[1]
  1334. elif i[0] == 'smtp_server':
  1335. smtp_server = i[1]
  1336. elif i[0] == 'smtp_security':
  1337. smtp_security = i[1]
  1338. elif i[0] == 'smtp_port':
  1339. smtp_port = i[1]
  1340. smtp_port = int(number_check(smtp_port))
  1341. if smtp_security == 'plain':
  1342. smtp = smtplib.SMTP(smtp_server, smtp_port)
  1343. elif smtp_security == 'starttls':
  1344. smtp = smtplib.SMTP(smtp_server, smtp_port)
  1345. smtp.starttls()
  1346. else:
  1347. # if smtp_security == 'tls':
  1348. smtp = smtplib.SMTP_SSL(smtp_server, smtp_port)
  1349. domain = load_domain(conn)
  1350. wiki_name = (await wiki_set())[0]
  1351. msg = email.mime.text.MIMEText(data)
  1352. msg['Subject'] = title
  1353. msg['From'] = wiki_name + ' <noreply@' + domain + '>'
  1354. msg['To'] = who
  1355. try:
  1356. smtp.login(smtp_email, smtp_pass)
  1357. smtp.sendmail('openNAMU@' + domain, who, msg.as_string())
  1358. smtp.quit()
  1359. return 1
  1360. except Exception as e:
  1361. print('Error : email send error')
  1362. print(e)
  1363. return 0
  1364. async def captcha_get(conn):
  1365. curs = conn.cursor()
  1366. data = ''
  1367. if await acl_check('', 'recaptcha_five_pass') == 0 and 'recapcha_pass' in flask.session and flask.session['recapcha_pass'] > 0:
  1368. pass
  1369. elif await acl_check('', 'recaptcha') == 1:
  1370. curs.execute(db_change('select data from other where name = "recaptcha"'))
  1371. recaptcha = curs.fetchall()
  1372. curs.execute(db_change('select data from other where name = "sec_re"'))
  1373. sec_re = curs.fetchall()
  1374. curs.execute(db_change('select data from other where name = "recaptcha_ver"'))
  1375. rec_ver = curs.fetchall()
  1376. if recaptcha and recaptcha[0][0] != '' and sec_re and sec_re[0][0] != '':
  1377. if not rec_ver or rec_ver[0][0] == '':
  1378. data += '' + \
  1379. '<script src="https://www.google.com/recaptcha/api.js" async defer></script>' + \
  1380. '<div class="g-recaptcha" data-sitekey="' + recaptcha[0][0] + '"></div>' + \
  1381. '<hr class="main_hr">' + \
  1382. ''
  1383. elif rec_ver[0][0] == 'v3':
  1384. data += '' + \
  1385. '<script src="https://www.google.com/recaptcha/api.js?render=' + recaptcha[0][0] + '"></script>' + \
  1386. '<input type="hidden" id="g-recaptcha" name="g-recaptcha">' + \
  1387. '<script type="text/javascript">' + \
  1388. 'grecaptcha.ready(function() {' + \
  1389. 'grecaptcha.execute(\'' + recaptcha[0][0] + '\', {action: \'homepage\'}).then(function(token) {' + \
  1390. 'document.getElementById(\'g-recaptcha\').value = token;' + \
  1391. '});' + \
  1392. '});' + \
  1393. '</script>' + \
  1394. ''
  1395. elif rec_ver[0][0] == 'cf':
  1396. data += '' + \
  1397. '<script src="https://challenges.cloudflare.com/turnstile/v0/api.js?compat=recaptcha" async defer></script>' + \
  1398. '<div class="g-recaptcha" data-sitekey="' + recaptcha[0][0] + '"></div>' + \
  1399. '<hr class="main_hr">' + \
  1400. ''
  1401. else:
  1402. # rec_ver[0][0] == 'h'
  1403. data += '''
  1404. <script src="https://js.hcaptcha.com/1/api.js" async defer></script>
  1405. <div class="h-captcha" data-sitekey="''' + recaptcha[0][0] + '''"></div>
  1406. <hr class="main_hr">
  1407. '''
  1408. return data
  1409. async def captcha_post(conn, re_data):
  1410. curs = conn.cursor()
  1411. if await acl_check('', 'recaptcha_five_pass') == 0 and 'recapcha_pass' in flask.session and flask.session['recapcha_pass'] > 0:
  1412. pass
  1413. elif await acl_check('', 'recaptcha') == 1:
  1414. curs.execute(db_change('select data from other where name = "sec_re"'))
  1415. sec_re = curs.fetchall()
  1416. curs.execute(db_change('select data from other where name = "recaptcha_ver"'))
  1417. rec_ver = curs.fetchall()
  1418. if await captcha_get(conn) != '':
  1419. url = ''
  1420. if not rec_ver or rec_ver[0][0] in ('', 'v3'):
  1421. url = 'https://www.google.com/recaptcha/api/siteverify'
  1422. elif rec_ver[0][0] == 'cf':
  1423. url = 'https://challenges.cloudflare.com/turnstile/v0/siteverify'
  1424. else:
  1425. # rec_ver[0][0] == 'h'
  1426. url = 'https://hcaptcha.com/siteverify'
  1427. async with aiohttp.ClientSession() as session:
  1428. async with session.post(url, data = {
  1429. "secret": sec_re[0][0],
  1430. "response": re_data
  1431. }) as res:
  1432. if res.status == 200:
  1433. json_data = await res.json()
  1434. if json_data['success'] != True:
  1435. return 1
  1436. if 'recapcha_pass' in flask.session:
  1437. if flask.session['recapcha_pass'] > 0:
  1438. flask.session['recapcha_pass'] -= 1
  1439. else:
  1440. flask.session['recapcha_pass'] = 5
  1441. else:
  1442. flask.session['recapcha_pass'] = 5
  1443. return 0
  1444. # Func-user
  1445. def do_user_name_check(conn, user_name):
  1446. curs = conn.cursor()
  1447. # XSS 필터
  1448. if html.escape(user_name) != user_name:
  1449. return 1
  1450. # IP와 혼동 방지
  1451. if ip_or_user(user_name) == 1:
  1452. return 1
  1453. # 슬래시 불가능
  1454. if user_name.find('/') != -1:
  1455. return 1
  1456. # ID 필터
  1457. curs.execute(db_change('select html from html_filter where kind = "name"'))
  1458. set_d = curs.fetchall()
  1459. for i in set_d:
  1460. check_r = re.compile(i[0], re.I)
  1461. if check_r.search(user_name):
  1462. return 1
  1463. # ID 길이 제한 (128글자)
  1464. if len(user_name) > 128:
  1465. return 1
  1466. # 중복 확인
  1467. curs.execute(db_change("select id from user_set where name = 'user_name' and data = ?"), [user_name])
  1468. if curs.fetchall():
  1469. return 1
  1470. curs.execute(db_change("select id from user_set where id = ?"), [user_name])
  1471. if curs.fetchall():
  1472. return 1
  1473. return 0
  1474. async def level_check(ip = ''):
  1475. ip = ip_check() if ip == '' else ip
  1476. other_set = {}
  1477. other_set['ip'] = ip
  1478. data = await python_to_golang('api_func_level', other_set)
  1479. return data["data"]
  1480. async def acl_check(name = '', tool = '', topic_num = '', ip = '', memo = ''):
  1481. ip = ip_check() if ip == '' else ip
  1482. other_set = {}
  1483. other_set['ip'] = ip
  1484. other_set['name'] = name
  1485. other_set['topic_number'] = topic_num
  1486. other_set['tool'] = tool
  1487. data = await python_to_golang('api_func_acl', other_set)
  1488. result = 0 if data["data"] else 1
  1489. if memo != '' and result == 0:
  1490. other_set = {}
  1491. other_set['ip'] = ip
  1492. other_set['what'] = memo
  1493. await python_to_golang('api_func_auth_post', other_set)
  1494. return result
  1495. async def ban_check(ip = None, tool = ''):
  1496. ip = ip_check() if not ip else ip
  1497. tool = '' if not tool else tool
  1498. other_set = {}
  1499. other_set['ip'] = ip
  1500. other_set['type'] = tool
  1501. data = await python_to_golang('api_func_ban', other_set)
  1502. data["ban"] = 1 if data["ban"] == "true" else 0
  1503. return [data["ban"], data["ban_type"]]
  1504. async def ip_pas(raw_ip):
  1505. other_set = {}
  1506. return_data = 0
  1507. if type(raw_ip) != type([]):
  1508. get_ip = [raw_ip]
  1509. return_data = 1
  1510. else:
  1511. get_ip = raw_ip
  1512. for for_a in range(1, len(get_ip) + 1):
  1513. other_set["data_" + str(for_a)] = get_ip[for_a - 1]
  1514. data = await python_to_golang('api_func_ip_post', other_set)
  1515. return data["data"][raw_ip] if return_data == 1 else data["data"]
  1516. # Func-edit
  1517. def get_edit_text_bottom(conn, tool = '') :
  1518. curs = conn.cursor()
  1519. b_text = ''
  1520. curs.execute(db_change('select data from other where name = "edit_bottom_text"'))
  1521. db_data = curs.fetchall()
  1522. if db_data and db_data[0][0] != '':
  1523. b_text = db_data[0][0] + '<hr class="main_hr">'
  1524. if tool != '':
  1525. if tool == 'edit':
  1526. curs.execute(db_change('select data from other where name = "edit_only_bottom_text"'))
  1527. elif tool == 'move':
  1528. curs.execute(db_change('select data from other where name = "move_bottom_text"'))
  1529. elif tool == 'delete':
  1530. curs.execute(db_change('select data from other where name = "delete_bottom_text"'))
  1531. else:
  1532. curs.execute(db_change('select data from other where name = "revert_bottom_text"'))
  1533. db_data = curs.fetchall()
  1534. if db_data and db_data[0][0] != '':
  1535. b_text = db_data[0][0] + '<hr class="main_hr">'
  1536. return b_text
  1537. def get_edit_text_bottom_check_box(conn):
  1538. curs = conn.cursor()
  1539. cccb_text = ''
  1540. curs.execute(db_change('select data from other where name = "copyright_checkbox_text"'))
  1541. sql_d = curs.fetchall()
  1542. if sql_d and sql_d[0][0] != '':
  1543. if 'bottom_check_box_pass' in flask.session and flask.session['bottom_check_box_pass'] > 0:
  1544. cccb_text = '' + \
  1545. sql_d[0][0] + \
  1546. '<hr class="main_hr">' + \
  1547. ''
  1548. else:
  1549. cccb_text = '' + \
  1550. '<label><input type="checkbox" name="copyright_agreement" value="yes"> ' + sql_d[0][0] + '</label>' + \
  1551. '<hr class="main_hr">' + \
  1552. ''
  1553. return cccb_text
  1554. def do_edit_text_bottom_check_box_check(conn, data):
  1555. curs = conn.cursor()
  1556. curs.execute(db_change('select data from other where name = "copyright_checkbox_text"'))
  1557. db_data = curs.fetchall()
  1558. if db_data and db_data[0][0] != '':
  1559. if 'bottom_check_box_pass' in flask.session and flask.session['bottom_check_box_pass'] > 0:
  1560. pass
  1561. elif data != 'yes':
  1562. return 1
  1563. if 'bottom_check_box_pass' in flask.session:
  1564. if flask.session['bottom_check_box_pass'] > 0:
  1565. flask.session['bottom_check_box_pass'] -= 1
  1566. else:
  1567. flask.session['bottom_check_box_pass'] = 5
  1568. else:
  1569. flask.session['bottom_check_box_pass'] = 5
  1570. return 0
  1571. async def do_edit_send_check(conn, data):
  1572. curs = conn.cursor()
  1573. curs.execute(db_change('select data from other where name = "edit_bottom_compulsion"'))
  1574. db_data = curs.fetchall()
  1575. if db_data and db_data[0][0] != '':
  1576. if await acl_check('', 'edit_bottom_compulsion') == 1:
  1577. if data == '':
  1578. return 1
  1579. return 0
  1580. async def do_edit_slow_check(conn, do_type = 'edit'):
  1581. curs = conn.cursor()
  1582. if do_type == 'edit':
  1583. curs.execute(db_change("select data from other where name = 'slow_edit'"))
  1584. else:
  1585. # do_type == 'thread'
  1586. curs.execute(db_change("select data from other where name = 'slow_thread'"))
  1587. slow_edit = curs.fetchall()
  1588. if slow_edit and slow_edit[0][0] != '':
  1589. if await acl_check('', 'slow_edit') == 1:
  1590. slow_edit = int(number_check(slow_edit[0][0]))
  1591. if do_type == 'edit':
  1592. curs.execute(db_change("select date from history where ip = ? order by date desc limit 1"), [ip_check()])
  1593. else:
  1594. curs.execute(db_change("select date from topic where ip = ? order by date desc limit 1"), [ip_check()])
  1595. last_edit_data = curs.fetchall()
  1596. if last_edit_data:
  1597. last_edit_data = int(re.sub(' |:|-', '', last_edit_data[0][0]))
  1598. now_edit_data = int((
  1599. datetime.datetime.now() - datetime.timedelta(seconds = slow_edit)
  1600. ).strftime("%Y%m%d%H%M%S"))
  1601. if last_edit_data > now_edit_data:
  1602. return 1
  1603. return 0
  1604. async def do_edit_filter(conn, data):
  1605. curs = conn.cursor()
  1606. ip = ip_check()
  1607. if await acl_check(tool = 'edit_filter_pass') == 1:
  1608. curs.execute(db_change("select plus, plus_t from html_filter where kind = 'regex_filter' and plus != ''"))
  1609. for data_list in curs.fetchall():
  1610. match = re.compile(data_list[0], re.I)
  1611. if match.search(data):
  1612. end = '0' if data_list[1] == 'X' else data_list[1]
  1613. if end != '0':
  1614. end = int(number_check(end))
  1615. time = datetime.datetime.now()
  1616. plus = datetime.timedelta(seconds = end)
  1617. r_time = (time + plus).strftime("%Y-%m-%d %H:%M:%S")
  1618. else:
  1619. r_time = '0'
  1620. curs.execute(db_change('delete from user_set where name = "edit_filter" and id = ?'), [ip])
  1621. curs.execute(db_change('insert into user_set (name, id, data) values ("edit_filter", ?, ?)'), [ip, data])
  1622. ban_insert(conn,
  1623. ip,
  1624. r_time,
  1625. 'edit filter',
  1626. '',
  1627. 'tool:edit filter'
  1628. )
  1629. return 1
  1630. return 0
  1631. def do_title_length_check(conn, name, check_type = 'document'):
  1632. curs = conn.cursor()
  1633. if check_type == 'topic':
  1634. curs.execute(db_change('select data from other where name = "title_topic_max_length"'))
  1635. db_data = curs.fetchall()
  1636. if db_data and db_data[0][0] != '':
  1637. db_data = int(number_check(db_data[0][0]))
  1638. if len(name) > db_data:
  1639. return 1
  1640. else:
  1641. curs.execute(db_change('select data from other where name = "title_max_length"'))
  1642. db_data = curs.fetchall()
  1643. if db_data and db_data[0][0] != '':
  1644. db_data = int(number_check(db_data[0][0]))
  1645. if len(name) > db_data:
  1646. return 1
  1647. return 0
  1648. # Func-insert
  1649. def do_add_thread(conn, thread_code, thread_data, thread_top = '', thread_id = ''):
  1650. curs = conn.cursor()
  1651. if thread_id == '':
  1652. curs.execute(db_change("select id from topic where code = ? order by id + 0 desc limit 1"), [thread_code])
  1653. db_data = curs.fetchall()
  1654. if db_data:
  1655. thread_id = str(int(db_data[0][0]) + 1)
  1656. else:
  1657. thread_id = '1'
  1658. curs.execute(db_change("insert into topic (id, data, date, ip, block, top, code) values (?, ?, ?, ?, ?, '', ?)"), [
  1659. thread_id,
  1660. thread_data,
  1661. get_time(),
  1662. ip_check(),
  1663. thread_top,
  1664. thread_code
  1665. ])
  1666. def do_reload_recent_thread(conn, topic_num, date, name = None, sub = None):
  1667. curs = conn.cursor()
  1668. curs.execute(db_change("select code from rd where code = ?"), [topic_num])
  1669. if curs.fetchall():
  1670. curs.execute(db_change("update rd set date = ? where code = ?"), [date, topic_num])
  1671. else:
  1672. curs.execute(db_change("insert into rd (title, sub, code, date, band, stop, agree, acl) values (?, ?, ?, ?, '', '', '', '')"), [name, sub, topic_num, date])
  1673. async def add_alarm(to_user, from_user, context):
  1674. other_set = {}
  1675. other_set['to'] = to_user
  1676. other_set['from'] = from_user
  1677. other_set['data'] = context
  1678. await python_to_golang('api_func_alarm_post', other_set)
  1679. def add_user(conn, user_name, user_pw, user_email = '', user_encode = ''):
  1680. curs = conn.cursor()
  1681. if user_encode == '':
  1682. user_pw_hash = pw_encode(conn, user_pw)
  1683. curs.execute(db_change('select data from other where name = "encode"'))
  1684. data_encode = curs.fetchall()
  1685. data_encode = data_encode[0][0]
  1686. else:
  1687. user_pw_hash = user_pw
  1688. data_encode = user_encode
  1689. curs.execute(db_change("select id from user_set limit 1"))
  1690. if not curs.fetchall():
  1691. user_auth = 'owner'
  1692. else:
  1693. user_auth = 'user'
  1694. curs.execute(db_change("insert into user_set (id, name, data) values (?, 'pw', ?)"), [user_name, user_pw_hash])
  1695. curs.execute(db_change("insert into user_set (id, name, data) values (?, 'acl', ?)"), [user_name, user_auth])
  1696. curs.execute(db_change("insert into user_set (id, name, data) values (?, 'date', ?)"), [user_name, get_time()])
  1697. curs.execute(db_change("insert into user_set (id, name, data) values (?, 'encode', ?)"), [user_name, data_encode])
  1698. if user_email != '':
  1699. curs.execute(db_change("insert into user_set (name, id, data) values ('email', ?, ?)"), [user_name, user_email])
  1700. def ua_plus(conn, u_id, u_ip, u_agent, time):
  1701. curs = conn.cursor()
  1702. curs.execute(db_change("select data from other where name = 'ua_get'"))
  1703. rep_data = curs.fetchall()
  1704. if rep_data and rep_data[0][0] != '':
  1705. pass
  1706. else:
  1707. curs.execute(db_change("insert into ua_d (name, ip, ua, today, sub) values (?, ?, ?, ?, '')"), [
  1708. u_id,
  1709. u_ip,
  1710. u_agent,
  1711. time
  1712. ])
  1713. def ban_insert(conn, name, end, why, login, blocker, type_d = None, release = 0):
  1714. curs = conn.cursor()
  1715. now_time = get_time()
  1716. band = type_d if type_d else ''
  1717. curs.execute(db_change("update rb set ongoing = '' where block = ? and band = ? and ongoing = '1'"), [name, band])
  1718. if release == 1:
  1719. curs.execute(db_change("insert into rb (block, end, today, blocker, why, band, ongoing, login) values (?, ?, ?, ?, ?, ?, '', '')"), [
  1720. name,
  1721. 'release',
  1722. now_time,
  1723. blocker,
  1724. why,
  1725. band
  1726. ])
  1727. else:
  1728. login = login if login != '' else ''
  1729. r_time = end if end != '0' else ''
  1730. curs.execute(db_change("insert into rb (block, end, today, blocker, why, band, ongoing, login) values (?, ?, ?, ?, ?, ?, '1', ?)"), [
  1731. name,
  1732. r_time,
  1733. now_time,
  1734. blocker,
  1735. why,
  1736. band,
  1737. login
  1738. ])
  1739. def history_plus_rc_max(conn, mode):
  1740. curs = conn.cursor()
  1741. curs.execute(db_change("select count(*) from rc where type = ?"), [mode])
  1742. if curs.fetchall()[0][0] >= 200:
  1743. curs.execute(db_change("select id, title from rc where type = ? order by date asc limit 1"), [mode])
  1744. rc_data = curs.fetchall()
  1745. if rc_data:
  1746. curs.execute(db_change('delete from rc where id = ? and title = ? and type = ?'), [rc_data[0][0], rc_data[0][1], mode])
  1747. def history_plus(conn, title, data, date, ip, send, leng, t_check = '', mode = ''):
  1748. curs = conn.cursor()
  1749. curs.execute(db_change('select data from other where name = "history_recording_off"'))
  1750. db_data = curs.fetchall()
  1751. if db_data and db_data[0][0] != '':
  1752. return 0
  1753. if mode == 'add' or mode == 'setting':
  1754. curs.execute(db_change("select id from history where title = ? order by id + 0 asc limit 1"), [title])
  1755. id_data = curs.fetchall()
  1756. id_data = str(int(id_data[0][0]) - 1) if id_data else '0'
  1757. else:
  1758. curs.execute(db_change("select id from history where title = ? order by id + 0 desc limit 1"), [title])
  1759. id_data = curs.fetchall()
  1760. id_data = str(int(id_data[0][0]) + 1) if id_data else '1'
  1761. mode = 'r1' if id_data == '1' else mode
  1762. if re.search('^user:', title):
  1763. mode = 'user'
  1764. elif re.search('^file:', title):
  1765. mode = 'file'
  1766. elif re.search('^category:', title):
  1767. mode = 'category'
  1768. send = re.sub(r'<|>', '', send)
  1769. send = send[:512] if len(send) > 512 else send
  1770. send = send + ' (' + t_check + ')' if t_check != '' else send
  1771. if mode != 'add' and mode != 'setting' and mode != 'user':
  1772. history_plus_rc_max(conn, 'normal')
  1773. curs.execute(db_change("insert into rc (id, title, date, type) values (?, ?, ?, 'normal')"), [id_data, title, date])
  1774. if mode != 'add' and mode != 'setting':
  1775. history_plus_rc_max(conn, mode)
  1776. curs.execute(db_change("select count(*) from data"))
  1777. count_data = curs.fetchall()
  1778. count_data = count_data[0][0] if count_data else 0
  1779. curs.execute(db_change('delete from other where name = "count_all_title"'))
  1780. curs.execute(db_change('insert into other (name, data, coverage) values ("count_all_title", ?, "")'), [str(count_data)])
  1781. curs.execute(db_change("insert into rc (id, title, date, type) values (?, ?, ?, ?)"), [id_data, title, date, mode])
  1782. data_set_exist = ''
  1783. if mode == 'delete':
  1784. data_set_exist = 'not_exist'
  1785. curs.execute(db_change('delete from data_set where doc_name = ? and set_name = "edit_request_doing"'), [title])
  1786. curs.execute(db_change('delete from data_set where doc_name = ? and set_name = "last_edit"'), [title])
  1787. curs.execute(db_change("insert into data_set (doc_name, doc_rev, set_name, set_data) values (?, '', 'last_edit', ?)"), [title, date])
  1788. curs.execute(db_change('delete from data_set where doc_name = ? and set_name = "length"'), [title])
  1789. curs.execute(db_change("insert into data_set (doc_name, doc_rev, set_name, set_data) values (?, '', 'length', ?)"), [title, len(data)])
  1790. curs.execute(db_change("update data_set set doc_rev = ? where doc_name = ? and (doc_rev = '' or doc_rev = 'not_exist')"), [data_set_exist, title])
  1791. curs.execute(db_change("insert into history (id, title, data, date, ip, send, leng, hide, type) values (?, ?, ?, ?, ?, ?, ?, '', ?)"), [id_data, title, data, date, ip, send, leng, mode])
  1792. # Func-error
  1793. async def re_error(conn, data):
  1794. curs = conn.cursor()
  1795. if data == 0:
  1796. if (await ban_check())[0] == 1:
  1797. end = '<div id="opennamu_get_user_info">' + html.escape(ip_check()) + '</div>'
  1798. else:
  1799. end = '<ul><li>' + get_lang(conn, 'authority_error') + '</li></ul>'
  1800. return easy_minify(conn, flask.render_template(skin_check(conn),
  1801. imp = [get_lang(conn, 'error'), await wiki_set(), await wiki_custom(conn), wiki_css([0, 0])],
  1802. data = '<h2>' + get_lang(conn, 'error') + '</h2>' + end,
  1803. menu = 0
  1804. )), 401
  1805. else:
  1806. title = get_lang(conn, 'error')
  1807. sub_title = title
  1808. return_code = 400
  1809. num = data
  1810. if num == 1:
  1811. data = get_lang(conn, 'no_login_error')
  1812. elif num == 2:
  1813. data = get_lang(conn, 'no_exist_user_error')
  1814. elif num == 3:
  1815. data = get_lang(conn, 'authority_error')
  1816. elif num == 4:
  1817. data = get_lang(conn, 'no_admin_block_error')
  1818. elif num == 5:
  1819. data = get_lang(conn, 'error_skin_set')
  1820. elif num == 8:
  1821. data = '' + \
  1822. get_lang(conn, 'long_id_error') + '<br>' + \
  1823. get_lang(conn, 'id_char_error') + ' <a href="/filter/name_filter">(' + get_lang(conn, 'id_filter_list') + ')</a><br>' + \
  1824. get_lang(conn, 'same_id_exist_error') + \
  1825. ''
  1826. elif num == 9:
  1827. data = get_lang(conn, 'file_exist_error')
  1828. elif num == 10:
  1829. data = get_lang(conn, 'password_error')
  1830. elif num == 11:
  1831. data = get_lang(conn, 'topic_long_error')
  1832. elif num == 12:
  1833. data = get_lang(conn, 'email_error')
  1834. elif num == 13:
  1835. data = get_lang(conn, 'recaptcha_error')
  1836. elif num == 14:
  1837. data = get_lang(conn, 'file_extension_error') + ' <a href="/filter/extension_filter">(' + get_lang(conn, 'extension_filter_list') + ')</a>'
  1838. elif num == 15:
  1839. data = get_lang(conn, 'edit_record_error')
  1840. elif num == 16:
  1841. data = get_lang(conn, 'same_file_error')
  1842. elif num == 17:
  1843. curs.execute(db_change('select data from other where name = "upload"'))
  1844. db_data = curs.fetchall()
  1845. file_max = number_check(db_data[0][0]) if db_data and db_data[0][0] != '' else '2'
  1846. data = get_lang(conn, 'file_capacity_error') + file_max
  1847. elif num == 18:
  1848. data = get_lang(conn, 'email_send_error')
  1849. elif num == 19:
  1850. data = get_lang(conn, 'move_error')
  1851. elif num == 20:
  1852. data = get_lang(conn, 'password_diffrent_error')
  1853. elif num == 21:
  1854. data = get_lang(conn, 'edit_filter_error')
  1855. elif num == 22:
  1856. data = get_lang(conn, 'file_name_error')
  1857. elif num == 23:
  1858. data = get_lang(conn, 'regex_error')
  1859. elif num == 24:
  1860. curs.execute(db_change("select data from other where name = 'slow_edit'"))
  1861. db_data = curs.fetchall()
  1862. db_data = '' if not db_data else db_data[0][0]
  1863. data = get_lang(conn, 'fast_edit_error') + db_data
  1864. elif num == 25:
  1865. data = get_lang(conn, 'too_many_dec_error')
  1866. elif num == 26:
  1867. data = get_lang(conn, 'application_not_found')
  1868. elif num == 27:
  1869. data = get_lang(conn, "invalid_password_error")
  1870. elif num == 28:
  1871. data = get_lang(conn, 'watchlist_overflow_error')
  1872. elif num == 29:
  1873. data = get_lang(conn, 'copyright_disagreed')
  1874. elif num == 30:
  1875. data = get_lang(conn, 'ie_wrong_callback')
  1876. elif num == 33:
  1877. data = get_lang(conn, 'restart_fail_error')
  1878. elif num == 34:
  1879. data = get_lang(conn, "update_error") + ' <a href="https://github.com/opennamu/opennamu">(Github)</a>'
  1880. elif num == 35:
  1881. data = get_lang(conn, 'same_email_error')
  1882. elif num == 36:
  1883. data = get_lang(conn, 'input_email_error')
  1884. elif num == 37:
  1885. data = get_lang(conn, 'error_edit_send_request')
  1886. elif num == 38:
  1887. curs.execute(db_change("select data from other where name = 'title_max_length'"))
  1888. db_data = curs.fetchall()
  1889. db_data = '' if not db_data else db_data[0][0]
  1890. data = get_lang(conn, 'error_title_length_too_long') + db_data
  1891. elif num == 39:
  1892. curs.execute(db_change("select data from other where name = 'title_topic_max_length'"))
  1893. db_data = curs.fetchall()
  1894. db_data = '' if not db_data else db_data[0][0]
  1895. data = get_lang(conn, 'error_title_length_too_long') + db_data
  1896. elif num == 40:
  1897. curs.execute(db_change("select data from other where name = 'password_min_length'"))
  1898. db_data = curs.fetchall()
  1899. password_min_length = '' if not db_data else db_data[0][0]
  1900. data = get_lang(conn, 'error_password_length_too_short') + password_min_length
  1901. elif num == 41:
  1902. curs.execute(db_change("select data from other where name = 'edit_timeout'"))
  1903. db_data = curs.fetchall()
  1904. db_data = '' if not db_data else db_data[0][0]
  1905. data = get_lang(conn, 'timeout_error') + db_data
  1906. elif num == 42:
  1907. curs.execute(db_change("select data from other where name = 'slow_thread'"))
  1908. db_data = curs.fetchall()
  1909. db_data = '' if not db_data else db_data[0][0]
  1910. data = get_lang(conn, 'fast_edit_error') + db_data
  1911. elif num == 43:
  1912. title = get_lang(conn, 'application_submitted')
  1913. sub_title = title
  1914. data = get_lang(conn, 'waiting_for_approval')
  1915. elif num == 44:
  1916. curs.execute(db_change("select data from other where name = 'document_content_max_length'"))
  1917. db_data = curs.fetchall()
  1918. db_data = '' if not db_data else db_data[0][0]
  1919. data = get_lang(conn, 'error_content_length_too_long') + db_data
  1920. elif num == 45:
  1921. data = get_lang(conn, 'cidr_error')
  1922. elif num == 46:
  1923. data = get_lang(conn, 'func_404_error')
  1924. title = '404'
  1925. return_code = 404
  1926. elif num == 47:
  1927. data = get_lang(conn, 'still_use_auth_error')
  1928. elif num == 48:
  1929. data = get_lang(conn, 'xss_data_include_error')
  1930. elif num == 49:
  1931. data = get_lang(conn, 'password_same_as_id_error')
  1932. else:
  1933. data = '???'
  1934. if num == 5:
  1935. if flask.request.path != '/skin_set':
  1936. data += '<br>' + get_lang(conn, 'error_skin_set_old') + ' <a href="/skin_set">(' + get_lang(conn, 'go') + ')</a>'
  1937. return easy_minify(conn, flask.render_template(skin_check(conn),
  1938. imp = [get_lang(conn, 'skin_set'), await wiki_set(), await wiki_custom(conn), wiki_css([0, 0])],
  1939. data = '' + \
  1940. '<div id="main_skin_set">' + \
  1941. '<h2>' + get_lang(conn, 'error') + '</h2>' + \
  1942. '<ul>' + \
  1943. '<li>' + data + '</a></li>' + \
  1944. '</ul>' + \
  1945. '</div>' + \
  1946. '',
  1947. menu = [['change', get_lang(conn, 'user_setting')], ['change/skin_set/main', get_lang(conn, 'main_skin_set')]]
  1948. ))
  1949. else:
  1950. return easy_minify(conn, flask.render_template(skin_check(conn),
  1951. imp = [title, await wiki_set(), await wiki_custom(conn), wiki_css([0, 0])],
  1952. data = '' + \
  1953. '<h2>' + sub_title + '</h2>' + \
  1954. '<ul>' + \
  1955. '<li>' + data + '</li>' + \
  1956. '</ul>' + \
  1957. '',
  1958. menu = 0
  1959. )), return_code