Update pack. structure from scripts to application

This commit is contained in:
Jadowyne Ulve 2025-04-26 21:17:47 -05:00
parent 8bf3b0a290
commit 9f4084a4d7
21 changed files with 16 additions and 24 deletions

View File

@ -1,4 +1,4 @@
from scripts import postsqldb from application import postsqldb
import config import config
import psycopg2 import psycopg2
@ -6,7 +6,7 @@ def getModalSKUs(site, payload, convert=True):
database_config = config.config() database_config = config.config()
with psycopg2.connect(**database_config) as conn: with psycopg2.connect(**database_config) as conn:
with conn.cursor() as cur: with conn.cursor() as cur:
with open("scripts/recipes/sql/itemsModal.sql") as file: with open("application/recipes/sql/itemsModal.sql") as file:
sql = file.read().replace("%%site_name%%", site) sql = file.read().replace("%%site_name%%", site)
cur.execute(sql, payload) cur.execute(sql, payload)
rows = cur.fetchall() rows = cur.fetchall()
@ -14,7 +14,7 @@ def getModalSKUs(site, payload, convert=True):
if rows and convert: if rows and convert:
rows = [postsqldb.tupleDictionaryFactory(cur.description, row) for row in rows] rows = [postsqldb.tupleDictionaryFactory(cur.description, row) for row in rows]
with open("scripts/recipes/sql/itemsModalCount.sql") as file: with open("application/recipes/sql/itemsModalCount.sql") as file:
sql = file.read().replace("%%site_name%%", site) sql = file.read().replace("%%site_name%%", site)
cur.execute(sql) cur.execute(sql)
@ -30,7 +30,7 @@ def getItemData(site:str, payload:tuple, convert:bool=True):
try: try:
with psycopg2.connect(**database_config) as conn: with psycopg2.connect(**database_config) as conn:
with conn.cursor() as cur: with conn.cursor() as cur:
with open("scripts/recipes/sql/getItemData.sql") as file: with open("application/recipes/sql/getItemData.sql") as file:
sql = file.read().replace("%%site_name%%", site) sql = file.read().replace("%%site_name%%", site)
cur.execute(sql, payload) cur.execute(sql, payload)
rows = cur.fetchone() rows = cur.fetchone()
@ -45,9 +45,9 @@ def getItemData(site:str, payload:tuple, convert:bool=True):
def getRecipes(site:str, payload:tuple, convert=True): def getRecipes(site:str, payload:tuple, convert=True):
recordset = [] recordset = []
count = 0 count = 0
with open("scripts/recipes/sql/getRecipes.sql", "r+") as file: with open("application/recipes/sql/getRecipes.sql", "r+") as file:
sql = file.read().replace("%%site_name%%", site) sql = file.read().replace("%%site_name%%", site)
with open(f"scripts/recipes/sql/getRecipesCount.sql", "r+") as file: with open(f"application/recipes/sql/getRecipesCount.sql", "r+") as file:
sqlcount = file.read().replace("%%site_name%%", site) sqlcount = file.read().replace("%%site_name%%", site)
try: try:
database_config = config.config() database_config = config.config()
@ -67,10 +67,10 @@ def getRecipes(site:str, payload:tuple, convert=True):
def getRecipe(site, payload:tuple, convert=True): def getRecipe(site, payload:tuple, convert=True):
database_config = config.config() database_config = config.config()
with open(f"application/recipes/sql/getRecipeByID.sql", "r+") as file:
sql = file.read().replace("%%site_name%%", site)
try: try:
with psycopg2.connect(**database_config) as conn: with psycopg2.connect(**database_config) as conn:
with open(f"scripts/recipes/sql/getRecipeByID.sql", "r+") as file:
sql = file.read().replace("%%site_name%%", site)
with conn.cursor() as cur: with conn.cursor() as cur:
cur.execute(sql, payload) cur.execute(sql, payload)
rows = cur.fetchone() rows = cur.fetchone()
@ -82,7 +82,7 @@ def getRecipe(site, payload:tuple, convert=True):
except (Exception, psycopg2.DatabaseError) as error: except (Exception, psycopg2.DatabaseError) as error:
raise postsqldb.DatabaseError(error, payload, sql) raise postsqldb.DatabaseError(error, payload, sql)
def getPicturePath(site:str, payload:tuple, convert:bool=True): def getPicturePath(site:str, payload:tuple):
database_config = config.config() database_config = config.config()
with psycopg2.connect(**database_config) as conn: with psycopg2.connect(**database_config) as conn:
with conn.cursor() as cur: with conn.cursor() as cur:
@ -93,7 +93,7 @@ def getPicturePath(site:str, payload:tuple, convert:bool=True):
def postAddRecipe(site:str, payload:tuple, convert:bool=True): def postAddRecipe(site:str, payload:tuple, convert:bool=True):
database_config = config.config() database_config = config.config()
record = () record = ()
with open("scripts/recipes/sql/postRecipe.sql") as file: with open("application/recipes/sql/postRecipe.sql") as file:
sql = file.read().replace("%%site_name%%", site) sql = file.read().replace("%%site_name%%", site)
try: try:
with psycopg2.connect(**database_config) as conn: with psycopg2.connect(**database_config) as conn:
@ -111,7 +111,7 @@ def postAddRecipe(site:str, payload:tuple, convert:bool=True):
def postAddRecipeItem(site:str, payload:tuple, convert:bool=True): def postAddRecipeItem(site:str, payload:tuple, convert:bool=True):
database_config = config.config() database_config = config.config()
record = () record = ()
with open("scripts/recipes/sql/postRecipeItem.sql") as file: with open("application/recipes/sql/postRecipeItem.sql") as file:
sql = file.read().replace("%%site_name%%", site) sql = file.read().replace("%%site_name%%", site)
try: try:
with psycopg2.connect(**database_config) as conn: with psycopg2.connect(**database_config) as conn:
@ -132,7 +132,7 @@ def postUpdateRecipe(site:str, payload:tuple, convert:bool=True):
with psycopg2.connect(**database_config) as conn: with psycopg2.connect(**database_config) as conn:
with conn.cursor() as cur: with conn.cursor() as cur:
set_clause, values = postsqldb.updateStringFactory(payload['update']) set_clause, values = postsqldb.updateStringFactory(payload['update'])
with open("scripts/recipes/sql/postUpdateRecipe.sql") as file: with open("application/recipes/sql/postUpdateRecipe.sql") as file:
sql = file.read().replace("%%site_name%%", site).replace("%%set_clause%%", set_clause) sql = file.read().replace("%%site_name%%", site).replace("%%set_clause%%", set_clause)
values.append(payload['id']) values.append(payload['id'])
cur.execute(sql, values) cur.execute(sql, values)
@ -149,7 +149,7 @@ def postUpdateRecipeItem(site:str, payload:tuple, convert:bool=True):
with psycopg2.connect(**database_config) as conn: with psycopg2.connect(**database_config) as conn:
with conn.cursor() as cur: with conn.cursor() as cur:
set_clause, values = postsqldb.updateStringFactory(payload['update']) set_clause, values = postsqldb.updateStringFactory(payload['update'])
with open("scripts/recipes/sql/postUpdateRecipeItem.sql") as file: with open("application/recipes/sql/postUpdateRecipeItem.sql") as file:
sql = file.read().replace("%%site_name%%", site).replace("%%set_clause%%", set_clause) sql = file.read().replace("%%site_name%%", site).replace("%%set_clause%%", set_clause)
values.append(payload['id']) values.append(payload['id'])
cur.execute(sql, values) cur.execute(sql, values)

