highperfocused/nostrdvm
1
0
Fork 0
mirror of https://github.com/believethehype/nostrdvm.git synced 2025-06-30 12:50:38 +02:00
Code Issues Packages Projects Releases Wiki Activity

Update dvmtaskinterface.py

Browse Source
This commit is contained in:
Believethehype
2024-10-11 10:24:52 +02:00
parent 7c4e07bd8e
commit c1618166c9
1 changed files with 6 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
nostr_dvm/interfaces/dvmtaskinterface.py
View File

@ -2,23 +2,22 @@ import asyncio
import json import json
import os import os
import subprocess import subprocess
import time
from subprocess import run
import sys import sys
from subprocess import run
from sys import platform from sys import platform
from threading import Thread from threading import Thread
from venv import create from venv import create
from nostr_sdk import Keys, Kind, LogLevel from nostr_sdk import Keys, Kind, LogLevel
from nostr_dvm.dvm import DVM from nostr_dvm.dvm import DVM
from nostr_dvm.utils.admin_utils import AdminConfig from nostr_dvm.utils.admin_utils import AdminConfig
from nostr_dvm.utils.backend_utils import keep_alive
from nostr_dvm.utils.dvmconfig import DVMConfig, build_default_config from nostr_dvm.utils.dvmconfig import DVMConfig, build_default_config
from nostr_dvm.utils.nip88_utils import NIP88Config from nostr_dvm.utils.nip88_utils import NIP88Config
from nostr_dvm.utils.nip89_utils import NIP89Config, check_and_set_d_tag from nostr_dvm.utils.nip89_utils import NIP89Config
from nostr_dvm.utils.output_utils import post_process_result from nostr_dvm.utils.output_utils import post_process_result
class DVMTaskInterface: class DVMTaskInterface:
NAME: str NAME: str
KIND: Kind KIND: Kind
@ -73,7 +72,7 @@ class DVMTaskInterface:
self.admin_config = admin_config self.admin_config = admin_config
asyncio.run(self.init_dvm(name, dvm_config, nip89config, nip88config, asyncio.run(self.init_dvm(name, dvm_config, nip89config, nip88config,
admin_config, options)) admin_config, options))
async def init_dvm(self, name, dvm_config: DVMConfig, nip89config: NIP89Config, nip88config: NIP88Config = None, async def init_dvm(self, name, dvm_config: DVMConfig, nip89config: NIP89Config, nip88config: NIP88Config = None,
admin_config: AdminConfig = None, options=None): admin_config: AdminConfig = None, options=None):
@ -109,8 +108,6 @@ class DVMTaskInterface:
pass pass
def run(self, join=False): def run(self, join=False):
#dvm = DVM(self.dvm_config, self.admin_config)
#asyncio.run(dvm.run_dvm(self.dvm_config, self.admin_config))
nostr_dvm_thread = Thread(target=self.DVM, args=[self.dvm_config, self.admin_config], daemon=False) nostr_dvm_thread = Thread(target=self.DVM, args=[self.dvm_config, self.admin_config], daemon=False)
nostr_dvm_thread.start() nostr_dvm_thread.start()
if join: if join:
@ -167,7 +164,7 @@ class DVMTaskInterface:
@staticmethod @staticmethod
def write_output(result, output): def write_output(result, output):
with open(os.path.abspath(output), 'w', encoding="utf8") as f: with open(os.path.abspath(output), 'w', encoding="utf8") as f:
f.write(result) f.write(result)
# f.close() # f.close()
@ -181,4 +178,3 @@ def process_venv(identifier):
DVMTaskInterface.write_output(result, args.output) DVMTaskInterface.write_output(result, args.output)
except Exception as e: except Exception as e:
DVMTaskInterface.write_output("Error: " + str(e), args.output) DVMTaskInterface.write_output("Error: " + str(e), args.output)