diff options
| -rw-r--r-- | data/templates/https/nginx.default.j2 | 2 | ||||
| -rw-r--r-- | python/vyos/configsession.py | 14 | ||||
| -rwxr-xr-x | src/services/vyos-http-api-server | 46 | 
3 files changed, 60 insertions, 2 deletions
| diff --git a/data/templates/https/nginx.default.j2 b/data/templates/https/nginx.default.j2 index dbb08e187..753c3a5c9 100644 --- a/data/templates/https/nginx.default.j2 +++ b/data/templates/https/nginx.default.j2 @@ -34,7 +34,7 @@ server {          ssl_protocols TLSv1.2 TLSv1.3;          # proxy settings for HTTP API, if enabled; 503, if not -        location ~ /(retrieve|configure|config-file|image|generate|show|reset|docs|openapi.json|redoc|graphql) { +        location ~ /(retrieve|configure|config-file|image|container-image|generate|show|reset|docs|openapi.json|redoc|graphql) {  {%     if server.api %}  {%         if server.api.socket %}                  proxy_pass http://unix:/run/api.sock; diff --git a/python/vyos/configsession.py b/python/vyos/configsession.py index 3a60f6d92..9864aa5c5 100644 --- a/python/vyos/configsession.py +++ b/python/vyos/configsession.py @@ -34,6 +34,8 @@ REMOVE_IMAGE = ['/opt/vyatta/bin/vyatta-boot-image.pl', '--del']  GENERATE = ['/opt/vyatta/bin/vyatta-op-cmd-wrapper', 'generate']  SHOW = ['/opt/vyatta/bin/vyatta-op-cmd-wrapper', 'show']  RESET = ['/opt/vyatta/bin/vyatta-op-cmd-wrapper', 'reset'] +ADD = ['/opt/vyatta/bin/vyatta-op-cmd-wrapper', 'add'] +DELETE = ['/opt/vyatta/bin/vyatta-op-cmd-wrapper', 'delete']  # Default "commit via" string  APP = "vyos-http-api" @@ -204,3 +206,15 @@ class ConfigSession(object):      def reset(self, path):          out = self.__run_command(RESET + path)          return out + +    def add_container_image(self, name): +        out = self.__run_command(ADD + ['container', 'image'] + [name]) +        return out + +    def delete_container_image(self, name): +        out = self.__run_command(DELETE + ['container', 'image'] + [name]) +        return out + +    def show_container_image(self): +        out = self.__run_command(SHOW + ['container', 'image']) +        return out diff --git a/src/services/vyos-http-api-server b/src/services/vyos-http-api-server index 60ea9a5ee..f59e089ae 100755 --- a/src/services/vyos-http-api-server +++ b/src/services/vyos-http-api-server @@ -175,6 +175,19 @@ class ImageModel(ApiModel):              }          } +class ContainerImageModel(ApiModel): +    op: StrictStr +    name: StrictStr = None + +    class Config: +        schema_extra = { +            "example": { +                "key": "id_key", +                "op": "add | delete | show", +                "name": "imagename", +            } +        } +  class GenerateModel(ApiModel):      op: StrictStr      path: List[StrictStr] @@ -389,7 +402,7 @@ class MultipartRoute(APIRoute):                  if endpoint in ('/retrieve','/generate','/show','/reset'):                      if request.ERR_NO_OP or request.ERR_NO_PATH:                          return error(400, "Missing required field. \"op\" and \"path\" fields are required") -                if endpoint in ('/config-file', '/image'): +                if endpoint in ('/config-file', '/image', '/container-image'):                      if request.ERR_NO_OP:                          return error(400, "Missing required field \"op\"") @@ -581,6 +594,37 @@ def image_op(data: ImageModel):      return success(res) +@app.post('/container-image') +def image_op(data: ContainerImageModel): +    session = app.state.vyos_session + +    op = data.op + +    try: +        if op == 'add': +            if data.name: +                name = data.name +            else: +                return error(400, "Missing required field \"name\"") +            res = session.add_container_image(name) +        elif op == 'delete': +            if data.name: +                name = data.name +            else: +                return error(400, "Missing required field \"name\"") +            res = session.delete_container_image(name) +        elif op == 'show': +            res = session.show_container_image() +        else: +            return error(400, "\"{0}\" is not a valid operation".format(op)) +    except ConfigSessionError as e: +        return error(400, str(e)) +    except Exception as e: +        logger.critical(traceback.format_exc()) +        return error(500, "An internal error occured. Check the logs for details.") + +    return success(res) +  @app.post('/generate')  def generate_op(data: GenerateModel):      session = app.state.vyos_session | 
