Andal.LND/edx-platform
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

remove VEDA reference from platform

Browse Source
This commit is contained in:
DawoudSheraz
2020-09-25 11:20:20 +05:00
parent d74f6d9800
commit b80fefdbdd
8 changed files with 12 additions and 247 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
openedx/core/djangoapps/video_pipeline/admin.py
View File

@@ -13,7 +13,6 @@ from openedx.core.djangoapps.video_pipeline.forms import (
from openedx.core.djangoapps.video_pipeline.models import (
CourseVideoUploadsEnabledByDefault,
VEMPipelineIntegration,
VideoPipelineIntegration,
VideoUploadsEnabledByDefault
)
@@ -33,8 +32,6 @@ class VEMPipelineIntegrationAdmin(ConfigurationModelAdmin):
form = VEMPipelineIntegrationAdminForm
admin.site.register(VideoPipelineIntegration, ConfigurationModelAdmin)
admin.site.register(VEMPipelineIntegration, VEMPipelineIntegrationAdmin)
admin.site.register(VideoUploadsEnabledByDefault, ConfigurationModelAdmin)
admin.site.register(CourseVideoUploadsEnabledByDefault, CourseVideoUploadsEnabledByDefaultAdmin)

13
openedx/core/djangoapps/video_pipeline/api.py
View File

@@ -9,7 +9,7 @@ from django.core.exceptions import ObjectDoesNotExist
from oauth2_provider.models import Application
from slumber.exceptions import HttpClientError
from openedx.core.djangoapps.video_pipeline.models import VEMPipelineIntegration, VideoPipelineIntegration
from openedx.core.djangoapps.video_pipeline.models import VEMPipelineIntegration
from openedx.core.djangoapps.video_pipeline.utils import create_video_pipeline_api_client
log = logging.getLogger(__name__)
@@ -72,22 +72,11 @@ def update_3rd_party_transcription_service_credentials(**credentials_payload):
error_response, is_updated = {}, False
vem_pipeline_integration = VEMPipelineIntegration.current()
veda_pipeline_integration = VideoPipelineIntegration.current()
if vem_pipeline_integration.enabled:
log.info('Sending transcript credentials to VEM for org: {} and provider: {}'.format(
credentials_payload.get('org'), credentials_payload.get('provider')
))
error_response, is_updated = send_transcript_credentials(vem_pipeline_integration, credentials_payload)
# If credentials update fail for VEM, return proper error message and discontinue to
# send credentials to VEDA because we are going to try it next time anyway
if not is_updated:
return error_response, is_updated
if veda_pipeline_integration.enabled:
log.info('Sending transcript credentials to VEDA for org: {} and provider: {}'.format(
credentials_payload.get('org'), credentials_payload.get('provider')
))
error_response, is_updated = send_transcript_credentials(veda_pipeline_integration, credentials_payload)
return error_response, is_updated

27
openedx/core/djangoapps/video_pipeline/management/commands/create_video_pipeline_integration.py
View File

@@ -1,27 +0,0 @@
"""
Management command `create_video_pipeline_integration` is used to create video pipeline integration record.
"""
from openedx.core.djangoapps.video_pipeline.models import VideoPipelineIntegration
from django.core.management.base import BaseCommand
class Command(BaseCommand):
# pylint: disable=missing-docstring
help = 'Creates the video pipeline integration record.'
def add_arguments(self, parser):
parser.add_argument('client_name')
parser.add_argument('api_url')
parser.add_argument('service_username')
parser.add_argument('--enabled', dest='enabled', action='store_true')
def handle(self, **fields):
VideoPipelineIntegration.objects.get_or_create(
client_name=fields['client_name'],
api_url=fields['api_url'],
service_username=fields['service_username'],
enabled=fields['enabled'],
)

76
openedx/core/djangoapps/video_pipeline/management/commands/tests/test_create_video_pipeline_integration.py
View File

@@ -1,76 +0,0 @@
"""
Tests for create_video_pipeline_integration management command.
"""
import ddt
from django.core.management import call_command
from django.test import TestCase
from openedx.core.djangoapps.video_pipeline.models import VideoPipelineIntegration
@ddt.ddt
class CreateVideoPipelineIntegration(TestCase):
"""
Management command test class.
"""
def setUp(self):
super(CreateVideoPipelineIntegration, self).setUp()
def assert_integration_created(self, args, options):
"""
Verify that the integration record was created.
"""
integration = VideoPipelineIntegration.current()
for index, attr in enumerate(('client_name', 'api_url', 'service_username')):
self.assertEqual(args[index], getattr(integration, attr))
self.assertEqual(integration.enabled, options.get('enabled'))
@ddt.data(
(
[
'veda',
'http://veda.edx.org/api/',
'veda_service_user',
],
{'enabled': False}
),
(
[
'veda',
'http://veda.edx.org/api/',
'veda_service_user',
],
{'enabled': True}
),
)
@ddt.unpack
def test_integration_creation(self, args, options):
"""
Verify that the create_video_pipeline_integration command works as expected.
"""
call_command('create_video_pipeline_integration', *args, **options)
self.assert_integration_created(args, options)
def test_idempotency(self):
"""
Verify that the command can be run repeatedly with the same args and options without any ill effects.
"""
args = [
'veda',
'http://veda.edx.org/api/',
'veda_service_user',
]
options = {'enabled': False}
call_command('create_video_pipeline_integration', *args, **options)
self.assert_integration_created(args, options)
# Verify that the command is idempotent
call_command('create_video_pipeline_integration', *args, **options)
self.assert_integration_created(args, options)
# Verify that only one record exists
self.assertEqual(VideoPipelineIntegration.objects.count(), 1)

24
openedx/core/djangoapps/video_pipeline/tests/mixins.py
View File

@@ -4,19 +4,13 @@ Mixins to test video pipeline integration.
from oauth2_provider.models import Application
from openedx.core.djangoapps.video_pipeline.models import VEMPipelineIntegration, VideoPipelineIntegration
from openedx.core.djangoapps.video_pipeline.models import VEMPipelineIntegration
class VideoPipelineMixin(object):
"""
Utility for working with the video pipelines (VEDA and VEM) service during testing.
Utility for working with the VEM video pipeline service during testing.
"""
veda_pipeline_integration_defaults = {
'enabled': True,
'api_url': 'https://video-pipeline.example.com/api/v1/',
'service_username': 'cms_veda_pipeline_service_user',
'client_name': 'veda_pipeline'
}
vem_pipeline_integration_defaults = {
'enabled': True,
@@ -30,14 +24,6 @@ class VideoPipelineMixin(object):
'https://video-encode-manager.example.com/api/v1/logout ' \
'https://video-encode-manager.example.com/api/v1/redirect'
def create_video_pipeline_integration(self, **kwargs):
"""
Creates a new `VideoPipelineIntegration` record with `veda_pipeline_integration_defaults`,
and it can be updated with any provided overrides.
"""
fields = dict(self.veda_pipeline_integration_defaults, **kwargs)
return VideoPipelineIntegration.objects.create(**fields)
def create_vem_pipeline_integration(self, **kwargs):
"""
Creates a new `VEMPipelineIntegration` record with `vem_pipeline_integration_defaults`,
@@ -46,15 +32,15 @@ class VideoPipelineMixin(object):
fields = dict(self.vem_pipeline_integration_defaults, **kwargs)
return VEMPipelineIntegration.objects.create(**fields)
def create_video_pipeline_oauth_client(self, user, vem_enabled=False, **kwargs):
def create_video_pipeline_oauth_client(self, user, **kwargs):
"""
Creates a new `Client` record with `video_pipeline_oauth_client_defaults`,
and it can be updated with any provided overrides.
"""
video_pipeline_oauth_client_defaults = {
'name': 'vem_pipeline' if vem_enabled else 'veda_pipeline',
'name': 'vem_pipeline',
'redirect_uris': self.request_uris,
'client_id': 'vem_client_id' if vem_enabled else 'video_pipeline_client_id',
'client_id': 'vem_client_id',
'client_secret': 'video_pipeline_client_secret',
'client_type': Application.CLIENT_CONFIDENTIAL
}

54
openedx/core/djangoapps/video_pipeline/tests/test_api.py
View File

@@ -21,55 +21,22 @@ class TestAPIUtils(VideoPipelineMixin, TestCase):
"""
def setUp(self):
"""
Setup VEDA and VEM oauth clients.
Setup VEM oauth client.
"""
self.add_veda_client()
self.add_vem_client()
def add_veda_client(self):
"""
Creates a VEDA oauth client
"""
self.veda_pipeline_integration = self.create_video_pipeline_integration()
self.veda_user = UserFactory(username=self.veda_pipeline_integration.service_username)
self.veda_oauth_client = self.create_video_pipeline_oauth_client(user=self.veda_user)
def add_vem_client(self):
"""
Creates a VEM oauth client
"""
self.vem_pipeline_integration = self.create_vem_pipeline_integration()
self.vem_user = UserFactory(username=self.vem_pipeline_integration.service_username)
self.vem_oauth_client = self.create_video_pipeline_oauth_client(user=self.vem_user, vem_enabled=True)
self.vem_oauth_client = self.create_video_pipeline_oauth_client(user=self.vem_user)
@patch('openedx.core.djangoapps.video_pipeline.api.log')
@patch('openedx.core.djangoapps.video_pipeline.utils.OAuthAPIClient')
def test_update_transcription_service_credentials_with_one_integration_disabled(self, mock_client, mock_logger):
def test_update_transcription_service_credentials_with_vem_disabled(self):
"""
Test that updating the credentials when one of the service integration is disabled, allows
the credentials to be updated for other pipeline.
Test updating the credentials when VEM integration is disabled.
"""
mock_client.request.return_value.ok = True
credentials_payload = {
'org': 'mit', 'provider': 'ABC Provider', 'api_key': '61c56a8d0'
}
self.veda_pipeline_integration.enabled = False
self.veda_pipeline_integration.save()
__, is_updated = update_3rd_party_transcription_service_credentials(**credentials_payload)
mock_logger.info.assert_called_with('Sending transcript credentials to VEM for org: {} and provider: {}'.format(
credentials_payload.get('org'), credentials_payload.get('provider')
))
self.assertTrue(is_updated)
def test_update_transcription_service_credentials_with_both_integration_disabled(self):
"""
Test updating the credentials when both service integration are disabled.
"""
# Disabling VEDA
self.veda_pipeline_integration.enabled = False
self.veda_pipeline_integration.save()
# Disabling VEM
self.vem_pipeline_integration.enabled = False
self.vem_pipeline_integration.save()
@@ -77,16 +44,6 @@ class TestAPIUtils(VideoPipelineMixin, TestCase):
__, is_updated = update_3rd_party_transcription_service_credentials()
self.assertFalse(is_updated)
def test_update_transcription_service_credentials_when_one_service_fails(self):
"""
Test that if one of the transcription service fails to update credentials,
response from `update_3rd_party_transcription_service_credentials` is False.
"""
self.vem_pipeline_integration.client_name = 'non_existent_client'
self.vem_pipeline_integration.save()
__, is_updated = update_3rd_party_transcription_service_credentials()
self.assertFalse(is_updated)
@ddt.data(
{
'username': 'Jason_cielo_24',
@@ -116,9 +73,6 @@ class TestAPIUtils(VideoPipelineMixin, TestCase):
mock_logger.info.assert_any_call('Sending transcript credentials to VEM for org: {} and provider: {}'.format(
credentials_payload.get('org'), credentials_payload.get('provider')
))
mock_logger.info.assert_any_call('Sending transcript credentials to VEDA for org: {} and provider: {}'.format(
credentials_payload.get('org'), credentials_payload.get('provider')
))
@patch('openedx.core.djangoapps.video_pipeline.api.log')
@patch('openedx.core.djangoapps.video_pipeline.utils.OAuthAPIClient')