OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	03/16/2023 12:55:54 PM	rwxr-xr-x
📄 __init__.py	2.3 KB	03/13/2021 04:30:48 PM	rw-r--r--
📁 __pycache__	-	03/16/2023 12:55:54 PM	rwxr-xr-x
📄 parser.py	2.31 KB	03/13/2021 04:30:48 PM	rw-r--r--

Editing: __init__.py

# encoding: utf-8
"""
parse_process.py

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

import os
import sys
import uuid

from exabgp.configuration.core import Section

from exabgp.configuration.process.parser import encoder
from exabgp.configuration.process.parser import run

from exabgp.configuration.parser import boolean

class ParseProcess(Section):
    syntax = 'process name-of-process {\n' '   run /path/to/command with its args;\n' '   encoder text|json;\n' '}'
    known = {
        'encoder': encoder,
        'respawn': boolean,
        'run': run,
    }

action = {
        'encoder': 'set-command',
        'respawn': 'set-command',
        'run': 'set-command',
    }

default = {
        'respawn': True,
    }

name = 'process'

def __init__(self, tokeniser, scope, error, logger):
        Section.__init__(self, tokeniser, scope, error, logger)
        self.processes = {}
        self._processes = []
        self.named = ''

def clear(self):
        self.processes = {}
        self._processes = []

def pre(self):
        self.named = self.tokeniser.line[1]
        if self.named in self._processes:
            return self.error.set('a process section called "%s" already exists' % self.named)
        self._processes.append(self.named)
        return True

def post(self):
        known = self.known.keys()
        configured = self.scope.get().keys()
        for default in self.default:
            if default not in configured:
                self.scope.set(default, self.default[default])
        difference = set(known).difference(configured)
        if difference:
            return self.error.set('unset process sections: %s' % ', '.join(difference))
        self.processes.update({self.named: self.scope.pop()})
        return True

def add_api(self):
        if not os.environ.get('exabgp_cli_pipe', ''):
            return
        name = 'api-internal-cli-%x' % uuid.uuid1().fields[0]
        api = {
            name: {
                'run': [sys.executable, os.path.join(os.environ.get('PWD', ''), sys.argv[0])],
                'encoder': 'text',
                'respawn': True,
            }
        }
        self._processes.append(name)
        self.processes.update(api)