OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	03/16/2023 12:55:54 PM	rwxr-xr-x
📄 __init__.py	4.19 KB	03/13/2021 04:30:48 PM	rw-r--r--
📁 __pycache__	-	03/16/2023 12:55:54 PM	rwxr-xr-x
📁 command	-	03/16/2023 12:55:54 PM	rwxr-xr-x
📄 processes.py	16.99 KB	03/13/2021 04:30:48 PM	rw-r--r--
📁 response	-	03/16/2023 12:55:54 PM	rwxr-xr-x
📄 transcoder.py	6.41 KB	03/13/2021 04:30:48 PM	rw-r--r--

Editing: __init__.py

# encoding: utf-8
"""
decoder/__init__.py

Created by Thomas Mangin on 2009-08-25.
Copyright (c) 2009-2017 Exa Networks. All rights reserved.
License: 3-clause BSD. (See the COPYRIGHT file)
"""

from exabgp.configuration.core.format import formated
from exabgp.configuration.operational.parser import operational

from exabgp.protocol.family import AFI
from exabgp.protocol.family import SAFI
from exabgp.protocol.family import Family

from exabgp.bgp.message.refresh import RouteRefresh

from exabgp.logger import Logger
from exabgp.reactor.api.command import Command
from exabgp.configuration.configuration import Configuration

# ======================================================================= Parser
#

class API(Command):
    def __init__(self, reactor):
        self.reactor = reactor
        self.logger = Logger()
        self.configuration = Configuration([])

def log_message(self, message, level='INFO'):
        self.logger.notice(message, 'api', level)

def log_failure(self, message, level='ERR'):
        error = str(self.configuration.tokeniser.error)
        report = '%s\nreason: %s' % (message, error) if error else message
        self.logger.error(report, 'api', level)

def text(self, reactor, service, command):
        for registered in self.functions:
            if registered == command or command.endswith(' ' + registered) or registered + ' ' in command:
                return self.callback['text'][registered](self, reactor, service, command)
        reactor.processes.answer_error(service)
        self.logger.warning('command from process not understood : %s' % command, 'api')
        return False

def api_route(self, command):
        action, line = command.split(' ', 1)

self.configuration.static.clear()
        if not self.configuration.partial('static', line, action):
            return []

if self.configuration.scope.location():
            return []

self.configuration.scope.to_context()
        changes = self.configuration.scope.pop_routes()
        return changes

def api_flow(self, command):
        action, flow, line = command.split(' ', 2)

self.configuration.flow.clear()
        if not self.configuration.partial('flow', line):
            return []

if self.configuration.scope.location():
            return []

self.configuration.scope.to_context()
        changes = self.configuration.scope.pop_routes()
        return changes

def api_vpls(self, command):
        action, line = command.split(' ', 1)

self.configuration.l2vpn.clear()
        if not self.configuration.partial('l2vpn', line):
            return []

self.configuration.scope.to_context()
        changes = self.configuration.scope.pop('l2vpn')
        return changes

def api_attributes(self, command, peers):
        action, line = command.split(' ', 1)

self.configuration.static.clear()
        if not self.configuration.partial('static', line):
            return []

self.configuration.scope.to_context()
        changes = self.configuration.scope.pop_routes()
        return changes

def api_refresh(self, command):
        tokens = formated(command).split(' ')[2:]
        if len(tokens) != 2:
            return False
        afi = AFI.value(tokens.pop(0))
        safi = SAFI.value(tokens.pop(0))
        if afi is None or safi is None:
            return False
        return [RouteRefresh(afi, safi)]

def api_eor(self, command):
        tokens = formated(command).split(' ')[2:]
        number = len(tokens)

if not number:
            return Family(1, 1)

if number != 2:
            return False

afi = AFI.fromString(tokens[0])
        if afi == AFI.undefined:
            return False

safi = SAFI.fromString(tokens[1])
        if safi == SAFI.undefined:
            return False

return Family(afi, safi)

def api_operational(self, command):
        tokens = formated(command).split(' ')

op = tokens[1].lower()
        what = tokens[2].lower()

if op != 'operational':
            return False

self.configuration.tokeniser.iterate.replenish(tokens[3:])
        # None or a class
        return operational(what, self.configuration.tokeniser.iterate)