every_holiday/VRCT
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[WIP/TEST] Add OSCQuery

Browse Source
This commit is contained in:
misyaguziya
2024-02-07 23:00:51 +09:00
parent a22e4b9b91
commit 52682a5c2e
2 changed files with 26 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
models/osc/osc_tools.py
View File

@@ -3,6 +3,8 @@ from pythonosc import osc_message_builder
from pythonosc import udp_client from pythonosc import udp_client
from pythonosc import dispatcher from pythonosc import dispatcher
from pythonosc import osc_server from pythonosc import osc_server
from tinyoscquery.queryservice import OSCQueryService
from tinyoscquery.utility import get_open_udp_port, get_open_tcp_port
# send OSC message typing # send OSC message typing
def sendTyping(flag=False, ip_address="127.0.0.1", port=9000): def sendTyping(flag=False, ip_address="127.0.0.1", port=9000):
@@ -45,12 +47,28 @@ def sendChangeVoice(ip_address="127.0.0.1", port=9000):
sendInputVoice(flag=0, ip_address=ip_address, port=port) sendInputVoice(flag=0, ip_address=ip_address, port=port)
sleep(0.05) sleep(0.05)
def receiveOscParameters(target, filter="/*", ip_address="127.0.0.1", port=9001): # def receiveOscParameters(target, filter="/*", ip_address="127.0.0.1", port=9001):
_dispatcher = dispatcher.Dispatcher() # _dispatcher = dispatcher.Dispatcher()
_dispatcher.map(filter, target) # _dispatcher.map(filter, target)
server = osc_server.ThreadingOSCUDPServer((ip_address, port), _dispatcher) # server = osc_server.ThreadingOSCUDPServer((ip_address, port), _dispatcher)
return server return server
def receiveOscParameters(target, filter="/avatar/parameters/*", ip_address="127.0.0.1", title="VRCT"):
osc_port = get_open_udp_port()
http_port = get_open_tcp_port()
osc_dispatcher = dispatcher.Dispatcher()
osc_dispatcher.map(filter, target)
osc_udp_server = osc_server.ThreadingOSCUDPServer((ip_address, osc_port), osc_dispatcher)
osc_client = OSCQueryService(title, http_port, osc_port)
osc_client.advertise_endpoint(filter)
return osc_udp_server, osc_client
if __name__ == "__main__": if __name__ == "__main__":
sendChangeVoice() import threading
sendChangeVoice()
def print_handler(address, *args):
print(f"{address}: {args}")
server, client = receiveOscParameters(print_handler, filter="/input/*")
server_thread = threading.Thread(target=server.serve_forever)
server_thread.start()

1
requirements.txt
View File

@@ -11,3 +11,4 @@ pyinstaller==6.2.0
transformers[torch] transformers[torch]
sentencepiece==0.1.99 sentencepiece==0.1.99
ctranslate2==3.21.0 ctranslate2==3.21.0
tinyoscquery @ git+https://github.com/cyberkitsune/tinyoscquery@0.1.2