from agent.pipeline.config.stages.base import JythonDataExtractorSource


class SNMP(JythonDataExtractorSource):
    JYTHON_SCRIPT = 'snmp.py'
    DATA_EXTRACTOR_API_ENDPOINT = 'data_extractors/snmp'

    def _get_script_params(self) -> list[dict]:
        return [
            {
                'key': 'SNMP_SOURCE_URL',
                'value': self._get_source_url()
            },
            {
                'key': 'INTERVAL_IN_SECONDS',
                'value': str(self.pipeline.interval)
            },
            {
                'key': 'SCHEMA_ID',
                'value': str(self.pipeline.get_schema_id())
            },
            {
                'key': 'QUERY_TIMEOUT',
                'value': str(self.pipeline.source.query_timeout)
            },
        ]


class SNMPRaw(JythonDataExtractorSource):
    JYTHON_SCRIPT = 'snmp_raw.py'
    DATA_EXTRACTOR_API_ENDPOINT = 'data_extractors/snmp/raw'

    def _get_script_params(self) -> list[dict]:
        return [
            {
                'key': 'SNMP_SOURCE_URL',
                'value': self._get_source_url()
            },
            {
                'key': 'INTERVAL_IN_SECONDS',
                'value': str(self.pipeline.interval)
            },
            {
                'key': 'QUERY_TIMEOUT',
                'value': str(self.pipeline.source.query_timeout)
            },
        ]

96dfdf873dcc886c1522ca1eae95901c2374fa02
<mask token>


class SNMPRaw(JythonDataExtractorSource):
    JYTHON_SCRIPT = 'snmp_raw.py'
    DATA_EXTRACTOR_API_ENDPOINT = 'data_extractors/snmp/raw'

    def _get_script_params(self) ->list[dict]:
        return [{'key': 'SNMP_SOURCE_URL', 'value': self._get_source_url()},
            {'key': 'INTERVAL_IN_SECONDS', 'value': str(self.pipeline.
            interval)}, {'key': 'QUERY_TIMEOUT', 'value': str(self.pipeline
            .source.query_timeout)}]

<mask token>


class SNMP(JythonDataExtractorSource):
    <mask token>
    <mask token>
    <mask token>


class SNMPRaw(JythonDataExtractorSource):
    JYTHON_SCRIPT = 'snmp_raw.py'
    DATA_EXTRACTOR_API_ENDPOINT = 'data_extractors/snmp/raw'

    def _get_script_params(self) ->list[dict]:
        return [{'key': 'SNMP_SOURCE_URL', 'value': self._get_source_url()},
            {'key': 'INTERVAL_IN_SECONDS', 'value': str(self.pipeline.
            interval)}, {'key': 'QUERY_TIMEOUT', 'value': str(self.pipeline
            .source.query_timeout)}]

<mask token>


class SNMP(JythonDataExtractorSource):
    JYTHON_SCRIPT = 'snmp.py'
    DATA_EXTRACTOR_API_ENDPOINT = 'data_extractors/snmp'

    def _get_script_params(self) ->list[dict]:
        return [{'key': 'SNMP_SOURCE_URL', 'value': self._get_source_url()},
            {'key': 'INTERVAL_IN_SECONDS', 'value': str(self.pipeline.
            interval)}, {'key': 'SCHEMA_ID', 'value': str(self.pipeline.
            get_schema_id())}, {'key': 'QUERY_TIMEOUT', 'value': str(self.
            pipeline.source.query_timeout)}]


class SNMPRaw(JythonDataExtractorSource):
    JYTHON_SCRIPT = 'snmp_raw.py'
    DATA_EXTRACTOR_API_ENDPOINT = 'data_extractors/snmp/raw'

    def _get_script_params(self) ->list[dict]:
        return [{'key': 'SNMP_SOURCE_URL', 'value': self._get_source_url()},
            {'key': 'INTERVAL_IN_SECONDS', 'value': str(self.pipeline.
            interval)}, {'key': 'QUERY_TIMEOUT', 'value': str(self.pipeline
            .source.query_timeout)}]

from agent.pipeline.config.stages.base import JythonDataExtractorSource


class SNMP(JythonDataExtractorSource):
    JYTHON_SCRIPT = 'snmp.py'
    DATA_EXTRACTOR_API_ENDPOINT = 'data_extractors/snmp'

    def _get_script_params(self) ->list[dict]:
        return [{'key': 'SNMP_SOURCE_URL', 'value': self._get_source_url()},
            {'key': 'INTERVAL_IN_SECONDS', 'value': str(self.pipeline.
            interval)}, {'key': 'SCHEMA_ID', 'value': str(self.pipeline.
            get_schema_id())}, {'key': 'QUERY_TIMEOUT', 'value': str(self.
            pipeline.source.query_timeout)}]


class SNMPRaw(JythonDataExtractorSource):
    JYTHON_SCRIPT = 'snmp_raw.py'
    DATA_EXTRACTOR_API_ENDPOINT = 'data_extractors/snmp/raw'

    def _get_script_params(self) ->list[dict]:
        return [{'key': 'SNMP_SOURCE_URL', 'value': self._get_source_url()},
            {'key': 'INTERVAL_IN_SECONDS', 'value': str(self.pipeline.
            interval)}, {'key': 'QUERY_TIMEOUT', 'value': str(self.pipeline
            .source.query_timeout)}]

from agent.pipeline.config.stages.base import JythonDataExtractorSource


class SNMP(JythonDataExtractorSource):
    JYTHON_SCRIPT = 'snmp.py'
    DATA_EXTRACTOR_API_ENDPOINT = 'data_extractors/snmp'

    def _get_script_params(self) -> list[dict]:
        return [
            {
                'key': 'SNMP_SOURCE_URL',
                'value': self._get_source_url()
            },
            {
                'key': 'INTERVAL_IN_SECONDS',
                'value': str(self.pipeline.interval)
            },
            {
                'key': 'SCHEMA_ID',
                'value': str(self.pipeline.get_schema_id())
            },
            {
                'key': 'QUERY_TIMEOUT',
                'value': str(self.pipeline.source.query_timeout)
            },
        ]


class SNMPRaw(JythonDataExtractorSource):
    JYTHON_SCRIPT = 'snmp_raw.py'
    DATA_EXTRACTOR_API_ENDPOINT = 'data_extractors/snmp/raw'

    def _get_script_params(self) -> list[dict]:
        return [
            {
                'key': 'SNMP_SOURCE_URL',
                'value': self._get_source_url()
            },
            {
                'key': 'INTERVAL_IN_SECONDS',
                'value': str(self.pipeline.interval)
            },
            {
                'key': 'QUERY_TIMEOUT',
                'value': str(self.pipeline.source.query_timeout)
            },
        ]
