summaryrefslogtreecommitdiffstats
path: root/src/ogRest.py
blob: 60a33b09de6a19bfd718046d679abb555afaae3c (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
import threading
import platform
import time
from enum import Enum
import json
import queue

if platform.system() == 'Linux':
	from src.linux import ogOperations

class ogResponses(Enum):
	BAD_REQUEST=0
	IN_PROGRESS=1
	OK=2

class ogRest():
	def __init__(self):
		self.msgqueue = queue.Queue(1000)

	def buildJsonResponse(self, idstr, content):
		data = { idstr :content }
		return json.dumps(data)

	def getResponse(self, response, idstr=None, content=None):
		msg = ''
		if response == ogResponses.BAD_REQUEST:
			msg = 'HTTP/1.0 400 Bad request'
		elif response == ogResponses.IN_PROGRESS:
			msg = 'HTTP/1.0 202 Accepted'
		elif response == ogResponses.OK:
			msg = 'HTTP/1.0 200 OK'
		else:
			return msg

		if not content == None:
			jsonmsg = self.buildJsonResponse(idstr, content)
			msg = msg + '\nContent-Type:application/json'
			msg = msg + '\nContent-Length:' + str(len(jsonmsg))
			msg = msg + '\n' + jsonmsg

		msg = msg + '\r\n\r\n'
		return msg

	def processOperation(self, op, URI, cmd, client):
		if ("GET" in op):
			if ("probe" in URI):
				self.process_probe(client)
			elif ("shell/output" in URI):
				self.process_shellout(client)
			else:
				client.send(self.getResponse(ogResponses.BAD_REQUEST))
		elif ("POST" in op):
			if ("poweroff" in URI):
				self.process_poweroff(client)
			elif ("reboot" in URI):
				self.process_reboot(client)
			elif ("shell/run" in URI):
				self.process_shellrun(client, cmd)
			else:
				client.send(self.getResponse(ogResponses.BAD_REQUEST))
		else:
			client.send(self.getResponse(ogResponses.BAD_REQUEST))

		return 0

	def process_reboot(self, client):
		# Rebooting thread
		def rebt():
			ogOperations.reboot()

		client.send(self.getResponse(ogResponses.IN_PROGRESS))
		client.disconnect()
		threading.Thread(target=rebt).start()

	def process_poweroff(self, client):
		# Powering off thread
		def pwoff():
			time.sleep(2)
			ogOperations.poweroff()

		client.send(self.getResponse(ogResponses.IN_PROGRESS))
		client.disconnect()
		threading.Thread(target=pwoff).start()

	def process_probe(self, client):
		client.send(self.getResponse(ogResponses.OK))

	def process_shellrun(self, client, cmd):
		# Executing cmd thread
		def execcmd(msgqueue):
			msgqueue.put(ogOperations.execCMD(cmd))

		if cmd == None:
			client.send(self.getResponse(ogResponses.BAD_REQUEST))
			return

		threading.Thread(target=execcmd, args=(self.msgqueue,)).start()
		client.send(self.getResponse(ogResponses.IN_PROGRESS))

	def process_shellout(self, client):
		if self.msgqueue.empty():
			client.send(self.getResponse(ogResponses.IN_PROGRESS, 'out', ''))
		else:
			out = self.msgqueue.get()
			client.send(self.getResponse(ogResponses.IN_PROGRESS, 'out', out))