|
|
@@ -0,0 +1,102 @@
|
|
|
+from __future__ import print_function, absolute_import, division
|
|
|
+
|
|
|
+print('receiver start')
|
|
|
+import sys
|
|
|
+
|
|
|
+import socket
|
|
|
+import traceback
|
|
|
+
|
|
|
+from path import Path
|
|
|
+
|
|
|
+from rgbmatrix import RGBMatrix, RGBMatrixOptions
|
|
|
+from rgbmatrix import graphics
|
|
|
+
|
|
|
+class Renderer(object):
|
|
|
+ def __init__(self):
|
|
|
+ o = RGBMatrixOptions()
|
|
|
+ o.chain_length = 4
|
|
|
+ self.matrix = RGBMatrix(options=o)
|
|
|
+ self.canvas = self.matrix.CreateFrameCanvas()
|
|
|
+
|
|
|
+ def swap(self):
|
|
|
+ self.canvas = self.matrix.SwapOnVSync(self.canvas)
|
|
|
+ self.canvas.Clear()
|
|
|
+
|
|
|
+ def print_text(self, text):
|
|
|
+ graphics.DrawText(self.canvas, fonts['10x20'], 0, 20, textColor, text)
|
|
|
+ self.swap()
|
|
|
+
|
|
|
+ def scroll_text(self, text, loop=1):
|
|
|
+ pos = self.canvas.width
|
|
|
+ i = 1
|
|
|
+ while True:
|
|
|
+ len = graphics.DrawText(self.canvas, fonts['10x20'], pos, 20, textColor, text)
|
|
|
+ pos -= 1
|
|
|
+ if (pos + len < 0):
|
|
|
+ pos = self.canvas.width
|
|
|
+ i += 1
|
|
|
+ if i > loop:
|
|
|
+ break
|
|
|
+
|
|
|
+ time.sleep(0.02)
|
|
|
+ self.swap()
|
|
|
+
|
|
|
+
|
|
|
+ def fit_text(self, text, width=128):
|
|
|
+ ff = reversed(sorted(fonts.items(), key=lambda e: int(e[0].split('x')[0])))
|
|
|
+ temp_canvas = self.matrix.CreateFrameCanvas()
|
|
|
+ for name, font in ff:
|
|
|
+ w = graphics.DrawText(temp_canvas, font, 0, -100, textColor, text)
|
|
|
+ if w < width:
|
|
|
+ break
|
|
|
+ else:
|
|
|
+ print('str len %s exceeds space' % w)
|
|
|
+
|
|
|
+ graphics.DrawText(self.canvas, font, 0, 20, textColor, text)
|
|
|
+ self.swap()
|
|
|
+
|
|
|
+
|
|
|
+try:
|
|
|
+ fonts = {}
|
|
|
+ for f in Path('/matrix/fonts').files('*.bdf'):
|
|
|
+ if not f.namebase.split('x')[0].isdigit() or not f.namebase[-1].isdigit():
|
|
|
+ continue
|
|
|
+ fo = graphics.Font()
|
|
|
+ fo.LoadFont(f)
|
|
|
+ fonts[f.namebase] = fo
|
|
|
+
|
|
|
+ textColor = graphics.Color(96, 128, 255)
|
|
|
+ r = Renderer()
|
|
|
+
|
|
|
+ # Create a TCP/IP socket
|
|
|
+ sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
|
|
+
|
|
|
+ # Bind the socket to the port
|
|
|
+ server_address = ('0.0.0.0', 10000)
|
|
|
+ print('starting up on %s port %s' % server_address)
|
|
|
+ sock.bind(server_address)
|
|
|
+ r.fit_text('Matrix ready.')
|
|
|
+
|
|
|
+ r.fit_text('111')
|
|
|
+
|
|
|
+
|
|
|
+ while True:
|
|
|
+ print('waiting to receive message')
|
|
|
+ data, address = sock.recvfrom(4096)
|
|
|
+
|
|
|
+ print('received %s bytes from %s' % (len(data), address))
|
|
|
+ method = ord(data[0])
|
|
|
+ data = data[1:]
|
|
|
+
|
|
|
+ if method == 0:
|
|
|
+ r.print_text(data.decode('utf-8'))
|
|
|
+ elif method == 1:
|
|
|
+ r.scroll_text(data.decode('utf-8'))
|
|
|
+ elif method == 2:
|
|
|
+ r.fit_text(data.decode('utf-8'))
|
|
|
+
|
|
|
+except Exception:
|
|
|
+ print(traceback.format_exc())
|
|
|
+
|
|
|
+finally:
|
|
|
+ print('receiver exit')
|