View File

@ -5,12 +5,10 @@ from main import unfoldCostLayers
from user_api import login_required from user_api import login_required
import os import os
import postsqldb, webpush import postsqldb, webpush
from scripts.recipes import database_recipes from application.recipes import database_recipes
from scripts import postsqldb as db from application import postsqldb as db
from flask_restx import Api, fields
recipes_api = Blueprint('recipes_api', __name__) recipes_api = Blueprint('recipes_api', __name__)
model_api = Api(recipes_api)
@recipes_api.route("/recipes") @recipes_api.route("/recipes")
@login_required @login_required
@ -140,14 +138,8 @@ def getItems():
return jsonify({"items":recordset, "end":math.ceil(count/limit), "error":False, "message":"items fetched succesfully!"}) return jsonify({"items":recordset, "end":math.ceil(count/limit), "error":False, "message":"items fetched succesfully!"})
return jsonify({"items":recordset, "end":math.ceil(count/limit), "error":True, "message":"There was an error with this GET statement"}) return jsonify({"items":recordset, "end":math.ceil(count/limit), "error":True, "message":"There was an error with this GET statement"})
update_model = model_api.model('model', {
'id': fields.Integer(min=1),
'update': fields.Raw(required=True, description="all the data to be updated!")
})
@recipes_api.route('/recipe/postUpdate', methods=["POST"]) @recipes_api.route('/recipe/postUpdate', methods=["POST"])
@login_required @login_required
@model_api.expect(update_model)
def postUpdate(): def postUpdate():
""" This is an endpoint for updating an RecipeTuple in the sites recipes table """ This is an endpoint for updating an RecipeTuple in the sites recipes table
--- ---

View File

@ -8,7 +8,7 @@ from workshop_api import workshop_api
import database import database
import postsqldb import postsqldb
from webpush import trigger_push_notifications_for_subscriptions from webpush import trigger_push_notifications_for_subscriptions
from scripts.recipes import recipes_api from application.recipes import recipes_api
from flasgger import Swagger from flasgger import Swagger