"use strict";(()=>{vare={};e.id=8893,e.ids=[8893],e.modules={39383:e=>{e.exports=require("@moduletrace/datasquirel/dist/package-shared/actions/users/user-auth")},75600:e=>{e.exports=require("next/dist/compiled/next-server/pages-api.runtime.prod.js")},72583:e=>{e.exports=require("sanitize-html")},9973:e=>{e.exports=require("serverless-mysql")},79428:e=>{e.exports=require("buffer")},55511:e=>{e.exports=require("crypto")},29021:e=>{e.exports=require("fs")},33873:e=>{e.exports=require("path")},1462:(e,a,r)=>{r.r(a),r.d(a,{config:()=>f,default:()=>D,routeModule:()=>E});vars={};r.r(s),r.d(s,{default:()=>A});vart=r(89947),i=r(2706),n=r(96762),l=r(29021),o=r.n(l),u=r(48786),d=r(67619),c=r(69842),b=r(98e3),m=r(47546);asyncfunctionp(e){leta;"production".match(/dev/)&&o().appendFileSync("./.tmp/sqlQuery.sql",e+"\n"+Date()+"\n\n\n","utf8");try{a=await(0,m.A)(e)}catch(e){(0,d.A)({component:"noDatabaseDbHandler",message:e.message}),console.log("ERROR in noDatabaseDbHandler =>",e.message)}returna||null}var_=r(10776);asyncfunctionA(e,a){if("POST"!==e.method)returna.json({msg:"Failed!"});letr=await(0,c.A)(e,a,!0);if(!r)returna.json({success:!1,msg:"Unauthorized"});lets=await(0,u.A)("SELECT * FROM users WHERE id = ?",[r.id]),t=s?.[0],{db_name:i,db_slug:n,db_description:l,db_image:m,duplicate:A,keepUpdated:D,keepDataUpdated:f}=e.body;if(n.match(/[^a-zA-Z0-9-_]/))returna.json({success:!1,msg:"Input Error"});letE=`datasquirel_user_${r.id}_${n}`,S=awaitp(`CREATE DATABASE IF NOT EXISTS \`${E}\` CHARACTER SET utf8mb4 COLLATE utf8mb4_bin`);if(!S?.affectedRows)returna.json({success:!1,msg:"Database Could Not be created!"});letN={user_id:r.id,db_name:i,db_slug:n,db_full_name:E,db_description:l,db_image:m};A&&D&&(N.active_clone="1",N.active_clone_parent_db=A),A&&f&&(N.active_data="1");letg=await(0,b.A)({dbFullName:"datasquirel",tableName:"user_databases",data:N});if(g.insertId)try{lete=`${process.env.DSQL_USER_DB_SCHEMA_PATH}/user-${r.id}/main.json`,s=JSON.parse(o().readFileSync(e,"utf8")),u={dbName:i,dbSlug:n,dbFullName:E,dbDescription:l,dbImage:m,tables:[]};if(A)try{lete=s.filter(e=>e.dbFullName===A)[0];u.tables=e.tables,D&&(u.childDatabase=!0,u.childDatabaseDbFullName=A,f&&(u.updateData=!0),e.childrenDatabases?e.childrenDatabases.push({dbFullName:E}):e.childrenDatabases=[{dbFullName:E}]);for(lete=0;e<u.tables.length;e++){leta=u.tables[e];await(0,b.A)({dbFullName:"datasquirel",tableName:"user_database_tables",data:{user_id:r.id,db_id:g.insertId,db_slug:n,table_name:a.tableFullName,table_slug:a.tableName}})}}catch(e){(0,d.A)({component:"/api/createUserDatabase/lines-117-159",message:e.message,user:r})}s.push(u),o().writeFileSync(`${e}`,JSON.stringify(s),"utf8"),A&&await(0,_.A)({userId:r.id,targetDatabase:E});letc=awaitp(`GRANT ALL PRIVILEGES ON ${E}.* TO '${process.env.DSQL_DB_FULL_ACCESS_USERNAME}'@'${process.env.DSQL_DB_TARGET_IP_ADDRESS||"%"}' WITH GRANT OPTION`);if(c.error)throwError(c.error);letS=awaitp(`GRANT SELECT ON ${E}.* TO '${process.env.DSQL_DB_READ_ONLY_USERNAME}'@'${process.env.DSQL_DB_TARGET_IP_ADDRESS||"%"}'`);if(S.error)throwError(S.error);t?.mariadb_user&&t?.mariadb_pass&&awaitp(`GRANT ALL PRIVILEGES ON ${E}.* TO '${t.mariadb_user}'@'${t.mariadb_host}'`),awaitp("FLUSH PRIVILEGES"),a.json({success:!0})}catch(e){(0,d.A)({component:"/api/createUserDatabase/main-catch-error",message:e.message,user:r}),a.json({success:!1,msg:"Database Files could not be written!"})}elsea.json({success:!1,msg:"Database Could Not Be Recorded!"})}letD=(0,n.M)(s,"default"),f=(0,n.M)(s,"config"),E=newt.PagesAPIRouteModule({definition:{kind:i.A.PAGES_API,page:"/api/createUserDatabase",pathname:"/api/createUserDatabase",bundlePath:"",filename:""},userland:s})},69842:(e,a,r)=>{r.d(a,{A:()=>i});vars=r(39383),t=r.n(s);asyncfunctioni(e,a,r){returnt()({req:e,level:r?"deep":void0}).payload}},48786:(e,a,r)=>{r.d(a,{A:()=>t});vars=r(7447);asyncfunctiont(...e){leta=(0,s.A)();try{if(!a)throwError("No Connection provided to DB_HANDLER function!");letr=awaita.query(...e);returnJSON.parse(JSON.stringify(r))}catch(e)
