o QDi @sddlmZddlmZddlZddlmZddlmZddl m Z ddl m Z dd l mZdd lmZdd lmZdd lmZd dlmZmZd dlmZejddejejejejejddejddejejejf d"d d!Z dS)#) annotations)ListN)Console)track)Prompt)FrictionlessException)Package)platform)Resource)system)commonhelpers)consolepublishname.)defaultsource List[str]rstrtypepathtargettitledebugbooltrusted standardsc  CsJt} tj} |r |t_|r|t_tj||d}|s*|s*d} tj| | dt j ddzPt t||||d} | j |d} t || d}| d tj|d d }t|| jjsYtd td }tddgddD]}|dkrx|j|| jj|ddqfWnty}ztj| ||dt j ddd}~ww| d| d|ddS)z Script data)rz(Providing "source" or "path" is required)note)code)rrrdatatyper)r resourcesz [bold]PublishT) packagifyz+Currently only CKAN publishing is supportedz!Please enter [bold]API Key[/bold]startendz Publishing...) description)apikey)control)r exceptionNz [bold]Resultz Succesefully published to [bold]z[/bold])rr frictionless_portalsr rrr create_source print_errortyperExitr listr rulecreate_adapter isinstanceckan CkanAdapterrraskrr CkanControl Exceptionprint_exceptionprint)rrrrrrrrrrportalsr resourcer$packageadapterr)stager+rA^/var/www/Datamplify/venv/lib/python3.10/site-packages/frictionless/console/commands/publish.pyconsole_publishsJ       rC)rrrrrrrrrrrrrrrrrr)! __future__rtypingrr/ rich.consoler rich.progressr rich.promptrr+rr>r r r=r r rrrcommandr resource_namerrOptionrrrrCrArArArBs0