ngskcloud
/
gcgj-dify-1.7.0
17
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

rename

Browse Source
pull/22801/head
Asuka Minato 10 months ago committed by -LAN-
parent 9e6e5aa0c9
commit f7dae27db2
No known key found for this signature in database
GPG Key ID: 6BA0D108DED011FF
1 changed files with 9 additions and 19 deletions
Show Stats Download Patch File Download Diff File

28
api/libs/oauth_data_source.py
Unescape Escape View File

@ -63,12 +63,10 @@ class NotionOAuth(OAuthDataSource):
} }
# save data source binding # save data source binding
data_source_binding = db.session.scalar( data_source_binding = db.session.scalar(
select(DataSourceOauthBinding).filter( select(DataSourceOauthBinding).where(
and_( DataSourceOauthBinding.tenant_id == current_user.current_tenant_id,
DataSourceOauthBinding.tenant_id == current_user.current_tenant_id, DataSourceOauthBinding.provider == "notion",
DataSourceOauthBinding.provider == "notion", DataSourceOauthBinding.access_token == access_token,
DataSourceOauthBinding.access_token == access_token,
)
) )
) )
if data_source_binding: if data_source_binding:
@ -101,12 +99,10 @@ class NotionOAuth(OAuthDataSource):
} }
# save data source binding # save data source binding
data_source_binding = db.session.scalar( data_source_binding = db.session.scalar(
select(DataSourceOauthBinding).filter( select(DataSourceOauthBinding).where(
and_( DataSourceOauthBinding.tenant_id == current_user.current_tenant_id,
DataSourceOauthBinding.tenant_id == current_user.current_tenant_id, DataSourceOauthBinding.provider == "notion",
DataSourceOauthBinding.provider == "notion", DataSourceOauthBinding.access_token == access_token,
DataSourceOauthBinding.access_token == access_token,
)
) )
) )
if data_source_binding: if data_source_binding:
@ -133,14 +129,8 @@ class NotionOAuth(OAuthDataSource):
DataSourceOauthBinding.id == binding_id, DataSourceOauthBinding.id == binding_id,
DataSourceOauthBinding.disabled == False, DataSourceOauthBinding.disabled == False,
) )
and_(
DataSourceOauthBinding.tenant_id == current_user.current_tenant_id,
DataSourceOauthBinding.provider == "notion",
DataSourceOauthBinding.id == binding_id,
DataSourceOauthBinding.disabled == False,
)
)
) )
if data_source_binding: if data_source_binding:
# get all authorized pages # get all authorized pages
pages = self.get_authorized_pages(data_source_binding.access_token) pages = self.get_authorized_pages(data_source_binding.access_token)

Write Preview
Loading…
Cancel
Save