5pja %SrSSKJr SSKrSSKJrJrJr SSKJ r J r SSK r SSK J r Jr SSKJrJrJrJrJrJrJrJr SS KJrJrJrJrJr SS KJr \"S 5r \RBS \RDS \RFS\RHS\RJS0r&S\'S'\RBS \RDS \RFS\RHS\RJS0r(S\'S'SSjr)"SS5r*g)u"Internal client for ``/api/v1/`` endpoints not covered by the OpenAPI spec. This module is **private** — external callers should interact through the public :class:`~modelscope_hub.api.HubApi` facade. Auth strategy ------------- The legacy API authenticates via a session cookie (``m_session_id``) rather than the ``Authorization: Bearer`` header used by the OpenAPI surface. On first use the client sets ``m_session_id = `` on the ``requests.Session`` cookie jar — no round-trip to ``/api/v1/login`` is needed for API calls. ) annotationsN)IOAnyBinaryIO) quote_plusurlparse) HTTPAdapterRetry)API_CONNECT_TIMEOUTAPI_MAX_RETRIES API_TIMEOUTLEGACY_API_PREFIXUPLOAD_BLOB_CONNECT_TIMEOUTUPLOAD_BLOB_READ_TIMEOUTUPLOAD_RETRY_ALLOWED_METHODSRepoType)InvalidParameter NetworkErrorRequestTimeoutError ServerErrorraise_for_status) get_logger legacy_apimodelsdatasetsstudiosskillsmcpsdict[str, str]_REPO_TYPE_SEGMENT_REPOS_SEGMENTc2[RXS35$)z4Return the URL path segment for the given repo_type.s)r!get) repo_types V/var/www/html/pdf-tiff/venv/lib/python3.13/site-packages/modelscope_hub/_legacy_api.py_resolve_segmentr(<s  ! !){!_ ==c\rSrSrSr\\S4S)Sjjr\S*Sj5r \S+Sj5r \ RS,Sj5r S-Sjr S.S/S jjr S0S jrSSSSSSS S .S1S jjrS2SjrS3SjrS4SjrS5SjrSSSS.S6SjjrS7SjrS8S9SjjrS:S;SjjrSSjrS?S@SjjrS?SASjjrSBSjrSSS .SCS!jjrS?SDS"jjrS#SSS$.SES%jjr SFSGS&jjr!SFSHS'jjr"S(r#g)I LegacyClientAzInternal client for /api/v1/ endpoints not covered by OpenAPI. All network IO goes through :meth:`_request`, which handles auth headers, retries, and structured error raising. Nc|XlURS5Ul[U4UlSUl[ R"5UlU(aXPRRS'[US/SQ[S9n[US9nURRSU5 URRS U5 g) N/Fz User-Agentg?)iiii)totalbackoff_factorstatus_forcelistallowed_methods) max_retrieszhttps://zhttp://)_tokenrstrip _endpointr _timeout_session_authenticatedrequestsSession_sessionheadersr rr mount)selftokenendpointtimeoutr4 user_agentretryadapters r'__init__LegacyClient.__init__Hs !-0CW/M &+# ((* 2GO $  NN5 !r)c4UR(dUR(dg[UR5R=(d SnUR R RSURUSS9 SUl[RSU5 g)aSet the ``m_session_id`` cookie on the session for legacy API auth. Both cookie and Bearer header are sent: older endpoints rely on the ``m_session_id`` cookie, while newer endpoints accept the ``Authorization: Bearer`` header. Sending both is harmless and maximises compatibility. N m_session_idr.)domainrTTz'Legacy session cookie set for domain=%s) r9r5rr7hostnamer<rOsetloggerdebug)r?rfs r'_ensure_session_auth!LegacyClient._ensure_session_authsl  & &dkk $..)228b !!.$++fSV!W&*# >Gr)F)params json_bodydatafilesr=rBstreamc 8UR5 URU5n URU5n UcUbUcU RSS5 [R SX5 UR RUU UUUUU U=(d URU S9 n [R SXU R"5 U R"S :aD[R S UU UU R"U R$(aU R$SS OS 5 ['U 5 U $![RRan [SU 35U eSn A f[Ran [SU 35U eSn A f[Ran [!SU 35U eSn A ff=f) z@Unified request dispatcher with auth, retry, and error handling.NrXz%s %s) methodurlrmjsonrorpr=rBrqzMax retries exceeded: zConnection failed: zRequest timed out: z %s %s -> %siz1Request failed: %s %s params=%s status=%s body=%sr/rd)rkrUrapoprirjr<requestr8r: exceptions RetryErrorrConnectionErrorrTimeoutr status_codetextr)r?rsrTrmrnrorpr=rBrqrtmerged_headersrespexcs r'_requestLegacyClient._requests !!#ood#w/   1y7H   ~t 4 Wf* L==((&04==) D$  ]F1A1AB   s " LLC  #'99 $3"    %""-- G 6se<=3 F'' E!4SE:; D L%(;C5&AB K Ls0%4DF9EFE..FFFcFUR5nURSU5$)zBExtract the 'Data' field from a standard legacy API JSON response.Data)rur%)r?rbodys r' _json_dataLegacyClient._json_datasyy{xx%%r)cXlSUlURRR 5 UR 5 UR SSSU0S9nURU5UR4$)uAuthenticate via access token and return (user_data, cookies). POST /api/v1/login Performs a full login round-trip that returns a git token and server-issued session cookies. For routine API access, the ``m_session_id`` cookie set by :meth:`_ensure_session_auth` is sufficient — this method is only needed when the caller wants the git token or the full cookie set from the server. FPOSTlogin AccessTokenrn)r5r9r<rOrPrkrr)r? access_tokenrs r'rLegacyClient.loginsd# &+# ##% !!#}}VW 8U}Vt$dll22r)c [U5nU[RS4;aFUR5VVs0sHupEUcM US[ U54_M nnnUR SX6S9nOUR SX2S9nUR U5$s snnf)uPOST /api/v1/{type}s — create a new repository. ``body`` is the fully-constructed request payload (PascalCase keys). The dataset endpoint requires multipart form data (matching the upstream server implementation), while model uses JSON. datasetNr)rpr)r(rDATASETitemsstrrr)r?r&rsegmentkvrprs r' create_repoLegacyClient.create_repos#9- ))95 537::<Q<411&Qs1v&D===ADt$$ Rs B B ch[U5nURSUSU35nURU5$)uGET /api/v1/{type}s/{repo_id} — fetch repository metadata. Uses cookie-based session auth which supports private repositories (unlike the OpenAPI Bearer-only endpoint). GETr.r(rr)r?repo_idr&rrs r' get_repo_infoLegacyClient.get_repo_infos8 #9-}}Uwiq $:;t$$r)r 2)owner page_number page_sizecUUS.nU(aXS'URSSUS9nUR5nUR S 5=(d /UR S 5=(d SUR S 5=(d UUR S5=(d US .$![a0nS[U5;aS[U5;a /SUUS .sS nA$eS nAff=f)uGET /api/v1/datasets — list datasets with full private visibility. The legacy endpoint returns ALL datasets for the authenticated user (including private ones that the OpenAPI search index may miss). ) PageNumberPageSizerrrrm fromIndextoIndexr)r total_countrrNr TotalCountrr)rrrrur%)r?rrrrmrrrs r' list_datasetsLegacyClient.list_datasetss&!"  #7O == 6=BDyy{XXf%+88L16Q88L1@[*-:     c#h&9C+@#$#.!*   s#B C$$CCCCcH[U5nURSUSU35 g)z`Delete a repository. DELETE /api/v1/models/{owner}/{name} DELETE /api/v1/datasets/{dataset_id} DELETEr.Nr(r)r?rr&rs r' delete_repoLegacyClient.delete_repo's' #9- h7)1WI 67r)c[U5nU[U5S.nU(aXWS'U[RSS4;aSOSnUR SUSUSU3US 9n UR U 5n [ U [5(aU $[ U [5(a2U RS 5=(d U RS 5=(d /$/$) zList files in a repository. Models/studios/etc: GET /api/v1/{type}s/{repo_id}/repo/files Datasets: GET /api/v1/datasets/{repo_id}/repo/tree )Revision RecursiveRootrrz repo/treez repo/filesrr.rFilesrp) r(rrrrr isinstancelistdictr%) r?rr&revision recursiverootrrmsuffixrros r'list_repo_filesLegacyClient.list_repo_files3s#9- Y"  !6N )h.>.> :-V V\h}}Uwiq 6($CF}St$ dD ! !K dD ! !88G$?(9?R ? r)c/nSnUSUUS.nU(a US:waXGS'URSSUS3US 9nURU5n [U [5(aU n OJ[U [5(a3U R S 5=(d U R S 5=(d /n O/n UR U 5 [U 5U:aU$US- nM) zList files in a dataset repo using pagination. Datasets can have millions of files, so this method pages through ``GET /api/v1/datasets/{repo_id}/repo/tree`` with ``PageNumber``/``PageSize`` params. r True)rrrrr.rrz datasets/z /repo/treerrrp)rrrrrr%extendlen) r?rrr root_path all_filesrrmrrorps r'list_dataset_files_paginated)LegacyClient.list_dataset_files_paginatedRs!#  $#)% &F Y#-!*v==G9J/!D ??4(D$%%D$'')DTXXg->D"   U #5zI% 1 K3r)cj[U5nURSUSUS35nURU5n[U[5(aRUR S5=(d 0nUR S5=(d /nUR S5=(d /nXx-$[U[ 5(aU$/$)zQList branches and tags of a repository. GET /api/v1/{type}s/{repo_id}/revisions rr. /revisions RevisionMapTagsBranches)r(rrrrr%r) r?rr&rrro revision_maptagsbranchess r'list_revisionsLegacyClient.list_revisionss #9-}}Uwiq $DEt$ dD ! !88M28bL##F+1rD#'' 39rH? "!$--t525r))end_timecZ[U5n0nUbX5S'URSUSUS3U=(d SS9nURU5n[U[5(aNUR S5=(d 0nUR S5=(d /UR S 5=(d /4$//4$) zList branches and tags as separate lists. GET /api/v1/{type}s/{repo_id}/revisions[?EndTime=...] Returns ``(branches, tags)`` where each element is a list of dicts with at least ``Revision`` and ``CreatedAt`` keys. NEndTimerr.rrrrrr(rrrrr%) r?rr&rrrmrrors r'list_revisions_detail"LegacyClient.list_revisions_details#9-!#   (9 }} iq  ,>T  t$ dD ! !88M28bL  ,2  (.B 2v r)cp[U5nX4S.nURSUSUS3US9nURU5$)zGCreate a tag on a repository. POST /api/v1/{type}s/{repo_id}/repo/tag )TagNameRefrr.z /repo/tagrr)r?rr&tagrrrrs r' create_tagLegacyClient.create_tagsG#9-0}}Vy')%DPT}Ut$$r)c[U5nU[R:XaURSUSUS3SU0S9nOURSUSUS3X4S.S9nUR U5$)zDelete a single file from the repository. DELETE /api/v1/{type}s/{owner}/{name}/file?FilePath=...&Revision=... (for models) DELETE /api/v1/datasets/{owner}/{name}/repo?FilePath=... (for datasets) rr./repoFilePathrz/file)rr)r(rrrr)r?rr& file_pathrrrs r' delete_fileLegacyClient.delete_files#9- (( (==)1WIU+"I.!D ==)1WIU+$-D!D t$$r)c x[U5nUUS.nURSSUSUSU3US9nURU5$)aCreate a Git commit with file operations. POST /api/v1/repos/{type}s/{repo_id}/commit/{revision} Each operation should be a dict with keys: - action: "create" | "update" | "delete" - path: path in repo - type: "normal" | "lfs" - size: file size in bytes - sha256: hex digest (empty string for normal files) - content: base64 content (for normal files) - encoding: "base64" (for normal files) )commit_messageactionsrrepos/r.z/commit/rr) r?rr& operationsrrrpayloadrs r' create_commitLegacyClient.create_commits]*#9-,! }} WIQwixz :  t$$r)cv[U5nSUS.nURSSUSUS3US9nURU5n0n[U[5(aUR S/5O/n U HNn U R S S 5n U R S 05n U R S05n U R S 5nXU 'MP U$) uCheck which blobs need uploading via the LFS batch API. POST /api/v1/repos/{type}s/{repo_id}/info/lfs/objects/batch Returns mapping: sha256 → upload_url (if needs upload) or None (exists). upload) operationobjectsrrr.z/info/lfs/objects/batchrroidrdrhrefr)r?rr&rrrrroresult resp_objectsobjrr upload_actionrs r'validate_blobsLegacyClient.validate_blobss#9- (W=}} WIQwi'> ?  t$(*2P&P (#mtxx ':m@YZ^ZbZbciZjYkkl>m ,,"   -'' Q!@FGS P P%(?u&EFC O PL) I s6:/E5FF"E11FFFF43F4c |[U5nUR[SUSUS[U5S[U53 $)zConstruct the file download URL (no request is made). URL pattern: {endpoint}/api/v1/{type}s/{repo_id}/repo?Revision={rev}&FilePath={path} r.z/repo?Revision=z &FilePath=)r(r7rr)r?rr&rrrs r'get_download_urlLegacyClient.get_download_urldsR#9-~~017)1WIF#H-.jI9N8O Q r)skill) element_typerrcTUUUUS.nURSSUS9nURU5$)zZGet collection details and its elements. GET /api/v1/collections?Fid=...&ElementType=... )Fid ElementTyperrr collectionsr)rr)r? collection_idrrrrmrs r'get_collectionLegacyClient.get_collectionxs<!'%!   }}UM&}At$$r)cL[U5nURSUSUSU3USS9$)zDownload the entire repo as a zip archive. GET /api/v1/{type}s/{repo_id}/archive/zip/{revision} Skills (and potentially other repo types) do not support per-file download via ``/repo?FilePath=...``. This method streams the archive endpoint instead. rr.z /archive/zip/T)r=rqr)r?rr&rr=rs r'download_archiveLegacyClient.download_archivesA#9-}} iq xj 9   r)cR[U5nXCS.nURSUSUS3UUSS9$)z`Start a streaming download of a file. Returns a Response with stream=True for chunked reading. )rrrr.rT)rmr=rqr)r?rr&rrr=rrms r'download_streamLegacyClient.download_streamsH#9-&>}} iq  '   r))r7r<r9r8r5) r@ str | NonerArrBintr4rrCrreturnNone)r r)r r)rQrr r!)rTrr rrI)r`dict[str, str] | Noner r )r r!)rsrrTrrmdict[str, Any] | Nonern Any | Noneror$rpr#r=r"rB int | Nonerqboolr requests.Response)rr'r r)rrr z/tuple[dict, requests.cookies.RequestsCookieJar])r&rrzdict[str, Any]r r)rrr&rr r)rrrrrrr r)rrr&rr r!)masterTN) rrr&rrrrr&rrr  list[dict])r(rr.) rrrrrrrrr r))rrr&rr r))rrr&rrr%r ztuple[list[dict], list[dict]]) rrr&rrrrrr r)r() rrr&rrrrrr r) rrr&rrr)rrrrr r)rrr&rrzlist[dict[str, Any]]r zdict[str, str | None]) rrroz(str | bytes | BinaryIO | IO[bytes] | Anyrrr=r"rBr%r r) rrr&rrrrrr r) rrrrrrrrr r)r(N) rrr&rrrr=r"r r') rrr&rrrrrr=r"r r')$__name__ __module__ __qualname____firstlineno____doc__rr rFpropertyrAr@setterrUrarkrrrrrrrrrrrrrrrr r rrr__static_attributes__r)r'r+r+Asa#*!% 000 0  0  0 0: \\&&I  H()- $'+)-"555 & 5  55%5'555 5n&3*% %! # #  #  #  # J8 !       D! ))) )  )  )\ 6( $    ' @%%% %  %  %0! %%% %  %  %L! %%% %  %  % %H&   J*."::7: : ' :: :H!         0$ %% %  %  % %8!)-      '    >!)-        '     r)r+)r&rr r)+r. __future__rr\typingrrr urllib.parserrr:requests.adaptersr r constantsr r rrrrrrrrrrrr utils.loggerrriMODELrSTUDIOSKILLMCPr!__annotations__r"r(r+r2r)r'r>s # $$-0   gf$ L !  NNH j OOY NNH LL& &N NNH j OOY NNH LL& "> }  }  r)