@@ -55,10 +55,54 @@ async def delete(*, session, url, data, headers=None):
5555
5656async def list_repos (* , session , org , token ):
5757 headers = {
58- "Authorization" : "token {token}" .format (token = token ),
59- "Accept" : "application/vnd.github.v3 +json" ,
58+ "Authorization" : "Bearer {token}" .format (token = token ),
59+ "Accept" : "application/vnd.github+json" ,
6060 }
6161 url = REPOS_URL .format (org = org )
6262 click .echo ("Retrieving repos at {}" .format (url ))
6363 response = await get (session = session , url = url , headers = headers )
6464 return response
65+
66+
67+ async def delete_content (
68+ * ,
69+ session ,
70+ repo ,
71+ dest ,
72+ token ,
73+ semaphore ,
74+ exists ,
75+ current_sha ,
76+ ):
77+ headers = {
78+ "Authorization" : "Bearer {token}" .format (token = token ),
79+ "Accept" : "application/vnd.github+json" ,
80+ }
81+
82+ data = {"message" : "Deleted {}" .format (dest )}
83+ if exists :
84+ data ["sha" ] = current_sha
85+
86+ url = BASE_URL .format (repo = repo , path = dest )
87+
88+ async with semaphore :
89+ response = await delete (
90+ session = session , url = url , data = data , headers = headers
91+ )
92+
93+ return response
94+
95+
96+ async def check_exists (* , session , repo , dest , token , semaphore , skip_missing ):
97+ headers = {"Authorization" : "Bearer {token}" .format (token = token )}
98+ url = BASE_URL .format (repo = repo , path = dest )
99+
100+ async with semaphore :
101+ response = await get (
102+ session = session ,
103+ url = url ,
104+ headers = headers ,
105+ skip_missing = skip_missing ,
106+ )
107+
108+ return response
0 commit comments