swarbhanu

'''
@author MManning
@file ion/processes/data/transforms/ctd/ctd_L1_conductivity.py
@description Transforms CTD parsed data into L1 product for conductivity
'''

from pyon.ion.transforma import TransformDataProcess
from pyon.core.exception import BadRequest
from interface.services.dm.ipubsub_management_service import PubsubManagementServiceProcessClient

swarbhanu

class TransformEventListener(TransformEventProcess):

    def on_start(self, event_type = None, event_origin = None, event_origin_type = None,  event_subtype = None, algorithm = None):
        self.listener = EventSubscriber(  origin=event_origin,
            origin_type = event_origin_type,
            event_type=event_type,
            sub_type=event_subtype,
            callback=self.process_event   )
        self.listener.start()

swarbhanu

#---------------------------------------------------------------------------------
# Create sms notification
#---------------------------------------------------------------------------------
from interface.objects import UserInfo
from pyon.event.event import EventPublisher
from ion.services.dm.presentation.user_notification_service import *

rr = pn.resource_registry

user = UserInfo(name = 'user')

swarbhanu

from interface.objects import DeliveryMode, UserInfo, DetectionFilterConfig
from pyon.event.event import EventPublisher


#---------------------------------------------------------------------------------
# Create email notification
#---------------------------------------------------------------------------------

rr = pn.resource_registry

swarbhanu

from interface.objects import DeliveryMode, UserInfo, DetectionFilterConfig
from pyon.util.int_test import IonIntegrationTestCase
from pyon.util.unit_test import PyonTestCase
from pyon.public import IonObject, RT, PRED, Container
from pyon.core.exception import NotFound, BadRequest
from nose.plugins.attrib import attr
from pyon.util.log import log
from pyon.event.event import EventPublisher
import gevent
from mock import Mock, mocksignature

swarbhanu

#!/usr/bin/env python

'''
@file ion/services/dm/ingestion/test/test_ingestion.py
@author Swarbhanu Chatterjee
@test ion.services.dm.ingestion.ingestion_management_service test suite to cover all ingestion mgmt service code
'''

import gevent
from mock import Mock

swarbhanu

#!/usr/bin/env python

'''
@file ion/services/dm/ingestion/test/test_ingestion.py
@author Swarbhanu Chatterjee
@test ion.services.dm.ingestion.ingestion_management_service test suite to cover all ingestion mgmt service code
'''

import gevent
from mock import Mock, sentinel, patch

swarbhanu

#!/usr/bin/env python
__license__ = 'Apache 2.0'
'''
@author Maurice Manning
@author Swarbhanu Chatterjee
@file ion/services/dm/ingestion/ingestion_management_service.py
@description Implementation for IngestionManagementService
'''
from interface.services.dm.iingestion_management_service import BaseIngestionManagementService
from pyon.core.exception import NotFound

swarbhanu

from interface.services.dm.iingestion_management_service import IngestionManagementServiceClient
from interface.services.dm.ipubsub_management_service import PubsubManagementServiceClient
from interface.services.coi.iresource_registry_service import ResourceRegistryServiceClient


from pyon.public import IonObject, RT, log, PRED
from pyon.ion.endpoint import ProcessPublisher
from pyon.public import log, StreamProcess

#########################################################################################

swarbhanu

#!/usr/bin/env python

'''
@file ion/services/dm/ingestion/test/test_ingestion.py
@author Swarbhanu Chatterjee
@test ion.services.dm.ingestion.ingestion_management_service test suite to cover all ingestion mgmt service code
'''

import gevent
from mock import Mock, sentinel, patch