added get job and enable/disable method to jsonrpc
This commit is contained in:
parent
27cdfd5e32
commit
caf37aec89
1 changed files with 17 additions and 4 deletions
|
|
@ -21,6 +21,7 @@ You should have received a copy of the GNU Affero General Public License
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
|
import json
|
||||||
import time
|
import time
|
||||||
|
|
||||||
from bjsonrpc.handlers import BaseHandler
|
from bjsonrpc.handlers import BaseHandler
|
||||||
|
|
@ -43,15 +44,17 @@ class JsonrpcBackend(Backend):
|
||||||
self.port = config["backends"]["jsonrpc"]["port"]
|
self.port = config["backends"]["jsonrpc"]["port"]
|
||||||
|
|
||||||
ServerHandler.interface = interface
|
ServerHandler.interface = interface
|
||||||
|
ServerHandler.config = config
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
while True:
|
while True:
|
||||||
server = createserver(host=self.host, port=self.port, handler_factory=ServerHandler).serve()
|
server = createserver(host=self.host, port=self.port, handler_factory=ServerHandler)
|
||||||
|
server.serve()
|
||||||
|
|
||||||
|
|
||||||
class ServerHandler(BaseHandler):
|
class ServerHandler(BaseHandler):
|
||||||
|
|
||||||
interface = None
|
interface = None
|
||||||
|
config = None
|
||||||
|
|
||||||
def time(self):
|
def time(self):
|
||||||
return time.time()
|
return time.time()
|
||||||
|
|
@ -59,5 +62,15 @@ class ServerHandler(BaseHandler):
|
||||||
def delta(self, start):
|
def delta(self, start):
|
||||||
return time.time() - start
|
return time.time() - start
|
||||||
|
|
||||||
def test(self):
|
def get_job_list(self):
|
||||||
return "test"
|
pass
|
||||||
|
|
||||||
|
def get_job_info_by_id(self, job_hex):
|
||||||
|
job = ServerHandler.interface.find_job_by_hex_string(job_hex)
|
||||||
|
job_dict = ServerHandler.interface.get_job_info_dict(job)
|
||||||
|
return json.dumps(job_dict, ensure_ascii=False)
|
||||||
|
|
||||||
|
def set_job_enabled(self, job_hex, enabled=True):
|
||||||
|
job = ServerHandler.interface.find_job_by_hex_string(job_hex)
|
||||||
|
job.set_enabled(enabled)
|
||||||
|
return True
|
||||||
Loading…
Add table
Add a link
Reference in a new issue