mirror of
https://github.com/onyx-and-iris/q3rcon-cli.git
synced 2026-03-24 02:39:18 +00:00
Compare commits
11 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 305af813b8 | |||
| 80638762d3 | |||
| 68f917286f | |||
| 3062cfa4d8 | |||
| 03597b580f | |||
| 296b1eff3e | |||
| 26a00bff42 | |||
| 60afda97dc | |||
| 968cd2dc8a | |||
| d7ea4d9fad | |||
| d0519bb8e9 |
12
README.md
12
README.md
@ -10,6 +10,9 @@
|
||||
## Table of Contents
|
||||
|
||||
- [Installation](#installation)
|
||||
- [Configuration](#configuration)
|
||||
- [Use](#use)
|
||||
- [Shell Completion](#shell-completion)
|
||||
- [License](#license)
|
||||
|
||||
## Installation
|
||||
@ -73,6 +76,7 @@ Usage: q3rcon-cli [OPTIONS] COMMAND
|
||||
|
||||
┏━ Options ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓
|
||||
┃ -i, --interactive Whether to start in interactive mode (defaults to false) ┃
|
||||
┃ -v, --version Show the version and exit ┃
|
||||
┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛
|
||||
|
||||
┏━ Connection options ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓
|
||||
@ -82,6 +86,14 @@ Usage: q3rcon-cli [OPTIONS] COMMAND
|
||||
┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛
|
||||
```
|
||||
|
||||
## Shell Completion
|
||||
|
||||
Shell completion scripts are available for *bash*, *zsh*, and *fish*.
|
||||
|
||||
```console
|
||||
q3rcon-cli --install-autocomplete
|
||||
```
|
||||
|
||||
## Special Thanks
|
||||
|
||||
- [lapetus-11](https://github.com/Iapetus-11) for writing the [aio-q3-rcon](https://github.com/Iapetus-11/aio-q3-rcon) package.
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
# SPDX-FileCopyrightText: 2026-present onyx-and-iris <code@onyxandiris.online>
|
||||
#
|
||||
# SPDX-License-Identifier: MIT
|
||||
__version__ = '0.2.4'
|
||||
__version__ = '0.3.3'
|
||||
|
||||
@ -1,9 +1,11 @@
|
||||
import clypi
|
||||
from aioq3rcon import Client, IncorrectPasswordError
|
||||
from clypi import Command, arg
|
||||
from clypi import Command, Spinner, arg
|
||||
from clypi import parsers as cp
|
||||
from typing_extensions import override
|
||||
|
||||
from . import console
|
||||
from .__about__ import __version__
|
||||
from .commands import (
|
||||
Fastrestart,
|
||||
Gametype,
|
||||
@ -37,6 +39,7 @@ class Q3rconCli(Command):
|
||||
help='The host to connect to',
|
||||
env='Q3RCON_CLI_HOST',
|
||||
group='Connection',
|
||||
parser=cp.Str(min=1),
|
||||
)
|
||||
port: int = arg(
|
||||
28960,
|
||||
@ -44,6 +47,7 @@ class Q3rconCli(Command):
|
||||
help='The port to connect to',
|
||||
env='Q3RCON_CLI_PORT',
|
||||
group='Connection',
|
||||
parser=cp.Int(min=1, max=65535),
|
||||
)
|
||||
password: str = arg(
|
||||
'',
|
||||
@ -51,15 +55,25 @@ class Q3rconCli(Command):
|
||||
help='The password for authentication',
|
||||
env='Q3RCON_CLI_PASSWORD',
|
||||
group='Connection',
|
||||
parser=cp.Str(min=8),
|
||||
)
|
||||
interactive: bool = arg(
|
||||
False,
|
||||
short='i',
|
||||
help='Whether to start in interactive mode (defaults to false)',
|
||||
)
|
||||
version: bool = arg(
|
||||
False,
|
||||
short='v',
|
||||
help='Show the version and exit',
|
||||
)
|
||||
|
||||
@override
|
||||
async def run(self):
|
||||
if self.version:
|
||||
print(f'q3rcon-cli version: {clypi.style(__version__, fg="green")}')
|
||||
return
|
||||
|
||||
if self.interactive:
|
||||
await self.run_interactive()
|
||||
else:
|
||||
@ -68,40 +82,47 @@ class Q3rconCli(Command):
|
||||
async def run_interactive(self):
|
||||
print(
|
||||
clypi.style('Entering interactive mode. Type', fg='blue'),
|
||||
clypi.style("'Q'", fg='red'),
|
||||
clypi.style("'Q'", fg='yellow'),
|
||||
clypi.style('to quit.', fg='blue'),
|
||||
)
|
||||
|
||||
DEFAULT_TIMEOUT = 2
|
||||
DEFAULT_FRAGMENT_READ_TIMEOUT = 0.25
|
||||
while command := input(clypi.style('cmd: ', fg='green')):
|
||||
if command.lower() == 'q':
|
||||
break
|
||||
|
||||
fragment_read_timeout = None
|
||||
if command in (
|
||||
'status',
|
||||
'fast_restart',
|
||||
'map_restart',
|
||||
'map',
|
||||
'map_rotate',
|
||||
):
|
||||
fragment_read_timeout = 1
|
||||
CMD_CONFIG = {
|
||||
'status': (2, 1, False),
|
||||
'fast_restart': (3, 1, True),
|
||||
'map_restart': (3, 1, True),
|
||||
'map': (3, 1, True),
|
||||
'map_rotate': (3, 1, True),
|
||||
}
|
||||
timeout, fragment_read_timeout, interpret = CMD_CONFIG.get(
|
||||
command.split()[0].lower(),
|
||||
(DEFAULT_TIMEOUT, DEFAULT_FRAGMENT_READ_TIMEOUT, False),
|
||||
)
|
||||
|
||||
async with Spinner(f"Sending command: '{command}'", suffix='...'):
|
||||
async with Client(
|
||||
self.host,
|
||||
self.port,
|
||||
self.password,
|
||||
fragment_read_timeout=fragment_read_timeout
|
||||
or DEFAULT_FRAGMENT_READ_TIMEOUT,
|
||||
timeout=timeout,
|
||||
fragment_read_timeout=fragment_read_timeout,
|
||||
) as client:
|
||||
try:
|
||||
if response := await client.send_command(command):
|
||||
console.out.print_response(response)
|
||||
response = await client.send_command(
|
||||
command, interpret=interpret
|
||||
)
|
||||
except TimeoutError:
|
||||
console.err.print(
|
||||
f"Timeout waiting for response for command: '{command}'"
|
||||
)
|
||||
|
||||
console.out.print_response(response)
|
||||
|
||||
|
||||
def main():
|
||||
try:
|
||||
|
||||
@ -1,5 +1,5 @@
|
||||
from aioq3rcon import Client
|
||||
from clypi import Command, arg
|
||||
from clypi import Command, Spinner, arg
|
||||
from typing_extensions import override
|
||||
|
||||
from q3rcon_cli import console
|
||||
@ -14,6 +14,8 @@ class Fastrestart(Command):
|
||||
|
||||
@override
|
||||
async def run(self):
|
||||
async with Spinner('Executing fast restart', suffix='...'):
|
||||
async with Client(self.host, self.port, self.password) as client:
|
||||
if response := await client.send_command('fast_restart'):
|
||||
response = await client.send_command('fast_restart', interpret=True)
|
||||
|
||||
console.out.print_response(response)
|
||||
|
||||
@ -1,5 +1,5 @@
|
||||
from aioq3rcon import Client
|
||||
from clypi import Command, Positional, Spinner, arg, cprint
|
||||
from clypi import Command, Positional, Spinner, arg
|
||||
from typing_extensions import override
|
||||
|
||||
from q3rcon_cli import console
|
||||
@ -24,16 +24,23 @@ class Gametype(Command):
|
||||
@override
|
||||
async def run(self):
|
||||
if not self.new_gametype:
|
||||
async with Spinner('Fetching current gametype', suffix='...'):
|
||||
async with Client(self.host, self.port, self.password) as client:
|
||||
if response := await client.send_command('g_gametype'):
|
||||
response = await client.send_command('g_gametype')
|
||||
console.out.print_cvar(response)
|
||||
return
|
||||
|
||||
async with Spinner(f'Changing gametype to {self.new_gametype}', suffix='...'):
|
||||
async with Client(self.host, self.port, self.password) as client:
|
||||
await client.send_command(f'g_gametype {self.new_gametype}')
|
||||
|
||||
if self.force:
|
||||
async with Spinner('Forcing gametype change', suffix='...'):
|
||||
async with Client(self.host, self.port, self.password) as client:
|
||||
client.timeout = 3
|
||||
client.fragment_read_timeout = 1
|
||||
await client.send_command('map_restart')
|
||||
|
||||
cprint(f'Gametype changed successfully to {self.new_gametype}.', fg='green')
|
||||
console.out.print(
|
||||
f'Gametype changed successfully to {self.new_gametype}.', style='green'
|
||||
)
|
||||
|
||||
@ -1,5 +1,5 @@
|
||||
from aioq3rcon import Client
|
||||
from clypi import Command, Positional, arg, cprint
|
||||
from clypi import Command, Positional, Spinner, arg
|
||||
from typing_extensions import override
|
||||
|
||||
from q3rcon_cli import console
|
||||
@ -19,12 +19,14 @@ class Hostname(Command):
|
||||
@override
|
||||
async def run(self):
|
||||
if not self.new_hostname:
|
||||
async with Spinner('Fetching current hostname', suffix='...'):
|
||||
async with Client(self.host, self.port, self.password) as client:
|
||||
if response := await client.send_command('sv_hostname'):
|
||||
response = await client.send_command('sv_hostname')
|
||||
console.out.print_cvar(response)
|
||||
return
|
||||
|
||||
async with Spinner(f'Changing hostname to {self.new_hostname}', suffix='...'):
|
||||
async with Client(self.host, self.port, self.password) as client:
|
||||
await client.send_command(f'sv_hostname {self.new_hostname}')
|
||||
|
||||
cprint(f'Hostname changed to: {self.new_hostname}', fg='green')
|
||||
console.out.print(f'Hostname changed to: {self.new_hostname}', style='green')
|
||||
|
||||
@ -1,5 +1,5 @@
|
||||
from aioq3rcon import Client
|
||||
from clypi import Command, Positional, Spinner, arg, cprint
|
||||
from clypi import Command, Positional, Spinner, arg
|
||||
from typing_extensions import override
|
||||
|
||||
from q3rcon_cli import console
|
||||
@ -19,8 +19,9 @@ class Map(Command):
|
||||
@override
|
||||
async def run(self):
|
||||
if not self.new_map:
|
||||
async with Spinner('Getting current map', suffix='...'):
|
||||
async with Client(self.host, self.port, self.password) as client:
|
||||
if response := await client.send_command('mapname'):
|
||||
response = await client.send_command('mapname')
|
||||
console.out.print_cvar(response)
|
||||
return
|
||||
|
||||
@ -30,4 +31,6 @@ class Map(Command):
|
||||
) as client:
|
||||
await client.send_command(f'map mp_{self.new_map.removeprefix("mp_")}')
|
||||
|
||||
cprint(f'Map changed to {self.new_map.removeprefix("mp_")}', fg='green')
|
||||
console.out.print(
|
||||
f'Map changed to {self.new_map.removeprefix("mp_")}', style='green'
|
||||
)
|
||||
|
||||
@ -1,5 +1,5 @@
|
||||
from aioq3rcon import Client
|
||||
from clypi import Command, arg
|
||||
from clypi import Command, Spinner, arg
|
||||
from typing_extensions import override
|
||||
|
||||
from q3rcon_cli import console
|
||||
@ -14,6 +14,8 @@ class Mapname(Command):
|
||||
|
||||
@override
|
||||
async def run(self):
|
||||
async with Spinner('Getting map name...'):
|
||||
async with Client(self.host, self.port, self.password) as client:
|
||||
if response := await client.send_command('mapname'):
|
||||
response = await client.send_command('mapname')
|
||||
|
||||
console.out.print_cvar(response)
|
||||
|
||||
@ -16,7 +16,8 @@ class Maprestart(Command):
|
||||
async def run(self):
|
||||
async with Spinner('Restarting map', suffix='...'):
|
||||
async with Client(
|
||||
self.host, self.port, self.password, fragment_read_timeout=1
|
||||
self.host, self.port, self.password, timeout=3, fragment_read_timeout=1
|
||||
) as client:
|
||||
if response := await client.send_command('map_restart'):
|
||||
response = await client.send_command('map_restart', interpret=True)
|
||||
|
||||
console.out.print_response(response)
|
||||
|
||||
@ -16,7 +16,12 @@ class Maprotate(Command):
|
||||
async def run(self):
|
||||
async with Spinner('Rotating map', suffix='...'):
|
||||
async with Client(
|
||||
self.host, self.port, self.password, fragment_read_timeout=1
|
||||
self.host,
|
||||
self.port,
|
||||
self.password,
|
||||
timeout=3,
|
||||
fragment_read_timeout=1,
|
||||
) as client:
|
||||
if response := await client.send_command('map_rotate'):
|
||||
response = await client.send_command('map_rotate', interpret=True)
|
||||
|
||||
console.out.print_response(response)
|
||||
|
||||
@ -1,5 +1,5 @@
|
||||
from aioq3rcon import Client
|
||||
from clypi import Command, arg
|
||||
from clypi import Command, Spinner, arg
|
||||
from typing_extensions import override
|
||||
|
||||
from q3rcon_cli import console
|
||||
@ -14,6 +14,8 @@ class Plugins(Command):
|
||||
|
||||
@override
|
||||
async def run(self):
|
||||
async with Spinner('Fetching plugins...'):
|
||||
async with Client(self.host, self.port, self.password) as client:
|
||||
if response := await client.send_command('plugins'):
|
||||
response = await client.send_command('plugins')
|
||||
|
||||
console.out.print_response(response)
|
||||
|
||||
@ -16,7 +16,8 @@ class Status(Command):
|
||||
async def run(self):
|
||||
async with Spinner('Fetching status', suffix='...'):
|
||||
async with Client(
|
||||
self.host, self.port, self.password, fragment_read_timeout=0.5
|
||||
self.host, self.port, self.password, fragment_read_timeout=1
|
||||
) as client:
|
||||
if response := await client.send_command('status'):
|
||||
response = await client.send_command('status')
|
||||
|
||||
console.out.print_status(response)
|
||||
|
||||
@ -50,9 +50,8 @@ class OutConsole(Console):
|
||||
return OutConsole.COLOUR_CODE_REGEX.sub('', s)
|
||||
|
||||
def print_response(self, response: str):
|
||||
response = self._remove_colour_codes(response).removeprefix('print\n')
|
||||
|
||||
cprint(f'\n{response}\n', fg=self.style)
|
||||
if response := self._remove_colour_codes(response).removeprefix('print\n'):
|
||||
cprint(response, fg=self.style)
|
||||
|
||||
def print_status(self, response: str):
|
||||
_slots = []
|
||||
@ -72,7 +71,7 @@ class OutConsole(Console):
|
||||
_names.append(self._remove_colour_codes(m.group('name')))
|
||||
_ips.append(m.group('ip'))
|
||||
elif m := OutConsole.STATUS_MAP_REGEX.match(line):
|
||||
cprint(f'\nCurrent map: {m.group("mapname")}', fg=self.style)
|
||||
cprint(f'Current map: {m.group("mapname")}', fg=self.style)
|
||||
|
||||
if not _slots:
|
||||
cprint('No players connected.', fg='red')
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user