^g, rddlmZmZmZmZmZddlmZddlm Z m Z ddl m Z ddl mZddlmZddlmZmZddlmZddl m Z ddl mZddlmZdd lmZmZmZddlmZdd lmZmZddlmZdd lmZeZej1d ed ed ee eefdedededefdZej1deegee eefdedefdZej9deegedddeddddee eefdeded edefd!Zy)") APIRouterDepends UploadFileFormQuery)Session)funcdistinct)get_db)get_current_userupload_csv_file)rradd_external_data_source)rr HTTPException)ExternalDatasourceCreateInternalDatasourceCreate)fetch_datasource_by_branchz /upload-csv/.filestore_id branch_iddbc<Kt|||||d{S7w)z9API endpoint for uploading CSV files and processing them.Nr )rrrrusers 9/var/www/html/hubwallet-dev/src/apps/datasource/router.py upload_csvrs!!xBE EE Es z/add-external-source/) dependenciesdatact|||S)z API route to add an external data source (Protected route). - Requires user authentication. - Accepts `store_id`,`branch_id`, 'Source type', 'URL' - Returns a structured API response. r)rrrs radd_external_sourcer "s $D"d 33z /{branch_id}/NzPage number (starts from 1)) descriptiongezNumber of records per paged)r#r$lepage page_sizec4t|||j||S)a API route to fetch datasource records by branch ID (Protected route). - Requires authentication. - Accepts `branch_id` as an integer. - If pagination (`page`, `page_size`) is provided, return paginated results. - If pagination is not provided, return all records. - Sorting Order: Status (`completed` > `pending` > `failed`), then `created_at` (latest first). )ruser_id)rr'r(rrs rget_datasourcer+3s &b)T\\4 SSr!)fastapirrrrrsqlalchemy.ormr sqlalchemyr r src.utils.dbr src.apps.auth.controllerr src.apps.datasource.controllerrrrsrc.apps.datasource.schemasrrrrouterpostintrr getr+r!rr8s{??"%5:&"5C55"Z"E ^I#Y&/ ! " F FFF  FF $G