flexget.api.core.server module#

class flexget.api.core.server.LogParser(query)[source]#

Bases: object

Filter log file.

Supports
  • ‘and’, ‘or’ and implicit ‘and’ operators;

  • parentheses;

  • quoted strings;

Parameters:

query (str | None)

evaluate(argument)[source]#
evaluate_and(argument)[source]#
evaluate_not(argument)[source]#
evaluate_or(argument)[source]#
evaluate_parenthesis(argument)[source]#
evaluate_quotes(argument)[source]#
evaluate_word(argument)[source]#
json_string(line)[source]#
matches(line)[source]#
class flexget.api.core.server.ObjectsContainer[source]#

Bases: object

config_validation_error = {'properties': {'config_path': {'type': 'string'}, 'error': {'type': 'string'}, 'message': {'type': 'string'}, 'status': {'type': 'string'}, 'status_code': {'type': 'integer'}}, 'required': ['status_code', 'message', 'status'], 'type': 'object'}#
crash_logs = {'items': {'properties': {'content': {'items': {'type': 'string'}, 'type': 'array'}, 'name': {'type': 'string'}}, 'type': 'object'}, 'type': 'array'}#
dump_threads_object = {'properties': {'threads': {'items': {'properties': {'dump': {'items': {'type': 'string'}, 'type': 'array'}, 'id': {'type': 'string'}, 'name': {'type': 'string'}}, 'type': 'object'}, 'type': 'array'}}, 'type': 'object'}#
pid_object = {'properties': {'pid': {'type': 'integer'}}, 'type': 'object'}#
raw_config_object = {'properties': {'raw_config': {'type': 'string'}}, 'type': 'object'}#
server_manage = {'additionalProperties': False, 'properties': {'force': {'type': 'boolean'}, 'operation': {'enum': ['reload', 'shutdown'], 'type': 'string'}}, 'required': ['operation'], 'type': 'object'}#
version_object = {'properties': {'api_version': {'type': 'string'}, 'flexget_version': {'type': 'string'}, 'latest_version': {'type': ['string', 'null']}}, 'type': 'object'}#
yaml_error_response = {'properties': {'column': {'type': 'integer'}, 'line': {'type': 'integer'}, 'message': {'type': 'string'}, 'reason': {'type': 'string'}, 'status': {'type': 'string'}, 'status_code': {'type': 'integer'}}, 'required': ['status_code', 'message', 'status'], 'type': 'object'}#
class flexget.api.core.server.ServerConfigAPI(api, *args, **kwargs)[source]#

Bases: APIResource

Parameters:

api (RestxAPI)

get(session=None)[source]#

Get Flexget Config in JSON form.

Parameters:

session (Session)

Return type:

Response

mediatypes()#
endpoint = 'server_server_config_api'#
methods: ClassVar[Collection[str] | None] = {'GET'}#

The methods this view is registered for. Uses the same default (["GET", "HEAD", "OPTIONS"]) as route and add_url_rule by default.

class flexget.api.core.server.ServerCrashLogAPI(api, *args, **kwargs)[source]#

Bases: APIResource

Parameters:

api (RestxAPI)

get(session)[source]#

Get Crash logs.

Parameters:

session (Session)

mediatypes()#
endpoint = 'server_server_crash_log_api'#
methods: ClassVar[Collection[str] | None] = {'GET'}#

The methods this view is registered for. Uses the same default (["GET", "HEAD", "OPTIONS"]) as route and add_url_rule by default.

class flexget.api.core.server.ServerDumpThreads(api, *args, **kwargs)[source]#

Bases: APIResource

Parameters:

api (RestxAPI)

get(session=None)[source]#

Dump Server threads for debugging.

Parameters:

session (Session)

Return type:

Response

mediatypes()#
endpoint = 'server_server_dump_threads'#
methods: ClassVar[Collection[str] | None] = {'GET'}#

The methods this view is registered for. Uses the same default (["GET", "HEAD", "OPTIONS"]) as route and add_url_rule by default.

class flexget.api.core.server.ServerLogAPI(api, *args, **kwargs)[source]#

Bases: APIResource

Parameters:

api (RestxAPI)

get(session=None)[source]#

Stream Flexget log Streams as line delimited JSON.

Parameters:

session (Session)

Return type:

Response

mediatypes()#
endpoint = 'server_server_log_api'#
methods: ClassVar[Collection[str] | None] = {'GET'}#

The methods this view is registered for. Uses the same default (["GET", "HEAD", "OPTIONS"]) as route and add_url_rule by default.

class flexget.api.core.server.ServerPIDAPI(api, *args, **kwargs)[source]#

Bases: APIResource

Parameters:

api (RestxAPI)

get(session=None)[source]#

Get server PID.

Parameters:

session (Session)

Return type:

Response

mediatypes()#
endpoint = 'server_server_pidapi'#
methods: ClassVar[Collection[str] | None] = {'GET'}#

The methods this view is registered for. Uses the same default (["GET", "HEAD", "OPTIONS"]) as route and add_url_rule by default.

class flexget.api.core.server.ServerRawConfigAPI(api, *args, **kwargs)[source]#

Bases: APIResource

Parameters:

api (RestxAPI)

get(session=None)[source]#

Get raw YAML config file.

Parameters:

session (Session)

Return type:

Response

mediatypes()#
post(session=None)[source]#

Update config.

Parameters:

session (Session)

Return type:

Response

endpoint = 'server_server_raw_config_api'#
methods: ClassVar[Collection[str] | None] = {'GET', 'POST'}#

The methods this view is registered for. Uses the same default (["GET", "HEAD", "OPTIONS"]) as route and add_url_rule by default.

class flexget.api.core.server.ServerReloadAPI(api, *args, **kwargs)[source]#

Bases: APIResource

Parameters:

api (RestxAPI)

mediatypes()#
post(session=None)[source]#

Manage server operations.

Parameters:

session (Session)

Return type:

Response

endpoint = 'server_server_reload_api'#
methods: ClassVar[Collection[str] | None] = {'POST'}#

The methods this view is registered for. Uses the same default (["GET", "HEAD", "OPTIONS"]) as route and add_url_rule by default.

class flexget.api.core.server.ServerVersionAPI(api, *args, **kwargs)[source]#

Bases: APIResource

Parameters:

api (RestxAPI)

get(session=None)[source]#

Flexget Version.

Parameters:

session (Session)

Return type:

Response

mediatypes()#
endpoint = 'server_server_version_api'#
methods: ClassVar[Collection[str] | None] = {'GET'}#

The methods this view is registered for. Uses the same default (["GET", "HEAD", "OPTIONS"]) as route and add_url_rule by default.

flexget.api.core.server.file_inode(file)[source]#
Parameters:

file (Path)

Return type:

int

flexget.api.core.server.reverse_readline(fh, start_byte=0, buf_size=8192)[source]#

Return the lines of a file in reverse order.

Parameters:
  • fh (IO)

  • start_byte (int)

  • buf_size (int)

Return type:

Generator[str, None, None]