o
    Ci                     @   s,   d dl mZ d dlmZ G dd deZdS )    )BaseCommand)DataSourcesc                   @   s   e Zd ZdZdd ZdS )Commandz,Create default data sources/connection typesc           
   
   O   s  g ddddddddddddd	ddd
ddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddddd ddd!ddd"ddd#ddd$dd}d%}d%}|D ]Q}t jj|d& |d' d }|r| j| jd(|d&  d)|d'  d* |d+7 }qt jj|d& |d' d | j| j	d,|d&  d)|d'  d- |d+7 }q| jd. | j| j	d,| d/ | j| jd(| d0 | jd1 t j
 d2}| jd3|  d4 | jd5d6d7d8d9d7d:d; | jd< d7d= d7d>  |D ]}	| j|	jd?d7|	jd9d7|	jd; qRd S )@N
POSTGRESQLDATABASE)nametypeCSVFILESSFTPREMOTE_FILESFTPSMBMONGODBORACLEMICROSOFTSQLSERVERMYSQL	SNOWFLAKENINJAINTEGRATIONSCONNECTWISEHALOPSASHOPIFYTALLY
QUICKBOOKS
SALESFORCEJIRAHUBSPOTGOOGLESHEETDBTPAX8BAMBOOHRZOHO_CRMZOHO_INVENTORY
ZOHO_BOOKSGOOGLEANALYTICOPENAIGEMINIDEEPSEEK
CLICKHOUSEr   r   r   u   ⚠️  Skipped: z (z) - already exists   u   ✅ Created: )z=
============================================================z data sourcesz data sources (already exist)z=============================================================
idu&   
📊 Total Data Sources in Database: 
IDz<5 NAMEz<30TYPEz<20z-----z------------------------------z--------------------<)r   objectsfilterfirststdoutwritestyleWARNINGcreateSUCCESSallorder_bycountr,   r   r   )
selfargskwargsdatasourcescreated_countskipped_countds_dataexistingall_datasourcesds rI   K/var/www/Datamplify/authentication/management/commands/Create_Datasource.pyhandle   s   	
# 
 
",zCommand.handleN)__name__
__module____qualname__helprK   rI   rI   rI   rJ   r      s    r   N)django.core.management.baser   Connections.modelsr   r   rI   rI   rI   rJ   <module>   s    