blob: f554a71d9a36f74fa3c84c97a8545e6b03e3e1df (
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
|
"""
This plugins allows commands to be sent to poezio via a named pipe.
"""
from plugin import BasePlugin
import threading
import os
import stat
import logging
log = logging.getLogger(__name__)
PIPENAME = "/tmp/poezio.fifo"
class Plugin(BasePlugin):
def init(self):
self.stop = False
self.pipename = self.config.get("pipename", PIPENAME)
if not os.path.exists(self.pipename):
os.mkfifo(self.pipename)
if not stat.S_ISFIFO(os.stat(self.pipename).st_mode):
log.error("File %s is not a fifo file" % self.pipename)
raise TypeError
thread = threading.Thread(target=self.main_loop)
thread.setDaemon(True)
thread.start()
def main_loop(self):
while not self.stop:
fd = open(self.pipename, 'r')
line = fd.read().strip()
self.api.run_command(line)
fd.close()
def cleanup(self):
self.stop = True
|
