admin/GoogleScrape
1
0
Fork 0
mirror of https://github.com/timberjoegithub/GoogleScrape.git synced 2026-07-22 00:19:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

new fixing

Browse Source
This commit is contained in:
Joe Steele
2024-06-10 11:02:01 -04:00
parent 9590a3ef28
commit f3794f3472
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
social.py
+8 -6
View File
@@ -36,6 +36,10 @@ from moviepy.editor import VideoFileClip, concatenate_videoclips
#twitter #twitter
import tweepy import tweepy
#Thread
import asyncio
#import aiohttps
from pathlib import Path from pathlib import Path
from sqlalchemy import create_engine from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.ext.declarative import declarative_base
@@ -686,8 +690,8 @@ def check_web_post(postname,postdate,headers):
def is_port_open(host, port): def is_port_open(host, port):
try: try:
isWebUp = urllib3.request("GET", host) is_web_up = urllib3.request("GET", host)
if isWebUp.status == 200: if is_web_up.status == 200:
return True return True
except Exception as error: except Exception as error:
print ('Could not open port to website: ', host, type(error)) print ('Could not open port to website: ', host, type(error))
@@ -698,7 +702,7 @@ def is_port_open(host, port):
def check_media(filename, headers): def check_media(filename, headers):
# Regex gilename to format like in WordPress media name # Regex gilename to format like in WordPress media name
#file_name_minus_extension = re.sub(r'\'|(....$)','', filename, flags=re.IGNORECASE) #file_name_minus_extension = re.sub(r'\'|(....$)','', filename, flags=re.IGNORECASE)
file_name_minus_extension = filename file_name_minus_extension = str(filename)
response = requests.get(env.wpAPI + "/media?search="+file_name_minus_extension, headers=headers,timeout=50) response = requests.get(env.wpAPI + "/media?search="+file_name_minus_extension, headers=headers,timeout=50)
try: try:
result = response.json() result = response.json()
@@ -729,9 +733,6 @@ def check_post(postname,postdate,headers2):
################################################################################################## ##################################################################################################
def threads(): def threads():
import asyncio
import aiohttp
# Replace 'your_access_token' with your actual access token for Meta's Threads # Replace 'your_access_token' with your actual access token for Meta's Threads
ACCESS_TOKEN = 'your_access_token' ACCESS_TOKEN = 'your_access_token'
# The URL for the Meta's Threads API endpoint to post a video # The URL for the Meta's Threads API endpoint to post a video
@@ -1113,6 +1114,7 @@ def post_to_wp(title, content, headers,date, rating,address, picslist):
print (' Got Date: ', newdate2, newdate) print (' Got Date: ', newdate2, newdate)
try: try:
post_id = check_post(title,newdate2,headers) post_id = check_post(title,newdate2,headers)
update_db_row(title,"wpurl","https://www.joeeatswhat.com/"+str(post_id),"onlyempty",outputs)
except Exception as error : except Exception as error :
print ('Could not check to see post already exists',error) print ('Could not check to see post already exists',error)
if not post_id: if not post_id: